[jira] [Created] (FLINK-24640) CEIL, FLOOR built-in functions for Timestamp should respect DST

2021-10-25 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-24640: --- Summary: CEIL, FLOOR built-in functions for Timestamp should respect DST Key: FLINK-24640 URL: https://issues.apache.org/jira/browse/FLINK-24640 Project: Flink

Re: [Discuss] Planning Flink 1.15

2021-10-25 Thread Israel Ekpo
Thanks for the update, Joe. Looking forward to this release. On Mon, Oct 25, 2021 at 11:13 AM Johannes Moser wrote: > Hi all, > > As people have already started working on their 1.15. > contribution, we'd like to start the discussion for > the release setup. > > - Release managers: As a team of

Re: [NOTICE] flink-streaming-java no longer depends on Scala and lost it's suffix

2021-10-25 Thread Chesnay Schepler
This time with proper formatting... flink-batch-sql-test flink-cep flink-cli-test flink-clients flink-connector-elasticsearch-base flink-connector-elasticsearch5 flink-connector-elasticsearch6 flink-connector-elasticsearch7 flink-connector-gcp-pubsub flink-connector-hbase-1.4 flink-connector-hbas

[NOTICE] flink-streaming-java no longer depends on Scala and lost it's suffix

2021-10-25 Thread Chesnay Schepler
Hello all, I just wanted to inform everyone that I just merged https://issues.apache.org/jira/browse/FLINK-24018, removing the transitive Scala dependencies from flink-streaming-java. This also means that the module lost it's Scala suffix, along with a lot of other modules. Please keep this

[jira] [Created] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

2021-10-25 Thread John Karp (Jira)
John Karp created FLINK-24639: - Summary: Improve assignment of Kinesis shards to subtasks Key: FLINK-24639 URL: https://issues.apache.org/jira/browse/FLINK-24639 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-24638) Unknown variable or type "org.apache.flink.table.utils.DateTimeUtils"

2021-10-25 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-24638: --- Summary: Unknown variable or type "org.apache.flink.table.utils.DateTimeUtils" Key: FLINK-24638 URL: https://issues.apache.org/jira/browse/FLINK-24638 Project:

[jira] [Created] (FLINK-24637) Move savepoint disposal operation cache into Dispatcher

2021-10-25 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24637: Summary: Move savepoint disposal operation cache into Dispatcher Key: FLINK-24637 URL: https://issues.apache.org/jira/browse/FLINK-24637 Project: Flink

[jira] [Created] (FLINK-24636) Move cluster deletion operation cache into ResourceManager

2021-10-25 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24636: Summary: Move cluster deletion operation cache into ResourceManager Key: FLINK-24636 URL: https://issues.apache.org/jira/browse/FLINK-24636 Project: Flink

[jira] [Created] (FLINK-24635) Clean up flink-examples

2021-10-25 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-24635: Summary: Clean up flink-examples Key: FLINK-24635 URL: https://issues.apache.org/jira/browse/FLINK-24635 Project: Flink Issue Type: Improvement Com

[Discuss] Planning Flink 1.15

2021-10-25 Thread Johannes Moser
Hi all, As people have already started working on their 1.15. contribution, we'd like to start the discussion for the release setup. - Release managers: As a team of three seems to have worked perfectly fine, we'd like to suggest Till, Yun Gao & Joe as the release managers for 1.15. - Timeline

[jira] [Created] (FLINK-24634) Java 11 profile should target JDK 8

2021-10-25 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24634: Summary: Java 11 profile should target JDK 8 Key: FLINK-24634 URL: https://issues.apache.org/jira/browse/FLINK-24634 Project: Flink Issue Type: Techn

[jira] [Created] (FLINK-24633) JobManager pod may stuck in containerCreating status during failover

2021-10-25 Thread Aitozi (Jira)
Aitozi created FLINK-24633: -- Summary: JobManager pod may stuck in containerCreating status during failover Key: FLINK-24633 URL: https://issues.apache.org/jira/browse/FLINK-24633 Project: Flink Iss

[jira] [Created] (FLINK-24632) "where ... in(..)" has wrong result

