Re: Flink native k8s integration vs. operator

Hi Alexis, The usage of Custom Resource Definitions (CRDs). The main reason given to > me was that such resources are global (for a given cluster) and that is not > desired. I know that ultimately a CR based on a CRD can be scoped to a > specific namespace, but customer is king… I don't think

[jira] [Created] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

Martijn Visser created FLINK-25738: -- Summary: Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors" Key: FLINK-25738 URL:

[jira] [Created] (FLINK-25739) Include dstl-dfs into distribution (opt/)

Roman Khachatryan created FLINK-25739: - Summary: Include dstl-dfs into distribution (opt/) Key: FLINK-25739 URL: https://issues.apache.org/jira/browse/FLINK-25739 Project: Flink Issue

[jira] [Created] (FLINK-25740) PulsarSourceOrderedE2ECase fails on azure

Roman Khachatryan created FLINK-25740: - Summary: PulsarSourceOrderedE2ECase fails on azure Key: FLINK-25740 URL: https://issues.apache.org/jira/browse/FLINK-25740 Project: Flink Issue

[jira] [Created] (FLINK-25743) Parameter flink.yarn. has no effect in yarn-session mode with flink-shade-hadoop-2-uber.jar

HunterHunter created FLINK-25743: Summary: Parameter flink.yarn. has no effect in yarn-session mode with flink-shade-hadoop-2-uber.jar Key: FLINK-25743 URL: https://issues.apache.org/jira/browse/FLINK-25743

Re: Re: [DISCUSS] Introduce Hash Lookup Join

Hi, Jing Glad to hear the agreement on the hint syntax, let's keep going! Best, Lincoln Lee Jing Zhang 于2022年1月20日周四 16:52写道： > Hi Jingsong, > Thanks for the feedback. > > > Is there a conclusion about naming here? (Maybe I missed something?) > Use USE_HASH or some other names. Slightly

Re: [VOTE] FLIP-201: Persist local state in working directory

+1 (binding) This would be useful especially for K8s users. Best, Yang David Morávek 于2022年1月20日周四 18:19写道： > +1 (non-binding) > > D. > > On Thu, Jan 20, 2022 at 10:14 AM Chesnay Schepler > wrote: > > > +1 (binding) > > > > On 19/01/2022 17:23, Matthias Pohl wrote: > > > +1 (binding) > > > >

[jira] [Created] (FLINK-25742) Remove the redundant serialization of RPC invocation at Flink side.

Yangze Guo created FLINK-25742: -- Summary: Remove the redundant serialization of RPC invocation at Flink side. Key: FLINK-25742 URL: https://issues.apache.org/jira/browse/FLINK-25742 Project: Flink

[jira] [Created] (FLINK-25741) Ignore buffer pools which have no floating buffer in buffer redistributing

Yangze Guo created FLINK-25741: -- Summary: Ignore buffer pools which have no floating buffer in buffer redistributing Key: FLINK-25741 URL: https://issues.apache.org/jira/browse/FLINK-25741 Project:

Re: Re: [DISCUSS] Introduce Hash Lookup Join

Thanks Jing, Looks good~ Best, Jingsong On Fri, Jan 21, 2022 at 2:00 PM Lincoln Lee wrote: > > Hi, Jing > Glad to hear the agreement on the hint syntax, let's keep going! > > Best, > Lincoln Lee > > > Jing Zhang 于2022年1月20日周四 16:52写道： > > > Hi Jingsong, > > Thanks for the feedback. > > > >

Re: Re: [DISCUSS] Introduce Hash Lookup Join

