[
https://issues.apache.org/jira/browse/FLINK-20383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-20383.
---------------------------------
Resolution: Fixed
> DataSet allround end-to-end test fails with NullPointerException
> ----------------------------------------------------------------
>
> Key: FLINK-20383
> URL: https://issues.apache.org/jira/browse/FLINK-20383
> Project: Flink
> Issue Type: Bug
> Components: API / DataSet
> Affects Versions: 1.12.0, 1.13.0
> Reporter: Robert Metzger
> Assignee: Arvid Heise
> Priority: Blocker
> Labels: pull-request-available, test-stability
> Fix For: 1.12.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=10204&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=ff888d9b-cd34-53cc-d90f-3e446d355529
> {code}
> 2020-11-26T19:45:51.5478354Z Nov 26 19:45:51 Running 'DataSet allround
> end-to-end test'
> 2020-11-26T19:45:51.5478763Z Nov 26 19:45:51
> ==============================================================================
> 2020-11-26T19:45:51.5490922Z Nov 26 19:45:51 TEST_DATA_DIR:
> /home/vsts/work/1/s/flink-end-to-end-tests/test-scripts/temp-test-directory-51548553152
> 2020-11-26T19:45:51.7135919Z Nov 26 19:45:51 Flink dist directory:
> /home/vsts/work/1/s/flink-dist/target/flink-1.12-SNAPSHOT-bin/flink-1.12-SNAPSHOT
> 2020-11-26T19:45:51.7232126Z Nov 26 19:45:51 Run DataSet-Allround-Test Program
> 2020-11-26T19:45:51.7266761Z Nov 26 19:45:51 Setting up SSL with: internal
> JDK dynamic
> 2020-11-26T19:45:51.7300820Z Nov 26 19:45:51 Using SAN
> dns:fv-az679-746.omrnvntobknexcvwb1hiviload.fx.internal.cloudapp.net,ip:10.1.0.4,ip:172.17.0.1,ip:172.18.0.1
> 2020-11-26T19:45:52.8564809Z Certificate was added to keystore
> 2020-11-26T19:45:54.9192018Z Certificate was added to keystore
> 2020-11-26T19:45:55.5263075Z Certificate reply was installed in keystore
> 2020-11-26T19:45:55.7151814Z Nov 26 19:45:55 Setting up SSL with: rest JDK
> dynamic
> 2020-11-26T19:45:55.7186828Z Nov 26 19:45:55 Using SAN
> dns:fv-az679-746.omrnvntobknexcvwb1hiviload.fx.internal.cloudapp.net,ip:10.1.0.4,ip:172.17.0.1,ip:172.18.0.1
> 2020-11-26T19:45:56.8610453Z Certificate was added to keystore
> 2020-11-26T19:45:59.2956135Z Certificate was added to keystore
> 2020-11-26T19:45:59.9115744Z Certificate reply was installed in keystore
> 2020-11-26T19:46:00.0800993Z Nov 26 19:46:00 Mutual ssl auth: false
> 2020-11-26T19:46:00.1688426Z Nov 26 19:46:00 Starting cluster.
> 2020-11-26T19:46:00.8775396Z Nov 26 19:46:00 Starting standalonesession
> daemon on host fv-az679-746.
> 2020-11-26T19:46:02.4016699Z Nov 26 19:46:02 Starting taskexecutor daemon on
> host fv-az679-746.
> 2020-11-26T19:46:02.4595285Z Nov 26 19:46:02 Waiting for Dispatcher REST
> endpoint to come up...
> 2020-11-26T19:46:03.5161706Z Nov 26 19:46:03 Waiting for Dispatcher REST
> endpoint to come up...
> 2020-11-26T19:46:04.6157725Z Nov 26 19:46:04 Waiting for Dispatcher REST
> endpoint to come up...
> 2020-11-26T19:46:05.7153907Z Nov 26 19:46:05 Waiting for Dispatcher REST
> endpoint to come up...
> 2020-11-26T19:46:07.4507631Z Nov 26 19:46:07 Waiting for Dispatcher REST
> endpoint to come up...
> 2020-11-26T19:46:08.6436701Z Nov 26 19:46:08 Dispatcher REST endpoint is up.
> 2020-11-26T19:46:08.6437477Z Nov 26 19:46:08 Start 3 more task managers
> 2020-11-26T19:46:09.4234133Z Nov 26 19:46:09 [INFO] 1 instance(s) of
> taskexecutor are already running on fv-az679-746.
> 2020-11-26T19:46:09.4242548Z Nov 26 19:46:09 Starting taskexecutor daemon on
> host fv-az679-746.
> 2020-11-26T19:46:11.0906754Z Nov 26 19:46:11 [INFO] 2 instance(s) of
> taskexecutor are already running on fv-az679-746.
> 2020-11-26T19:46:11.0920876Z Nov 26 19:46:11 Starting taskexecutor daemon on
> host fv-az679-746.
> 2020-11-26T19:46:14.2637898Z Nov 26 19:46:14 [INFO] 3 instance(s) of
> taskexecutor are already running on fv-az679-746.
> 2020-11-26T19:46:14.2688442Z Nov 26 19:46:14 Starting taskexecutor daemon on
> host fv-az679-746.
> 2020-11-26T19:46:25.7685789Z Nov 26 19:46:25 Job has been submitted with
> JobID fa6775cf8a2ed83f2e4ba98930bc2cb2
> 2020-11-26T19:47:37.4444212Z
> 2020-11-26T19:47:37.4448196Z
> ------------------------------------------------------------
> 2020-11-26T19:47:37.4448668Z The program finished with the following
> exception:
> 2020-11-26T19:47:37.4448911Z
> 2020-11-26T19:47:37.4453074Z
> org.apache.flink.client.program.ProgramInvocationException: The main method
> caused an error: org.apache.flink.client.program.ProgramInvocationException:
> Job failed (JobID: fa6775cf8a2ed83f2e4ba98930bc2cb2)
> 2020-11-26T19:47:37.4458530Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:330)
> 2020-11-26T19:47:37.4459217Z at
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198)
> 2020-11-26T19:47:37.4459771Z at
> org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114)
> 2020-11-26T19:47:37.4460243Z at
> org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:743)
> 2020-11-26T19:47:37.4460711Z at
> org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:242)
> 2020-11-26T19:47:37.4461161Z at
> org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:971)
> 2020-11-26T19:47:37.4461649Z at
> org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1047)
> 2020-11-26T19:47:37.4462191Z at
> org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
> 2020-11-26T19:47:37.4462932Z at
> org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1047)
> 2020-11-26T19:47:37.4471377Z Caused by:
> java.util.concurrent.ExecutionException:
> org.apache.flink.client.program.ProgramInvocationException: Job failed
> (JobID: fa6775cf8a2ed83f2e4ba98930bc2cb2)
> 2020-11-26T19:47:37.4489158Z at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2020-11-26T19:47:37.4489770Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> 2020-11-26T19:47:37.4490173Z at
> org.apache.flink.client.program.ContextEnvironment.getJobExecutionResult(ContextEnvironment.java:112)
> 2020-11-26T19:47:37.4490584Z at
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:76)
> 2020-11-26T19:47:37.4490985Z at
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:873)
> 2020-11-26T19:47:37.4492050Z at
> org.apache.flink.batch.tests.DataSetAllroundTestProgram.main(DataSetAllroundTestProgram.java:181)
> 2020-11-26T19:47:37.4492407Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2020-11-26T19:47:37.4492964Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2020-11-26T19:47:37.4493418Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2020-11-26T19:47:37.4493799Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2020-11-26T19:47:37.4494196Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:316)
> 2020-11-26T19:47:37.4494512Z ... 8 more
> 2020-11-26T19:47:37.4494866Z Caused by:
> org.apache.flink.client.program.ProgramInvocationException: Job failed
> (JobID: fa6775cf8a2ed83f2e4ba98930bc2cb2)
> 2020-11-26T19:47:37.4495434Z at
> org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:119)
> 2020-11-26T19:47:37.4495929Z at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
> 2020-11-26T19:47:37.4496350Z at
> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
> 2020-11-26T19:47:37.4497022Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2020-11-26T19:47:37.4497454Z at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2020-11-26T19:47:37.4497924Z at
> org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$22(RestClusterClient.java:602)
> 2020-11-26T19:47:37.4498599Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2020-11-26T19:47:37.4499059Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2020-11-26T19:47:37.4499496Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2020-11-26T19:47:37.4499924Z at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2020-11-26T19:47:37.4500389Z at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:379)
> 2020-11-26T19:47:37.4500859Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2020-11-26T19:47:37.4501395Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2020-11-26T19:47:37.4501846Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2020-11-26T19:47:37.4502258Z at
> java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
> 2020-11-26T19:47:37.4502691Z at
> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:943)
> 2020-11-26T19:47:37.4503137Z at
> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
> 2020-11-26T19:47:37.4503557Z at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2020-11-26T19:47:37.4503990Z at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-11-26T19:47:37.4504346Z at java.lang.Thread.run(Thread.java:748)
> 2020-11-26T19:47:37.4504693Z Caused by:
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2020-11-26T19:47:37.4505141Z at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
> 2020-11-26T19:47:37.4505653Z at
> org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:117)
> 2020-11-26T19:47:37.4506010Z ... 19 more
> 2020-11-26T19:47:37.4506333Z Caused by:
> org.apache.flink.runtime.JobException: Recovery is suppressed by
> NoRestartBackoffTimeStrategy
> 2020-11-26T19:47:37.4506873Z at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:116)
> 2020-11-26T19:47:37.4507477Z at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:78)
> 2020-11-26T19:47:37.4508045Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:224)
> 2020-11-26T19:47:37.4508543Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:217)
> 2020-11-26T19:47:37.4509573Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:208)
> 2020-11-26T19:47:37.4510110Z at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:533)
> 2020-11-26T19:47:37.4510595Z at
> org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:89)
> 2020-11-26T19:47:37.4511054Z at
> org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:419)
> 2020-11-26T19:47:37.4511451Z at
> sun.reflect.GeneratedMethodAccessor29.invoke(Unknown Source)
> 2020-11-26T19:47:37.4511841Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2020-11-26T19:47:37.4512223Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2020-11-26T19:47:37.4512625Z at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:286)
> 2020-11-26T19:47:37.4513178Z at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:201)
> 2020-11-26T19:47:37.4513651Z at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
> 2020-11-26T19:47:37.4514126Z at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:154)
> 2020-11-26T19:47:37.4514535Z at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
> 2020-11-26T19:47:37.4514891Z at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
> 2020-11-26T19:47:37.4515271Z at
> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
> 2020-11-26T19:47:37.4515660Z at
> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
> 2020-11-26T19:47:37.4516037Z at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
> 2020-11-26T19:47:37.4516427Z at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> 2020-11-26T19:47:37.4516811Z at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> 2020-11-26T19:47:37.4517210Z at
> akka.actor.Actor$class.aroundReceive(Actor.scala:517)
> 2020-11-26T19:47:37.4517577Z at
> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
> 2020-11-26T19:47:37.4520483Z at
> akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
> 2020-11-26T19:47:37.4520859Z at
> akka.actor.ActorCell.invoke(ActorCell.scala:561)
> 2020-11-26T19:47:37.4521208Z at
> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
> 2020-11-26T19:47:37.4521543Z at akka.dispatch.Mailbox.run(Mailbox.scala:225)
> 2020-11-26T19:47:37.4524388Z at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
> 2020-11-26T19:47:37.4525133Z at
> akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> 2020-11-26T19:47:37.4525599Z at
> akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> 2020-11-26T19:47:37.4526099Z at
> akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> 2020-11-26T19:47:37.4526629Z at
> akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> 2020-11-26T19:47:37.4527162Z Caused by: java.lang.NullPointerException
> 2020-11-26T19:47:37.4527553Z at
> org.apache.flink.runtime.io.network.partition.PipelinedSubpartition.notifyDataAvailable(PipelinedSubpartition.java:500)
> 2020-11-26T19:47:37.4528065Z at
> org.apache.flink.runtime.io.network.partition.PipelinedSubpartition.add(PipelinedSubpartition.java:163)
> 2020-11-26T19:47:37.4528524Z at
> org.apache.flink.runtime.io.network.partition.PipelinedSubpartition.finish(PipelinedSubpartition.java:133)
> 2020-11-26T19:47:37.4529000Z at
> org.apache.flink.runtime.io.network.partition.BufferWritingResultPartition.finish(BufferWritingResultPartition.java:215)
> 2020-11-26T19:47:37.4529403Z at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:737)
> 2020-11-26T19:47:37.4529908Z at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:547)
> 2020-11-26T19:47:37.4530233Z at java.lang.Thread.run(Thread.java:748)
> 2020-11-26T19:47:37.4656278Z Nov 26 19:47:37 [FAIL] Test script contains
> errors.
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
