[flink] 02/02: [FLINK-26931][Connector/Pulsar] Add producer name for testing the unique producer in Pulsar.

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 56f8c0ea1f05d4829188b5213fea2d7567e7ae94
Author: Yufan Sheng <yu...@streamnative.io>
AuthorDate: Fri Apr 29 04:39:35 2022 +0800

    [FLINK-26931][Connector/Pulsar] Add producer name for testing the unique producer in Pulsar.
---
 .../java/org/apache/flink/connector/pulsar/sink/PulsarSinkITCase.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/sink/PulsarSinkITCase.java b/flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/sink/PulsarSinkITCase.java
index 8d40bb7c237..0be8463a1c9 100644
--- a/flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/sink/PulsarSinkITCase.java
+++ b/flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/sink/PulsarSinkITCase.java
@@ -75,6 +75,7 @@ class PulsarSinkITCase extends PulsarTestSuiteBase {
                         .setAdminUrl(operator().adminUrl())
                         .setDeliveryGuarantee(guarantee)
                         .setTopics(topic)
+                        .setProducerName("pulsar-sink-it-case")
                         .setSerializationSchema(flinkSchema(new SimpleStringSchema()))
                         .build();