[flink-connector-kafka] 02/02: [hotfix] Remove full qualifier for SinkWriter.Context in test

[tzulitai]

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

tzulitai pushed a commit to branch v4.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git

commit 75368b77038fe58b2acea18ada806188f9818e48
Author: Tzu-Li (Gordon) Tai <tzuli...@apache.org>
AuthorDate: Thu Apr 6 16:02:24 2023 -0700

    [hotfix] Remove full qualifier for SinkWriter.Context in test
---
 .../streaming/connectors/kafka/table/ReducingUpsertWriterTest.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriterTest.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriterTest.java
index 5ef36e75..f08ec1d2 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriterTest.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriterTest.java
@@ -20,6 +20,7 @@ package org.apache.flink.streaming.connectors.kafka.table;
 import org.apache.flink.api.common.ExecutionConfig;
 import org.apache.flink.api.common.operators.ProcessingTimeService;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
+import org.apache.flink.api.connector.sink2.SinkWriter;
 import org.apache.flink.api.connector.sink2.StatefulSink;
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.catalog.Column;
@@ -276,7 +277,7 @@ public class ReducingUpsertWriterTest {
                         11.11,
                         11,
                         null),
-                new org.apache.flink.api.connector.sink2.SinkWriter.Context() {
+                new SinkWriter.Context() {
                     @Override
                     public long currentWatermark() {
                         throw new UnsupportedOperationException("Not 
implemented.");