Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
1.12.0
Description
As a user of the new Kafka Source introduced in (FLINK-18323), I always have to specify the return type:
DataStream<Event> events = env.fromSource(source, WatermarkStrategy.noWatermarks(),
"Kafka Source").returns(TypeInformation.of(Event.class));
The old Kafka source implementation implements ResultTypeQueryable, which allows the DataStream API to get the return type from the deserializer.
The new Kafka Source also should have access to the produced type from the deserializer to forward it.
Attachments
Issue Links
- links to