[
https://issues.apache.org/jira/browse/FLINK-28977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597638#comment-17597638
]
Martijn Visser commented on FLINK-28977:
----------------------------------------
Fixed in master: ee4d27411b3bf1cfcc4171aab777eb8bf08f1550
> NullPointerException in HybridSourceSplitEnumerator.close
> ---------------------------------------------------------
>
> Key: FLINK-28977
> URL: https://issues.apache.org/jira/browse/FLINK-28977
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Common
> Affects Versions: 1.14.4, 1.15.1
> Reporter: Michael
> Assignee: Michael
> Priority: Major
> Labels: pull-request-available, pull-requests-available
> Fix For: 1.17.0
>
>
> HybridSource pipeline has an intermittent error when reading from s3, usually
> this error is fixed when pipeline restarts after recovering from checkpoint.
> But intermittently happens:
> 2022/08/02 22:26:51.435 INFO o.a.f.runtime.jobmaster.JobMaster - Trying to
> recover from a global failure.
> org.apache.flink.util.FlinkException: Global failure triggered by
> OperatorCoordinator for 'Source: hybrid-source -> decrypt -> map2Events ->
> filterOutNulls -> assignTimestampsAndWatermarks -> logRawJson' (operator
> fd9fbc680ee884c4eafd0b9c2d3d007f).
> at
> org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder$LazyInitializedCoordinatorContext.failJob(OperatorCoordinatorHolder.java:545)
> at
> org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.cleanAndFailJob(RecreateOnResetOperatorCoordinator.java:393)
> ...
> Caused by: java.lang.NullPointerException: null
> at
> org.apache.flink.connector.base.source.hybridspp.HybridSourceSplitEnumerator.close(HybridSourceSplitEnumerator.java:246)
> at
> org.apache.flink.runtime.source.coordinator.SourceCoordinator.close(SourceCoordinator.java:151)
> at
> org.apache.flink.runtime.operators.coordination.ComponentClosingUtils.lambda$closeAsyncWithTimeout$0(ComponentClosingUtils.java:70)
> at java.lang.Thread.run(Thread.java:750)
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