2021-10-25 Thread xuyang (Jira)
xuyang created FLINK-24632: -- Summary: "where ... in(..)" has wrong result Key: FLINK-24632 URL: https://issues.apache.org/jira/browse/FLINK-24632 Project: Flink Issue Type: Bug Reporter:

[jira] [Created] (FLINK-24631) Avoiding directly use the labels as selector for deployment and service

2021-10-25 Thread Aitozi (Jira)
Aitozi created FLINK-24631: -- Summary: Avoiding directly use the labels as selector for deployment and service Key: FLINK-24631 URL: https://issues.apache.org/jira/browse/FLINK-24631 Project: Flink

Re: [VOTE] FLIP-176: Unified Iteration to Support Algorithms (Flink ML)

2021-10-25 Thread Becket Qin
+1 (binding) Thanks for the FLIP. Jiangjie (Becket) Qin On Mon, Oct 25, 2021 at 4:45 PM Yunfeng Zhou wrote: > Sorry that I misunderstood the usage of "binding". I am not a Flink > committer so my vote should be a non-binding one. > > Best, > Yunfeng > > On Mon, Oct 25, 2021 at 4:33 PM Yunfeng

[jira] [Created] (FLINK-24630) Implement row projection in AvroToRowDataConverters#createRowConverter

2021-10-25 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-24630: --- Summary: Implement row projection in AvroToRowDataConverters#createRowConverter Key: FLINK-24630 URL: https://issues.apache.org/jira/browse/FLINK-24630 Project: Flink

Re: [VOTE] FLIP-176: Unified Iteration to Support Algorithms (Flink ML)

2021-10-25 Thread Yunfeng Zhou
Sorry that I misunderstood the usage of "binding". I am not a Flink committer so my vote should be a non-binding one. Best, Yunfeng On Mon, Oct 25, 2021 at 4:33 PM Yunfeng Zhou wrote: > Excellent work to support iteration for Flink. > > +1 (binding) > > Best regards, > Yunfeng > > On Sat, Oct 2

Re: [VOTE] FLIP-176: Unified Iteration to Support Algorithms (Flink ML)

2021-10-25 Thread Yunfeng Zhou
Excellent work to support iteration for Flink. +1 (binding) Best regards, Yunfeng On Sat, Oct 23, 2021 at 12:27 AM Till Rohrmann wrote: > Thanks for creating this FLIP. > > +1 (binding) > > Cheers, > Till > > > On Fri, Oct 22, 2021 at 6:29 AM Guowei Ma wrote: > > > +1 (binding) > > > > Best,

[jira] [Created] (FLINK-24629) Sorting start-time/duration/end-time not working under pages of vertex taskManagers and sub-tasks

2021-10-25 Thread Junhan Yang (Jira)
Junhan Yang created FLINK-24629: --- Summary: Sorting start-time/duration/end-time not working under pages of vertex taskManagers and sub-tasks Key: FLINK-24629 URL: https://issues.apache.org/jira/browse/FLINK-24629

Re: [DISCUSS] Should we drop Row SerializationSchema/DeserializationSchema?

2021-10-25 Thread Francesco Guardiani
Last remainder: unless there are any objections, I will proceed with deprecating these by the end of the week. On Thu, Oct 21, 2021 at 4:28 PM Konstantin Knauf wrote: > +1 for deprecating and then dropping them. > > On Thu, Oct 21, 2021 at 3:31 PM Timo Walther wrote: > > > Hi Francesco, > > > >

[jira] [Created] (FLINK-24628) Invalid JDBC query template when no fields are selected

2021-10-25 Thread Paul Lin (Jira)
Paul Lin created FLINK-24628: Summary: Invalid JDBC query template when no fields are selected Key: FLINK-24628 URL: https://issues.apache.org/jira/browse/FLINK-24628 Project: Flink Issue Type: B

Re: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage

2021-10-25 Thread Jingsong Li
Hi Ingo, Really appreciate your feedback. #1. The reason why we insist on using no "connector" option is that we want to bring the following design to users: - With the "connector" option, it is a mapping, unmanaged table. - Without the "connector" option, it is a managed table. It may be an Iceb