This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
from 3199922 [FLINK-30254][Connector/Pulsar] Resolve dependency
convergence errors
new c613f4b [FLINK-23969][connector/pulsar] Create e2e tests for pulsar
connector.
new db11068 [FLINK-24018][build] Remove Scala dependencies from Java APIs
new 52cbdb5 [hotfix][connector/testing-framework] Let
ExternalContext#generateTestData returns List to preserve order
new 8de314d [FLINK-25038][testutils] Refactor FlinkContainer to split JM
and TMs to individual containers and supports HA
new cacdffb [FLINK-25159][tests] Disable broken E2E tests
new 9046e81 [FLINK-25210][pulsar][e2e][tests] add resource file to test
jar
new 082bd2f [FLINK-25287][connectors/testing-framework] Refactor
connector testing framework interfaces for more scenarios
new e94e54b [FLINK-25287][connectors/pulsar] Use connector testing
framework interface for Pulsar tests
new 4f85230 [hotfix][connectors] Improve the typo and code style
new 87b9f1b [FLINK-25840][tests] Add semantics test support for connector
test framework
new 6971aa1 [FLINK-25288][tests][pulsar] Make pulsar e2e tests more robust
new 704ef1f [FLINK-24246][connector/pulsar] Bump PulsarClient version to
latest 2.9.1
new 9c98b83 [FLINK-26025][connector/pulsar] Replace MockPulsar with new
Pulsar test tools based on PulsarStandalone.
new 39169fa [hotfix][pulsar] Disable tests
new 44d53a7 [FLINK-26210][pulsar][tests] Add jaxb-api to e2e test
new bca31db Update version to 1.16-SNAPSHOT
new 356cf23 [FLINK-27854][tests] Add support for FlinkContainers to work
with both existing Docker images and flink-dist builds
new 65ae7f7 [FLINK-27199][Connector/Pulsar] Bump the pulsar-client-all to
latest 2.10.0.
new 9714ebb [FLINK-28409][tests] Move FlinkContainerTestEnvironment and
dependendencies into flink-connector-test-utils
new f4a7fa0 Update version to 1.17-SNAPSHOT
new f333cf2 [FLINK-29285][tests] Move TestUtils#getResource
new 712f647 [FLINK-26182][Connector/pulsar] Extract common logic from
Pulsar source testing tools.
new 0ce6280 [FLINK-26182][Connector/pulsar] Create e2e tests for the
Pulsar source and sink based on the connector testing framework.
new 79e968d [FLINK-29532][Connector/Pulsar] Update Pulsar dependency to
2.10.1. This closes #20980
new 1b1aa9a [FLINK-29495][Connector/Pulsar] Refactor Pulsar tests from
JUnit4 annotation to JUnit5 annotation for disabling tests on Java 11
new 9004447 [FLINK-29709][Connector/Pulsar] Bump the Pulsar to latest
2.10.2 (#21204)
new bf7af29 [FLINK-26027][Connector/Pulsar] Expose Pulsar producer
metrics and add FLIP-33 sink metrics. (#21249)
new 858931e [FLINK-30336][Connector/Pulsar] Sync missing Pulsar e2e tests
to external repo
new 7360e65 [hotfix] Increase timeout for compile and test runs
new e35b5e7 [hotfix] Set version to 4.0-SNAPSHOT
new ded956e [hotfix][architecture] Add ProductionCodeArchitectureTest
The 31 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/ci.yml | 4 +-
flink-connector-pulsar-e2e-tests/pom.xml | 258 +++++++++++++++++++++
.../flink/tests/util/pulsar/PulsarSinkE2ECase.java | 56 +++++
.../util/pulsar/PulsarSourceOrderedE2ECase.java | 45 ++--
.../util/pulsar/PulsarSourceUnorderedE2ECase.java | 35 +--
.../FlinkContainerWithPulsarEnvironment.java | 65 ++++++
.../common/PulsarContainerTestEnvironment.java | 16 +-
.../source/ExclusiveSubscriptionContext.java | 15 +-
.../pulsar/source/FailoverSubscriptionContext.java | 15 +-
.../src/test/resources/log4j2-test.properties | 24 +-
flink-connector-pulsar/pom.xml | 3 +-
...st.java => ProductionCodeArchitectureTest.java} | 9 +-
flink-sql-connector-pulsar/pom.xml | 2 +-
pom.xml | 4 +-
14 files changed, 467 insertions(+), 84 deletions(-)
create mode 100644 flink-connector-pulsar-e2e-tests/pom.xml
create mode 100644
flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSinkE2ECase.java
copy
flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarUnorderedSourceITCase.java
=>
flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java
(52%)
copy
flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarUnorderedSourceITCase.java
=>
flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java
(71%)
create mode 100644
flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java
copy
flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/NeverStopCursor.java
=>
flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/PulsarContainerTestEnvironment.java
(59%)
copy
flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/source/cases/SharedSubscriptionContext.java
=>
flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/source/ExclusiveSubscriptionContext.java
(72%)
copy
flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/source/cases/SharedSubscriptionContext.java
=>
flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/source/FailoverSubscriptionContext.java
(72%)
copy .github/workflows/weekly.yml =>
flink-connector-pulsar-e2e-tests/src/test/resources/log4j2-test.properties (70%)
copy
flink-connector-pulsar/src/test/java/org/apache/flink/architecture/{TestCodeArchitectureTest.java
=> ProductionCodeArchitectureTest.java} (81%)
