Hi Roman,
I've been following the FLIP-530 proposal for dynamic job configuration
with great interest - thank you for spearheading this valuable initiative.
The ability to adjust configurations on-the-fly will undoubtedly be a
significant enhancement for Flink.
As I was thinking through its pract
It uses aligned checkpoint by default in Flink which needs to process
all the data buffered in the pipeline(network and operators) during
checkpointing. In your use case, as the process speed is very slow and
so it may take too long to process the buffered data. You could try to
enable unalign chec
Hello flink devs, I would like to know if the rabbitmq flink connector is still
under support? I can see some PRs that are waiting for an approval a year ago,
there is no more feedback about this PR for example:
https://github.com/apache/flink-connector-rabbitmq/pull/29
So anyone that wants to
sleepy0521 created FLINK-37809:
--
Summary: sqlserver limit statement support
Key: FLINK-37809
URL: https://issues.apache.org/jira/browse/FLINK-37809
Project: Flink
Issue Type: Improvement
Hi Xuyang,
Thx for driving this FLIP. I believe delta join is truly helpful for large
state scenarios. The overall design LGTM. Also, I like the idea of updating
the cache using the data from its own side.
I have one minor question: for storages like Paimon, it has its own cache
in its LookupFunc
Hi Flink Community,
I'm pleased to announce that FLIP-528: Support EXPLAIN EXECUTE STATEMENT
SET Syntax in Flink SQL [1] has been approved.
The proposal received four approving votes (3 binding) [2]:
Dawid Wysakowicz (binding)
Gustavo de Morais (non-binding)
Piotr Nowojski (binding)
Sergey Nuyan
Keith Lee created FLINK-37808:
-
Summary: Checkpoint completed after job failure
Key: FLINK-37808
URL: https://issues.apache.org/jira/browse/FLINK-37808
Project: Flink
Issue Type: Bug
C
Piotr Nowojski created FLINK-37807:
--
Summary: Report s5cmd cancellation in a nicer way
Key: FLINK-37807
URL: https://issues.apache.org/jira/browse/FLINK-37807
Project: Flink
Issue Type: Impr
Documenting the supported options is a fair concern, but at the same
time also a mountain of work as it would require going through all
options and creating well-defined rules for what is a job setting and
what isn't, enforcing that and possibly also change a whole bunch of
code to make that re
Weijun Wang created FLINK-37806:
---
Summary: Add some time cost metrics of some steps
Key: FLINK-37806
URL: https://issues.apache.org/jira/browse/FLINK-37806
Project: Flink
Issue Type: Sub-task
Weijun Wang created FLINK-37805:
---
Summary: Add some time cost logs of some steps
Key: FLINK-37805
URL: https://issues.apache.org/jira/browse/FLINK-37805
Project: Flink
Issue Type: Sub-task
I'm happy to announce that we have unanimously approved this release.
There are 9 approving votes, 4 of which are binding:
* Xiqian YU non-binding
* Ferenc Csaky non-binding
* Tianzhu non-binding
* ouyangwulin non-binding
* Leonard Xu binding
* Zakelly Lan binding
* Xingbo Huang binding
*
Hello everyone,
I'm very happy to share with you that FLIP-516 [1] has been approved with 6
approving votes (5 binding) [2].
Ron Liu (binding)
Zakelly Lan (binding)
Hao Li (non-binding)
Arvid Heise (binding)
Timo Walther (binding)
Dawid Wysakowicz (binding)
Thanks for the votes and discussions,
13 matches
Mail list logo
