[jira] [Created] (FLINK-22170) Manual test for hive dialect

2021-04-08 Thread Rui Li (Jira)
Rui Li created FLINK-22170: -- Summary: Manual test for hive dialect Key: FLINK-22170 URL: https://issues.apache.org/jira/browse/FLINK-22170 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-22169) Beautify the CliTableauResultView when print

2021-04-08 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22169: - Summary: Beautify the CliTableauResultView when print Key: FLINK-22169 URL: https://issues.apache.org/jira/browse/FLINK-22169 Project: Flink Issue Type:

[jira] [Created] (FLINK-22168) Partition insert with union all will fail

2021-04-08 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-22168: Summary: Partition insert with union all will fail Key: FLINK-22168 URL: https://issues.apache.org/jira/browse/FLINK-22168 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22166) Empty values with sort willl fail

2021-04-08 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-22166: Summary: Empty values with sort willl fail Key: FLINK-22166 URL: https://issues.apache.org/jira/browse/FLINK-22166 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22167) Partial insert not works when complex fields reorder

2021-04-08 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-22167: Summary: Partial insert not works when complex fields reorder Key: FLINK-22167 URL: https://issues.apache.org/jira/browse/FLINK-22167 Project: Flink Issue

[jira] [Created] (FLINK-22165) How to set rabbitmq correlationId when using rabbitmq sink in dataStreamEnv

2021-04-08 Thread Spongebob (Jira)
Spongebob created FLINK-22165: - Summary: How to set rabbitmq correlationId when using rabbitmq sink in dataStreamEnv Key: FLINK-22165 URL: https://issues.apache.org/jira/browse/FLINK-22165 Project: Flink

[jira] [Created] (FLINK-22164) Add jobId and JobName variable to JobManager metrics in per-job deployment mode

2021-04-08 Thread Lu Niu (Jira)
Lu Niu created FLINK-22164: -- Summary: Add jobId and JobName variable to JobManager metrics in per-job deployment mode Key: FLINK-22164 URL: https://issues.apache.org/jira/browse/FLINK-22164 Project: Flink

Flink does not cleanup some disk memory after submitting jar over rest

2021-04-08 Thread Great Info
I have deployed my own flink setup in AWS ECS. One Service for JobManager and one Service for task Managers. I am running one ECS task for a job manager and 3 ecs tasks for TASK managers. I have a kind of batch job which I upload using flink rest every-day with changing new arguments, when I

[jira] [Created] (FLINK-22163) DataTypes implementation for flink-csv with ZonedDateTime support

2021-04-08 Thread Jira
François Lacombe created FLINK-22163: Summary: DataTypes implementation for flink-csv with ZonedDateTime support Key: FLINK-22163 URL: https://issues.apache.org/jira/browse/FLINK-22163 Project:

[jira] [Created] (FLINK-22162) Make Max Operator name Length Configurable

2021-04-08 Thread Lu Niu (Jira)
Lu Niu created FLINK-22162: -- Summary: Make Max Operator name Length Configurable Key: FLINK-22162 URL: https://issues.apache.org/jira/browse/FLINK-22162 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22161) 'Run Mesos WordCount test' failed on Azure

2021-04-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-22161: --- Summary: 'Run Mesos WordCount test' failed on Azure Key: FLINK-22161 URL: https://issues.apache.org/jira/browse/FLINK-22161 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22160) Test Window TVF based aggregation and TopN

2021-04-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-22160: --- Summary: Test Window TVF based aggregation and TopN Key: FLINK-22160 URL: https://issues.apache.org/jira/browse/FLINK-22160 Project: Flink Issue Type: Test

Dev process: testing one suite only (and are our docs suggesting Java 8 accurate?)

2021-04-08 Thread Adam Roberts
Hey everyone, I'm looking to get the full set of unit tests working using AdoptOpenJDK 11 with the OpenJ9 VM and I'm basically seeing problems with the runtime tests (always going OoM creating new threads) and I'd also like to have a go at https://issues.apache.org/jira/browse/FLINK-21672. That

[jira] [Created] (FLINK-22159) Add documentation for the new window TVF based operations

2021-04-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-22159: --- Summary: Add documentation for the new window TVF based operations Key: FLINK-22159 URL: https://issues.apache.org/jira/browse/FLINK-22159 Project: Flink Issue Type:

[jira] [Created] (FLINK-22158) Test native Kubernetes pod template

