[jira] [Created] (FLINK-27713) Bump Apache Beam to 2.40.0

LuNng Wang created FLINK-27713: -- Summary: Bump Apache Beam to 2.40.0 Key: FLINK-27713 URL: https://issues.apache.org/jira/browse/FLINK-27713 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-27714) Migrate to java-operator-sdk v3

Matyas Orhidi created FLINK-27714: - Summary: Migrate to java-operator-sdk v3 Key: FLINK-27714 URL: https://issues.apache.org/jira/browse/FLINK-27714 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27715) Add more Python ML examples

Huang Xingbo created FLINK-27715: Summary: Add more Python ML examples Key: FLINK-27715 URL: https://issues.apache.org/jira/browse/FLINK-27715 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-27716) Add Python API docs in ML

Huang Xingbo created FLINK-27716: Summary: Add Python API docs in ML Key: FLINK-27716 URL: https://issues.apache.org/jira/browse/FLINK-27716 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-27717) Document operator compatibility guarantees

Gyula Fora created FLINK-27717: -- Summary: Document operator compatibility guarantees Key: FLINK-27717 URL: https://issues.apache.org/jira/browse/FLINK-27717 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-27718) Hive dialect supports to count mutiple fields

luoyuxia created FLINK-27718: Summary: Hive dialect supports to count mutiple fields Key: FLINK-27718 URL: https://issues.apache.org/jira/browse/FLINK-27718 Project: Flink Issue Type: Sub-task

[DISCUSS] Update Scala 2.12.7 to 2.12.15

Hi everyone, I would like to get some opinions from our Scala users, therefore I'm also looping in the user mailing list. Flink currently is tied to Scala 2.12.7. As outlined in FLINK-12461 [1] there is a binary incompatibility introduced by Scala 2.12.8, which currently limits Flink from upgradi

Flatmap node at 100%

Hi, Im seeing this behaviour in my flink job, what can I do to remove this bottleneck [image: image.png]

Re: [VOTE] Creating an Apache Flink slack workspace

And here's my own +1 (binding). Thanks everyone for voting. The vote has been open for 72h+ and is closed now. I'll conclude the result in a separate email. Best, Xintong On Thu, May 19, 2022 at 9:37 PM Roc Marshal wrote: > +1. (non-binding.) > > > Best Regards > > Roc. > > > At 2022-05-17

Re: [DISCUSS] FLIP-224: Blacklist Mechanism

I have a number of concerns: Is the id used for deleting an item the same sent in the initial request (and not one returned by Flink)? I'm very concerned that the tm/node id can contain special characters. The GET query should return a map, not a list of items. This makes it easier to work wi

[jira] [Created] (FLINK-27719) Create Apache Flink slack workspace

Xintong Song created FLINK-27719: Summary: Create Apache Flink slack workspace Key: FLINK-27719 URL: https://issues.apache.org/jira/browse/FLINK-27719 Project: Flink Issue Type: Improvement

[RESULT][VOTE] Creating an Apache Flink slack workspace

