jixuan1989
/
IoTDB
mirror of https://github.com/apache/iotdb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

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>
This commit is contained in:
dependabot[bot] 2021-10-12 09:34:25 +08:00 committed by GitHub
parent 51a02f7a48
commit 6cf35651a3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatTest.java
View File

@ -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);
}

2
pom.xml
View File

@ -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-->