rmoff · April 15, 2024 10:32
diff --git a/flink-rmoff-sql-client-asgard08.log b/flink-rmoff-sql-client-asgard08.log
 2024-04-15 11:25:36,164 INFO  org.apache.flink.client.program.rest.RestClusterClient       [] - Successfully submitted job 'collect' (926ca3f6cfa9f0a4b5bc7f215b4681eb) to 'http://localhost:8081'.
 2024-04-15 11:25:36,256 ERROR org.apache.flink.table.gateway.service.operation.OperationManager [] - Failed to execute the operation a2f854a9-938c-4c57-a484-4abe9d8eeb78.
 org.apache.flink.table.api.TableException: Failed to execute sql
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1084) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:435) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:207) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
 	at java.lang.Thread.run(Thread.java:829) [?:?]
 Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'collect'.
 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2253) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:110) ~[?:?]
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1065) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	... 13 more
 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
 	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:75) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) ~[?:?]
 	at java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:479) ~[?:?]
 	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) ~[?:?]
 	at java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) ~[?:?]
 	at java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) ~[?:?]
 	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) ~[?:?]
 	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) ~[?:?]
 Caused by: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
 	at org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) ~[?:?]
 	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) ~[?:?]
 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1705) ~[?:?]
 	... 3 more
 Caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314) ~[?:?]
 	at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:319) ~[?:?]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1702) ~[?:?]
 	... 3 more
 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[?:?]
 	... 3 more
 Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:234) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:894) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionGraph.initializeJobVertex(ExecutionGraph.java:224) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:875) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:829) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:163) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:371) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:214) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[?:?]
 	... 3 more
 Caused by: java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
 	at java.net.URLClassLoader.findClass(URLClassLoader.java:476) ~[?:?]
 	at java.lang.ClassLoader.loadClass(ClassLoader.java:594) ~[?:?]
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:65) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.lang.ClassLoader.loadClass(ClassLoader.java:527) ~[?:?]
 	at org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:192) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.lang.Class.forName0(Native Method) ~[?:?]
 	at java.lang.Class.forName(Class.java:398) ~[?:?]
 	at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2003) ~[?:?]
 	at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870) ~[?:?]
 	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201) ~[?:?]
 	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?]
 	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?]
 	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?]
 	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?]
 	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?]
 	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?]
 	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?]
 	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?]
 	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?]
 	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:489) ~[?:?]
 	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:447) ~[?:?]
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:477) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:292) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:225) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:894) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionGraph.initializeJobVertex(ExecutionGraph.java:224) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:875) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:829) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:163) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:371) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:214) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[?:?]
 	... 3 more
 2024-04-15 11:25:36,329 ERROR org.apache.flink.table.gateway.service.SqlGatewayServiceImpl [] - Failed to fetchResults.
 org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed to execute the operation a2f854a9-938c-4c57-a484-4abe9d8eeb78.
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	at java.lang.Thread.run(Thread.java:829) [?:?]
 Caused by: org.apache.flink.table.api.TableException: Failed to execute sql
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1084) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:435) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:207) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	... 7 more
 Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'collect'.
 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2253) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:110) ~[?:?]
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1065) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:435) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:207) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	... 7 more
 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
 	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:75) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) ~[?:?]
 	at java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:479) ~[?:?]
 	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) ~[?:?]
 	at java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) ~[?:?]
 	at java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) ~[?:?]
 	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) ~[?:?]
 	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) ~[?:?]
 Caused by: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
 	at org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) ~[?:?]
 	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) ~[?:?]
 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1705) ~[?:?]
 	... 3 more
 Caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314) ~[?:?]
 	at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:319) ~[?:?]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1702) ~[?:?]
 	... 3 more
 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[?:?]
 	... 3 more
 Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:234) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:894) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionGraph.initializeJobVertex(ExecutionGraph.java:224) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:875) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:829) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:163) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:371) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:214) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[?:?]
 	... 3 more
 Caused by: java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
 	at java.net.URLClassLoader.findClass(URLClassLoader.java:476) ~[?:?]
 	at java.lang.ClassLoader.loadClass(ClassLoader.java:594) ~[?:?]
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:65) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.lang.ClassLoader.loadClass(ClassLoader.java:527) ~[?:?]
 	at org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:192) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.lang.Class.forName0(Native Method) ~[?:?]
 	at java.lang.Class.forName(Class.java:398) ~[?:?]
 	at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2003) ~[?:?]
 	at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870) ~[?:?]
 	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201) ~[?:?]
 	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?]
 	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?]
 	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?]
 	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?]
 	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?]
 	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?]
 	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?]
 	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?]
 	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?]
 	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:489) ~[?:?]
 	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:447) ~[?:?]
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:477) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:292) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:225) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:894) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionGraph.initializeJobVertex(ExecutionGraph.java:224) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:875) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:829) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:163) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:371) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:214) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[?:?]
 	... 3 more
 2024-04-15 11:25:36,331 ERROR org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler [] - Unhandled exception.
 org.apache.flink.table.gateway.api.utils.SqlGatewayException: org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to fetchResults.
 	at org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:85) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:84) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:52) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:196) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:83) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.Optional.ifPresent(Optional.java:183) [?:?]
 	at org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:45) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:80) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:49) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:94) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:55) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:208) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:69) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) [flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [flink-dist-1.18.1.jar:1.18.1]
 	at java.lang.Thread.run(Thread.java:829) [?:?]
 Caused by: org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to fetchResults.
 	at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServiceImpl.java:229) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:83) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	... 48 more
 Caused by: org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed to execute the operation a2f854a9-938c-4c57-a484-4abe9d8eeb78.
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	... 1 more
 Caused by: org.apache.flink.table.api.TableException: Failed to execute sql
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1084) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:435) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:207) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	... 1 more
 Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'collect'.
 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2253) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:110) ~[?:?]
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1065) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:435) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:207) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
 	at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	... 1 more
 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
 	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:75) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) ~[?:?]
 	at java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:479) ~[?:?]
 	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) ~[?:?]
 	at java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) ~[?:?]
 	at java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) ~[?:?]
 	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) ~[?:?]
 	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) ~[?:?]
 Caused by: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
 	at org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) ~[?:?]
 	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) ~[?:?]
 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1705) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	... 1 more
 Caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314) ~[?:?]
 	at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:319) ~[?:?]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1702) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	... 1 more
 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	... 1 more
 Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:234) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:894) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionGraph.initializeJobVertex(ExecutionGraph.java:224) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:875) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:829) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:163) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:371) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:214) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	... 1 more
 Caused by: java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
 	at java.net.URLClassLoader.findClass(URLClassLoader.java:476) ~[?:?]
 	at java.lang.ClassLoader.loadClass(ClassLoader.java:594) ~[?:?]
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:65) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.lang.ClassLoader.loadClass(ClassLoader.java:527) ~[?:?]
 	at org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:192) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.lang.Class.forName0(Native Method) ~[?:?]
 	at java.lang.Class.forName(Class.java:398) ~[?:?]
 	at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2003) ~[?:?]
 	at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870) ~[?:?]
 	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201) ~[?:?]
 	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?]
 	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?]
 	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?]
 	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?]
 	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?]
 	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496) ~[?:?]
 	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390) ~[?:?]
 	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228) ~[?:?]
 	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687) ~[?:?]
 	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:489) ~[?:?]
 	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:447) ~[?:?]
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:477) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:292) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:225) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:894) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.ExecutionGraph.initializeJobVertex(ExecutionGraph.java:224) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:875) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:829) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:163) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:371) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:214) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	... 1 more
 2024-04-15 11:25:36,346 WARN  org.apache.flink.table.client.cli.CliClient                  [] - Could not execute SQL statement.
 org.apache.flink.table.client.gateway.SqlExecutionException: Failed to get response for the operation a2f854a9-938c-4c57-a484-4abe9d8eeb78.
 	at org.apache.flink.table.client.gateway.ExecutorImpl.getFetchResultResponse(ExecutorImpl.java:488) ~[flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.gateway.ExecutorImpl.fetchUtilResultsReady(ExecutorImpl.java:448) ~[flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.gateway.ExecutorImpl.executeStatement(ExecutorImpl.java:309) ~[flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.cli.parser.SqlMultiLineParser.parse(SqlMultiLineParser.java:113) ~[flink-sql-client-1.18.1.jar:1.18.1]
 	at org.jline.reader.impl.LineReaderImpl.acceptLine(LineReaderImpl.java:2964) ~[flink-sql-client-1.18.1.jar:1.18.1]
 	at org.jline.reader.impl.LineReaderImpl$1.apply(LineReaderImpl.java:3778) ~[flink-sql-client-1.18.1.jar:1.18.1]
 	at org.jline.reader.impl.LineReaderImpl.readLine(LineReaderImpl.java:679) ~[flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.cli.CliClient.getAndExecuteStatements(CliClient.java:194) [flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:179) [flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:121) [flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:114) [flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:169) [flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.SqlClient.start(SqlClient.java:118) [flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:228) [flink-sql-client-1.18.1.jar:1.18.1]
 	at org.apache.flink.table.client.SqlClient.main(SqlClient.java:179) [flink-sql-client-1.18.1.jar:1.18.1]
 Caused by: org.apache.flink.runtime.rest.util.RestClientException: [Internal server error., <Exception on server side:
 org.apache.flink.table.gateway.api.utils.SqlGatewayException: org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to fetchResults.
 	at org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:85)
 	at org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:84)
 	at org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler.respondToRequest(AbstractSqlGatewayRestHandler.java:52)
 	at org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:196)
 	at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:83)
 	at java.base/java.util.Optional.ifPresent(Optional.java:183)
 	at org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:45)
 	at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:80)
 	at org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:49)
 	at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
 	at org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115)
 	at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:94)
 	at org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:55)
 	at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
 	at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:208)
 	at org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:69)
 	at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
 	at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
 	at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
 	at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
 	at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
 	at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
 	at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
 	at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
 	at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
 	at org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
 	at java.base/java.lang.Thread.run(Thread.java:829)
 Caused by: org.apache.flink.table.gateway.api.utils.SqlGatewayException: Failed to fetchResults.
 	at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServiceImpl.java:229)
 	at org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(FetchResultsHandler.java:83)
 	... 48 more
 Caused by: org.apache.flink.table.gateway.service.utils.SqlExecutionException: Failed to execute the operation a2f854a9-938c-4c57-a484-4abe9d8eeb78.
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.processThrowable(OperationManager.java:414)
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:267)
 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
 	... 1 more
 Caused by: org.apache.flink.table.api.TableException: Failed to execute sql
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1084)
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120)
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:435)
 	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:207)
 	at org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.lambda$executeStatement$1(SqlGatewayServiceImpl.java:212)
 	at org.apache.flink.table.gateway.service.operation.OperationManager.lambda$submitOperation$1(OperationManager.java:119)
 	at org.apache.flink.table.gateway.service.operation.OperationManager$Operation.lambda$run$0(OperationManager.java:258)
 	... 7 more
 Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'collect'.
 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2253)
 	at org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:110)
 	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1065)
 	... 13 more
 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
 	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:75)
 	at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642)
 	at java.base/java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:479)
 	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
 	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
 	at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
 	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
 	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
 Caused by: 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.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
 	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
 	at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
 	at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1705)
 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
 	at java.base/java.lang.Thread.run(Thread.java:829)
 Caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314)
 	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:319)
 	at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1702)
 	... 3 more
 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114)
 	at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700)
 	... 3 more
 Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:234)
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:894)
 	at org.apache.flink.runtime.executiongraph.ExecutionGraph.initializeJobVertex(ExecutionGraph.java:224)
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:875)
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:829)
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221)
 	at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:163)
 	at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:371)
 	at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:214)
 	at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140)
 	at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156)
 	at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122)
 	at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379)
 	at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356)
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128)
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100)
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
 	... 4 more
 Caused by: java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
 	at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:476)
 	at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:594)
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67)
 	at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:65)
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51)
 	at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:527)
 	at org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:192)
 	at java.base/java.lang.Class.forName0(Native Method)
 	at java.base/java.lang.Class.forName(Class.java:398)
 	at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78)
 	at java.base/java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2003)
 	at java.base/java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870)
 	at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201)
 	at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687)
 	at java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496)
 	at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390)
 	at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228)
 	at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687)
 	at java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496)
 	at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390)
 	at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228)
 	at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687)
 	at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:489)
 	at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:447)
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539)
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527)
 	at org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67)
 	at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:477)
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:292)
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:225)
 	... 20 more

 End of exception on server side>]
 	at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:646) ~[flink-dist-1.18.1.jar:1.18.1]
 	at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$6(RestClient.java:626) ~[flink-dist-1.18.1.jar:1.18.1]
 	at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072) ~[?:?]
 	at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
 	at java.lang.Thread.run(Thread.java:829) ~[?:?]
