From 6cf35651a356d3d3a330d6c67f3d6169eb26e752 Mon Sep 17 00:00:00 2001
From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com>
Date: Tue, 12 Oct 2021 09:34:25 +0800
Subject: [PATCH] Bump flink.version from 1.11.1 to 1.14.0 (#4112)

* Bump flink.version from 1.11.1 to 1.14.0

Bumps `flink.version` from 1.11.1 to 1.14.0.

Updates `flink-clients_2.11` from 1.11.1 to 1.14.0

Updates `flink-java` from 1.11.1 to 1.14.0
- [Release notes](https://github.com/apache/flink/releases)
- [Commits](https://github.com/apache/flink/compare/release-1.11.1...release-1.14.0)

Updates `flink-streaming-java_2.11` from 1.11.1 to 1.14.0

---
updated-dependencies:
- dependency-name: org.apache.flink:flink-clients_2.11
  dependency-type: direct:development
  update-type: version-update:semver-minor
- dependency-name: org.apache.flink:flink-java
  dependency-type: direct:production
  update-type: version-update:semver-minor
- dependency-name: org.apache.flink:flink-streaming-java_2.11
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

* Print row

* Update tests

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Haonan <hhaonan@outlook.com>
---
 .../flink/tsfile/RowTsFileInputFormatTest.java     | 14 +++++++-------
 pom.xml                                            |  2 +-
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java
index d278a6de0a4..91a01267b88 100644
--- a/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java
+++ b/flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java
@@ -66,13 +66,13 @@ public class RowTsFileInputFormatTest extends RowTsFileInputFormatTestBase {
     }
 
     String[] expected = {
-      "1,1.2,20,null,2.3,11,19",
-      "2,null,20,50,25.4,10,21",
-      "3,1.4,21,null,null,null,null",
-      "4,1.2,20,51,null,null,null",
-      "6,7.2,10,11,null,null,null",
-      "7,6.2,20,21,null,null,null",
-      "8,9.2,30,31,null,null,null"
+      "+I[1, 1.2, 20, null, 2.3, 11, 19]",
+      "+I[2, null, 20, 50, 25.4, 10, 21]",
+      "+I[3, 1.4, 21, null, null, null, null]",
+      "+I[4, 1.2, 20, 51, null, null, null]",
+      "+I[6, 7.2, 10, 11, null, null, null]",
+      "+I[7, 6.2, 20, 21, null, null, null]",
+      "+I[8, 9.2, 30, 31, null, null, null]"
     };
     assertArrayEquals(actual.toArray(), expected);
   }
diff --git a/pom.xml b/pom.xml
index 16e0a3109ab..30b574fc1ba 100644
--- a/pom.xml
+++ b/pom.xml
@@ -119,7 +119,7 @@
         <logback.version>1.2.3</logback.version>
         <joda.version>2.9.9</joda.version>
         <spark.version>2.4.3</spark.version>
-        <flink.version>1.11.1</flink.version>
+        <flink.version>1.14.0</flink.version>
         <common.io.version>2.5</common.io.version>
         <commons.collections4>4.4</commons.collections4>
         <!-- keep consistent with client-cpp/tools/thrift/pom.xml-->