Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

Congrats, Matyas! Best, Paul Lam > 2022年11月22日 15:35，Sergey Nuyanzin 写道： > > Congratulations, Matyas! > > On Tue, Nov 22, 2022 at 8:31 AM Steven Wu wrote: > >> Congrats, Matyas! >> >> On Mon, Nov 21, 2022 at 11:19 PM godfrey he wrote: >> >>> Congratulations, Matyas! >>> >>> Matthias Pohl

[jira] [Created] (FLINK-30138) BlobServerCleanupTest utilizes failsWithin with a quite low timeout which might result in test instabilities

Matthias Pohl created FLINK-30138: - Summary: BlobServerCleanupTest utilizes failsWithin with a quite low timeout which might result in test instabilities Key: FLINK-30138 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-30139) CodeGenLoader fails when temporary directory is a symlink

Jingsong Lee created FLINK-30139: Summary: CodeGenLoader fails when temporary directory is a symlink Key: FLINK-30139 URL: https://issues.apache.org/jira/browse/FLINK-30139 Project: Flink Iss

[jira] [Created] (FLINK-30140) flink-runtime intergration tests fail due to Process Exit Code: 239

Matthias Pohl created FLINK-30140: - Summary: flink-runtime intergration tests fail due to Process Exit Code: 239 Key: FLINK-30140 URL: https://issues.apache.org/jira/browse/FLINK-30140 Project: Flink

Re: [VOTE] Release 1.15.3, release candidate #1

Thanks Fabian, +1 (binding) - verified checksum & signature - built from source - run sample jobs with standalone cluster, ui & logs look good Best, Xintong On Tue, Nov 22, 2022 at 2:12 PM Matthias Pohl wrote: > Thanks Fabian for driving this release. > > +1 (non-binding) > > * Downloaded a

[jira] [Created] (FLINK-30141) MinioTestContainerTest failed due to IllegalStateException in container startup

Matthias Pohl created FLINK-30141: - Summary: MinioTestContainerTest failed due to IllegalStateException in container startup Key: FLINK-30141 URL: https://issues.apache.org/jira/browse/FLINK-30141 Pro

Re: FRocksDB Some Question

Thank you for your reply. I will join the discussion after careful review Yanfei Lei 于2022年11月22日周二 12:20写道： > Hi ConradJam, > > Thanks for bringing this up. > In fact, @Sebastian has tried to update RocksDB to 6.29.5[1], but there are > some regressions on MapState[2]. If you want to use the ne

[jira] [Created] (FLINK-30142) Flink ML operators lose table watermark after transform()

Yunfeng Zhou created FLINK-30142: Summary: Flink ML operators lose table watermark after transform() Key: FLINK-30142 URL: https://issues.apache.org/jira/browse/FLINK-30142 Project: Flink Iss

Re: Re: [DISCUSS] FLIP-269: Properly Handling the Processing Timers on Job Termination

Hi, All in all I would agree with Dawid's proposal. We can add the flexibility of how to deal with the timers in the low level API via adding a handler - if someone needs to customize it, he will always have a workaround. Note after giving it more thought, I agree that registering some handlers is

[jira] [Created] (FLINK-30143) Table Store fails when temporary directory is a symlink

Caizhi Weng created FLINK-30143: --- Summary: Table Store fails when temporary directory is a symlink Key: FLINK-30143 URL: https://issues.apache.org/jira/browse/FLINK-30143 Project: Flink Issue T

[jira] [Created] (FLINK-30144) Guarantee Flink ML operators function correctly with object-reuse enabled

Yunfeng Zhou created FLINK-30144: Summary: Guarantee Flink ML operators function correctly with object-reuse enabled Key: FLINK-30144 URL: https://issues.apache.org/jira/browse/FLINK-30144 Project: Fl

Re: [DISCUSS] FLIP-272: Generalized delegation token support

Hi Danny, Please find my answers inline. G On Mon, Nov 21, 2022 at 9:27 PM Danny Cranmer wrote: > Hey, > > > All the rest which is public can be considered accidental leak (for > example > "DelegationTokenManager" where Java doesn't support internal interfaces). > > If the classes are interna

Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

Congratulations Mátyás! On Tue, Nov 22, 2022, 06:40 Matthias Pohl wrote: > Congratulations, Matyas :) > > On Tue, Nov 22, 2022 at 11:44 AM Xingbo Huang wrote: > > > Congrats Matyas! > > > > Best, > > Xingbo > > > > Yanfei Lei 于2022年11月22日周二 11:18写道： > > > > > Congrats Matyas! 🍻 > > > > > > Zhe