Hi Lincoln, Thanks for the feedback. > The previous discussion for the hint syntax left a minor difference there: whether to use both sides of join table names or just one 'build' side table name only. I would prefer the later one. Users only need to pass the `build` side table(usually the

Re: [VOTE] Creating external connector repositories

+1 Thanks, Zhu Jing Ge 于2022年1月20日周四 16:26写道： > +1 (non-binding) > > Thanks for driving this Martijn! > > Best regards, > Jing > > On Thu, Jan 20, 2022 at 8:24 AM Yun Gao > wrote: > > > +1 > > > > Thanks Martijn for the efforts! > > > > Best, > > Yun > > > > > >

[jira] [Created] (FLINK-25722) Support Python UDAF in Thread Mode

Huang Xingbo created FLINK-25722: Summary: Support Python UDAF in Thread Mode Key: FLINK-25722 URL: https://issues.apache.org/jira/browse/FLINK-25722 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25723) Support Pandas UDAF in Thread Mode

Huang Xingbo created FLINK-25723: Summary: Support Pandas UDAF in Thread Mode Key: FLINK-25723 URL: https://issues.apache.org/jira/browse/FLINK-25723 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25721) Support Pandas UDF in Thread Mode

Huang Xingbo created FLINK-25721: Summary: Support Pandas UDF in Thread Mode Key: FLINK-25721 URL: https://issues.apache.org/jira/browse/FLINK-25721 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25725) Refactor web-dashboard's folder structure and use Angular DI injection token for better reusability

Junhan Yang created FLINK-25725: --- Summary: Refactor web-dashboard's folder structure and use Angular DI injection token for better reusability Key: FLINK-25725 URL: https://issues.apache.org/jira/browse/FLINK-25725

[jira] [Created] (FLINK-25726) Implement GlobalCommitter as custom post commit topology

Fabian Paul created FLINK-25726: --- Summary: Implement GlobalCommitter as custom post commit topology Key: FLINK-25726 URL: https://issues.apache.org/jira/browse/FLINK-25726 Project: Flink Issue

Re: [VOTE] Creating external connector repositories

+1 (non-binding) Thanks for driving this Martijn! Best regards, Jing On Thu, Jan 20, 2022 at 8:24 AM Yun Gao wrote: > +1 > > Thanks Martijn for the efforts! > > Best, > Yun > > > -- > From:Yun Tang > Send Time:2022 Jan. 20

[jira] [Created] (FLINK-25715) Application Mode: Add option to submit a failed job on application error

David Morávek created FLINK-25715: - Summary: Application Mode: Add option to submit a failed job on application error Key: FLINK-25715 URL: https://issues.apache.org/jira/browse/FLINK-25715 Project:

[jira] [Created] (FLINK-25716) Translate "Streaming Concepts" page of "Application Development > Table API & SQL" to Chinese

Martijn Visser created FLINK-25716: -- Summary: Translate "Streaming Concepts" page of "Application Development > Table API & SQL" to Chinese Key: FLINK-25716 URL: https://issues.apache.org/jira/browse/FLINK-25716

Re: Re: [DISCUSS] Introduce Hash Lookup Join

Hi Jingsong, Thanks for the feedback. > Is there a conclusion about naming here? (Maybe I missed something?) Use USE_HASH or some other names. Slightly confusing in the FLIP. 'SHUFFLE_HASH' is final hint name, 'USE_HASH' is rejected. I've updated the FLIP. > And the problem of what to write

[jira] [Created] (FLINK-25718) FLIP-206: Support PyFlink Runtime Execution in Thread Mode

Huang Xingbo created FLINK-25718: Summary: FLIP-206: Support PyFlink Runtime Execution in Thread Mode Key: FLINK-25718 URL: https://issues.apache.org/jira/browse/FLINK-25718 Project: Flink

[jira] [Created] (FLINK-25719) Support General Python UDF in Thread Mode

Huang Xingbo created FLINK-25719: Summary: Support General Python UDF in Thread Mode Key: FLINK-25719 URL: https://issues.apache.org/jira/browse/FLINK-25719 Project: Flink Issue Type:

Re: [VOTE] FLIP-205: Support cache in DataStream for Batch Processing

+1 (non-binding) On Thu, Jan 20, 2022 at 3:26 PM Yun Gao wrote: > +1 (binding) > > Thanks Xuannan for driving this! > > Best, > Yun > > > -- > From:David Morávek > Send Time:2022 Jan. 20 (Thu.) 15:12 > To:dev > Subject:Re: [VOTE]

Re: [VOTE] FLIP-201: Persist local state in working directory

+1 (non-binding) D. On Thu, Jan 20, 2022 at 10:14 AM Chesnay Schepler wrote: > +1 (binding) > > On 19/01/2022 17:23, Matthias Pohl wrote: > > +1 (binding) > > > > Best, > > Matthias > > > > On Mon, Jan 10, 2022 at 2:53 PM Till Rohrmann > wrote: > > > >> +1 (binding) > >> > >> Cheers, > >>

[jira] [Created] (FLINK-25728) StreamMultipleInputProcessor holds mass CompletableFuture instances under certain scenario

pc wang created FLINK-25728: --- Summary: StreamMultipleInputProcessor holds mass CompletableFuture instances under certain scenario Key: FLINK-25728 URL: https://issues.apache.org/jira/browse/FLINK-25728

Re: [ANNOUNCE] Apache Flink 1.14.3 released

Congrats to everyone involved ! Etienne Le 20/01/2022 à 05:29, Thomas Weise a écrit : The Apache Flink community is very happy to announce the release of Apache Flink 1.14.3, which is the second bugfix release for the Apache Flink 1.14 series. Apache Flink® is an open-source stream processing

[jira] [Created] (FLINK-25720) Support Python UDTF in Thread Mode

Huang Xingbo created FLINK-25720: Summary: Support Python UDTF in Thread Mode Key: FLINK-25720 URL: https://issues.apache.org/jira/browse/FLINK-25720 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25727) Flink SQL convert constant string to char type which cause hive udtf json_tuple not work

syntomic created FLINK-25727: Summary: Flink SQL convert constant string to char type which cause hive udtf json_tuple not work Key: FLINK-25727 URL: https://issues.apache.org/jira/browse/FLINK-25727

[jira] [Created] (FLINK-25717) Chinese version document Penging word misspelling

aresyhzhang created FLINK-25717: --- Summary: Chinese version document Penging word misspelling Key: FLINK-25717 URL: https://issues.apache.org/jira/browse/FLINK-25717 Project: Flink Issue Type:

[jira] [Created] (FLINK-25724) Support Python DataStream API in Thread Mode

Huang Xingbo created FLINK-25724: Summary: Support Python DataStream API in Thread Mode Key: FLINK-25724 URL: https://issues.apache.org/jira/browse/FLINK-25724 Project: Flink Issue Type:

Re: [VOTE] FLIP-201: Persist local state in working directory

+1 (binding) On 19/01/2022 17:23, Matthias Pohl wrote: +1 (binding) Best, Matthias On Mon, Jan 10, 2022 at 2:53 PM Till Rohrmann wrote: +1 (binding) Cheers, Till On Mon, Jan 10, 2022 at 2:30 PM Etienne Chauchot wrote: +1 Best Etienne Chauchot Le 10/01/2022 à 10:22, Till Rohrmann a

[jira] [Created] (FLINK-25729) Replace the deprecated FlinkKinesisConsumer with a Kinesis Consumer based on the AWS SDK for Java 2.x

Zichen Liu created FLINK-25729: -- Summary: Replace the deprecated FlinkKinesisConsumer with a Kinesis Consumer based on the AWS SDK for Java 2.x Key: FLINK-25729 URL: https://issues.apache.org/jira/browse/FLINK-25729

[jira] [Created] (FLINK-25714) Remove @ant-design/icons-angular dependency once NG-ZORRO supports node v16.X

Junhan Yang created FLINK-25714: --- Summary: Remove @ant-design/icons-angular dependency once NG-ZORRO supports node v16.X Key: FLINK-25714 URL: https://issues.apache.org/jira/browse/FLINK-25714 Project:

Re: [ANNOUNCE] Apache Flink 1.14.3 released

Thank you so much for taking care of this Thomas and Martijn! A patch release was long overdue. Regards, Timo On 20.01.22 13:01, Till Rohrmann wrote: Thanks a lot for being our release manager Thomas and Martijn and to everyone who contributed to this release :-) Cheers, Till On Thu, Jan

