2024-09-18 10:57:40,896 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -------------------------------------------------------------------------------- 2024-09-18 10:57:40,897 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting KubernetesSessionClusterEntrypoint (Version: 1.19.1, Scala: 2.12, Rev:5edb5a9, Date:2024-06-06T14:45:33+02:00) 2024-09-18 10:57:40,897 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - OS current user: yawyd 2024-09-18 10:57:40,897 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Current Hadoop/Kerberos user: 2024-09-18 10:57:40,897 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM: OpenJDK 64-Bit Server VM - Amazon.com Inc. - 11/11.0.24+8-LTS 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Arch: amd64 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Maximum heap size: 8002 MiBytes 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JAVA_HOME: /home/yawyd/.sdkman/candidates/java/current 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - No Hadoop Dependency available 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM Options: 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:+IgnoreUnrecognizedVMOptions 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Da=b 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog.file=/home/yawyd/k8s-manifests/flink/oas/log/flink-yawyd-kubernetes-session-0-earth.log 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configuration=file:/home/yawyd/k8s-manifests/flink/oas/conf/log4j-console.properties 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configurationFile=file:/home/yawyd/k8s-manifests/flink/oas/conf/log4j-console.properties 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlogback.configurationFile=file:/home/yawyd/k8s-manifests/flink/oas/conf/logback-console.xml 2024-09-18 10:57:40,898 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Program Arguments: 2024-09-18 10:57:40,899 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dkubernetes.cluster-id=learn 2024-09-18 10:57:40,899 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dkubernetes.namespace=data 2024-09-18 10:57:40,899 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Classpath: /home/yawyd/k8s-manifests/flink/oas/lib/flink-cep-1.19.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/flink-connector-files-1.19.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/flink-csv-1.19.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/flink-json-1.19.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/flink-scala_2.12-1.19.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/flink-table-api-java-uber-1.19.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/flink-table-planner-loader-1.19.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/flink-table-runtime-1.19.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/log4j-1.2-api-2.17.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/log4j-api-2.17.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/log4j-core-2.17.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/log4j-slf4j-impl-2.17.1.jar:/home/yawyd/k8s-manifests/flink/oas/lib/flink-dist-1.19.1.jar:::: 2024-09-18 10:57:40,899 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -------------------------------------------------------------------------------- 2024-09-18 10:57:40,900 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Registered UNIX signal handlers for [TERM, HUP, INT] 2024-09-18 10:57:40,906 INFO org.apache.flink.configuration.GlobalConfiguration [] - Using standard YAML parser to load flink configuration file from /home/yawyd/k8s-manifests/flink/oas/conf/config.yaml. 2024-09-18 10:57:40,933 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.process.size, 1728m 2024-09-18 10:57:40,933 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.bind-host, localhost 2024-09-18 10:57:40,933 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.execution.failover-strategy, region 2024-09-18 10:57:40,933 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.taskmanager, ./conf/taskmanager-pod-template.yaml 2024-09-18 10:57:40,934 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.address, localhost 2024-09-18 10:57:40,934 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.memory.process.size, 1600m 2024-09-18 10:57:40,934 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.port, 6123 2024-09-18 10:57:40,934 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.bind-address, localhost 2024-09-18 10:57:40,934 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.bind-host, localhost 2024-09-18 10:57:40,934 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.host, localhost 2024-09-18 10:57:40,934 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.namespace, data 2024-09-18 10:57:40,934 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: parallelism.default, 1 2024-09-18 10:57:40,934 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1 2024-09-18 10:57:40,935 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.address, localhost 2024-09-18 10:57:40,935 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.jobmanager, ./conf/jobmanager-pod-template.yaml 2024-09-18 10:57:40,935 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.all, -Da=b 2024-09-18 10:57:40,935 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading dynamic configuration property: kubernetes.namespace, data 2024-09-18 10:57:40,935 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading dynamic configuration property: kubernetes.cluster-id, learn 2024-09-18 10:57:41,034 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting KubernetesSessionClusterEntrypoint. 2024-09-18 10:57:41,049 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install default filesystem. 2024-09-18 10:57:41,050 INFO org.apache.flink.core.fs.FileSystem [] - Hadoop is not in the classpath/dependencies. The extended set of supported File Systems via Hadoop is not available. 2024-09-18 10:57:41,060 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: external-resource-gpu 2024-09-18 10:57:41,063 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-influx 2024-09-18 10:57:41,064 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-jmx 2024-09-18 10:57:41,064 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-slf4j 2024-09-18 10:57:41,064 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-prometheus 2024-09-18 10:57:41,064 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-statsd 2024-09-18 10:57:41,064 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-datadog 2024-09-18 10:57:41,064 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-graphite 2024-09-18 10:57:41,073 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install security context. 2024-09-18 10:57:41,080 INFO org.apache.flink.runtime.security.modules.HadoopModuleFactory [] - Cannot create Hadoop Security Module because Hadoop cannot be found in the Classpath. 2024-09-18 10:57:41,083 INFO org.apache.flink.runtime.security.modules.JaasModule [] - Jaas file will be created as /tmp/jaas-14166509081485106661.conf. 2024-09-18 10:57:41,086 INFO org.apache.flink.runtime.security.contexts.HadoopSecurityContextFactory [] - Cannot install HadoopSecurityContext because Hadoop cannot be found in the Classpath. 2024-09-18 10:57:41,087 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Initializing cluster services. 2024-09-18 10:57:41,091 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Using working directory: WorkingDirectory(/tmp/jm_06dab9a6301a49ec7c29a40719a0872d). 2024-09-18 10:57:41,235 INFO org.apache.flink.runtime.rpc.pekko.PekkoRpcServiceUtils [] - Trying to start actor system, external address localhost:6123, bind address localhost:6123. 2024-09-18 10:57:41,657 INFO org.apache.pekko.event.slf4j.Slf4jLogger [] - Slf4jLogger started 2024-09-18 10:57:41,674 INFO org.apache.pekko.remote.RemoteActorRefProvider [] - Pekko Cluster not in use - enabling unsafe features anyway because `pekko.remote.use-unsafe-remote-features-outside-cluster` has been enabled. 2024-09-18 10:57:41,674 INFO org.apache.pekko.remote.Remoting [] - Starting remoting 2024-09-18 10:57:41,759 INFO org.apache.pekko.remote.Remoting [] - Remoting started; listening on addresses :[pekko.tcp://flink@localhost:6123] 2024-09-18 10:57:41,835 INFO org.apache.flink.runtime.rpc.pekko.PekkoRpcServiceUtils [] - Actor system started at pekko.tcp://flink@localhost:6123 2024-09-18 10:57:41,844 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Loading delegation token providers 2024-09-18 10:57:41,846 INFO org.apache.flink.runtime.security.token.hadoop.HadoopFSDelegationTokenProvider [] - Hadoop FS is not available (not packaged with this application): NoClassDefFoundError : "org/apache/hadoop/conf/Configuration". 2024-09-18 10:57:41,847 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token provider hadoopfs loaded and initialized 2024-09-18 10:57:41,847 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token provider hbase loaded and initialized 2024-09-18 10:57:41,847 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: external-resource-gpu 2024-09-18 10:57:41,848 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-influx 2024-09-18 10:57:41,848 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-jmx 2024-09-18 10:57:41,848 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-slf4j 2024-09-18 10:57:41,848 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-prometheus 2024-09-18 10:57:41,848 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-statsd 2024-09-18 10:57:41,848 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-datadog 2024-09-18 10:57:41,848 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-graphite 2024-09-18 10:57:41,848 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token providers loaded successfully 2024-09-18 10:57:41,849 INFO org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Loading delegation token receivers 2024-09-18 10:57:41,850 INFO org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receiver hadoopfs loaded and initialized 2024-09-18 10:57:41,850 INFO org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receiver hbase loaded and initialized 2024-09-18 10:57:41,850 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: external-resource-gpu 2024-09-18 10:57:41,850 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-influx 2024-09-18 10:57:41,851 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-jmx 2024-09-18 10:57:41,851 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-slf4j 2024-09-18 10:57:41,851 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-prometheus 2024-09-18 10:57:41,851 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-statsd 2024-09-18 10:57:41,851 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-datadog 2024-09-18 10:57:41,851 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-graphite 2024-09-18 10:57:41,851 INFO org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receivers loaded successfully 2024-09-18 10:57:41,851 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Checking provider and receiver instances consistency 2024-09-18 10:57:41,851 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Provider and receiver instances are consistent 2024-09-18 10:57:41,851 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Obtaining delegation tokens 2024-09-18 10:57:41,852 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation tokens obtained successfully 2024-09-18 10:57:41,853 WARN org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - No tokens obtained so skipping notifications 2024-09-18 10:57:41,864 INFO org.apache.flink.runtime.blob.BlobServer [] - Created BLOB server storage directory /tmp/jm_06dab9a6301a49ec7c29a40719a0872d/blobStorage 2024-09-18 10:57:41,866 INFO org.apache.flink.runtime.blob.BlobServer [] - Started BLOB server at 127.0.0.1:38815 - max concurrent requests: 50 - max backlog: 1000 2024-09-18 10:57:41,876 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl [] - No metrics reporter configured, no metrics will be exposed/reported. 2024-09-18 10:57:41,876 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl [] - No trace reporter configured, no metrics will be exposed/reported. 2024-09-18 10:57:41,879 INFO org.apache.flink.runtime.rpc.pekko.PekkoRpcServiceUtils [] - Trying to start actor system, external address localhost:0, bind address localhost:0. 2024-09-18 10:57:41,889 INFO org.apache.pekko.event.slf4j.Slf4jLogger [] - Slf4jLogger started 2024-09-18 10:57:41,891 INFO org.apache.pekko.remote.RemoteActorRefProvider [] - Pekko Cluster not in use - enabling unsafe features anyway because `pekko.remote.use-unsafe-remote-features-outside-cluster` has been enabled. 2024-09-18 10:57:41,891 INFO org.apache.pekko.remote.Remoting [] - Starting remoting 2024-09-18 10:57:41,896 INFO org.apache.pekko.remote.Remoting [] - Remoting started; listening on addresses :[pekko.tcp://flink-metrics@localhost:38565] 2024-09-18 10:57:41,900 INFO org.apache.flink.runtime.rpc.pekko.PekkoRpcServiceUtils [] - Actor system started at pekko.tcp://flink-metrics@localhost:38565 2024-09-18 10:57:41,907 INFO org.apache.flink.runtime.rpc.pekko.PekkoRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at pekko://flink-metrics/user/rpc/MetricQueryService . 2024-09-18 10:57:41,920 INFO org.apache.flink.runtime.dispatcher.FileExecutionGraphInfoStore [] - Initializing FileExecutionGraphInfoStore: Storage directory /tmp/executionGraphStore-8651d941-035d-4ac5-b950-23dc2990b1fe, expiration time 3600000, maximum cache size 52428800 bytes. 2024-09-18 10:57:41,961 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Upload directory /tmp/flink-web-5af7d113-54f1-4c0c-a31f-4a84af666441/flink-web-upload does not exist. 2024-09-18 10:57:41,961 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Created directory /tmp/flink-web-5af7d113-54f1-4c0c-a31f-4a84af666441/flink-web-upload for file uploads. 2024-09-18 10:57:41,962 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Starting rest endpoint. 2024-09-18 10:57:42,036 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined location of main cluster component log file: /home/yawyd/k8s-manifests/flink/oas/log/flink-yawyd-kubernetes-session-0-earth.log 2024-09-18 10:57:42,036 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined location of main cluster component stdout file: /home/yawyd/k8s-manifests/flink/oas/log/flink-yawyd-kubernetes-session-0-earth.out 2024-09-18 10:57:42,104 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Rest endpoint listening at 127.0.0.1:8081 2024-09-18 10:57:42,105 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - http://127.0.0.1:8081 was granted leadership with leaderSessionID=00000000-0000-0000-0000-000000000000 2024-09-18 10:57:42,106 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Web frontend listening at http://127.0.0.1:8081. 2024-09-18 10:57:42,114 INFO org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils [] - The derived from fraction jvm overhead memory (172.800mb (181193935 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead 2024-09-18 10:57:42,119 WARN org.apache.flink.kubernetes.entrypoint.KubernetesResourceManagerFactory [] - Configured size for 'taskmanager.memory.process.size' is ignored. Total memory size for TaskManagers are dynamically decided in fine-grained resource management. 2024-09-18 10:57:42,127 INFO org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] - DefaultDispatcherRunner was granted leadership with leader id 00000000-0000-0000-0000-000000000000. Creating new DispatcherLeaderProcess. 2024-09-18 10:57:42,130 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess. 2024-09-18 10:57:42,131 INFO org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Starting resource manager service. 2024-09-18 10:57:42,131 INFO org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Resource manager service is granted leadership with session id 00000000-0000-0000-0000-000000000000. 2024-09-18 10:57:42,132 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Recover all persisted job graphs that are not finished, yet. 2024-09-18 10:57:42,133 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 0 persisted job graphs. 2024-09-18 10:57:42,140 INFO org.apache.flink.runtime.rpc.pekko.PekkoRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at pekko://flink/user/rpc/dispatcher_0 . 2024-09-18 10:57:42,669 INFO org.apache.flink.configuration.GlobalConfiguration [] - Using standard YAML parser to load flink configuration file from /home/yawyd/k8s-manifests/flink/oas/conf/config.yaml. 2024-09-18 10:57:42,672 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.process.size, 1728m 2024-09-18 10:57:42,672 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.bind-host, localhost 2024-09-18 10:57:42,672 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.execution.failover-strategy, region 2024-09-18 10:57:42,672 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.taskmanager, ./conf/taskmanager-pod-template.yaml 2024-09-18 10:57:42,672 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.address, localhost 2024-09-18 10:57:42,672 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.memory.process.size, 1600m 2024-09-18 10:57:42,672 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.port, 6123 2024-09-18 10:57:42,672 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.bind-address, localhost 2024-09-18 10:57:42,673 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.bind-host, localhost 2024-09-18 10:57:42,673 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.host, localhost 2024-09-18 10:57:42,673 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.namespace, data 2024-09-18 10:57:42,673 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: parallelism.default, 1 2024-09-18 10:57:42,673 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1 2024-09-18 10:57:42,673 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.address, localhost 2024-09-18 10:57:42,673 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.jobmanager, ./conf/jobmanager-pod-template.yaml 2024-09-18 10:57:42,673 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.all, -Da=b 2024-09-18 10:57:42,676 INFO org.apache.flink.runtime.rpc.pekko.PekkoRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager at pekko://flink/user/rpc/resourcemanager_1 . 2024-09-18 10:57:42,682 INFO org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Starting the resource manager. 2024-09-18 10:57:42,686 INFO org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Starting the slot manager. 2024-09-18 10:57:42,686 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Starting tokens update task 2024-09-18 10:57:42,687 WARN org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - No tokens obtained so skipping notifications 2024-09-18 10:57:42,687 WARN org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Tokens update task not started because either no tokens obtained or none of the tokens specified its renewal date 2024-09-18 10:57:43,076 INFO org.apache.flink.kubernetes.KubernetesResourceManagerDriver [] - Recovered 0 pods from previous attempts, current attempt id is 1. 2024-09-18 10:57:43,076 INFO org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Recovered 0 workers from previous attempt. 2024-09-18 10:58:06,215 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - RECEIVED SIGNAL 2: SIGINT. Shutting down as requested. 2024-09-18 10:58:06,222 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Shutting KubernetesSessionClusterEntrypoint down with application status UNKNOWN. Diagnostics Cluster entrypoint has been closed externally.. 2024-09-18 10:58:06,222 INFO org.apache.flink.runtime.blob.BlobServer [] - Stopped BLOB server at 127.0.0.1:38815 2024-09-18 10:58:06,278 INFO org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Shutting down remote daemon. 2024-09-18 10:58:06,279 INFO org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Remote daemon shut down; proceeding with flushing remote transports. 2024-09-18 10:58:06,279 INFO org.apache.pekko.actor.CoordinatedShutdown [] - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 2024-09-18 10:58:06,281 INFO org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Shutting down remote daemon. 2024-09-18 10:58:06,281 INFO org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Remote daemon shut down; proceeding with flushing remote transports. 2024-09-18 10:58:06,292 INFO org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Remoting shut down. 2024-09-18 10:58:06,292 INFO org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Remoting shut down.