Skip to content

Commit 373be6f

Browse files
committed
[FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws
1 parent acd6992 commit 373be6f

File tree

211 files changed

+74
-30954
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

211 files changed

+74
-30954
lines changed

.github/workflows/common.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ on:
3030
jdk_version:
3131
description: "Jdk version to test against."
3232
required: false
33-
default: 8, 11
33+
default: 11, 17
3434
type: string
3535
cache_flink_binary:
3636
description: "Whether to cache the Flink binary. Should be false for SNAPSHOT URLs, true otherwise."

.github/workflows/nightly.yml

Lines changed: 2 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -25,21 +25,12 @@ jobs:
2525
if: github.repository_owner == 'apache'
2626
strategy:
2727
matrix:
28-
flink: [1.20-SNAPSHOT]
29-
java: [ '8, 11, 17']
28+
flink: [2.0-SNAPSHOT]
29+
java: ['11, 17, 21']
3030
uses: ./.github/workflows/common.yml
3131
with:
3232
flink_version: ${{ matrix.flink }}
3333
jdk_version: ${{ matrix.java }}
3434
flink_url: https://s3.amazonaws.com/flink-nightly/flink-${{ matrix.flink }}-bin-scala_2.12.tgz
3535
cache_flink_binary: false
3636
secrets: inherit
37-
38-
python_test:
39-
strategy:
40-
matrix:
41-
flink: [1.20-SNAPSHOT]
42-
uses: apache/flink-connector-shared-utils/.github/workflows/python_ci.yml@ci_utils
43-
with:
44-
flink_version: ${{ matrix.flink }}
45-

.github/workflows/push_pr.yml

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -26,19 +26,12 @@ jobs:
2626
uses: ./.github/workflows/common.yml
2727
strategy:
2828
matrix:
29-
flink: [1.20.0]
30-
java: [ '8, 11, 17']
29+
flink: [2.0.0]
30+
java: ['11, 17, 21']
3131
with:
3232
flink_version: ${{ matrix.flink }}
3333
jdk_version: ${{ matrix.java }}
3434
flink_url: https://archive.apache.org/dist/flink/flink-${{ matrix.flink }}/flink-${{ matrix.flink }}-bin-scala_2.12.tgz
3535
cache_flink_binary: true
3636
secrets: inherit
3737

38-
python_test:
39-
strategy:
40-
matrix:
41-
flink: [1.20.0]
42-
uses: apache/flink-connector-shared-utils/.github/workflows/python_ci.yml@ci_utils
43-
with:
44-
flink_version: ${{ matrix.flink }}

flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/pom.xml

Lines changed: 0 additions & 195 deletions
This file was deleted.

flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/main/java/org/apache/flink/streaming/kinesis/test/CustomWatermarkExtractor.java

Lines changed: 0 additions & 53 deletions
This file was deleted.

flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/src/main/java/org/apache/flink/streaming/kinesis/test/Event.java

Lines changed: 0 additions & 71 deletions
This file was deleted.

0 commit comments

Comments
 (0)