Piotr Nowojski created FLINK-39330:
--------------------------------------
Summary:
FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails
Key: FLINK-39330
URL: https://issues.apache.org/jira/browse/FLINK-39330
Project: Flink
Issue Type: Bug
Components: Connectors / Common
Affects Versions: 2.3.0
Reporter: Piotr Nowojski
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=73539&view=logs&j=2e8cb2f7-b2d3-5c62-9c05-cd756d33a819&t=49d3c873-4717-5e09-1f8c-9da6a2a97847
{noformat}
Mar 25 07:58:18 07:58:18.535 [ERROR] Errors:
Mar 25 07:58:18 07:58:18.536 [ERROR]
FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover:113->runTestWithNewMiniCluster:314->lambda$testBoundedTextFileSourceWithJobManagerFailover$1:114->testBoundedTextFileSource:127->testBoundedTextFileSource:174
ยป Runtime Failed to fetch next result
M
{noformat}
{noformat}
Mar 25 07:58:18 07:58:18.111 [ERROR] Tests run: 7, Failures: 0, Errors: 1,
Skipped: 0, Time elapsed: 311.1 s <<< FAILURE! -- in
org.apache.flink.connector.file.src.FileSourceTextLinesITCase
Mar 25 07:58:18 07:58:18.111 [ERROR]
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover(Path)
-- Time elapsed: 300.5 s <<< ERROR!
Mar 25 07:58:18 java.lang.RuntimeException: Failed to fetch next result
Mar 25 07:58:18 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:127)
Mar 25 07:58:18 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:98)
Mar 25 07:58:18 at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.testBoundedTextFileSource(FileSourceTextLinesITCase.java:174)
Mar 25 07:58:18 at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.testBoundedTextFileSource(FileSourceTextLinesITCase.java:127)
Mar 25 07:58:18 at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.lambda$testBoundedTextFileSourceWithJobManagerFailover$1(FileSourceTextLinesITCase.java:114)
Mar 25 07:58:18 at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.runTestWithNewMiniCluster(FileSourceTextLinesITCase.java:314)
Mar 25 07:58:18 at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover(FileSourceTextLinesITCase.java:113)
Mar 25 07:58:18 at
java.base/java.lang.reflect.Method.invoke(Method.java:568)
Mar 25 07:58:18 at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
Mar 25 07:58:18 at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
Mar 25 07:58:18 at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
Mar 25 07:58:18 at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
Mar 25 07:58:18 at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
Mar 25 07:58:18 Caused by: java.io.IOException: Failed to fetch job execution
result
Mar 25 07:58:18 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:189)
Mar 25 07:58:18 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:122)
Mar 25 07:58:18 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:124)
Mar 25 07:58:18 ... 12 more
Mar 25 07:58:18 Caused by: java.util.concurrent.ExecutionException:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
Mar 25 07:58:18 at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
Mar 25 07:58:18 at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096)
Mar 25 07:58:18 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:187)
Mar 25 07:58:18 ... 14 more
Mar 25 07:58:18 Caused by:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
Mar 25 07:58:18 at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:180)
Mar 25 07:58:18 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:140)
Mar 25 07:58:18 at
java.base/java.util.concurrent.CompletableFuture.uniApplyNow(CompletableFuture.java:684)
Mar 25 07:58:18 at
java.base/java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:662)
Mar 25 07:58:18 at
java.base/java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:2168)
Mar 25 07:58:18 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:137)
Mar 25 07:58:18 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:186)
Mar 25 07:58:18 ... 14 more
Mar 25 07:58:18 Caused by: org.apache.flink.runtime.JobException: Recovery is
suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1,
backoffTimeMS=0)
Mar 25 07:58:18 at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:213)
Mar 25 07:58:18 at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailureAndReport(ExecutionFailureHandler.java:163)
Mar 25 07:58:18 at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:118)
Mar 25 07:58:18 at
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:300)
Mar 25 07:58:18 at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:291)
Mar 25 07:58:18 at
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:284)
Mar 25 07:58:18 at
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:836)
Mar 25 07:58:18 at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:813)
Mar 25 07:58:18 at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
Mar 25 07:58:18 at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1741)
{noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
