Added error handling and default logic for Flink version detection

apache · Jan 9, 2024 · 7428ec2 · 7428ec2
1 parent c153f38
commit 7428ec2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/util/TestFlinkPackage.java b/flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/util/TestFlinkPackage.java
@@ -38,7 +38,8 @@ public void testVersion() {
 
   @Test
   public void testDefaultVersion() {
-    // It's difficult to reproduce a reflection error in a unit test, so we just inject a mocked fault to test
+    // It's difficult to reproduce a reflection error in a unit test, so we just inject a mocked
+    // fault to test
     // the default logic
     FlinkVersionDetector detectorWithReflectionError = Mockito.spy(FlinkVersionDetector.class);
     Mockito.when(detectorWithReflectionError.getVersionFromJar()).thenThrow(RuntimeException.class);