[GitHub] [flink] StephanEwen commented on a change in pull request #13784: [FLINK-19698][connectors/common] API improvements to the Sources.

2020-11-03 Thread GitBox
StephanEwen commented on a change in pull request #13784: URL: https://github.com/apache/flink/pull/13784#discussion_r516139098 ## File path: flink-core/src/main/java/org/apache/flink/api/common/state/CheckpointListener.java ## @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache

[GitHub] [flink] StephanEwen commented on a change in pull request #13784: [FLINK-19698][connectors/common] API improvements to the Sources.

2020-10-28 Thread GitBox
StephanEwen commented on a change in pull request #13784: URL: https://github.com/apache/flink/pull/13784#discussion_r513286480 ## File path: flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java ## @@ -565,6 +565,20 @@ else if (t instanceof Error) {