2021-04-08 Thread Yang Wang (Jira)
Yang Wang created FLINK-22158: - Summary: Test native Kubernetes pod template Key: FLINK-22158 URL: https://issues.apache.org/jira/browse/FLINK-22158 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-22157) Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException

2021-04-08 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-22157: --- Summary: Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException Key: FLINK-22157 URL: https://issues.apache.org/jira/browse/FLINK-22157

[jira] [Created] (FLINK-22156) HiveDialectQueryITCase fails on Azure because of no output for 900 seconds

2021-04-08 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-22156: --- Summary: HiveDialectQueryITCase fails on Azure because of no output for 900 seconds Key: FLINK-22156 URL: https://issues.apache.org/jira/browse/FLINK-22156 Project:

[jira] [Created] (FLINK-22155) Fix EXPLAIN implementation

2021-04-08 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22155: - Summary: Fix EXPLAIN implementation Key: FLINK-22155 URL: https://issues.apache.org/jira/browse/FLINK-22155 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22154) PushFilterIntoTableSourceScanRule fails to deal with IN expressions

2021-04-08 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-22154: --- Summary: PushFilterIntoTableSourceScanRule fails to deal with IN expressions Key: FLINK-22154 URL: https://issues.apache.org/jira/browse/FLINK-22154 Project: Flink

[jira] [Created] (FLINK-22153) Manually test the sort-merge blocking shuffle

2021-04-08 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-22153: --- Summary: Manually test the sort-merge blocking shuffle Key: FLINK-22153 URL: https://issues.apache.org/jira/browse/FLINK-22153 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-22152) Fix the bug of same timers are registered multiple times

2021-04-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-22152: Summary: Fix the bug of same timers are registered multiple times Key: FLINK-22152 URL: https://issues.apache.org/jira/browse/FLINK-22152 Project: Flink

Re: [DISCUSS] Backport FLIP-27 Kafka source connector fixes with API change to release-1.12.

2021-04-08 Thread Becket Qin
Hi Arvid, There are interface changes to the Kafka source, and there is a backwards compatible change in the base source implementation. Therefore technically speaking, users might be able to run the Kafka source in 1.13 with a 1.12 Flink job. However, it could be tricky because there might be

[jira] [Created] (FLINK-22151) Implement type inference for agg functions

2021-04-08 Thread Timo Walther (Jira)
Timo Walther created FLINK-22151: Summary: Implement type inference for agg functions Key: FLINK-22151 URL: https://issues.apache.org/jira/browse/FLINK-22151 Project: Flink Issue Type:

Re: Zigzag shape in TM JVM used memory

2021-04-08 Thread Piotr Nowojski
Hi, I don't think there is a Flink specific answer to this question. Just do what you would normally do with a normal Java application running inside a JVM. If there is an OOM on heap space, you can either try to bump the heap space, or reduce usage of it. The only Flink specific part is probably

[jira] [Created] (FLINK-22150) Test user-defined window in Python DataStream API

2021-04-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-22150: Summary: Test user-defined window in Python DataStream API Key: FLINK-22150 URL: https://issues.apache.org/jira/browse/FLINK-22150 Project: Flink Issue

[jira] [Created] (FLINK-22149) Test Python UDAF in Group Window

2021-04-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-22149: Summary: Test Python UDAF in Group Window Key: FLINK-22149 URL: https://issues.apache.org/jira/browse/FLINK-22149 Project: Flink Issue Type: Test

Re: [VOTE] Apache Flink Stateful Functions 3.0.0, release candidate #1

2021-04-08 Thread Tzu-Li (Gordon) Tai
Thanks for voting and testing everyone! We have a total of 6 +1 votes, 3 of which are binding: - Igal Shilman - Gordon Tai (binding) - Konstantin Knauf - Seth Wiesman - Yu Li (binding) - Robert Metzger (binding) I'll proceed now with finalizing the release of StateFun 3.0.0. The official

[jira] [Created] (FLINK-22148) Planner rules should use RexCall#equsls to check whether two rexCalls are equivalent

2021-04-08 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-22148: -- Summary: Planner rules should use RexCall#equsls to check whether two rexCalls are equivalent Key: FLINK-22148 URL: https://issues.apache.org/jira/browse/FLINK-22148

Re: [DISCUSS] Backport FLIP-27 Kafka source connector fixes with API change to release-1.12.

2021-04-08 Thread Arvid Heise
Hi Becket, did you need to change anything to the source interface itself? Wouldn't it be possible for users to simply use the 1.13 connector with their Flink 1.12 deployment? I think the late-upgrade argument can be made for any feature, but I also see that the Kafka connector is of high