Hi everyone, The proposal of creating an Apache Flink slack workspace has been approved. [1] There are 19 approving votes, 11 of which are binding. - Jark Wu (binding) - Robert Metzger (binding) - Yu Li (binding) - Martijn Visser (non-binding) - Jingsong Li (non-binding) - Márton Balassi (bindin

[jira] [Created] (FLINK-27720) Slack: Update the project website regarding communication channels

Xintong Song created FLINK-27720: Summary: Slack: Update the project website regarding communication channels Key: FLINK-27720 URL: https://issues.apache.org/jira/browse/FLINK-27720 Project: Flink

[jira] [Created] (FLINK-27721) Slack: set up archive

Xintong Song created FLINK-27721: Summary: Slack: set up archive Key: FLINK-27721 URL: https://issues.apache.org/jira/browse/FLINK-27721 Project: Flink Issue Type: Sub-task Report

[jira] [Created] (FLINK-27722) Slack: set up auto-updated invitation link

Xintong Song created FLINK-27722: Summary: Slack: set up auto-updated invitation link Key: FLINK-27722 URL: https://issues.apache.org/jira/browse/FLINK-27722 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-27723) Slack: revisit how this communication channel works

Xintong Song created FLINK-27723: Summary: Slack: revisit how this communication channel works Key: FLINK-27723 URL: https://issues.apache.org/jira/browse/FLINK-27723 Project: Flink Issue Typ

[jira] [Created] (FLINK-27724) The SubtaskCheckpointCoordinatorImpl#close() isn't called in anywhere

fanrui created FLINK-27724: -- Summary: The SubtaskCheckpointCoordinatorImpl#close() isn't called in anywhere Key: FLINK-27724 URL: https://issues.apache.org/jira/browse/FLINK-27724 Project: Flink Is

Re: [DISCUSS] Update Scala 2.12.7 to 2.12.15

As a Scala API user I'd prefer a breaking change to get all the benefits of the latest Scala minor versions. On Fri, May 20, 2022, 11:37 Martijn Visser wrote: > Hi everyone, > > I would like to get some opinions from our Scala users, therefore I'm also > looping in the user mailing list. > > Fli

Re: [DISCUSS] Update Scala 2.12.7 to 2.12.15

Hi, Martijn. Even if we upgrade scala to 2.12.15 to support Java17, it just fix the compilation of FLINK-25000 . There is another problem[1] that Scala <=2.13 can't generate jvm11 or higher bytecode version. The flink project target class bytecod

Re: [DISCUSS] Update Scala 2.12.7 to 2.12.15

It's not necessarily required that the scala byte code matches the version of the java byte code. By and large such inconsistencies are inevitable w.r.t. external libraries. On 20/05/2022 12:23, Ran Tao wrote: Hi, Martijn. Even if we upgrade scala to 2.12.15 to support Java17, it just fix the

Re: [DISCUSS] Update Scala 2.12.7 to 2.12.15

Got it. But I think the runtime java environment e.g. jdk11 env may cannot optimize these scala lower bytecode very well. However currently no direct report show this problem. hah~ Chesnay Schepler 于2022年5月20日 周五19:53写道： > It's not necessarily required that the scala byte code matches the > ver

[jira] [Created] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table

Alexander Preuss created FLINK-27725: Summary: Create tests for TypeInformation and TypeSerializer classes in table Key: FLINK-27725 URL: https://issues.apache.org/jira/browse/FLINK-27725 Project:

Re: [VOTE] FLIP-91: Support SQL Gateway

+1 (non-binding) Best, Yufei Zhang On Fri, May 20, 2022 at 11:24 AM Paul Lam wrote: > +1 (non-binding) > > Best, > Paul Lam > > > 2022年5月20日 10:48，Jark Wu 写道： > > > > +1 (binding) > > > > Best, > > Jark > > > > On Fri, 20 May 2022 at 10:39, Shengkai Fang wrote: > > > >> Hi, everyone. > >> > >

Re: [VOTE] FLIP-91: Support SQL Gateway

+1 (non-binding) Best, Shqiprim Bunjaku On Fri, May 20, 2022 at 5:56 PM Yufei Zhang wrote: > +1 (non-binding) > > Best, > Yufei Zhang > > On Fri, May 20, 2022 at 11:24 AM Paul Lam wrote: > > > +1 (non-binding) > > > > Best, > > Paul Lam > > > > > 2022年5月20日 10:48，Jark Wu 写道： > > > > > > +1 (b

[jira] [Created] (FLINK-27726) shad thrift and fb303 in hive connector

Chen Qin created FLINK-27726: Summary: shad thrift and fb303 in hive connector Key: FLINK-27726 URL: https://issues.apache.org/jira/browse/FLINK-27726 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27727) [JUnit5 Migration] Migrate TypeSerializerUpgradeTestBase to Junit5

Sergey Nuyanzin created FLINK-27727: --- Summary: [JUnit5 Migration] Migrate TypeSerializerUpgradeTestBase to Junit5 Key: FLINK-27727 URL: https://issues.apache.org/jira/browse/FLINK-27727 Project: Fli

[jira] [Created] (FLINK-27728) dockerFile build results in five vulnerabilities

James Busche created FLINK-27728: Summary: dockerFile build results in five vulnerabilities Key: FLINK-27728 URL: https://issues.apache.org/jira/browse/FLINK-27728 Project: Flink Issue Type: