|
Change Variable Type ser : Utils.TypeInformationSerializationSchema<Tuple2<Integer,byte[]>> to ser : TypeInformationSerializationSchema<Tuple2<Integer,byte[]>> in method public testGrowing() : void in class org.apache.flink.streaming.connectors.kafka.util.UtilsTest |
From |
To |
|
Change Variable Type serSchema : Utils.TypeInformationSerializationSchema<Tuple2<Long,byte[]>> to serSchema : TypeInformationSerializationSchema<Tuple2<Long,byte[]>> in method public bigRecordTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase |
From |
To |
|
Change Variable Type ser : Utils.TypeInformationSerializationSchema<Tuple2<Integer,Integer>> to ser : TypeInformationSerializationSchema<Tuple2<Integer,Integer>> in method public testTypeInformationSerializationSchema() : void in class org.apache.flink.streaming.connectors.kafka.util.UtilsTest |
From |
To |