[
https://issues.apache.org/jira/browse/FLINK-39330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18089617#comment-18089617
]
Abhijeet Sharma commented on FLINK-39330:
-----------------------------------------
P.R Here [https://github.com/apache/flink/pull/28474] (Waiting on CI Run to be
completed)
> 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
> Assignee: Abhijeet Sharma
> Priority: Major
> Labels: pull-request-available
>
> 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)
