Beam High Priority Issue Report (35)

2023-05-22 Thread beamactions
This is your daily summary of Beam's current high priority issues that may need attention. See https://beam.apache.org/contribute/issue-priorities for the meaning and expectations around issue priorities. Unassigned P1 Issues: https://github.com/apache/beam/issues/26785 [Failing Test]: Tes

Re: Beam SQL found limitations

2023-05-22 Thread Alexey Romanenko
Hi Piotr, Thanks for details! I cross-post this to dev@ as well since, I guess, people there can provide more insights on this. A while ago, I faced the similar issues trying to run Beam SQL against TPC-DS benchmark. We had a discussion around that [1], please, take a look since it can be hel

Watermark Alignment on Flink Runner's UnboundedSourceWrapper

2023-05-22 Thread Talat Uyarer via dev
Maybe the User list does not have knowledge about this. That's why I also resend on the Dev list. Sorry for cross posting Hi All, I have a stream aggregation job which reads from Kafka and writes some Sinks. When I submit my job Flink checkpoint size keeps increasing if I use unaligned checkpoi