[jira] [Updated] (FLINK-20637) Table convert to dataStream twice will result in two data streams

2020-12-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-20637: - Parent: FLINK-19976 Issue Type: Sub-task (was: Improvement) > Table convert to

[jira] [Closed] (FLINK-20626) Canceling a job when it is failing will result in job hanging in CANCELING state

2020-12-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-20626. --- Resolution: Fixed Fixed via master: 58cc2a5fbd419d6a9e4f9c251ac01ecf59a8c5a2 release-1.12:

[GitHub] [flink] zhisheng17 commented on pull request #14365: [hotfix][filesystem]improve the filesystem connector doc

2020-12-16 Thread GitBox
zhisheng17 commented on pull request #14365: URL: https://github.com/apache/flink/pull/14365#issuecomment-747275195 @leonardBang thanks, i have rebase and squash the commit This is an automated message from the Apache Git

[jira] [Commented] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode

2020-12-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250874#comment-17250874 ] Yang Wang commented on FLINK-20617: --- [~Georger] Thanks for your verification. I believe it is a

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

2020-12-16 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[GitHub] [flink] rkhachatryan commented on a change in pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-12-16 Thread GitBox
rkhachatryan commented on a change in pull request #14057: URL: https://github.com/apache/flink/pull/14057#discussion_r544876522 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/AlternatingControllerTest.java ## @@ -84,6 +84,24 @@ public

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

2020-12-16 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

2020-12-16 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Attachment: jstack > flink-connector-elasticsearch6 will deadlock >

[jira] [Comment Edited] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Xiao Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250826#comment-17250826 ] Xiao Cai edited comment on FLINK-19880 at 12/17/20, 7:39 AM: - Hi [~jark] ,I

[jira] [Comment Edited] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Xiao Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250826#comment-17250826 ] Xiao Cai edited comment on FLINK-19880 at 12/17/20, 7:39 AM: - Hi [~jark] ,I

[jira] [Commented] (FLINK-20612) Add benchmarks for scheduler

2020-12-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250863#comment-17250863 ] Zhu Zhu commented on FLINK-20612: - Thanks for proposing this [~Thesharing] and sharing the statistics.

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

2020-12-16 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Commented] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

2020-12-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250861#comment-17250861 ] Piotr Nowojski commented on FLINK-20618: Thanks for the extra explanation [~zlzhang0122]. Could

[GitHub] [flink] rkhachatryan commented on a change in pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-12-16 Thread GitBox
rkhachatryan commented on a change in pull request #14057: URL: https://github.com/apache/flink/pull/14057#discussion_r544868039 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/AlternatingControllerTest.java ## @@ -68,6 +68,22 @@ */

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

2020-12-16 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

2020-12-16 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink version: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[jira] [Updated] (FLINK-20642) Introduce InternalRow to optimize Row used in Python UDAF

2020-12-16 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-20642: - Component/s: API / Python > Introduce InternalRow to optimize Row used in Python UDAF >

[jira] [Updated] (FLINK-20642) Introduce InternalRow to optimize Row used in Python UDAF

2020-12-16 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-20642: - Fix Version/s: 1.13.0 > Introduce InternalRow to optimize Row used in Python UDAF >

[jira] [Created] (FLINK-20642) Introduce InternalRow to optimize Row used in Python UDAF

2020-12-16 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20642: Summary: Introduce InternalRow to optimize Row used in Python UDAF Key: FLINK-20642 URL: https://issues.apache.org/jira/browse/FLINK-20642 Project: Flink

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

2020-12-16 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee updated FLINK-20641: - Description: flink vision: 1.11.1 elasticsearch connector version: 6.3.1 My job graph is

[GitHub] [flink] rkhachatryan commented on a change in pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-12-16 Thread GitBox
rkhachatryan commented on a change in pull request #14057: URL: https://github.com/apache/flink/pull/14057#discussion_r544865125 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -451,11 +451,20 @@