diff --git a/flink-rmoff-standalonesession-0-asgard08.log b/flink-rmoff-standalonesession-0-asgard08.log
 2024-04-15 11:25:36,161 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher     [] - Received JobGraph submission 'collect' (926ca3f6cfa9f0a4b5bc7f215b4681eb).
 2024-04-15 11:25:36,161 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher     [] - Submitting job 'collect' (926ca3f6cfa9f0a4b5bc7f215b4681eb).
 2024-04-15 11:25:36,162 INFO  org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner [] - JobMasterServiceLeadershipRunner for job 926ca3f6cfa9f0a4b5bc7f215b4681eb was granted leadership with leader id 00000000-0000-0000-0000-000000000000. Creating new JobMasterServiceProcess.
 2024-04-15 11:25:36,163 INFO  org.apache.flink.runtime.rpc.pekko.PekkoRpcService           [] - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at pekko://flink/user/rpc/jobmanager_3 .
 2024-04-15 11:25:36,163 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Initializing job 'collect' (926ca3f6cfa9f0a4b5bc7f215b4681eb).
 2024-04-15 11:25:36,163 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Using restart back off time strategy NoRestartBackoffTimeStrategy for collect (926ca3f6cfa9f0a4b5bc7f215b4681eb).
 2024-04-15 11:25:36,164 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Created execution graph 75703cc112fc9dfbe24c62f422c06dfa for job 926ca3f6cfa9f0a4b5bc7f215b4681eb.
 2024-04-15 11:25:36,164 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Running initialization on master for job collect (926ca3f6cfa9f0a4b5bc7f215b4681eb).
 2024-04-15 11:25:36,164 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Successfully ran initialization on master in 0 ms.
 2024-04-15 11:25:36,180 INFO  org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorCoordinator [] - Closing the CollectSinkOperatorCoordinator.
 2024-04-15 11:25:36,182 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher     [] - Job 926ca3f6cfa9f0a4b5bc7f215b4681eb 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.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
 	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
 	at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
 	at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1705)
 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
 	at java.base/java.lang.Thread.run(Thread.java:829)
 Caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314)
 	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:319)
 	at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1702)
 	... 3 more
 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114)
 	at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700)
 	... 3 more
 Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:234)
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:894)
 	at org.apache.flink.runtime.executiongraph.ExecutionGraph.initializeJobVertex(ExecutionGraph.java:224)
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:875)
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:829)
 	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221)
 	at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:163)
 	at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:371)
 	at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:214)
 	at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140)
 	at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156)
 	at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122)
 	at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379)
 	at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356)
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128)
 	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100)
 	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
 	... 4 more
 Caused by: java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
 	at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:476)
 	at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:594)
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67)
 	at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:65)
 	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51)
 	at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:527)
 	at org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:192)
 	at java.base/java.lang.Class.forName0(Native Method)
 	at java.base/java.lang.Class.forName(Class.java:398)
 	at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78)
 	at java.base/java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2003)
 	at java.base/java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870)
 	at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201)
 	at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687)
 	at java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496)
 	at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390)
 	at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228)
 	at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687)
 	at java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496)
 	at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390)
 	at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228)
 	at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687)
 	at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:489)
 	at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:447)
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539)
 	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527)
 	at org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67)
 	at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:477)
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:292)
 	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:225)
 	... 20 more
 2024-04-15 11:25:36,185 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher     [] - Job 926ca3f6cfa9f0a4b5bc7f215b4681eb has been registered for cleanup in the JobResultStore after reaching a terminal state.
	2024-04-15 11:25:36,161 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Received JobGraph submission 'collect' (926ca3f6cfa9f0a4b5bc7f215b4681eb).
	2024-04-15 11:25:36,161 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Submitting job 'collect' (926ca3f6cfa9f0a4b5bc7f215b4681eb).
	2024-04-15 11:25:36,162 INFO org.apache.flink.runtime.jobmaster.JobMasterServiceLeadershipRunner [] - JobMasterServiceLeadershipRunner for job 926ca3f6cfa9f0a4b5bc7f215b4681eb was granted leadership with leader id 00000000-0000-0000-0000-000000000000. Creating new JobMasterServiceProcess.
	2024-04-15 11:25:36,163 INFO org.apache.flink.runtime.rpc.pekko.PekkoRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at pekko://flink/user/rpc/jobmanager_3 .
	2024-04-15 11:25:36,163 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Initializing job 'collect' (926ca3f6cfa9f0a4b5bc7f215b4681eb).
	2024-04-15 11:25:36,163 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Using restart back off time strategy NoRestartBackoffTimeStrategy for collect (926ca3f6cfa9f0a4b5bc7f215b4681eb).
	2024-04-15 11:25:36,164 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Created execution graph 75703cc112fc9dfbe24c62f422c06dfa for job 926ca3f6cfa9f0a4b5bc7f215b4681eb.
	2024-04-15 11:25:36,164 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Running initialization on master for job collect (926ca3f6cfa9f0a4b5bc7f215b4681eb).
	2024-04-15 11:25:36,164 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Successfully ran initialization on master in 0 ms.
	2024-04-15 11:25:36,180 INFO org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorCoordinator [] - Closing the CollectSinkOperatorCoordinator.
	2024-04-15 11:25:36,182 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Job 926ca3f6cfa9f0a4b5bc7f215b4681eb 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.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
	at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
	at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1705)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
	Caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:319)
	at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1702)
	... 3 more
	Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
	at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114)
	at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700)
	... 3 more
	Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator Source: t_foo[3] -> Sink: Collect table sink
	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:234)
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:894)
	at org.apache.flink.runtime.executiongraph.ExecutionGraph.initializeJobVertex(ExecutionGraph.java:224)
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:875)
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:829)
	at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:221)
	at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:163)
	at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:371)
	at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:214)
	at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140)
	at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:156)
	at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122)
	at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379)
	at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356)
	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128)
	at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100)
	at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
	... 4 more
	Caused by: java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
	at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:476)
	at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:594)
	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67)
	at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:65)
	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51)
	at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:527)
	at org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:192)
	at java.base/java.lang.Class.forName0(Native Method)
	at java.base/java.lang.Class.forName(Class.java:398)
	at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78)
	at java.base/java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2003)
	at java.base/java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1870)
	at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2201)
	at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687)
	at java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496)
	at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390)
	at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228)
	at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687)
	at java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2496)
	at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2390)
	at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2228)
	at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1687)
	at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:489)
	at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:447)
	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539)
	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527)
	at org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67)
	at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:477)
	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:292)
	at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:225)
	... 20 more
	2024-04-15 11:25:36,185 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Job 926ca3f6cfa9f0a4b5bc7f215b4681eb has been registered for cleanup in the JobResultStore after reaching a terminal state.