2024-09-18 10:55:18,239 INFO org.apache.flink.client.cli.CliFrontend [] - -------------------------------------------------------------------------------- 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - Starting Command Line Client (Version: 1.19.1, Scala: 2.12, Rev:5edb5a9, Date:2024-06-06T14:45:33+02:00) 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - OS current user: yawyd 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - Current Hadoop/Kerberos user: 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - JVM: OpenJDK 64-Bit Server VM - Amazon.com Inc. - 11/11.0.24+8-LTS 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - Arch: amd64 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - Maximum heap size: 8002 MiBytes 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - JAVA_HOME: /home/yawyd/.sdkman/candidates/java/current 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - No Hadoop Dependency available 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - JVM Options: 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - -XX:+IgnoreUnrecognizedVMOptions 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - -Da=b 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - -Dlog.file=/home/yawyd/k8s-manifests/flink/oas/log/flink-yawyd-client-earth.log 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - -Dlog4j.configuration=file:/home/yawyd/k8s-manifests/flink/oas/conf/log4j-cli.properties 2024-09-18 10:55:18,240 INFO org.apache.flink.client.cli.CliFrontend [] - -Dlog4j.configurationFile=file:/home/yawyd/k8s-manifests/flink/oas/conf/log4j-cli.properties 2024-09-18 10:55:18,241 INFO org.apache.flink.client.cli.CliFrontend [] - -Dlogback.configurationFile=file:/home/yawyd/k8s-manifests/flink/oas/conf/logback.xml 2024-09-18 10:55:18,241 INFO org.apache.flink.client.cli.CliFrontend [] - Program Arguments: 2024-09-18 10:55:18,241 INFO org.apache.flink.client.cli.CliFrontend [] - submit 2024-09-18 10:55:18,241 INFO org.apache.flink.client.cli.CliFrontend [] - 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:55:18,241 INFO org.apache.flink.client.cli.CliFrontend [] - -------------------------------------------------------------------------------- 2024-09-18 10:55:18,242 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:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.process.size, 1728m 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.bind-host, localhost 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.execution.failover-strategy, region 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.taskmanager, ./conf/taskmanager-pod-template.yaml 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.address, localhost 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.memory.process.size, 1600m 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.port, 6123 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.bind-address, localhost 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.bind-host, localhost 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.host, localhost 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.namespace, data 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: parallelism.default, 1 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.address, localhost 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.jobmanager, ./conf/jobmanager-pod-template.yaml 2024-09-18 10:55:18,271 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.all, -Da=b 2024-09-18 10:55:18,290 INFO org.apache.flink.client.cli.CliFrontend [] - Loading FallbackYarnSessionCli 2024-09-18 10:55:18,304 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:55:18,313 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: external-resource-gpu 2024-09-18 10:55:18,316 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-influx 2024-09-18 10:55:18,317 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-jmx 2024-09-18 10:55:18,317 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-slf4j 2024-09-18 10:55:18,317 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-prometheus 2024-09-18 10:55:18,317 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-statsd 2024-09-18 10:55:18,317 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-datadog 2024-09-18 10:55:18,317 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-graphite 2024-09-18 10:55:18,344 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:55:18,352 INFO org.apache.flink.runtime.security.modules.JaasModule [] - Jaas file will be created as /tmp/jaas-7154341485311612654.conf. 2024-09-18 10:55:18,355 INFO org.apache.flink.runtime.security.contexts.HadoopSecurityContextFactory [] - Cannot install HadoopSecurityContext because Hadoop cannot be found in the Classpath.