Home Explore Help
Sign In
cecf
/
deploy
5
0
Fork 0
Files Issues 0 Pull Requests 0 Wiki
Tree: afab9cf38c
Branches Tags
deploy
/
ob-agent-stream
/
log
/
flink-yawyd-kubernetes-session-0-earth.log

flink-yawyd-kubernetes-session-0-earth.log 26 KB
History Raw

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158 
  1. 2024-09-18 10:57:40,896 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - --------------------------------------------------------------------------------
    2. 

  2. 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)
    3. 

  3. 2024-09-18 10:57:40,897 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  OS current user: yawyd
    4. 

  4. 2024-09-18 10:57:40,897 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Current Hadoop/Kerberos user: <no hadoop dependency found>
    5. 

  5. 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
    6. 

  6. 2024-09-18 10:57:40,898 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Arch: amd64
    7. 

  7. 2024-09-18 10:57:40,898 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Maximum heap size: 8002 MiBytes
    8. 

  8. 2024-09-18 10:57:40,898 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  JAVA_HOME: /home/yawyd/.sdkman/candidates/java/current
    9. 

  9. 2024-09-18 10:57:40,898 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  No Hadoop Dependency available
    10. 

  10. 2024-09-18 10:57:40,898 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  JVM Options:
    11. 

  11. 2024-09-18 10:57:40,898 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -XX:+IgnoreUnrecognizedVMOptions
    12. 

  12. 2024-09-18 10:57:40,898 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -Da=b
    13. 

  13. 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
    14. 

  14. 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
    15. 

  15. 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
    16. 

  16. 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
    17. 

  17. 2024-09-18 10:57:40,898 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Program Arguments:
    18. 

  18. 2024-09-18 10:57:40,899 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -Dkubernetes.cluster-id=learn
    19. 

  19. 2024-09-18 10:57:40,899 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -Dkubernetes.namespace=data
    20. 

  20. 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::::
    21. 

  21. 2024-09-18 10:57:40,899 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - --------------------------------------------------------------------------------
    22. 

  22. 2024-09-18 10:57:40,900 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Registered UNIX signal handlers for [TERM, HUP, INT]
    23. 

  23. 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.
    24. 

  24. 2024-09-18 10:57:40,933 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.memory.process.size, 1728m
    25. 

  25. 2024-09-18 10:57:40,933 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.bind-host, localhost
    26. 

  26. 2024-09-18 10:57:40,933 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.execution.failover-strategy, region
    27. 

  27. 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
    28. 

  28. 2024-09-18 10:57:40,934 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.address, localhost
    29. 

  29. 2024-09-18 10:57:40,934 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.memory.process.size, 1600m
    30. 

  30. 2024-09-18 10:57:40,934 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.port, 6123
    31. 

  31. 2024-09-18 10:57:40,934 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: rest.bind-address, localhost
    32. 

  32. 2024-09-18 10:57:40,934 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.bind-host, localhost
    33. 

  33. 2024-09-18 10:57:40,934 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.host, localhost
    34. 

  34. 2024-09-18 10:57:40,934 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: kubernetes.namespace, data
    35. 

  35. 2024-09-18 10:57:40,934 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: parallelism.default, 1
    36. 

  36. 2024-09-18 10:57:40,934 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
    37. 

  37. 2024-09-18 10:57:40,935 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: rest.address, localhost
    38. 

  38. 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
    39. 

  39. 2024-09-18 10:57:40,935 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: env.java.opts.all, -Da=b
    40. 

  40. 2024-09-18 10:57:40,935 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading dynamic configuration property: kubernetes.namespace, data
    41. 

  41. 2024-09-18 10:57:40,935 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading dynamic configuration property: kubernetes.cluster-id, learn
    42. 

  42. 2024-09-18 10:57:41,034 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Starting KubernetesSessionClusterEntrypoint.
    43. 

  43. 2024-09-18 10:57:41,049 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Install default filesystem.
    44. 

  44. 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.
    45. 

  45. 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
    46. 

  46. 2024-09-18 10:57:41,063 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID not found, creating it: metrics-influx
    47. 

  47. 2024-09-18 10:57:41,064 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID not found, creating it: metrics-jmx
    48. 

  48. 2024-09-18 10:57:41,064 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID not found, creating it: metrics-slf4j
    49. 

  49. 2024-09-18 10:57:41,064 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID not found, creating it: metrics-prometheus
    50. 

  50. 2024-09-18 10:57:41,064 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID not found, creating it: metrics-statsd
    51. 

  51. 2024-09-18 10:57:41,064 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID not found, creating it: metrics-datadog
    52. 

  52. 2024-09-18 10:57:41,064 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID not found, creating it: metrics-graphite
    53. 

  53. 2024-09-18 10:57:41,073 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Install security context.
    54. 

  54. 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.
    55. 

  55. 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.
    56. 

  56. 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.
    57. 

  57. 2024-09-18 10:57:41,087 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Initializing cluster services.
    58. 

  58. 2024-09-18 10:57:41,091 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Using working directory: WorkingDirectory(/tmp/jm_06dab9a6301a49ec7c29a40719a0872d).
    59. 

  59. 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.
    60. 

  60. 2024-09-18 10:57:41,657 INFO  org.apache.pekko.event.slf4j.Slf4jLogger                     [] - Slf4jLogger started
    61. 

  61. 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.
    62. 

  62. 2024-09-18 10:57:41,674 INFO  org.apache.pekko.remote.Remoting                             [] - Starting remoting
    63. 

  63. 2024-09-18 10:57:41,759 INFO  org.apache.pekko.remote.Remoting                             [] - Remoting started; listening on addresses :[pekko.tcp://flink@localhost:6123]
    64. 

  64. 2024-09-18 10:57:41,835 INFO  org.apache.flink.runtime.rpc.pekko.PekkoRpcServiceUtils      [] - Actor system started at pekko.tcp://flink@localhost:6123
    65. 

  65. 2024-09-18 10:57:41,844 INFO  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Loading delegation token providers
    66. 

  66. 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".
    67. 

  67. 2024-09-18 10:57:41,847 INFO  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token provider hadoopfs loaded and initialized
    68. 

  68. 2024-09-18 10:57:41,847 INFO  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token provider hbase loaded and initialized
    69. 

  69. 2024-09-18 10:57:41,847 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: external-resource-gpu
    70. 

  70. 2024-09-18 10:57:41,848 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-influx
    71. 

  71. 2024-09-18 10:57:41,848 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-jmx
    72. 

  72. 2024-09-18 10:57:41,848 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-slf4j
    73. 

  73. 2024-09-18 10:57:41,848 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-prometheus
    74. 

  74. 2024-09-18 10:57:41,848 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-statsd
    75. 

  75. 2024-09-18 10:57:41,848 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-datadog
    76. 

  76. 2024-09-18 10:57:41,848 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-graphite
    77. 

  77. 2024-09-18 10:57:41,848 INFO  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token providers loaded successfully
    78. 

  78. 2024-09-18 10:57:41,849 INFO  org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Loading delegation token receivers
    79. 

  79. 2024-09-18 10:57:41,850 INFO  org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receiver hadoopfs loaded and initialized
    80. 

  80. 2024-09-18 10:57:41,850 INFO  org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receiver hbase loaded and initialized
    81. 

  81. 2024-09-18 10:57:41,850 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: external-resource-gpu
    82. 

  82. 2024-09-18 10:57:41,850 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-influx
    83. 

  83. 2024-09-18 10:57:41,851 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-jmx
    84. 

  84. 2024-09-18 10:57:41,851 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-slf4j
    85. 

  85. 2024-09-18 10:57:41,851 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-prometheus
    86. 

  86. 2024-09-18 10:57:41,851 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-statsd
    87. 

  87. 2024-09-18 10:57:41,851 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-datadog
    88. 

  88. 2024-09-18 10:57:41,851 INFO  org.apache.flink.core.plugin.DefaultPluginManager            [] - Plugin loader with ID found, reusing it: metrics-graphite
    89. 

  89. 2024-09-18 10:57:41,851 INFO  org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receivers loaded successfully
    90. 

  90. 2024-09-18 10:57:41,851 INFO  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Checking provider and receiver instances consistency
    91. 

  91. 2024-09-18 10:57:41,851 INFO  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Provider and receiver instances are consistent
    92. 

  92. 2024-09-18 10:57:41,851 INFO  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Obtaining delegation tokens
    93. 

  93. 2024-09-18 10:57:41,852 INFO  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation tokens obtained successfully
    94. 

  94. 2024-09-18 10:57:41,853 WARN  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - No tokens obtained so skipping notifications
    95. 

  95. 2024-09-18 10:57:41,864 INFO  org.apache.flink.runtime.blob.BlobServer                     [] - Created BLOB server storage directory /tmp/jm_06dab9a6301a49ec7c29a40719a0872d/blobStorage
    96. 

  96. 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
    97. 

  97. 2024-09-18 10:57:41,876 INFO  org.apache.flink.runtime.metrics.MetricRegistryImpl          [] - No metrics reporter configured, no metrics will be exposed/reported.
    98. 

  98. 2024-09-18 10:57:41,876 INFO  org.apache.flink.runtime.metrics.MetricRegistryImpl          [] - No trace reporter configured, no metrics will be exposed/reported.
    99. 

  99. 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.
    100. 

  100. 2024-09-18 10:57:41,889 INFO  org.apache.pekko.event.slf4j.Slf4jLogger                     [] - Slf4jLogger started
    101. 

  101. 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.
    102. 

  102. 2024-09-18 10:57:41,891 INFO  org.apache.pekko.remote.Remoting                             [] - Starting remoting
    103. 

  103. 2024-09-18 10:57:41,896 INFO  org.apache.pekko.remote.Remoting                             [] - Remoting started; listening on addresses :[pekko.tcp://flink-metrics@localhost:38565]
    104. 

  104. 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
    105. 

  105. 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 .
    106. 

  106. 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.
    107. 

  107. 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. 
    108. 

  108. 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.
    109. 

  109. 2024-09-18 10:57:41,962 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Starting rest endpoint.
    110. 

  110. 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
    111. 

  111. 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
    112. 

  112. 2024-09-18 10:57:42,104 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Rest endpoint listening at 127.0.0.1:8081
    113. 

  113. 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
    114. 

  114. 2024-09-18 10:57:42,106 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Web frontend listening at http://127.0.0.1:8081.
    115. 

  115. 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
    116. 

  116. 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.
    117. 

  117. 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.
    118. 

  118. 2024-09-18 10:57:42,130 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess.
    119. 

  119. 2024-09-18 10:57:42,131 INFO  org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Starting resource manager service.
    120. 

  120. 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.
    121. 

  121. 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.
    122. 

  122. 2024-09-18 10:57:42,133 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 0 persisted job graphs.
    123. 

  123. 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 .
    124. 

  124. 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.
    125. 

  125. 2024-09-18 10:57:42,672 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.memory.process.size, 1728m
    126. 

  126. 2024-09-18 10:57:42,672 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.bind-host, localhost
    127. 

  127. 2024-09-18 10:57:42,672 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.execution.failover-strategy, region
    128. 

  128. 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
    129. 

  129. 2024-09-18 10:57:42,672 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.address, localhost
    130. 

  130. 2024-09-18 10:57:42,672 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.memory.process.size, 1600m
    131. 

  131. 2024-09-18 10:57:42,672 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.port, 6123
    132. 

  132. 2024-09-18 10:57:42,672 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: rest.bind-address, localhost
    133. 

  133. 2024-09-18 10:57:42,673 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.bind-host, localhost
    134. 

  134. 2024-09-18 10:57:42,673 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.host, localhost
    135. 

  135. 2024-09-18 10:57:42,673 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: kubernetes.namespace, data
    136. 

  136. 2024-09-18 10:57:42,673 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: parallelism.default, 1
    137. 

  137. 2024-09-18 10:57:42,673 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
    138. 

  138. 2024-09-18 10:57:42,673 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: rest.address, localhost
    139. 

  139. 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
    140. 

  140. 2024-09-18 10:57:42,673 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: env.java.opts.all, -Da=b
    141. 

  141. 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 .
    142. 

  142. 2024-09-18 10:57:42,682 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Starting the resource manager.
    143. 

  143. 2024-09-18 10:57:42,686 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Starting the slot manager.
    144. 

  144. 2024-09-18 10:57:42,686 INFO  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Starting tokens update task
    145. 

  145. 2024-09-18 10:57:42,687 WARN  org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - No tokens obtained so skipping notifications
    146. 

  146. 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
    147. 

  147. 2024-09-18 10:57:43,076 INFO  org.apache.flink.kubernetes.KubernetesResourceManagerDriver  [] - Recovered 0 pods from previous attempts, current attempt id is 1.
    148. 

  148. 2024-09-18 10:57:43,076 INFO  org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Recovered 0 workers from previous attempt.
    149. 

  149. 2024-09-18 10:58:06,215 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - RECEIVED SIGNAL 2: SIGINT. Shutting down as requested.
    150. 

  150. 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..
    151. 

  151. 2024-09-18 10:58:06,222 INFO  org.apache.flink.runtime.blob.BlobServer                     [] - Stopped BLOB server at 127.0.0.1:38815
    152. 

  152. 2024-09-18 10:58:06,278 INFO  org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Shutting down remote daemon.
    153. 

  153. 2024-09-18 10:58:06,279 INFO  org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Remote daemon shut down; proceeding with flushing remote transports.
    154. 

  154. 2024-09-18 10:58:06,279 INFO  org.apache.pekko.actor.CoordinatedShutdown                   [] - Running CoordinatedShutdown with reason [ActorSystemTerminateReason]
    155. 

  155. 2024-09-18 10:58:06,281 INFO  org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Shutting down remote daemon.
    156. 

  156. 2024-09-18 10:58:06,281 INFO  org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Remote daemon shut down; proceeding with flushing remote transports.
    157. 

  157. 2024-09-18 10:58:06,292 INFO  org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Remoting shut down.
    158. 

  158. 2024-09-18 10:58:06,292 INFO  org.apache.pekko.remote.RemoteActorRefProvider$RemotingTerminator [] - Remoting shut down.
    159.