[jira] [Created] (FLINK-33513) Metastore delegation-token can be cached?

2023-11-10 Thread katty he (Jira)
katty he created FLINK-33513: Summary: Metastore delegation-token can be cached? Key: FLINK-33513 URL: https://issues.apache.org/jira/browse/FLINK-33513 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-33514) FlinkScalaKryoInstantiator class not found in KryoSerializer

2023-11-10 Thread Jake.zhang (Jira)
Jake.zhang created FLINK-33514: -- Summary: FlinkScalaKryoInstantiator class not found in KryoSerializer Key: FLINK-33514 URL: https://issues.apache.org/jira/browse/FLINK-33514 Project: Flink Iss

[jira] [Created] (FLINK-33515) PythonDriver need to stream python process output to log instead of collecting it in memory

2023-11-10 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-33515: - Summary: PythonDriver need to stream python process output to log instead of collecting it in memory Key: FLINK-33515 URL: https://issues.apache.org/jira/browse/FLINK-33515

[jira] [Created] (FLINK-33516) Create dedicated PyFlink channel

2023-11-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33516: -- Summary: Create dedicated PyFlink channel Key: FLINK-33516 URL: https://issues.apache.org/jira/browse/FLINK-33516 Project: Flink Issue Type: Improvement

RE: Request a release of flink-connector-kafka version 3.1.0 (to consume kafka 3.4.0 with Flink 1.18)

2023-11-10 Thread Jean-Marc Paulin
Hi, I am not exactly thrilled by the False positive statement. This always leads to a difficult discussion with customers. Is there a chance of releasing a version of the connector to just add support for Kafka 3.4.0, in conjunction with Flink 1.18 ? Kind regards Jean-Marc ___

[jira] [Created] (FLINK-33517) Implement restore tests for Value node

2023-11-10 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-33517: - Summary: Implement restore tests for Value node Key: FLINK-33517 URL: https://issues.apache.org/jira/browse/FLINK-33517 Project: Flink Issue Type: Sub-task

Re: Adding a new channel to Apache Flink slack workspace

2023-11-10 Thread Martijn Visser
Hi all, I've created https://issues.apache.org/jira/browse/FLINK-33516 and I'll work on this. Thanks! Cheers, Martijn On Fri, Nov 10, 2023 at 7:50 AM Yun Tang wrote: > > +1 and glad to see more guys are using PyFlink. > > Best > Yun Tang > > From: Jing Ge > Sen

[jira] [Created] (FLINK-33518) Implement restore tests for WatermarkAssigner node

2023-11-10 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-33518: - Summary: Implement restore tests for WatermarkAssigner node Key: FLINK-33518 URL: https://issues.apache.org/jira/browse/FLINK-33518 Project: Flink Issue Type: Sub-

Re: Request a release of flink-connector-kafka version 3.1.0 (to consume kafka 3.4.0 with Flink 1.18)

2023-11-10 Thread Martijn Visser
Hi Jean-Marc, To be fair, the Flink project has a lot of dependencies that have false-positives from a Flink pov. We just can't fix all of them. Let's see what others say on this topic. Best regards, Martijn On Fri, Nov 10, 2023 at 10:56 AM Jean-Marc Paulin wrote: > > Hi, > > I am not exactly

Re: [VOTE] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-10 Thread Rui Fan
+1(binding) Best, Rui On Fri, Nov 10, 2023 at 11:58 AM Junrui Lee wrote: > Hi everyone, > > Thank you to everyone for the feedback on FLIP-381: Deprecate configuration > getters/setters that return/set complex Java objects[1] which has been > discussed in this thread [2]. > > I would like to st

Re: [DISCUSS] FLIP-364: Improve the restart-strategy