[jira] [Created] (FLINK-25731) Mark FlinkKinesisProducer/FlinkKinesisConsumer as deprecated

Zichen Liu created FLINK-25731: -- Summary: Mark FlinkKinesisProducer/FlinkKinesisConsumer as deprecated Key: FLINK-25731 URL: https://issues.apache.org/jira/browse/FLINK-25731 Project: Flink

Re: Request for Flink 1.12.8 release

Hi, Yes, that's right. Best, Guowei On Thu, Jan 20, 2022 at 2:08 PM V N, Suchithra (Nokia - IN/Bangalore) < suchithra@nokia.com> wrote: > Hi Guowei, > > Flink 1.12.7 is already released. Request is for 1.12.8 release with log4j > 2.17.1. You meant 1.12.8 here? > > Regards, > Suchithra > >

[jira] [Created] (FLINK-25730) Fix chaining strategy (and typo?) in RowTimeMiniBatchAssginerOperator

Q Kang created FLINK-25730: -- Summary: Fix chaining strategy (and typo?) in RowTimeMiniBatchAssginerOperator Key: FLINK-25730 URL: https://issues.apache.org/jira/browse/FLINK-25730 Project: Flink

Re: [ANNOUNCE] Apache Flink 1.14.3 released

Congrats! Thanks Thomas & Martijn for driving the release and to everyone that contributed to it. Best, D. On Thu, Jan 20, 2022 at 11:34 AM Etienne Chauchot wrote: > Congrats to everyone involved ! > > Etienne > > Le 20/01/2022 à 05:29, Thomas Weise a écrit : > > The Apache Flink community is

