[ZEPPELIN-5047]. Upgrade flink to 1.11.2

### What is this PR for? Trivial PR to upgrade flink to 1.11.2 ### What type of PR is it? [ Improvement] ### Todos * [ ] - Task ### What is the Jira issue? * https://issues.apache.org/jira/browse/ZEPPELIN-5047 ### How should this be tested? * CI pass ### Screenshots (if appropriate) ### Questions: * Does the licenses files need update? No * Is there breaking changes for older versions? No * Does this needs documentation? No Author: Jeff Zhang <[email protected]> Closes apache#3915 from zjffdu/ZEPPELIN-5047 and squashes the following commits: 24749f6 [Jeff Zhang] [ZEPPELIN-5047]. Upgrade flink to 1.11.2
Kick156 · Sep 20, 2020 · 7ca1409 · 7ca1409
1 parent 55375ed
commit 7ca1409
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/flink/pom.xml b/flink/pom.xml
@@ -43,7 +43,7 @@
 
     <properties>
         <flink1.10.version>1.10.2</flink1.10.version>
-        <flink1.11.version>1.11.1</flink1.11.version>
+        <flink1.11.version>1.11.2</flink1.11.version>
     </properties>
 
     <dependencies>

diff --git a/...er-integration/src/test/java/org/apache/zeppelin/integration/FlinkIntegrationTest111.java b/...er-integration/src/test/java/org/apache/zeppelin/integration/FlinkIntegrationTest111.java
@@ -29,7 +29,7 @@ public class FlinkIntegrationTest111 extends FlinkIntegrationTest {
   @Parameterized.Parameters
   public static List<Object[]> data() {
     return Arrays.asList(new Object[][]{
-            {"1.11.1"}
+            {"1.11.2"}
     });
   }
 

diff --git a/...ntegration/src/test/java/org/apache/zeppelin/integration/ZeppelinFlinkClusterTest111.java b/...ntegration/src/test/java/org/apache/zeppelin/integration/ZeppelinFlinkClusterTest111.java
@@ -29,7 +29,7 @@ public class ZeppelinFlinkClusterTest111 extends ZeppelinFlinkClusterTest {
   @Parameterized.Parameters
   public static List<Object[]> data() {
     return Arrays.asList(new Object[][]{
-            {"1.11.1"}
+            {"1.11.2"}
     });
   }