[jira] [Created] (FLINK-30145) Evaluate operator error log entry: JmDeploymentStatus.ERROR.Count

Gabor Somogyi created FLINK-30145: - Summary: Evaluate operator error log entry: JmDeploymentStatus.ERROR.Count Key: FLINK-30145 URL: https://issues.apache.org/jira/browse/FLINK-30145 Project: Flink

[jira] [Created] (FLINK-30146) Evaluate operator error log entry: Exception while listing jobs

Gabor Somogyi created FLINK-30146: - Summary: Evaluate operator error log entry: Exception while listing jobs Key: FLINK-30146 URL: https://issues.apache.org/jira/browse/FLINK-30146 Project: Flink

[jira] [Created] (FLINK-30147) Evaluate operator error log entry: Failed to submit a listener notification task

Gabor Somogyi created FLINK-30147: - Summary: Evaluate operator error log entry: Failed to submit a listener notification task Key: FLINK-30147 URL: https://issues.apache.org/jira/browse/FLINK-30147 Pr

[jira] [Created] (FLINK-30148) Evaluate operator error log entry: Failed to submit job to session cluster

Gabor Somogyi created FLINK-30148: - Summary: Evaluate operator error log entry: Failed to submit job to session cluster Key: FLINK-30148 URL: https://issues.apache.org/jira/browse/FLINK-30148 Project:

[jira] [Created] (FLINK-30151) Evaluate operator error log entry: AuditUtils

Gabor Somogyi created FLINK-30151: - Summary: Evaluate operator error log entry: AuditUtils Key: FLINK-30151 URL: https://issues.apache.org/jira/browse/FLINK-30151 Project: Flink Issue Type: S

[jira] [Created] (FLINK-30150) Evaluate operator error log entry: REST service in session cluster is bad now

Gabor Somogyi created FLINK-30150: - Summary: Evaluate operator error log entry: REST service in session cluster is bad now Key: FLINK-30150 URL: https://issues.apache.org/jira/browse/FLINK-30150 Proje

[jira] [Created] (FLINK-30149) Evaluate operator error log entry: Error during event processing

Gabor Somogyi created FLINK-30149: - Summary: Evaluate operator error log entry: Error during event processing Key: FLINK-30149 URL: https://issues.apache.org/jira/browse/FLINK-30149 Project: Flink

[jira] [Created] (FLINK-30152) Failure in setting up the CI agent

Matthias Pohl created FLINK-30152: - Summary: Failure in setting up the CI agent Key: FLINK-30152 URL: https://issues.apache.org/jira/browse/FLINK-30152 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30153) YARNSessionCapacitySchedulerITCase fails with NoClassDefFoundError

Matthias Pohl created FLINK-30153: - Summary: YARNSessionCapacitySchedulerITCase fails with NoClassDefFoundError Key: FLINK-30153 URL: https://issues.apache.org/jira/browse/FLINK-30153 Project: Flink

[jira] [Created] (FLINK-30154) flinkConfiguration in SessionJob is not accepted

Emmanuel Leroy created FLINK-30154: -- Summary: flinkConfiguration in SessionJob is not accepted Key: FLINK-30154 URL: https://issues.apache.org/jira/browse/FLINK-30154 Project: Flink Issue Ty

Re: Stack Overflow Question re compressing broadcast state

Hey, Would be great if you could help with any of that. I could definitely help with reviews. Best, Dawid On 22/11/2022 01:17, Ken Krugler wrote: Hi Dawid, Thanks for following up on this. Let me know if you’d like me to update the documentation, that seems pretty straightforward :) Ad

Re: [VOTE] FLIP-272: Generalized delegation token support

+1 (binding) Gyula On Mon, Nov 21, 2022 at 9:27 PM Danny Cranmer wrote: > +1 (binding). > > Danny, > > On Mon, Nov 21, 2022 at 4:23 PM Ferenc Csaky > wrote: > > > +1 (non-binding) > > > > Best, > > F > > > > > > --- Original Message --- > > On Friday, November 18th, 2022 at 16:11, Márt

[jira] [Created] (FLINK-30155) Pretty print MutatedConfigurationException