Re: [ANNOUNCE] Apache Flink 1.14.3 released

Thanks a lot for being our release manager Thomas and Martijn and to everyone who contributed to this release :-) Cheers, Till On Thu, Jan 20, 2022 at 12:23 PM David Morávek wrote: > Congrats! Thanks Thomas & Martijn for driving the release and to everyone > that contributed to it. > > Best, >

[jira] [Created] (FLINK-25732) Dispatcher#requestMultipleJobDetails returns non-serialiable collection

Chesnay Schepler created FLINK-25732: Summary: Dispatcher#requestMultipleJobDetails returns non-serialiable collection Key: FLINK-25732 URL: https://issues.apache.org/jira/browse/FLINK-25732

[jira] [Created] (FLINK-25733) [FLIP-171] Create A migration guide for Kinesis Table API connector

Ahmed Hamdy created FLINK-25733: --- Summary: [FLIP-171] Create A migration guide for Kinesis Table API connector Key: FLINK-25733 URL: https://issues.apache.org/jira/browse/FLINK-25733 Project: Flink

[jira] [Created] (FLINK-25734) Chinese Translation - Update documentation for Kinesis Table Api

Ahmed Hamdy created FLINK-25734: --- Summary: Chinese Translation - Update documentation for Kinesis Table Api Key: FLINK-25734 URL: https://issues.apache.org/jira/browse/FLINK-25734 Project: Flink

[jira] [Created] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink

Zichen Liu created FLINK-25735: -- Summary: Chinese Translation - Add documentation for KDS Async Sink Key: FLINK-25735 URL: https://issues.apache.org/jira/browse/FLINK-25735 Project: Flink Issue

[jira] [Created] (FLINK-25736) Chinese Translation - Update documentation for Kinesis Table Api

Zichen Liu created FLINK-25736: -- Summary: Chinese Translation - Update documentation for Kinesis Table Api Key: FLINK-25736 URL: https://issues.apache.org/jira/browse/FLINK-25736 Project: Flink

[jira] [Created] (FLINK-25737) Chinese Translation - Add documentation for Firehose Async Sink

Zichen Liu created FLINK-25737: -- Summary: Chinese Translation - Add documentation for Firehose Async Sink Key: FLINK-25737 URL: https://issues.apache.org/jira/browse/FLINK-25737 Project: Flink