diff --git a/README.md b/README.md index 0f3319d2..986c1da4 100644 --- a/README.md +++ b/README.md @@ -36,7 +36,8 @@ supported versions of Flink and Pravega. | Git Branch | Pravega Version | Flink Version | Status | Artifact Link | |-------------------------------------------------------------------------------------|-----------------|---------------|-------------------|--------------------------------------------------------------------------------------| -| [master](https://github.com/pravega/flink-connectors) | 0.14 | 1.16 | Under Development | https://github.com/pravega/flink-connectors/packages/1441637 | +| [master](https://github.com/pravega/flink-connectors) | 0.14 | 1.17 | Under Development | https://github.com/pravega/flink-connectors/packages/1441637 | +| [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 | | [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/ | | [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/ | | [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/ | diff --git a/gradle.properties b/gradle.properties index 6e43aa04..d2b61365 100644 --- a/gradle.properties +++ b/gradle.properties @@ -17,7 +17,7 @@ # 3rd party Versions. assertjVersion=3.23.1 checkstyleToolVersion=7.1 -flinkVersion=1.16.0 +flinkVersion=1.17.1 flinkScalaVersion=2.12 jacksonVersion=2.8.9 twitterMvnRepoVersion=4.3.4-TWTTR diff --git a/gradle/jacoco.gradle b/gradle/jacoco.gradle index 97080f7d..0c671ec6 100644 --- a/gradle/jacoco.gradle +++ b/gradle/jacoco.gradle @@ -27,4 +27,9 @@ jacocoTestReport { } } -test { finalizedBy jacocoTestReport } +test { + jacoco { + excludes = ['**Metadata**$Handler'] + } + finalizedBy jacocoTestReport +} diff --git a/src/test/java/io/pravega/connectors/flink/sink/PravegaSinkWriterITCase.java b/src/test/java/io/pravega/connectors/flink/sink/PravegaSinkWriterITCase.java index 68a4a095..3185bf6c 100644 --- a/src/test/java/io/pravega/connectors/flink/sink/PravegaSinkWriterITCase.java +++ b/src/test/java/io/pravega/connectors/flink/sink/PravegaSinkWriterITCase.java @@ -173,6 +173,11 @@ public int getNumberOfParallelSubtasks() { return 1; } + @Override + public int getAttemptNumber() { + return 0; + } + @Override public SinkWriterMetricGroup metricGroup() { return metricGroup;