Hi, 这个报错一般是JDK版本不一致导致的。建议统一build flink和执行flink作业时的Java版本，（都用JDK8 或者 都用JDK11）。 用JDK11时没有sun.misc的问题可以试试勾选掉Idea的Settings-> Build, Execution and Deployment -> Compiler-> Java Compiler的Use '--release' option for cross-compilation' 选项。
Best, Biao Geng z_mmG <13520871...@163.com> 于2024年4月30日周二 15:08写道： > > JDK11 编译的flink1.19的源码 > 因为他说没有sun.misc，所以启动用的jdk8 > > 已连接到地址为 ''127.0.0.1:8339'，传输: '套接字'' 的目标虚拟机 > > Job has been submitted with JobID 0975ec264edfd11d236dd190e7708d70 > > > ------------------------------------------------------------ > > The program finished with the following exception: > > > org.apache.flink.client.program.ProgramInvocationException: The main > method caused an error: > org.apache.flink.client.program.ProgramInvocationException: Job failed > (JobID: 0975ec264edfd11d236dd190e7708d70) > > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:373) > > at > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:223) > > at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:113) > > at > org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:1026) > > at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:247) > > at > org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1270) > > at > org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$10(CliFrontend.java:1367) > > at > org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28) > > at > org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1367) > > at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1335) > > Caused by: java.util.concurrent.ExecutionException: > org.apache.flink.client.program.ProgramInvocationException: Job failed > (JobID: 0975ec264edfd11d236dd190e7708d70) > > at > java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) > > at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895) > > at > org.apache.flink.client.program.StreamContextEnvironment.getJobExecutionResult(StreamContextEnvironment.java:170) > > at > org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:121) > > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2325) > > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2303) > > at org.apache.flink.streaming.examples.ys.WordCount.main(WordCount.java:34) > > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > > at java.lang.reflect.Method.invoke(Method.java:498) > > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:356) > > ... 9 more > > Caused by: org.apache.flink.client.program.ProgramInvocationException: Job > failed (JobID: 0975ec264edfd11d236dd190e7708d70) > > at > org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$getJobExecutionResult$6(ClusterClientJobClientAdapter.java:130) > > at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:602) > > at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577) > > at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) > > at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) > > at > org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$6(FutureUtils.java:302) > > at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) > > at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) > > at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) > > at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) > > at > org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$35(RestClusterClient.java:901) > > at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) > > at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) > > at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) > > at > java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) > > at > org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$6(FutureUtils.java:302) > > at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) > > at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) > > at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) > > at > java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:561) > > at > java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:929) > > at > java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442) > > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > > at java.lang.Thread.run(Thread.java:748) > > Caused by: org.apache.flink.runtime.client.JobExecutionException: Job > execution failed. > > at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > > at > org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$getJobExecutionResult$6(ClusterClientJobClientAdapter.java:128) > > ... 24 more > > Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed > by NoRestartBackoffTimeStrategy > > at > org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:219) > > at > org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailureAndReport(ExecutionFailureHandler.java:166) > > at > org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:121) > > at > org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:279) > > at > org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:270) > > at > org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:263) > > at > org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:788) > > at > org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:765) > > at > org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:83) > > at > org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:496) > > at sun.reflect.GeneratedMethodAccessor21.invoke(Unknown Source) > > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > > at java.lang.reflect.Method.invoke(Method.java:498) > > at > org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$1(PekkoRpcActor.java:318) > > at > org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) > > at > org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:316) > > at > org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229) > > at > org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88) > > at > org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174) > > at > org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33) > > at > org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29) > > at scala.PartialFunction.applyOrElse(PartialFunction.scala:127) > > at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126) > > at > org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29) > > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175) > > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) > > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) > > at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547) > > at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545) > > at > org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229) > > at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590) > > at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557) > > at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:280) > > at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:241) > > at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:253) > > at > java.util.concurrent.ForkJoinTask.doExec$$$capture(ForkJoinTask.java:289) > > at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java) > > at > java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) > > at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) > > at > java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) > > Caused by: java.lang.NoSuchMethodError: > java.nio.ByteBuffer.position(I)Ljava/nio/ByteBuffer; > > at > org.apache.flink.core.memory.DataOutputSerializer.wrapAsByteBuffer(DataOutputSerializer.java:51) > > at > org.apache.flink.runtime.io.network.api.writer.RecordWriter.serializeRecord(RecordWriter.java:157) > > at > org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:108) > > at > org.apache.flink.runtime.io.network.api.writer.ChannelSelectorRecordWriter.emit(ChannelSelectorRecordWriter.java:55) > > at > org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:140) > > at > org.apache.flink.streaming.runtime.io.RecordWriterOutput.collectAndCheckIfChained(RecordWriterOutput.java:120) > > at > org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:101) > > at > org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:53) > > at > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:60) > > at > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:32) > > at > org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:38) > > at > org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:75) > > at > org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:50) > > at > org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29) > > at > org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask$AsyncDataOutputToOutput.emitRecord(SourceOperatorStreamTask.java:310) > > at > org.apache.flink.streaming.api.operators.source.SourceOutputWithWatermarks.collect(SourceOutputWithWatermarks.java:110) > > at > org.apache.flink.streaming.api.operators.source.SourceOutputWithWatermarks.collect(SourceOutputWithWatermarks.java:101) > > at > org.apache.flink.api.connector.source.lib.util.IteratorSourceReaderBase.pollNext(IteratorSourceReaderBase.java:111) > > at > org.apache.flink.api.connector.source.util.ratelimit.RateLimitedSourceReader.pollNext(RateLimitedSourceReader.java:69) > > at > org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:421) > > at > org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) > > at > org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:600) > > at > org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:930) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:879) > > at > org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:960) > > at > org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:939) > > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:753) > > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:568) > > at java.lang.Thread.run(Thread.java:748) > > 已与地址为 ''127.0.0.1:8339'，传输: '套接字'' 的目标虚拟机断开连接 >
