ankit0811 commented on issue #11036:
URL: https://github.com/apache/hudi/issues/11036#issuecomment-2233667107
@danny0405 I tired using 1.0-beta2 and get s3a atomic writes not supported
exception
here is the stack trace
```
"message":"JobMaster for job 7c57d7e79fef591c171e8e487112be09
failed.","name":"org.apache.flink.util.FlinkException","cause":{"commonElementCount":14,"localizedMessage":"Could
not start the JobMaster.","message":"Could not start the
JobMaster.","name":"org.apache.flink.runtime.jobmaster.JobMasterException","cause":{"commonElementCount":14,"localizedMessage":"Failed
to start the operator coordinators","message":"Failed to start the operator
coordinators","name":"org.apache.flink.util.FlinkRuntimeException","cause":{"commonElementCount":14,"localizedMessage":"Unable
to instantiate class
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider","message":"Unable
to instantiate class
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider","name":"org.apache.hudi.exception.HoodieException","cause":{"commonElementCount":14,"name":"java.lang.reflect.InvocationTargetException","cause":{"commonElementCount":14,"localizedMessage":"Unsupported
scheme :s3a, since this
fs can not support atomic creation","message":"Unsupported scheme :s3a, since
this fs can not support atomic
creation","name":"org.apache.hudi.exception.HoodieLockException","extendedStackTrace":"org.apache.hudi.exception.HoodieLockException:
Unsupported scheme :s3a, since this fs can not support atomic creation\n\tat
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider.<init>(FileSystemBasedLockProvider.java:90)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockMana
ger.java:113) ~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startA
llOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc
-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n"},"extendedStackTrace":"java.lang.reflect.InvocationTargetExce
ption: null\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(St
reamWriteOperatorCoordinator.java:350) ~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.jav
a:927) ~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseS
tatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\nCaused by:
org.apache.hudi.exception.HoodieLockException: Unsupported scheme :s3a, since
this fs can not support atomic creation\n\tat
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider.<init>(FileSystemBasedLockProvider.java:90)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
~[?:?]\n\tat jdk.internal.reflect.DelegatingConstructorAcce
ssorImpl.newInstance(Unknown Source) ~[?:?]\n\tat
java.lang.reflect.Constructor.newInstance(Unknown Source) ~[?:?]\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(Oper
atorCoordinatorHolder.java:194) ~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-d
ist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat scala.PartialFunction.applyOrElse$(
PartialFunction.scala:122) ~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14
more\n"},"extendedStackTrace":"org.apache.hudi.exception.HoodieException:
Unable to instantiate class
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:75)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\t
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat o
rg.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df
1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\nCaused by:
java.lang.reflect.InvocationTargetException\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat org
.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoor
dinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:61
2) ~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatem
ents.scala:20) ~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
org.apache.hudi.exception.HoodieLockException: Unsupported scheme :s3a, since
this fs can not support atomic creation\n\tat
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider.<init>(FileSystemBasedLockProvider.java:90)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat org.apac
he.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOpera
torCoordinatorHandler.java:82) ~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb
7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14
more\n"},"extendedStackTrace":"org.apache.flink.util.FlinkRuntimeException:
Failed to sta
rt the operator coordinators\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:169)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat org.ap
ache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) ~[flink-
scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\nCaused by:
org.apache.hudi.exception.HoodieException: Unable to instantiate class
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:75)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetad
ataTable(StreamWriteOperatorCoordinator.java:350) ~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(Jo
bMaster.java:927) ~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.
apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
java.lang.reflect.InvocationTargetException\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat org.apache.hudi.common.util.ReflectionUtils.loadClas
s(ReflectionUtils.java:73) ~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultO
peratorCoordinatorHandler.java:164) ~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb
7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat scala.PartialFunction
$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
org.apache.hudi.exception.HoodieLockException: Unsupported scheme :s3a, since
this fs can not support atomic creation\n\tat
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider.<init>(FileSystemBasedLockProvider.java:90)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat org.apache.hudi.client.transaction.lock.LockManager.unloc
k(LockManager.java:100) ~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.
2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtim
e.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14
more\n"},"extendedStackTrace":"org.apache.flink.runtime.jobmaster.JobMasterException:
Could not start the JobMaster.\n\tat org.apache.flin
k.runtime.jobmaster.JobMaster.onStart(JobMaster.java:390)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatem
ent.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\nCaused by:
org.apache.flink.util.FlinkRuntimeException: Failed to start the operator
coordinators\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:169)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~
[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2
bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
org.apache.hudi.exception.HoodieException: Unable to instantiate class
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:75)
~[flink
-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164
) ~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apac
he.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat scala.PartialFunction$OrElse.applyOrElse(PartialFunctio
n.scala:171) ~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
java.lang.reflect.InvocationTargetException\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFl
inkWriteClient.java:320) ~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[fl
ink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[fl
ink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
org.apache.hudi.exception.HoodieLockException: Unsupported scheme :s3a, since
this fs can not support atomic creation\n\tat
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider.<init>(FileSystemBasedLockProvider.java:90)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat jdk.internal.
reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source) ~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOp
eratorCoordinator.java:195) ~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388) ~[fli
nk-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFu
nction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14
more\n"},"extendedStackTrace":"org.apache.flink.util.FlinkException: JobMaster
for job 7c57d7e79fef591c171e8e487112be09 failed.\n\tat
org.apache.flink.runtime.dispatcher.Dispatcher.jobMasterFailed(Dispatcher.java:1206)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.dispatcher.Dispatcher.jobManagerRunnerFailed(Dispatcher.java:695)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.dispatcher.Dispatcher.lambda$runJob$4(Dispatcher.java:617)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
java.util.concurrent.CompletableFuture.uniHandle(Unknown Source) ~[?:?]\n\tat
java.util.concurre
nt.CompletableFuture$UniHandle.tryFire(Unknown Source) ~[?:?]\n\tat
java.util.concurrent.CompletableFuture$Completion.run(Unknown Source)
~[?:?]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:443)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:443)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache
.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
scala.PartialFunction$OrElse.applyOrElse(P
artialFunction.scala:172)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.actor.Actor.aroundReceive(Actor.scala:537)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.actor.Actor.aroundReceive$(Actor.scala:535)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.actor.ActorCell.invoke(ActorCell.scala:548)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.dispatc
h.Mailbox.run(Mailbox.scala:231)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.dispatch.Mailbox.exec(Mailbox.scala:243)
[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
java.util.concurrent.ForkJoinTask.doExec(Unknown Source) [?:?]\n\tat
java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source)
[?:?]\n\tat java.util.concurrent.ForkJoinPool.scan(Unknown Source) [?:?]\n\tat
java.util.concurrent.ForkJoinPool.runWorker(Unknown Source) [?:?]\n\tat
java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source) [?:?]\nCaused by:
org.apache.flink.runtime.jobmaster.JobMasterException: Could not start the
JobMaster.\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:390)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(Akka
RpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyO
rElse(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
org.apache.flink.util.FlinkRuntimeException: Failed to start the operator
coordinators\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:169)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat org
.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.Un
itCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
org.apache.hudi.exception.HoodieException: Unable to instantiate class
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:75)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat org.apache.hudi.client.HoodieFlinkTableServic
eClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221) ~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduli
ng(SchedulerBase.java:624) ~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka
_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
java.lang.reflect.InvocationTargetException\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat jdk.internal.reflect.NativeConstructorAccessorImpl.newInstanc
e(Unknown Source) ~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat
org.apache.hudi.common.util.ReflectionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat org.apa
che.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat org.apache.flin
k.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123) ~[
flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14 more\nCaused by:
org.apache.hudi.exception.HoodieLockException: Unsupported scheme :s3a, since
this fs can not support atomic creation\n\tat
org.apache.hudi.client.transaction.lock.FileSystemBasedLockProvider.<init>(FileSystemBasedLockProvider.java:90)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:?]\n\tat
jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
~[?:?]\n\tat
jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown
Source) ~[?:?]\n\tat java.lang.reflect.Constructor.newInstance(Unknown Source)
~[?:?]\n\tat org.apache.hudi.common.util.Reflect
ionUtils.loadClass(ReflectionUtils.java:73)
~[flink-s3-fs-presto-1.15.2.jar:1.15.2]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.getLockProvider(LockManager.java:113)
~[?:?]\n\tat
org.apache.hudi.client.transaction.lock.LockManager.unlock(LockManager.java:100)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkTableServiceClient.initMetadataTable(HoodieFlinkTableServiceClient.java:221)
~[?:?]\n\tat
org.apache.hudi.client.HoodieFlinkWriteClient.initMetadataTable(HoodieFlinkWriteClient.java:320)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.initMetadataTable(StreamWriteOperatorCoordinator.java:350)
~[?:?]\n\tat
org.apache.hudi.sink.StreamWriteOperatorCoordinator.start(StreamWriteOperatorCoordinator.java:195)
~[?:?]\n\tat
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.start(OperatorCoordinatorHolder.java:194)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startOperatorCoor
dinators(DefaultOperatorCoordinatorHandler.java:164)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.DefaultOperatorCoordinatorHandler.startAllOperatorCoordinators(DefaultOperatorCoordinatorHandler.java:82)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.scheduler.SchedulerBase.startScheduling(SchedulerBase.java:624)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startScheduling(JobMaster.java:1010)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.startJobExecution(JobMaster.java:927)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.jobmaster.JobMaster.onStart(JobMaster.java:388)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStart(RpcEndpoint.java:181)
~[flink-dist-1.15.2.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.lambda$start$0(AkkaRpcActor.java:612)
~[flink-rpc-akka_8908cf19-c41
8-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StoppedState.start(AkkaRpcActor.java:611)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:185)
~[flink-rpc-akka_8908cf19-c418-4000-9df1-cc2bb7ac9412.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]\n\tat
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]\n\tat
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\tat
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
~[?:?]\n\tat scal
a.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
~[flink-scala_2.12-1.15.2.jar:1.15.2]\n\t... 14
more\n"},"endOfBatch":false,"loggerFqcn":"org.apache.logging.slf4j.Log4jLogger","contextMap":{},"threadId":172,"threadPriority":5}
```
Can you tell me what am I missing here?
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
