Re: About Native Deployment's Autoscaling implementation

Hi Talat! Sorry for the late reply, I have been busy with some fixes for the release and travelling. I think the prometheus metrics integration sounds like a great idea that would cover the needs of most users. This way users can also integrate easily with the custom Flink metrics too. maxReplic

[jira] [Created] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

Yang Wang created FLINK-27834: - Summary: Flink kubernetes operator dockerfile could not work with podman Key: FLINK-27834 URL: https://issues.apache.org/jira/browse/FLINK-27834 Project: Flink Is

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #2

Thanks Jim for providing the information and Gyula for sharing the concerns. I will create the release candidate #3 after we have more progress on the FLINK-27804, whether we are sure it is resolved or we have found the root cause. Also I will try to make the Dockerfile could work for podman. B

[jira] [Created] (FLINK-27833) PulsarSourceITCase.testTaskManagerFailure failed with AssertionError

Huang Xingbo created FLINK-27833: Summary: PulsarSourceITCase.testTaskManagerFailure failed with AssertionError Key: FLINK-27833 URL: https://issues.apache.org/jira/browse/FLINK-27833 Project: Flink

[jira] [Created] (FLINK-27832) SplitAggregateITCase tests failed with Could not acquire the minimum required resources

Huang Xingbo created FLINK-27832: Summary: SplitAggregateITCase tests failed with Could not acquire the minimum required resources Key: FLINK-27832 URL: https://issues.apache.org/jira/browse/FLINK-27832

[jira] [Created] (FLINK-27831) Provide example of Beam on the k8s operator

Márton Balassi created FLINK-27831: -- Summary: Provide example of Beam on the k8s operator Key: FLINK-27831 URL: https://issues.apache.org/jira/browse/FLINK-27831 Project: Flink Issue Type: I

Re: [VOTE] FLIP-235: Hybrid Shuffle Mode

+1 (non-binding) Best Regards, Jing On Sun, May 29, 2022 at 5:16 AM Aitozi wrote: > +1 (non-binding) > > Best, > Aitozi > > Yangze Guo 于2022年5月27日周五 11:17写道： > > > +1 > > > > Best, > > Yangze Guo > > > > On Thu, May 26, 2022 at 4:42 PM Xintong Song > > wrote: > > > > > > +1 > > > > > > Best,

Table API thrift support

Hi there, We would like to discuss and potentially upstream our thrift support patches to flink. For some context, we have been internally patched flink-1.11.2 to support FlinkSQL jobs read/write to thrift encoded kafka source/sink. Over the course of last 12 months, those patches supports a few

[jira] [Created] (FLINK-27830) My Pyflink job could not submit to Flink cluster

TongMeng created FLINK-27830: Summary: My Pyflink job could not submit to Flink cluster Key: FLINK-27830 URL: https://issues.apache.org/jira/browse/FLINK-27830 Project: Flink Issue Type: Bug

[RESULT][VOTE] FLIP-227: Support overdraft buffer

Hi everyone, FLIP-227[1] has been accepted. There are 5 approving votes, 3 of which are binding.[2] - Non-Binding: Anton Kalashnikov - Binding: Piotr Nowojski - Binding: Dawid Wysakowicz - Binding: David Morávek - Non-Binding: fanrui None against. Thanks again to everyone who is concerned abou

Re: [VOTE] FLIP-227: Support overdraft buffer

+1(non-binding) Best wishes fanrui On Thu, May 26, 2022 at 9:18 PM David Morávek wrote: > +1 (binding) > > On Thu, May 26, 2022 at 11:55 AM Dawid Wysakowicz > wrote: > > > +1 (binding) > > > > On Thu, 26 May 2022, 11:21 Piotr Nowojski, wrote: > > > > > Yes, it will be a good improvement :) >