Re: HybridSource: how to specify different watermark strategies for underlying sources

2023-01-17 Thread David Christle via user
since the current GCP > connector is not a FLIP-27 compatible source? > > Best regards, > > Martijn > > Op vr 13 jan. 2023 om 08:03 schreef David Christle via user < > user@flink.apache.org>: > >> Hello, >> >> I'm trying to use the HybridSo

HybridSource: how to specify different watermark strategies for underlying sources

2023-01-12 Thread David Christle via user
Hello, I'm trying to use the HybridSource to read from a bounded FLIP-27 Iceberg source and an unbounded FLIP-27 PubSub source. Based on my searches, the most common patterns for assigning timestamps and watermarks with FLIP-27 sources are either via the fromSource method in StreamingExecutionEnvi