[ 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)