[flink] 07/08: [FLINK-21996][refactor] Pull in-line serialization call into separate statement to improve Exception handling accuracy.

[sewen]

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit ad54508bda62d7ba0840c5048684fcc83696c43a
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Sat Apr 10 18:04:35 2021 +0200

    [FLINK-21996][refactor] Pull in-line serialization call into separate 
statement to improve Exception handling accuracy.
---
 .../flink/runtime/source/coordinator/SourceCoordinatorContext.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java
index 1c05321..598bc86 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java
@@ -182,14 +182,15 @@ public class SourceCoordinatorContext<SplitT extends 
SourceSplit>
                             .assignment()
                             .forEach(
                                     (id, splits) -> {
+                                        final AddSplitEvent<SplitT> 
addSplitEvent;
                                         try {
-                                            
operatorCoordinatorContext.sendEvent(
-                                                    new 
AddSplitEvent<>(splits, splitSerializer),
-                                                    id);
+                                            addSplitEvent =
+                                                    new 
AddSplitEvent<>(splits, splitSerializer);
                                         } catch (IOException e) {
                                             throw new FlinkRuntimeException(
                                                     "Failed to serialize 
splits.", e);
                                         }
+                                        
operatorCoordinatorContext.sendEvent(addSplitEvent, id);
                                     });
                     return null;
                 },