2023-11-10 Thread Rui Fan
I'll start voting next Monday if there isn't any other comment. Best, Rui On Thu, Oct 19, 2023 at 6:59 PM Rui Fan <1996fan...@gmail.com> wrote: > Hi Konstantin and Max, > > Thanks for your feedback! > > Sorry, I forgot to mention the default value of > `restart-strategy.exponential-delay.max-att

Re: [VOTE] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-10 Thread Yuepeng Pan
+1(non-binding) Best, Roc On 2023/11/10 03:58:10 Junrui Lee wrote: > Hi everyone, > > Thank you to everyone for the feedback on FLIP-381: Deprecate configuration > getters/setters that return/set complex Java objects[1] which has been > discussed in this thread [2]. > > I would like to start a

Re: [DISCUSS] Release flink-connector-pulsar 4.1.0

2023-11-10 Thread tison
> does it include support for Flink 1.18? Not yet. Tests for 1.16 and 1.17 can pass, but the latest 1.18-SNAPSHOT is not (and ditto 1.18.0). I'm afraid it's not a trivial fix so let's mark it as an issue but not a blocker. Best, tison. Martijn Visser 于2023年11月9日周四 16:21写道: > Hi Tison, > > I w

[jira] [Created] (FLINK-33519) standalone mode could not create keytab secret

2023-11-10 Thread chaoran.su (Jira)
chaoran.su created FLINK-33519: -- Summary: standalone mode could not create keytab secret Key: FLINK-33519 URL: https://issues.apache.org/jira/browse/FLINK-33519 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33520) FileNotFoundException when running GPUDriverTest

2023-11-10 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-33520: --- Summary: FileNotFoundException when running GPUDriverTest Key: FLINK-33520 URL: https://issues.apache.org/jira/browse/FLINK-33520 Project: Flink Issue Type: Te

[jira] [Created] (FLINK-33521) Implement restore tests for PythonCalc node

2023-11-10 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-33521: -- Summary: Implement restore tests for PythonCalc node Key: FLINK-33521 URL: https://issues.apache.org/jira/browse/FLINK-33521 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] FLIP-390: Support System out and err to be redirected to LOG or discarded

2023-11-10 Thread Piotr Nowojski
Thanks! :) Best, Piotrek czw., 9 lis 2023 o 16:15 Rui Fan <1996fan...@gmail.com> napisał(a): > Hi Piotr, > > Thanks for your feedback! > > > Or implement your own loop? It shouldn't be more than a couple of lines. > > Implementing it directly is fine, I have updated the FLIP. > And this logic ca

Re: Adding a new channel to Apache Flink slack workspace

2023-11-10 Thread Robin Moffatt
wonderful, thanks Martin! On Fri, 10 Nov 2023 at 09:56, Martijn Visser wrote: > Hi all, > > I've created https://issues.apache.org/jira/browse/FLINK-33516 and > I'll work on this. Thanks! > > Cheers, Martijn > > On Fri, Nov 10, 2023 at 7:50 AM Yun Tang wrote: > > > > +1 and glad to see more guy

Re: Adding a new channel to Apache Flink slack workspace

2023-11-10 Thread Robin Moffatt
*Martijn, sorry! On Fri, 10 Nov 2023 at 16:54, Robin Moffatt wrote: > wonderful, thanks Martin! > > On Fri, 10 Nov 2023 at 09:56, Martijn Visser > wrote: > >> Hi all, >> >> I've created https://issues.apache.org/jira/browse/FLINK-33516 and >> I'll work on this. Thanks! >> >> Cheers, Martijn >>

[jira] [Created] (FLINK-33522) Savepoint upgrade mode fails despite the savepoint succeeding

2023-11-10 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-33522: -- Summary: Savepoint upgrade mode fails despite the savepoint succeeding Key: FLINK-33522 URL: https://issues.apache.org/jira/browse/FLINK-33522 Project: Fl

Re: [DISCUSS] FLIP-389: Annotate SingleThreadFetcherManager and FutureCompletingBlockingQueue as PublicEvolving

2023-11-10 Thread Becket Qin
Hi Hongshun and Martijn, Sorry for the late reply as I was on travel and still catching up with the emails. Please allow me to provide more context. 1. The original design of SplitFetcherManager and its subclasses was to make them public to the Source developers. The goal is to let us take care o

[jira] [Created] (FLINK-33523) DataType ARRAY fails to cast into Object[]

2023-11-10 Thread Prabhu Joseph (Jira)
Prabhu Joseph created FLINK-33523: - Summary: DataType ARRAY fails to cast into Object[] Key: FLINK-33523 URL: https://issues.apache.org/jira/browse/FLINK-33523 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33524) IntervalJoinOperator 's judgment on late data has bug

2023-11-10 Thread ZhangTao (Jira)
ZhangTao created FLINK-33524: Summary: IntervalJoinOperator 's judgment on late data has bug Key: FLINK-33524 URL: https://issues.apache.org/jira/browse/FLINK-33524 Project: Flink Issue Type: Bug