Martijn Visser created FLINK-34192:
--------------------------------------
Summary: 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
{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)
