flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Till Rohrmann (Jira)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-18468) TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination fails with DuplicateJobSubmissionException
Date Fri, 03 Jul 2020 15:31:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-18468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151033#comment-17151033
] 

Till Rohrmann commented on FLINK-18468:
---------------------------------------

The problem of this test case is that we are waiting on the job result and then submit the
same job (same {{JobID}}) again. Having received the job result does not mean that the job
is completely cleaned up on the cluster which can cause a {{DuplicateJobSubmissionException}}.
I'm wondering whether this is actually a valid test case and whether we shouldn't submit the
new job under a new {{JobID}}.

> TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination fails with DuplicateJobSubmissionException
> ------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-18468
>                 URL: https://issues.apache.org/jira/browse/FLINK-18468
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Coordination, Tests
>    Affects Versions: 1.12.0
>            Reporter: Robert Metzger
>            Priority: Critical
>              Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=4149&view=logs&j=3b6ec2fd-a816-5e75-c775-06fb87cb6670&t=2aff8966-346f-518f-e6ce-de64002a5034
> {code}
> [ERROR] testJobReExecutionAfterTaskExecutorTermination(org.apache.flink.runtime.taskexecutor.TaskExecutorITCase)
 Time elapsed: 1.222 s  <<< ERROR!
> java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.DuplicateJobSubmissionException:
Job has already been submitted.
> 	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> 	at org.apache.flink.runtime.taskexecutor.TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination(TaskExecutorITCase.java:108)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message