Hi Benoît,
Do you mean if you register one TableSource, and add two sinks from the
same TableSource, the source will duplicate ?
If so, maybe you can check
*TableEnvironmentImpl.isEagerOperationTranslation*, it's *false* by
default. But in *StreamTableEnvironmentImpl*, it's *true* because we need
Hello all!
I'm having a problem with TableSources' DataStream being duplicated when
pulled on from 2 sinks.
I understand that sometimes the best plan might just be to duplicate and
read both times a TableSource/SourceFunction; but in my case I can't quite
reproduce the data as say Kafka would. I