Piotr Nowojski created FLINK-30155: -- Summary: Pretty print MutatedConfigurationException Key: FLINK-30155 URL: https://issues.apache.org/jira/browse/FLINK-30155 Project: Flink Issue Type: Ne

Re: [DISCUSS] OLM Bundles for Flink Kubernetes Operator

Hi Ted! My main concern here is how do we ensure that the bundle uploaded to the OLM registry is vetted by the community and corresponds to the latest release. I think we definitely should not upload anything until the release process is complete and the community actually tested the bundle. So m

[jira] [Created] (FLINK-30156) [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the AsyncSinkBase

Hong Liang Teoh created FLINK-30156: --- Summary: [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the AsyncSinkBase Key: FLINK-30156 URL: https://issues.apache.org/jira/browse/FLINK-30156

Re: Table API thrift support

Hi Yuxia, Martijin, Thanks for your feedback on FLIP-237! My understanding is that FLIP-237 better focuses on thrift encoding/decoding in Datastream/Table API/ Pyflink. To address feedbacks, I made follow changes to FLIP-237

Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

Congrats! Am Di., 22. Nov. 2022 um 11:46 Uhr schrieb Péter Váry < peter.vary.apa...@gmail.com>: > Congratulations Mátyás! > > On Tue, Nov 22, 2022, 06:40 Matthias Pohl > wrote: > > > Congratulations, Matyas :) > > > > On Tue, Nov 22, 2022 at 11:44 AM Xingbo Huang > wrote: > > > > > Congrats Mat

[jira] [Created] (FLINK-30157) Trigger Events Before JM Recovery and Unhealthy Job Restarts

Matyas Orhidi created FLINK-30157: - Summary: Trigger Events Before JM Recovery and Unhealthy Job Restarts Key: FLINK-30157 URL: https://issues.apache.org/jira/browse/FLINK-30157 Project: Flink

[DISCUSS] OLM Bundles for Flink Kubernetes Operator

Hi Gyula, Agree, we should include the bundle file and let community inspect them in the staging repo. In addition, people can do a few things to test the bundle files. 1.Run CI test suits (https://github.com/tedhtchang/olm#run-ci-test-suits-before-creating-pr) with the bundle files

[jira] [Created] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

James Mcguire created FLINK-30158: - Summary: [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes Key: FLINK-30158 URL: https://issues.apache.org/jira/browse/FLINK-

Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

Congrats! On Tue, Nov 22, 2022 at 1:47 PM Konstantin Knauf wrote: > Congrats! > > Am Di., 22. Nov. 2022 um 11:46 Uhr schrieb Péter Váry < > peter.vary.apa...@gmail.com>: > > > Congratulations Mátyás! > > > > On Tue, Nov 22, 2022, 06:40 Matthias Pohl .invalid> > > wrote: > > > > > Congratulation

Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

Congrats Matyas! Best regards, Yuxia - 原始邮件 - 发件人: "Peter Huang" 收件人: "dev" 发送时间: 星期三, 2022年 11 月 23日 上午 8:24:00 主题: Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi Congrats! On Tue, Nov 22, 2022 at 1:47 PM Konstantin Knauf wrote: > Congrats! > > Am Di., 22. Nov. 2022 um 1

[jira] [Created] (FLINK-30159) Add Transformer for ANOVATest

Jiang Xin created FLINK-30159: - Summary: Add Transformer for ANOVATest Key: FLINK-30159 URL: https://issues.apache.org/jira/browse/FLINK-30159 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-30160) Add Transformer for FValueTest

Jiang Xin created FLINK-30160: - Summary: Add Transformer for FValueTest Key: FLINK-30160 URL: https://issues.apache.org/jira/browse/FLINK-30160 Project: Flink Issue Type: Sub-task Compo

[ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Hi everyone, On behalf of the Apache Flink PMC, I'm very happy to announce that Godfrey He and Xingbo Huang have joined the Flink PMC! Godfrey He becomes a Flink committer in Sep 2020. His contributions are mainly focused on the Flink table module, covering almost all important parts such as Clie

Re: SQL Gateway and SQL Client

Hi Jim, Sorry for late response. Just another busy week :) Last week, I’ve discussed within my team about my design. My teammates think it’s better to unify the local and remote mode, so I’ve investigated and redesigned a new plan. I’ll inform you after the rewriting of FLIP finished (will be so

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congrats，Godfrey and Xingbo! Best, Biao Geng 获取 Outlook for iOS 发件人: Dian Fu 发送时间: Wednesday, November 23, 2022 12:18:01 PM 收件人: dev 主题: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang Hi everyone, On behalf of the Apac

Re: [DISCUSS] Flink release retro

I updated the Flink release wiki article [1] as discussed in my previous email. An explicit request for feedback on the release process will be part of the release announcement from now onwards. Additionally, I added a subsection in wrapping up the release where we suggest creating a summary per re

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congratulations，Godfrey and Xingbo! Best, Leonard > On Nov 23, 2022, at 12:32 PM, Geng Biao wrote: > > Congrats，Godfrey and Xingbo! > Best,

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congrats，Godfrey and Xingbo! Best regards, Yuxia - 原始邮件 - 发件人: "Geng Biao" 收件人: "dev" 发送时间: 星期三, 2022年 11 月 23日 下午 12:32:52 主题: Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang Congrats，Godfrey and Xingbo! Best, Biao Geng 获取 Outlook for iOS

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congratulations, Godfrey and Xingbo! Best, Zakelly On Wed, Nov 23, 2022 at 2:07 PM yuxia wrote: > > Congrats，Godfrey and Xingbo! > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Geng Biao" > 收件人: "dev" > 发送时间: 星期三, 2022年 11 月 23日 下午 12:32:52 > 主题: Re: [ANNOUNCE] New Apache Flink PMC Memb

Re: [DISCUSS] OLM Bundles for Flink Kubernetes Operator

I'm curious how the RC automation works now - is it fully automatic? For example, a RC Debian image gets created, something like: ghcr.io/apache/flink-kubernetes-operator:95128bf and is pushed to ghcr.io … then that's used in the rc helm c

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congratulations Godfrey and Xingbo, well deserved! Zakelly Lan 于2022年11月23日周三 14:11写道： > Congratulations, Godfrey and Xingbo! > > Best, > Zakelly > > On Wed, Nov 23, 2022 at 2:07 PM yuxia wrote: > > > > Congrats，Godfrey and Xingbo! > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件

[jira] [Created] (FLINK-30161) Add TableSchema validation before it is commited

Shammon created FLINK-30161: --- Summary: Add TableSchema validation before it is commited Key: FLINK-30161 URL: https://issues.apache.org/jira/browse/FLINK-30161 Project: Flink Issue Type: Improvemen

Re: Re: [DISCUSS] FLIP-269: Properly Handling the Processing Timers on Job Termination

Thanks Yun/Piotrek, Some brief comments inline below. On Tue, Nov 22, 2022 at 1:37 AM Piotr Nowojski wrote: > Hi, > > All in all I would agree with Dawid's proposal. +1 We can add the flexibility > of how to deal with the timers in the low level API via adding a handler - > if someone needs t

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congrats, Godfrey and Xingbo! Best, Lincoln Lee Benchao Li 于2022年11月23日周三 14:17写道： > Congratulations Godfrey and Xingbo, well deserved! > > Zakelly Lan 于2022年11月23日周三 14:11写道： > > > Congratulations, Godfrey and Xingbo! > > > > Best, > > Zakelly > > > > On Wed, Nov 23, 2022 at 2:07 PM yuxia >

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congrats, Godfrey and Xingbo! Best, Runkang He Lincoln Lee 于2022年11月23日周三 15:21写道： > Congrats, Godfrey and Xingbo! > > Best, > Lincoln Lee > > > Benchao Li 于2022年11月23日周三 14:17写道： > > > Congratulations Godfrey and Xingbo, well deserved! > > > > Zakelly Lan 于2022年11月23日周三 14:11写道： > > > > > Co

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congratulations, Godfrey and Xingbo! Best, Shuiqiang Runker Hanna 于2022年11月23日周三 15:28写道： > Congrats, Godfrey and Xingbo! > > Best, > Runkang He > > Lincoln Lee 于2022年11月23日周三 15:21写道： > > > Congrats, Godfrey and Xingbo! > > > > Best, > > Lincoln Lee > > > > > > Benchao Li 于2022年11月23日周三 14:1

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congratulations, Godfrey and Xingbo! Best, Wei > 2022年11月23日 下午3:29，Shuiqiang Chen 写道： > > Congratulations, Godfrey and Xingbo! > > Best, > Shuiqiang > > Runker Hanna 于2022年11月23日周三 15:28写道： > >> Congrats, Godfrey and Xingbo! >> >> Best, >> Runkang He >> >> Lincoln Lee 于2022年11月23日周三 15: