cleverblue opened a new pull request #17822:
URL: https://github.com/apache/flink/pull/17822
RESOURCE_PARAMS extraction logs:
jvm_params: -Xmx2051014652 -Xms2051014652 -XX:MaxMetaspaceSize=268435456
dynamic_configs: -D jobmanager.memory.off-heap.size=134217728b -D
jobmanager.memory.jvm-overhead.min=272629764b -D
jobmanager.memory.jvm-metaspace.size=268435456b -D
jobmanager.memory.heap.size=2051014652b -D
jobmanager.memory.jvm-overhead.max=272629764b
logs: INFO [] - Loading configuration property: jobmanager.rpc.address,
localhost
INFO [] - Loading configuration property: jobmanager.rpc.port, 6123
INFO [] - Loading configuration property: jobmanager.memory.process.size,
2600m
INFO [] - Loading configuration property: taskmanager.memory.process.size,
2728m
INFO [] - Loading configuration property: taskmanager.memory.flink.size,
2280m
INFO [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
INFO [] - Loading configuration property: parallelism.default, 1
INFO [] - Loading configuration property:
jobmanager.execution.failover-strategy, region
INFO [] - Loading configuration property: classloader.resolve-order,
parent-first
INFO [] - Final Master Memory configuration:
INFO [] - Total Process Memory: 2.539gb (2726297600 bytes)
INFO [] - Total Flink Memory: 2.035gb (2185232380 bytes)
INFO [] - JVM Heap: 1.910gb (2051014652 bytes)
INFO [] - Off-heap: 128.000mb (134217728 bytes)
INFO [] - JVM Metaspace: 256.000mb (268435456 bytes)
INFO [] - JVM Overhead: 260.000mb (272629764 bytes)
2021-11-17 15:53:38,655 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
--------------------------------------------------------------------------------
2021-11-17 15:53:38,655 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting
StandaloneSessionClusterEntrypoint (Version: 1.14.0, Scala: 2.12, Rev:460b386,
Date:2021-09-22T08:39:40+02:00)
2021-11-17 15:53:38,655 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - OS current
user: root
2021-11-17 15:53:38,655 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Current
Hadoop/Kerberos user: <no hadoop dependency found>
2021-11-17 15:53:38,655 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM: Java
HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.181-b13
2021-11-17 15:53:38,655 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Maximum heap
size: 1874 MiBytes
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JAVA_HOME:
/usr/java/jdk1.8.0_181-cloudera
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - No Hadoop
Dependency available
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM Options:
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
-Xmx2051014652
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
-Xms2051014652
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
-XX:MaxMetaspaceSize=268435456
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
-Dlog.file=/opt/flink-1.14.0/log/flink-root-standalonesession-0-node09.log
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
-Dlog4j.configuration=file:/opt/flink-1.14.0/conf/log4j.properties
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
-Dlog4j.configurationFile=file:/opt/flink-1.14.0/conf/log4j.properties
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
-Dlogback.configurationFile=file:/opt/flink-1.14.0/conf/logback.xml
2021-11-17 15:53:38,656 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Program
Arguments:
2021-11-17 15:53:38,657 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
--configDir
2021-11-17 15:53:38,657 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
/opt/flink-1.14.0/conf
2021-11-17 15:53:38,657 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
--executionMode
2021-11-17 15:53:38,657 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - cluster
2021-11-17 15:53:38,657 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
jobmanager.memory.off-heap.size=134217728b
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
jobmanager.memory.jvm-overhead.min=272629764b
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
jobmanager.memory.jvm-metaspace.size=268435456b
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
jobmanager.memory.heap.size=2051014652b
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
jobmanager.memory.jvm-overhead.max=272629764b
2021-11-17 15:53:38,658 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Classpath:
/opt/flink-1.14.0/lib/flink-cep_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-cep-scala_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-clients_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-compress-1.14.0.jar:/opt/flink-1.14.0/lib/flink-connector-base-1.14.0.jar:/opt/flink-1.14.0/lib/flink-connector-jdbc_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-connector-kafka_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-connector-pulsar_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-csv-1.14.0.jar:/opt/flink-1.14.0/lib/flink-json-1.14.0.jar:/opt/flink-1.14.0/lib/flink-shaded-zookeeper-3.4.14.jar:/opt/flink-1.14.0/lib/flink-sql-client_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-sql-connector-kafka_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-table_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-table-common-1.14.0.jar:/opt/flink-1.14.0/lib/flink-table-planner_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-t
able-runtime_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-walkthrough-common_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/flink-walkthrough-datastream-java-1.14.0.jar:/opt/flink-1.14.0/lib/flink-yarn_2.12-1.14.0.jar:/opt/flink-1.14.0/lib/kafka-clients-3.0.0.jar:/opt/flink-1.14.0/lib/log4j-1.2-api-2.14.1.jar:/opt/flink-1.14.0/lib/log4j-api-2.14.1.jar:/opt/flink-1.14.0/lib/log4j-core-2.14.1.jar:/opt/flink-1.14.0/lib/log4j-slf4j-impl-2.14.1.jar:/opt/flink-1.14.0/lib/flink-dist_2.12-1.14.0.jar:::
2021-11-17 15:53:38,659 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
--------------------------------------------------------------------------------
2021-11-17 15:53:38,660 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Registered
UNIX signal handlers for [TERM, HUP, INT]
2021-11-17 15:53:38,692 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: jobmanager.rpc.address, localhost
2021-11-17 15:53:38,693 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: jobmanager.rpc.port, 6123
2021-11-17 15:53:38,693 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: jobmanager.memory.process.size, 2600m
2021-11-17 15:53:38,693 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: taskmanager.memory.process.size, 2728m
2021-11-17 15:53:38,693 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: taskmanager.memory.flink.size, 2280m
2021-11-17 15:53:38,693 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: taskmanager.numberOfTaskSlots, 1
2021-11-17 15:53:38,693 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: parallelism.default, 1
2021-11-17 15:53:38,694 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: jobmanager.execution.failover-strategy, region
2021-11-17 15:53:38,694 INFO
org.apache.flink.configuration.GlobalConfiguration [] - Loading
configuration property: classloader.resolve-order, parent-first
2021-11-17 15:53:38,735 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting
StandaloneSessionClusterEntrypoint.
2021-11-17 15:53:38,800 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install
default filesystem.
2021-11-17 15:53:38,809 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.
2021-11-17 15:53:38,858 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install
security context.
2021-11-17 15:53:38,866 INFO
org.apache.flink.runtime.security.modules.HadoopModuleFactory [] - Cannot
create Hadoop Security Module because Hadoop cannot be found in the Classpath.
2021-11-17 15:53:38,870 INFO
org.apache.flink.runtime.security.modules.JaasModule [] - Jaas file
will be created as /tmp/jaas-2426690826999442858.conf.
2021-11-17 15:53:38,875 INFO
org.apache.flink.runtime.security.contexts.HadoopSecurityContextFactory [] -
Cannot install HadoopSecurityContext because Hadoop cannot be found in the
Classpath.
2021-11-17 15:53:38,877 INFO
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Initializing
cluster services.
2021-11-17 15:53:39,549 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to
start actor system, external address localhost:6123, bind address 0.0.0.0:6123.
2021-11-17 15:53:41,097 INFO akka.event.slf4j.Slf4jLogger
[] - Slf4jLogger started
2021-11-17 15:53:41,130 INFO akka.remote.RemoteActorRefProvider
[] - Akka Cluster not in use - enabling unsafe features anyway
because `akka.remote.use-unsafe-remote-features-outside-cluster` has been
enabled.
2021-11-17 15:53:41,131 INFO akka.remote.Remoting
[] - Starting remoting
2021-11-17 15:53:41,393 INFO akka.remote.Remoting
[] - Remoting started; listening on addresses
:[akka.tcp://flink@localhost:6123]
2021-11-17 15:53:41,556 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system
started at akka.tcp://flink@localhost:6123
2021-11-17 15:53:41,596 INFO org.apache.flink.configuration.Configuration
[] - Config uses fallback configuration key
'jobmanager.rpc.address' instead of key 'rest.address'
2021-11-17 15:53:41,631 INFO org.apache.flink.runtime.blob.BlobServer
[] - Created BLOB server storage directory
/tmp/blobStore-789cefa7-0277-4012-9bc5-263af7f52367
2021-11-17 15:53:41,636 INFO org.apache.flink.runtime.blob.BlobServer
[] - Started BLOB server at 0.0.0.0:34485 - max concurrent
requests: 50 - max backlog: 1000
2021-11-17 15:53:41,665 INFO
org.apache.flink.runtime.metrics.MetricRegistryImpl [] - No metrics
reporter configured, no metrics will be exposed/reported.
2021-11-17 15:53:41,671 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to
start actor system, external address localhost:0, bind address 0.0.0.0:0.
2021-11-17 15:53:41,786 INFO akka.event.slf4j.Slf4jLogger
[] - Slf4jLogger started
2021-11-17 15:53:41,823 INFO akka.remote.RemoteActorRefProvider
[] - Akka Cluster not in use - enabling unsafe features anyway
because `akka.remote.use-unsafe-remote-features-outside-cluster` has been
enabled.
2021-11-17 15:53:41,823 INFO akka.remote.Remoting
[] - Starting remoting
2021-11-17 15:53:42,078 INFO akka.remote.Remoting
[] - Remoting started; listening on addresses
:[akka.tcp://flink-metrics@localhost:43037]
2021-11-17 15:53:42,088 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system
started at akka.tcp://flink-metrics@localhost:43037
2021-11-17 15:53:42,119 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC
endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at
akka://flink-metrics/user/rpc/MetricQueryService .
2021-11-17 15:53:42,150 INFO
org.apache.flink.runtime.dispatcher.FileExecutionGraphInfoStore [] -
Initializing FileExecutionGraphInfoStore: Storage directory
/tmp/executionGraphStore-44597f98-5add-4a05-88d0-7348c9e15cb7, expiration time
3600000, maximum cache size 52428800 bytes.
2021-11-17 15:53:42,283 INFO org.apache.flink.configuration.Configuration
[] - Config uses fallback configuration key
'jobmanager.rpc.address' instead of key 'rest.address'
2021-11-17 15:53:42,283 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Upload
directory /tmp/flink-web-7259e8bd-803e-44d8-ad73-bd69237f9483/flink-web-upload
does not exist.
2021-11-17 15:53:42,284 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Created
directory /tmp/flink-web-7259e8bd-803e-44d8-ad73-bd69237f9483/flink-web-upload
for file uploads.
2021-11-17 15:53:42,286 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Starting rest
endpoint.
2021-11-17 15:53:42,835 INFO
org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined
location of main cluster component log file:
/opt/flink-1.14.0/log/flink-root-standalonesession-0-node09.log
2021-11-17 15:53:42,835 INFO
org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined
location of main cluster component stdout file:
/opt/flink-1.14.0/log/flink-root-standalonesession-0-node09.out
2021-11-17 15:53:43,036 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Rest endpoint
listening at localhost:8081
2021-11-17 15:53:43,036 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] -
http://localhost:8081 was granted leadership with
leaderSessionID=00000000-0000-0000-0000-000000000000
2021-11-17 15:53:43,038 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Web frontend
listening at http://localhost:8081.
2021-11-17 15:53:43,067 INFO
org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] -
DefaultDispatcherRunner was granted leadership with leader id
00000000-0000-0000-0000-000000000000. Creating new DispatcherLeaderProcess.
2021-11-17 15:53:43,108 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] -
Start SessionDispatcherLeaderProcess.
2021-11-17 15:53:43,135 INFO
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] -
Starting resource manager service.
2021-11-17 15:53:43,190 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] -
Recover all persisted job graphs.
2021-11-17 15:53:43,190 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] -
Successfully recovered 0 persisted job graphs.
2021-11-17 15:53:43,324 INFO
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] -
Resource manager service is granted leadership with session id
00000000-0000-0000-0000-000000000000.
2021-11-17 15:53:43,365 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC
endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at
akka://flink/user/rpc/dispatcher_0 .
2021-11-17 15:53:43,470 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC
endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager
at akka://flink/user/rpc/resourcemanager_1 .
2021-11-17 15:53:43,485 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
Starting the resource manager.
2021-11-17 15:53:46,071 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
Registering TaskManager with ResourceID 127.0.0.1:40267-c8b3c5
(akka.tcp://flink@127.0.0.1:40267/user/rpc/taskmanager_0) at ResourceManager
2021-11-17 15:56:37,162 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Received
JobGraph submission 'UnnamedTable__0' (c5309d6799393099b2beb88975a7fea3).
2021-11-17 15:56:37,163 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Submitting
job 'UnnamedTable__0' (c5309d6799393099b2beb88975a7fea3).
2021-11-17 15:56:37,225 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC
endpoint for org.apache.flink.runtime.jobmaster.JobMaster at
akka://flink/user/rpc/jobmanager_2 .
2021-11-17 15:56:37,244 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Initializing job 'UnnamedTable__0'
(c5309d6799393099b2beb88975a7fea3).
2021-11-17 15:56:37,309 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Using restart back off time strategy
NoRestartBackoffTimeStrategy for UnnamedTable__0
(c5309d6799393099b2beb88975a7fea3).
2021-11-17 15:56:37,380 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Running initialization on master for job UnnamedTable__0
(c5309d6799393099b2beb88975a7fea3).
2021-11-17 15:56:37,380 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Successfully ran initialization on master in 0 ms.
2021-11-17 15:56:37,673 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Job
c5309d6799393099b2beb88975a7fea3 reached terminal state FAILED.
org.apache.flink.runtime.client.JobInitializationException: Could not start
the JobMaster.
at
org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97)
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1595)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.CompletionException:
java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot
instantiate the coordinator for operator Source:
KafkaSource-default_catalog.default_database.RealDataKafkaProducer ->
Calc(select=[0 AS $f0])
at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
at
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1592)
... 3 more
Caused by: java.lang.RuntimeException:
org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for
operator Source:
KafkaSource-default_catalog.default_database.RealDataKafkaProducer ->
Calc(select=[0 AS $f0])
at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:316)
at
org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114)
at
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)
... 3 more
Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the
coordinator for operator Source:
KafkaSource-default_catalog.default_database.RealDataKafkaProducer ->
Calc(select=[0 AS $f0])
at
org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:217)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:791)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:196)
at
org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:107)
at
org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:334)
at
org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:190)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:130)
at
org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:132)
at
org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:110)
at
org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:346)
at
org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:323)
at
org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:106)
at
org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:94)
at
org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
... 4 more
Caused by: java.lang.ClassCastException: cannot assign instance of
org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.OffsetResetStrategy
to field
org.apache.flink.connector.kafka.source.enumerator.initializer.ReaderHandledOffsetsInitializer.offsetResetStrategy
of type org.apache.kafka.clients.consumer.OffsetResetStrategy in instance of
org.apache.flink.connector.kafka.source.enumerator.initializer.ReaderHandledOffsetsInitializer
at
java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2287)
at
java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1417)
at
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2293)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)
at
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)
at
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287)
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211)
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:617)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:602)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:589)
at
org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67)
at
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:431)
at
org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:211)
... 17 more
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
