Hi Robert,
The exception is caused by converting Table which contain retractions and
updates to a DataStream. During table-to-stream conversion, this could lead
to an exception similar to
Table sink 'Unregistered_DataStream_Sink_1' doesn't support consuming
update changes [...].
In the case you n
I have a job that joins 2 streams using the Table API:
DataStream stream = env.fromSource(dataSource,
WatermarkStrategy.forMonotonousTimestamps(), "Kafka Source");
DataStream logTableStream = env.fromSource(logTableSource,
WatermarkStrategy.forMonotonousTimestamps(), "Log Table Sou
