+1 (non-binding)
- verified signatures
- build with Java 8 and Java 11 - build success
Minor observation
- RAT check flagged that README.md is missing ASL
On Fri, 27 Oct 2023 at 23:40, Xianxun Ye wrote:
> +1(non-binding)
>
> - Started a local Flink 1.18 cluster, read and wrote with Kafka and U
Thanks for digging into the git history, Jark. I agree it makes sense to
deprecate this API in 2.0.
Cheers,
Jiangjie (Becket) Qin
On Fri, Oct 27, 2023 at 5:47 PM Jark Wu wrote:
> Hi Becket,
>
> I checked the history of "
> *table.optimizer.source.predicate-pushdown-enabled*",
> it seems it was
Thanks, Alexander for your reply.
Our solution initiated from this inquiry on Stack Overflow:
https://stackoverflow.com/questions/52179898/does-flink-support-keyed-watermarks-if-not-is-there-any-plan-of-implementing-i
The idea is to generate a watermark for each key (sub-stream), in order to
avo
Thanks Timo for preparing the FLIP.
Regarding "By default, DISTRIBUTED BY assumes a list of columns for an
implicit hash partitioning."
Do you think it's useful to add some extensibility for the hash
strategy. One scenario I can foresee is if we write bucketed data into
Hive, and if Flink's hash s
Hi All,
The JobResultStore interface includes an Abstract implementation known as
`AbstractThreadsafeJobResultStore`.
This implementation is extended by two concrete implementations:
`FileSystemJobResultStore` and `EmbeddedJobResultStore`.
Both of these concrete implementations handle two types of