[GitHub] [flink-web] leonardBang opened a new pull request #401: Fix the broken Getting-started link of flink project

2020-12-16 Thread GitBox
leonardBang opened a new pull request #401: URL: https://github.com/apache/flink-web/pull/401 # change: the link https://ci.apache.org/projects/flink/flink-docs-release-1.12/getting-started/index.html is broken update the link to

[jira] [Created] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

2020-12-16 Thread Echo Lee (Jira)
Echo Lee created FLINK-20641: Summary: flink-connector-elasticsearch6 will deadlock Key: FLINK-20641 URL: https://issues.apache.org/jira/browse/FLINK-20641 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20640) Use cython to optimize the logic of Python UDAF

2020-12-16 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20640: Summary: Use cython to optimize the logic of Python UDAF Key: FLINK-20640 URL: https://issues.apache.org/jira/browse/FLINK-20640 Project: Flink Issue Type:

[jira] [Created] (FLINK-20639) Use list to optimize the Row used by Python UDAF intermediate results

2020-12-16 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20639: Summary: Use list to optimize the Row used by Python UDAF intermediate results Key: FLINK-20639 URL: https://issues.apache.org/jira/browse/FLINK-20639 Project: Flink

[jira] [Commented] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode

2020-12-16 Thread Georger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250851#comment-17250851 ] Georger commented on FLINK-20617: - [~fly_in_gis]  I has try , it works ,but it looks so weird ... >

[jira] [Commented] (FLINK-20557) Support statement set in SQL CLI

2020-12-16 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250836#comment-17250836 ] Fangliang Liu commented on FLINK-20557: --- [~jark] OK, thanks for your reply. > Support statement

[jira] [Commented] (FLINK-20638) Flink hive modules Function with the same name bug

2020-12-16 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250829#comment-17250829 ] HideOnBush commented on FLINK-20638: When there are two objects of the same name residing in two

[GitHub] [flink-docker] xintongsong opened a new pull request #48: Update Dockerfiles for 1.11.3 release

2020-12-16 Thread GitBox
xintongsong opened a new pull request #48: URL: https://github.com/apache/flink-docker/pull/48 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] HuangXingBo commented on a change in pull request #14401: [FLINK-20621][python] Refactor the TypeInformation implementation in Python DataStream API.

2020-12-16 Thread GitBox
HuangXingBo commented on a change in pull request #14401: URL: https://github.com/apache/flink/pull/14401#discussion_r544789178 ## File path: flink-python/pyflink/common/typeinfo.py ## @@ -91,66 +73,117 @@ def from_internal_type(self, obj): return obj -class

[jira] [Comment Edited] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Xiao Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250826#comment-17250826 ] Xiao Cai edited comment on FLINK-19880 at 12/17/20, 6:38 AM: - Hi [~jark] ,I

[jira] [Commented] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Xiao Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250826#comment-17250826 ] Xiao Cai commented on FLINK-19880: -- Hi [~jark] ,I found that there are two places to fix, one is to add

[jira] [Created] (FLINK-20638) Flink hive modules Function with the same name bug

2020-12-16 Thread HideOnBush (Jira)
HideOnBush created FLINK-20638: -- Summary: Flink hive modules Function with the same name bug Key: FLINK-20638 URL: https://issues.apache.org/jira/browse/FLINK-20638 Project: Flink Issue Type:

[GitHub] [flink-docker] xintongsong opened a new pull request #47: release 1.11.3

2020-12-16 Thread GitBox
xintongsong opened a new pull request #47: URL: https://github.com/apache/flink-docker/pull/47 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-20632) Missing docker images for 1.12 release

2020-12-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20632: --- Priority: Critical (was: Major) > Missing docker images for 1.12 release >

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

2020-12-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250824#comment-17250824 ] Robert Metzger commented on FLINK-20632: As a temporary workaround, you can build the docker

[jira] [Commented] (FLINK-20631) cannot find native-k8s when deploying flink using native kubernetes

