This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 6cf3565 Bump flink.version from 1.11.1 to 1.14.0 (#4112)
6cf3565 is described below
commit 6cf35651a356d3d3a330d6c67f3d6169eb26e752
Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
AuthorDate: Tue Oct 12 09:34:25 2021 +0800
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] <[email protected]>
* Print row
* Update tests
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Haonan <[email protected]>
---
.../iotdb/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 d278a6d..91a0126 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 16e0a31..30b574f 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-->