This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch v3.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
commit 9d5bb0d939b7167cda775f70b6bd512130c6fa17
Author: Yufan Sheng <yu...@streamnative.io>
AuthorDate: Mon Feb 21 17:28:21 2022 +0800
[FLINK-26210][pulsar][tests] Add jaxb-api to e2e test
---
flink-connector-pulsar-e2e-tests/pom.xml | 15 +++++++++++++++
.../tests/util/pulsar/PulsarSourceOrderedE2ECase.java | 4 ++++
.../common/FlinkContainerWithPulsarEnvironment.java | 1 +
3 files changed, 20 insertions(+)
diff --git a/flink-connector-pulsar-e2e-tests/pom.xml
b/flink-connector-pulsar-e2e-tests/pom.xml
index ab47a08..424b106 100644
--- a/flink-connector-pulsar-e2e-tests/pom.xml
+++ b/flink-connector-pulsar-e2e-tests/pom.xml
@@ -46,6 +46,13 @@ under the License.
<artifactId>flink-connector-pulsar</artifactId>
<version>${project.version}</version>
</dependency>
+ <!-- pulsar-client-all requires jaxb-api for
javax.xml.bind.annotation.XmlElement -->
+ <!-- packaged in flink-dist but not provided in e2e
environment. -->
+ <dependency>
+ <groupId>javax.xml.bind</groupId>
+ <artifactId>jaxb-api</artifactId>
+ <version>${jaxb.api.version}</version>
+ </dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-pulsar</artifactId>
@@ -153,6 +160,14 @@ under the License.
<type>jar</type>
<outputDirectory>${project.build.directory}/dependencies</outputDirectory>
</dependency>
+ <dependency>
+
<groupId>javax.xml.bind</groupId>
+
<artifactId>jaxb-api</artifactId>
+
<version>${jaxb-api.version}</version>
+
<destFileName>jaxb-api.jar</destFileName>
+ <type>jar</type>
+
<outputDirectory>${project.build.directory}/dependencies</outputDirectory>
+ </dependency>
<artifactItem>
<groupId>org.slf4j</groupId>
<artifactId>jul-to-slf4j</artifactId>
diff --git
a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java
b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java
index 502b41d..234c1a0 100644
---
a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java
+++
b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java
@@ -29,11 +29,15 @@ import
org.apache.flink.tests.util.pulsar.cases.ExclusiveSubscriptionContext;
import org.apache.flink.tests.util.pulsar.cases.FailoverSubscriptionContext;
import
org.apache.flink.tests.util.pulsar.common.FlinkContainerWithPulsarEnvironment;
import
org.apache.flink.tests.util.pulsar.common.PulsarContainerTestEnvironment;
+import org.apache.flink.testutils.junit.FailsOnJava11;
+
+import org.junit.experimental.categories.Category;
/**
* Pulsar E2E test based on connector testing framework. It's used for
Failover & Exclusive
* subscription.
*/
+@Category(value = {FailsOnJava11.class})
public class PulsarSourceOrderedE2ECase extends SourceTestSuiteBase<String> {
// Defines the Semantic.
diff --git
a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java
b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java
index ccfe277..9a1c6dd 100644
---
a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java
+++
b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/common/FlinkContainerWithPulsarEnvironment.java
@@ -42,6 +42,7 @@ public class FlinkContainerWithPulsarEnvironment extends
FlinkContainerTestEnvir
resourcePath("bcprov-jdk15on.jar"),
resourcePath("bcutil-jdk15on.jar"),
resourcePath("bcprov-ext-jdk15on.jar"),
+ resourcePath("jaxb-api.jar"),
resourcePath("jul-to-slf4j.jar"));
}