2020-12-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250822#comment-17250822 ] Yang Wang commented on FLINK-20631: --- It seems that you are using the image for 1.11. Could you please

[jira] [Updated] (FLINK-20582) Fix typos in `CREATE Statements` docs

2020-12-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20582: Component/s: Table SQL / Ecosystem > Fix typos in `CREATE Statements` docs >

[jira] [Commented] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode

2020-12-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250821#comment-17250821 ] Yang Wang commented on FLINK-20617: --- [~Georger] Do you have a test via adding 

[jira] [Updated] (FLINK-20632) Missing docker images for 1.12 release

2020-12-16 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20632: --- Summary: Missing docker images for 1.12 release (was: Missing docker images for 1.12

[jira] [Created] (FLINK-20637) Table convert to dataStream twice will result in two data streams

2020-12-16 Thread Wu (Jira)
Wu created FLINK-20637: -- Summary: Table convert to dataStream twice will result in two data streams Key: FLINK-20637 URL: https://issues.apache.org/jira/browse/FLINK-20637 Project: Flink Issue Type:

[jira] [Updated] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19880: Component/s: Table SQL / Ecosystem > flink-json The validation and incoming parameters do not match >

[jira] [Updated] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19880: Labels: starter (was: flink-json format.ignore-parse-errors) > flink-json The validation and incoming

[jira] [Commented] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250816#comment-17250816 ] Jark Wu commented on FLINK-19880: - The problem lies in the

[GitHub] [flink] zhuzhurk commented on a change in pull request #13883: [FLINK-19920][runtime] Remove legacy failover strategy

2020-12-16 Thread GitBox
zhuzhurk commented on a change in pull request #13883: URL: https://github.com/apache/flink/pull/13883#discussion_r544827551 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java ## @@ -49,7 +49,7 @@ import

[jira] [Updated] (FLINK-18775) Rework PyFlink Documentation

2020-12-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18775: Fix Version/s: (was: 1.11.4) > Rework PyFlink Documentation > > >

[jira] [Closed] (FLINK-18775) Rework PyFlink Documentation

2020-12-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18775. --- Fix Version/s: (was: 1.13.0) 1.12.0 Resolution: Fixed > Rework PyFlink

[jira] [Commented] (FLINK-18932) Add a "Overview" document under the "Python API" section

2020-12-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250812#comment-17250812 ] Dian Fu commented on FLINK-18932: - I'm closing this JIRA as it should be have already been covered in

[jira] [Closed] (FLINK-18932) Add a "Overview" document under the "Python API" section

2020-12-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18932. --- Resolution: Duplicate > Add a "Overview" document under the "Python API" section >

[jira] [Updated] (FLINK-18775) Rework PyFlink Documentation

2020-12-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18775: - Fix Version/s: (was: 1.11.3) 1.11.4 > Rework PyFlink Documentation >

[jira] [Updated] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

2020-12-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20412: - Fix Version/s: (was: 1.11.3) 1.11.4 > Collect Result Fetching

[jira] [Updated] (FLINK-20537) Failed to call Hive UDF with string literal arguments

2020-12-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20537: - Fix Version/s: (was: 1.11.3) 1.11.4 > Failed to call Hive UDF with

[jira] [Updated] (FLINK-15018) Add event time page to Concepts

2020-12-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15018: - Fix Version/s: (was: 1.11.3) 1.11.4 > Add event time page to Concepts >

[GitHub] [flink] bytesmithing commented on pull request #14014: [FLINK-10274][flink-core]Add `env.pid.dir` configuration to CoreOptions

2020-12-16 Thread GitBox
bytesmithing commented on pull request #14014: URL: https://github.com/apache/flink/pull/14014#issuecomment-747214461 Thanks god, I finished the project building and regenerated the doc. Please take a look. @zentol This is

[GitHub] [flink] bytesmithing commented on a change in pull request #14014: [FLINK-10274][flink-core]Add `env.pid.dir` configuration to CoreOptions

2020-12-16 Thread GitBox
bytesmithing commented on a change in pull request #14014: URL: https://github.com/apache/flink/pull/14014#discussion_r544821737 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java ## @@ -218,6 +218,17 @@

[jira] [Updated] (FLINK-20636) Require unaligned checkpoints to be disabled in StateFun applications

2020-12-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20636: --- Labels: pull-request-available (was: ) > Require unaligned checkpoints to be disabled in

[GitHub] [flink-statefun] tzulitai opened a new pull request #187: [FLINK-20636] Validate that unaligned checkpoints is not enabled

2020-12-16 Thread GitBox
tzulitai opened a new pull request #187: URL: https://github.com/apache/flink-statefun/pull/187 Due to how StateFun has feedback loops, with unaligned checkpoints a function dispatcher operator may receive a feedback checkpoint barrier (from other parallel subtasks that process the

[jira] [Created] (FLINK-20636) Require unaligned checkpoints to be disabled in StateFun applications

2020-12-16 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20636: --- Summary: Require unaligned checkpoints to be disabled in StateFun applications Key: FLINK-20636 URL: https://issues.apache.org/jira/browse/FLINK-20636

[jira] [Comment Edited] (FLINK-19612) Support CUMULATE window table function in planner

2020-12-16 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250797#comment-17250797 ] Suhan Mao edited comment on FLINK-19612 at 12/17/20, 4:18 AM: -- [~jark]  Hi,

[jira] [Comment Edited] (FLINK-19612) Support CUMULATE window table function in planner

2020-12-16 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250797#comment-17250797 ] Suhan Mao edited comment on FLINK-19612 at 12/17/20, 4:18 AM: -- [~jark]  Hi,

[jira] [Commented] (FLINK-19612) Support CUMULATE window table function in planner

2020-12-16 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250797#comment-17250797 ] Suhan Mao commented on FLINK-19612: --- [~jark]  Hi, I'm interested in how we implement this. Do you

[jira] [Comment Edited] (FLINK-20612) Add benchmarks for scheduler

2020-12-16 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250775#comment-17250775 ] Zhilong Hong edited comment on FLINK-20612 at 12/17/20, 3:38 AM: - Thank

[GitHub] [flink] Jiayi-Liao closed pull request #11480: [FLINK-16597] handle exception thrown from close method in OutputFormat

2020-12-16 Thread GitBox
Jiayi-Liao closed pull request #11480: URL: https://github.com/apache/flink/pull/11480 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Commented] (FLINK-20615) Local recovery and sticky scheduling end-to-end test timeout with "IOException: Stream Closed"

2020-12-16 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250777#comment-17250777 ] Huang Xingbo commented on FLINK-20615: --

[jira] [Commented] (FLINK-20612) Add benchmarks for scheduler

2020-12-16 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250775#comment-17250775 ] Zhilong Hong commented on FLINK-20612: -- Thank you for your reply, [~trohrmann]. We implemented two

[jira] [Updated] (FLINK-20616) Support row-based operation to accept user-defined function directly

2020-12-16 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-20616: - Description: Usage {code:java} @udf(result_type=DataTypes.ROW([DataTypes.FIELD("a",

[GitHub] [flink] flinkbot commented on pull request #14410: [FLINK-20616][python] Support row-based operation to accept user-defined function directly

2020-12-16 Thread GitBox
flinkbot commented on pull request #14410: URL: https://github.com/apache/flink/pull/14410#issuecomment-747180777 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-20616) Support row-based operation to accept user-defined function directly

2020-12-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20616: --- Labels: pull-request-available (was: ) > Support row-based operation to accept

[jira] [Comment Edited] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

2020-12-16 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250770#comment-17250770 ] zlzhang0122 edited comment on FLINK-20618 at 12/17/20, 3:24 AM: > the

[GitHub] [flink] HuangXingBo opened a new pull request #14410: [FLINK-20616][python] Support row-based operation to accept user-defined function directly

2020-12-16 Thread GitBox
HuangXingBo opened a new pull request #14410: URL: https://github.com/apache/flink/pull/14410 ## What is the purpose of the change *This pull request will support row-based operation to accept user-defined function directly* ## Verifying this change This change added

[jira] [Comment Edited] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

2020-12-16 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250770#comment-17250770 ] zlzhang0122 edited comment on FLINK-20618 at 12/17/20, 3:21 AM: > the

[jira] [Comment Edited] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

2020-12-16 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250770#comment-17250770 ] zlzhang0122 edited comment on FLINK-20618 at 12/17/20, 3:21 AM: > the

[jira] [Updated] (FLINK-20635) Scala REPL with java.lang.NoSuchMethod: Errorjava.lang.NoSuchMethodError

2020-12-16 Thread Lu Guoqing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu Guoqing updated FLINK-20635: --- Description: When I use Scala REPL shell with YARN mode, there will be an error occured, just like

[jira] [Created] (FLINK-20635) Scala REPL with java.lang.NoSuchMethod: Errorjava.lang.NoSuchMethodError

2020-12-16 Thread Lu Guoqing (Jira)
Lu Guoqing created FLINK-20635: -- Summary: Scala REPL with java.lang.NoSuchMethod: Errorjava.lang.NoSuchMethodError Key: FLINK-20635 URL: https://issues.apache.org/jira/browse/FLINK-20635 Project: Flink

[jira] [Commented] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

2020-12-16 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250770#comment-17250770 ] zlzhang0122 commented on FLINK-20618: - > the other task run well > > [~roman_khachatryan]  Could

[jira] [Updated] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

2020-12-16 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zlzhang0122 updated FLINK-20618: Attachment: (was: 2020-12-17 10-51-42 的屏幕截图.png) > Some of the source operator subtasks will

[jira] [Updated] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

2020-12-16 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zlzhang0122 updated FLINK-20618: Attachment: 2020-12-17 11-10-06 的屏幕截图.png > Some of the source operator subtasks will stuck when

[jira] [Updated] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

2020-12-16 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zlzhang0122 updated FLINK-20618: Attachment: 2020-12-17 10-51-42 的屏幕截图.png > Some of the source operator subtasks will stuck when

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

2020-12-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250768#comment-17250768 ] Zhu Zhu commented on FLINK-20254: - another instance:

[GitHub] [flink] zhuzhurk merged pull request #14405: [FLINK-20626][runtime] Fix issue of concurrent failing and cancelling of an ExecutionGraph

2020-12-16 Thread GitBox
zhuzhurk merged pull request #14405: URL: https://github.com/apache/flink/pull/14405 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Commented] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-12-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250767#comment-17250767 ] Zhu Zhu commented on FLINK-20389: - another instance:

[GitHub] [flink] zhuzhurk commented on pull request #14405: [FLINK-20626][runtime] Fix issue of concurrent failing and cancelling of an ExecutionGraph

2020-12-16 Thread GitBox
zhuzhurk commented on pull request #14405: URL: https://github.com/apache/flink/pull/14405#issuecomment-747173940 Thanks for reviewing @tillrohrmann The failed test UnalignedCheckpointITCase is a known and unrelated issue https://issues.apache.org/jira/browse/FLINK-20389. So will

[GitHub] [flink] flinkbot commented on pull request #14409: [FLINK-20634][dist] Remove start-scala-shell.sh in bin folder when co…

2020-12-16 Thread GitBox
flinkbot commented on pull request #14409: URL: https://github.com/apache/flink/pull/14409#issuecomment-747172309 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-20634) Flink with Scala 2.12 that scala shell is not supported still provides start-scala-shell.sh

2020-12-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20634: --- Labels: pull-request-available (was: ) > Flink with Scala 2.12 that scala shell is not

[jira] [Closed] (FLINK-20601) Rework PyFlink CLI documentation

2020-12-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20601. --- Resolution: Fixed Merged to - master via e3c7a5921db48400a8b19e6a8ce62cd24e473896 - release-1.12 via

[GitHub] [flink] paul8263 opened a new pull request #14409: [FLINK-20634][dist] Remove start-scala-shell.sh in bin folder when co…

2020-12-16 Thread GitBox
paul8263 opened a new pull request #14409: URL: https://github.com/apache/flink/pull/14409 …mpiled with profile scala-2.12 enabled ## What is the purpose of the change Flink scala shell does not work with Scala 2.12. But it still provides start-scala-shell.sh in bin

[GitHub] [flink] dianfu closed pull request #14367: [FLINK-20601][docs] Rework PyFlink CLI documentation.

2020-12-16 Thread GitBox
dianfu closed pull request #14367: URL: https://github.com/apache/flink/pull/14367 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode

2020-12-16 Thread Georger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Georger updated FLINK-20617: Attachment: taskmanager.out > Kafka Consumer Deserializer Exception on application mode >

[GitHub] [flink] dianfu commented on pull request #14367: [FLINK-20601][docs] Rework PyFlink CLI documentation.

2020-12-16 Thread GitBox
dianfu commented on pull request #14367: URL: https://github.com/apache/flink/pull/14367#issuecomment-747171025 I'm merging this PR as currently the documentation about how to submit PyFlink jobs is missing. @XComp Thanks again for the review.

[jira] [Commented] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode

2020-12-16 Thread Georger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250762#comment-17250762 ] Georger commented on FLINK-20617: - it seems the  org.apache.kafka.common.serialization.Deserializer has

[jira] [Commented] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode

2020-12-16 Thread Georger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250761#comment-17250761 ] Georger commented on FLINK-20617: - it seems not the problem , i have only use 

[jira] [Created] (FLINK-20634) Flink with Scala 2.12 that scala shell is not supported still provides start-scala-shell.sh

2020-12-16 Thread Yao Zhang (Jira)
Yao Zhang created FLINK-20634: - Summary: Flink with Scala 2.12 that scala shell is not supported still provides start-scala-shell.sh Key: FLINK-20634 URL: https://issues.apache.org/jira/browse/FLINK-20634

[jira] [Updated] (FLINK-20633) test_configuration.test_add_all test failed in py35

2020-12-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20633: Summary: test_configuration.test_add_all test failed in py35 (was: test_configuration. test_add_all test

[jira] [Created] (FLINK-20633) test_configuration. test_add_all test failed in py35

2020-12-16 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20633: Summary: test_configuration. test_add_all test failed in py35 Key: FLINK-20633 URL: https://issues.apache.org/jira/browse/FLINK-20633 Project: Flink Issue

[GitHub] [flink] jrthe42 commented on pull request #14404: [FLINK-20624][table-planner]Refactor StreamExecJoinRule, StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

2020-12-16 Thread GitBox
jrthe42 commented on pull request #14404: URL: https://github.com/apache/flink/pull/14404#issuecomment-747162076 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 releas

2020-12-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250747#comment-17250747 ] Dian Fu commented on FLINK-20632: - Oh, just found that [~xintongsong] has replied. Thanks a lot ~ >

[GitHub] [flink] shuiqiangchen commented on pull request #14401: [FLINK-20621][python] Refactor the TypeInformation implementation in Python DataStream API.

2020-12-16 Thread GitBox
shuiqiangchen commented on pull request #14401: URL: https://github.com/apache/flink/pull/14401#issuecomment-747157946 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-20529) Publish Dockerfiles for release 1.12.0

2020-12-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250744#comment-17250744 ] Dian Fu commented on FLINK-20529: - The PR for the docker image is still under view:

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 releas

2020-12-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250739#comment-17250739 ] Dian Fu commented on FLINK-20632: - FYI: there is already a PR:

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 releas

2020-12-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250736#comment-17250736 ] Xintong Song commented on FLINK-20632: -- Hi [~peperg], Docker Hub requires all official images to

  1   2   3   >