[
https://issues.apache.org/jira/browse/FLINK-34192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-34192:
--------------------------------------
Assignee: Jiabao Sun
> Update flink-connector-kafka to be compatible with updated SinkV2 interfaces
> ----------------------------------------------------------------------------
>
> Key: FLINK-34192
> URL: https://issues.apache.org/jira/browse/FLINK-34192
> Project: Flink
> Issue Type: Technical Debt
> Components: Connectors / Kafka
> Reporter: Martijn Visser
> Assignee: Jiabao Sun
> Priority: Blocker
> Labels: pull-request-available
>
> {code:java}
> Error:
> /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestUtils.java:[101,76]
> incompatible types: java.util.List<org.apache.flink.types.Row> cannot be
> converted to java.util.List<java.lang.String>
> Error:
> /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[136,46]
> cannot find symbol
> Error: symbol: method
> mock(org.apache.flink.metrics.MetricGroup,org.apache.flink.metrics.groups.OperatorIOMetricGroup)
> Error: location: class
> org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
> Error:
> /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[171,46]
> cannot find symbol
> Error: symbol: method mock(org.apache.flink.metrics.MetricGroup)
> Error: location: class
> org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
> Error:
> /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[204,54]
> cannot find symbol
> Error: symbol: method mock(org.apache.flink.metrics.MetricGroup)
> Error: location: class
> org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
> Error:
> /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[233,54]
> cannot find symbol
> Error: symbol: method mock(org.apache.flink.metrics.MetricGroup)
> Error: location: class
> org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
> Error:
> /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[263,54]
> cannot find symbol
> Error: symbol: method mock(org.apache.flink.metrics.MetricGroup)
> Error: location: class
> org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
> Error:
> /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[294,54]
> cannot find symbol
> Error: symbol: method mock(org.apache.flink.metrics.MetricGroup)
> Error: location: class
> org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
> Error:
> /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[337,54]
> cannot find symbol
> Error: symbol: method mock(org.apache.flink.metrics.MetricGroup)
> Error: location: class
> org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
> Error:
> /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[525,46]
> cannot find symbol
> Error: symbol: method mock(org.apache.flink.metrics.MetricGroup)
> Error: location: class
> org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
> Error: -> [Help 1]
> {code}
> https://github.com/apache/flink-connector-kafka/actions/runs/7597711401/job/20692858078#step:14:221
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
