Skip to content

Commit cc8ce07

Browse files
committed
java 8 fix
1 parent 57595fc commit cc8ce07

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlRecordEmitterTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ record -> {
8989

9090
private MySqlRecordEmitter<Void> createRecordEmitter() {
9191
return new MySqlRecordEmitter<>(
92-
new DebeziumDeserializationSchema<>() {
92+
new DebeziumDeserializationSchema<Void>() {
9393
@Override
9494
public void deserialize(SourceRecord record, Collector<Void> out) {
9595
throw new UnsupportedOperationException();

0 commit comments

Comments
 (0)