Skip to content

Commit faca104

Browse files
authored
[issue-721] Upgrade Flink 1.17 (#722)
Signed-off-by: Brian Zhou <[email protected]>
1 parent a55bfe1 commit faca104

File tree

4 files changed

+14
-3
lines changed

4 files changed

+14
-3
lines changed

README.md

+2-1
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,8 @@ supported versions of Flink and Pravega.
3636

3737
| Git Branch | Pravega Version | Flink Version | Status | Artifact Link |
3838
|-------------------------------------------------------------------------------------|-----------------|---------------|-------------------|--------------------------------------------------------------------------------------|
39-
| [master](https://github.com/pravega/flink-connectors) | 0.14 | 1.16 | Under Development | https://github.com/pravega/flink-connectors/packages/1441637 |
39+
| [master](https://github.com/pravega/flink-connectors) | 0.14 | 1.17 | Under Development | https://github.com/pravega/flink-connectors/packages/1441637 |
40+
| [r0.14-flink1.16](https://github.com/pravega/flink-connectors/tree/r0.14-flink1.16) | 0.14 | 1.16 | Under Development | https://github.com/pravega/flink-connectors/packages/1704300 |
4041
| [r0.13](https://github.com/pravega/flink-connectors/tree/r0.13) | 0.13 | 1.16 | Released | https://repo1.maven.org/maven2/io/pravega/pravega-connectors-flink-1.16_2.12/0.13.0/ |
4142
| [r0.13-flink1.15](https://github.com/pravega/flink-connectors/tree/r0.13-flink1.15) | 0.13 | 1.15 | Released | https://repo1.maven.org/maven2/io/pravega/pravega-connectors-flink-1.15_2.12/0.13.0/ |
4243
| [r0.13-flink1.14](https://github.com/pravega/flink-connectors/tree/r0.13-flink1.14) | 0.13 | 1.14 | Released | https://repo1.maven.org/maven2/io/pravega/pravega-connectors-flink-1.14_2.12/0.13.0/ |

gradle.properties

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
# 3rd party Versions.
1818
assertjVersion=3.23.1
1919
checkstyleToolVersion=7.1
20-
flinkVersion=1.16.0
20+
flinkVersion=1.17.1
2121
flinkScalaVersion=2.12
2222
jacksonVersion=2.8.9
2323
twitterMvnRepoVersion=4.3.4-TWTTR

gradle/jacoco.gradle

+6-1
Original file line numberDiff line numberDiff line change
@@ -27,4 +27,9 @@ jacocoTestReport {
2727
}
2828
}
2929

30-
test { finalizedBy jacocoTestReport }
30+
test {
31+
jacoco {
32+
excludes = ['**Metadata**$Handler']
33+
}
34+
finalizedBy jacocoTestReport
35+
}

src/test/java/io/pravega/connectors/flink/sink/PravegaSinkWriterITCase.java

+5
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,11 @@ public int getNumberOfParallelSubtasks() {
173173
return 1;
174174
}
175175

176+
@Override
177+
public int getAttemptNumber() {
178+
return 0;
179+
}
180+
176181
@Override
177182
public SinkWriterMetricGroup metricGroup() {
178183
return metricGroup;

0 commit comments

Comments
 (0)