[jira] [Created] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

2020-03-12 Thread Yun Gao (Jira)
Yun Gao created FLINK-16582: --- Summary: NettyBufferPoolTest may have warns on NettyBuffer leak Key: FLINK-16582 URL: https://issues.apache.org/jira/browse/FLINK-16582 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #11385: [FLINK-11395][formats] Support for Avro StreamingFileSink

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11385: [FLINK-11395][formats] Support for Avro StreamingFileSink URL: https://github.com/apache/flink/pull/11385#issuecomment-597956562 ## CI report: * f878f74b9dd6bd4794f070960cc77c15f2ed94f7 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#issuecomment-597788287 ## CI report: * 55525e050ada84dcd0e1ea935dffe3b7f09faa42 UNKNOWN * 823cf79209f3ee0b6a38f9a185cdd5e506f3c6ea Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN *

[GitHub] [flink] dianfu commented on a change in pull request #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation

2020-03-12 Thread GitBox
dianfu commented on a change in pull request #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation URL: https://github.com/apache/flink/pull/11375#discussion_r392040809 ## File path: docs/dev/table/python/index.md ## @@ -0,0 +1,35 @@ +--- +title:

[GitHub] [flink] wuchong edited a comment on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7

2020-03-12 Thread GitBox
wuchong edited a comment on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396#issuecomment-598561129 Could you also update `test_sql_client.sh`

[GitHub] [flink] wuchong commented on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7

2020-03-12 Thread GitBox
wuchong commented on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396#issuecomment-598561129 Could you also update `test_sql_client.sh` end-to-end

[jira] [Commented] (FLINK-16581) Minibatch deduplication lack state TTL

2020-03-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058437#comment-17058437 ] Jingsong Lee commented on FLINK-16581: -- CC: [~jark] > Minibatch deduplication lack state TTL >

[jira] [Created] (FLINK-16581) Minibatch deduplication lack state TTL

2020-03-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-16581: Summary: Minibatch deduplication lack state TTL Key: FLINK-16581 URL: https://issues.apache.org/jira/browse/FLINK-16581 Project: Flink Issue Type: Bug

[GitHub] [flink] TisonKun commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
TisonKun commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#discussion_r392039386 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392037901 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#issuecomment-595841256 ## CI report: * 71e99474dc27f501c2c512e80761edd2057c00d0

[GitHub] [flink] flinkbot edited a comment on issue #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#issuecomment-597788287 ## CI report: * eb546e4bbf07492886da99bfac28496af894cd8c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396#issuecomment-598553173 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7

2020-03-12 Thread GitBox
flinkbot commented on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396#issuecomment-598553173 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#issuecomment-597788287 ## CI report: * eb546e4bbf07492886da99bfac28496af894cd8c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink…

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink… URL: https://github.com/apache/flink/pull/11395#issuecomment-598517763 ## CI report: * 5a7f34903762fc0e644b0a0b59146b76c701d52c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#issuecomment-595841256 ## CI report: * 71e99474dc27f501c2c512e80761edd2057c00d0

[GitHub] [flink] flinkbot edited a comment on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#issuecomment-597497985 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] leonardBang commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

2020-03-12 Thread GitBox
leonardBang commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#discussion_r392032018 ## File path: flink-table/flink-sql-client/pom.xml

[GitHub] [flink] hequn8128 commented on a change in pull request #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation

2020-03-12 Thread GitBox
hequn8128 commented on a change in pull request #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation URL: https://github.com/apache/flink/pull/11375#discussion_r392027289 ## File path: docs/dev/table/python/installation.md ## @@ -0,0 +1,40 @@

[GitHub] [flink] hequn8128 commented on a change in pull request #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation

2020-03-12 Thread GitBox
hequn8128 commented on a change in pull request #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation URL: https://github.com/apache/flink/pull/11375#discussion_r392026355 ## File path: docs/dev/table/python/index.md ## @@ -0,0 +1,35 @@ +---

[GitHub] [flink] flinkbot commented on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7

2020-03-12 Thread GitBox
flinkbot commented on issue #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396#issuecomment-598550234 Thanks a lot for your contribution to the Apache Flink

[GitHub] [flink] leonardBang opened a new pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7

2020-03-12 Thread GitBox
leonardBang opened a new pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396 [FLINK-16170][Connectors/elasticsearch]SearchTemplateRequest

[jira] [Updated] (FLINK-16170) SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7

2020-03-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16170: --- Labels: pull-request-available (was: ) > SearchTemplateRequest ClassNotFoundException when

[GitHub] [flink] rkhachatryan commented on issue #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
rkhachatryan commented on issue #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#issuecomment-598549360 Thanks for reviewing @zhijiangW . I've addressed the issues and squashed commits.

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#issuecomment-597497985 ## CI report: *

[jira] [Updated] (FLINK-16548) [Requirement] Consistent id to identify jm/tm in different cluster modes

2020-03-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16548: --- Parent: FLINK-15679 Issue Type: Sub-task (was: Wish) > [Requirement] Consistent id to

[GitHub] [flink] HuangXingBo commented on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
HuangXingBo commented on issue #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#issuecomment-598547910 Thanks a lot for @dianfu review, I have addressed

[GitHub] [flink] zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#discussion_r392026854 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#discussion_r392026596 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ##

[GitHub] [flink] zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#discussion_r392026418 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java

[GitHub] [flink] zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#discussion_r392026468 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java

[GitHub] [flink] zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask

2020-03-12 Thread GitBox
zhijiangW commented on a change in pull request #11382: [FLINK-16554][task] split StreamTask URL: https://github.com/apache/flink/pull/11382#discussion_r392026565 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/CheckpointingOperation.java

[jira] [Created] (FLINK-16580) flink-connector-kafka desrializer

2020-03-12 Thread Jira
李开青 created FLINK-16580: --- Summary: flink-connector-kafka desrializer Key: FLINK-16580 URL: https://issues.apache.org/jira/browse/FLINK-16580 Project: Flink Issue Type: Wish Components:

[GitHub] [flink] dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#discussion_r392020113 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#discussion_r392009919 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#discussion_r392020113 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#discussion_r392012728 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#discussion_r392019385 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#discussion_r392004453 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#discussion_r392010635 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-12 Thread GitBox
dianfu commented on a change in pull request #11374: [FLINK-16524][python] Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls URL: https://github.com/apache/flink/pull/11374#discussion_r391999149 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink…

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink… URL: https://github.com/apache/flink/pull/11395#issuecomment-598517763 ## CI report: * 43c018ea5e3be93ed538fe32165dda04138fbcf3 Travis:

[jira] [Comment Edited] (FLINK-16578) join lateral table function with condition fails with exception

2020-03-12 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058401#comment-17058401 ] Shuo Cheng edited comment on FLINK-16578 at 3/13/20, 3:35 AM: -- I come up

[jira] [Comment Edited] (FLINK-16578) join lateral table function with condition fails with exception

2020-03-12 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058401#comment-17058401 ] Shuo Cheng edited comment on FLINK-16578 at 3/13/20, 3:34 AM: -- I come up

[GitHub] [flink] flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink…

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink… URL: https://github.com/apache/flink/pull/11395#issuecomment-598517763 ## CI report: * 43c018ea5e3be93ed538fe32165dda04138fbcf3 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[jira] [Commented] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case

2020-03-12 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058402#comment-17058402 ] godfrey he commented on FLINK-16577: as [~icshuo] [~jark] said, maybe using `broad type` is sample

[jira] [Commented] (FLINK-16578) join lateral table function with condition fails with exception

2020-03-12 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058401#comment-17058401 ] Shuo Cheng commented on FLINK-16578: One hack way is copy `RelDecorrelator` from Calcite and

[jira] [Updated] (FLINK-16578) join lateral table function with condition fails with exception

2020-03-12 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Cheng updated FLINK-16578: --- Description: Reproducing:   {code:java} // CorrelateITCase.scala @Test def

[jira] [Commented] (FLINK-16579) Upgrade Calcite version to 1.23 for Flink SQL

2020-03-12 Thread Forward Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058398#comment-17058398 ] Forward Xu commented on FLINK-16579: hi, [~jark] I noticed that the current calcite version has just

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[jira] [Commented] (FLINK-16578) join lateral table function with condition fails with exception

2020-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058395#comment-17058395 ] Jark Wu commented on FLINK-16578: - Do we have to wait Calcite 1.23? Is that possible to fix in Flink

[GitHub] [flink] flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink…

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink… URL: https://github.com/apache/flink/pull/11395#issuecomment-598517763 ## CI report: * 43c018ea5e3be93ed538fe32165dda04138fbcf3 Travis:

[jira] [Created] (FLINK-16579) Upgrade Calcite version to 1.23 for Flink SQL

2020-03-12 Thread Jark Wu (Jira)
Jark Wu created FLINK-16579: --- Summary: Upgrade Calcite version to 1.23 for Flink SQL Key: FLINK-16579 URL: https://issues.apache.org/jira/browse/FLINK-16579 Project: Flink Issue Type: Task

[jira] [Closed] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

2020-03-12 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-10742. Resolution: Fixed Merged in master: db5d753da7dbac3cc274bba683081503be94c99d > Let Netty use Flink's

[jira] [Commented] (FLINK-16578) join lateral table function with condition fails with exception

2020-03-12 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058390#comment-17058390 ] Shuo Cheng commented on FLINK-16578: cc [~jark], [~danny0405] > join lateral table function with

[jira] [Commented] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case

2020-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058392#comment-17058392 ] Jark Wu commented on FLINK-16577: - A simple way is always using BigDecimal for numerics? > Exception

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392009665 ## File path:

[jira] [Created] (FLINK-16578) join lateral table function with condition fails with exception

2020-03-12 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-16578: -- Summary: join lateral table function with condition fails with exception Key: FLINK-16578 URL: https://issues.apache.org/jira/browse/FLINK-16578 Project: Flink

[jira] [Closed] (FLINK-16008) Add rules to transpose the join condition of Python Correlate node

2020-03-12 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16008. --- Resolution: Resolved > Add rules to transpose the join condition of Python Correlate node >

[jira] [Commented] (FLINK-16008) Add rules to transpose the join condition of Python Correlate node

2020-03-12 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058388#comment-17058388 ] Hequn Cheng commented on FLINK-16008: - Resolved in 1.11.0 via

[GitHub] [flink] hequn8128 merged pull request #11299: [FLINK-16008][table-planner][table-planner-blink] Add rules to transpose the join condition of Python Correlate node

2020-03-12 Thread GitBox
hequn8128 merged pull request #11299: [FLINK-16008][table-planner][table-planner-blink] Add rules to transpose the join condition of Python Correlate node URL: https://github.com/apache/flink/pull/11299 This is an

[jira] [Comment Edited] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058385#comment-17058385 ] Jark Wu edited comment on FLINK-16441 at 3/13/20, 3:05 AM: --- Hi [~gyfora],

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392009286 ## File path:

[jira] [Commented] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058385#comment-17058385 ] Jark Wu commented on FLINK-16441: - I [~gyfora], I reviewed the changes. I think I had some

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392008712 ## File path:

[jira] [Updated] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

2020-03-12 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-10742: - Fix Version/s: 1.11.0 > Let Netty use Flink's buffers directly in credit-based mode >

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392007033 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink…

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink… URL: https://github.com/apache/flink/pull/11395#issuecomment-598517763 ## CI report: * 43c018ea5e3be93ed538fe32165dda04138fbcf3 Travis:

[GitHub] [flink] zhijiangW merged pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly on receiver side

2020-03-12 Thread GitBox
zhijiangW merged pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly on receiver side URL: https://github.com/apache/flink/pull/7368 This is an automated message from the Apache Git Service. To

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392005079 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392002851 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
danny0405 commented on a change in pull request #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#discussion_r392002765 ## File path:

[GitHub] [flink] danny0405 commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-12 Thread GitBox
danny0405 commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-598521784 > Thanks @danny0405 so much for this huge work, I left some comments. I notice there are a lot of alias name in the plans

[jira] [Comment Edited] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case

2020-03-12 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058370#comment-17058370 ] Shuo Cheng edited comment on FLINK-16577 at 3/13/20, 2:45 AM: -- I think one

[GitHub] [flink] flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink…

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink… URL: https://github.com/apache/flink/pull/11395#issuecomment-598517763 ## CI report: * 43c018ea5e3be93ed538fe32165dda04138fbcf3 Travis:

[jira] [Commented] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case

2020-03-12 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058370#comment-17058370 ] Shuo Cheng commented on FLINK-16577: I think one possible solution is when we get value from

[jira] [Commented] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case

2020-03-12 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058365#comment-17058365 ] Shuo Cheng commented on FLINK-16577: cc [~godfreyhe], [~jark] > Exception will be thrown when

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-03-12 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058366#comment-17058366 ] Caizhi Weng commented on FLINK-14807: - Hi [~sewen] Our current implementation (through

[jira] [Created] (FLINK-16577) Exception will be thrown when computing columnInterval relmetadata in some case

2020-03-12 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-16577: -- Summary: Exception will be thrown when computing columnInterval relmetadata in some case Key: FLINK-16577 URL: https://issues.apache.org/jira/browse/FLINK-16577 Project:

[jira] [Commented] (FLINK-16548) [Requirement] Consistent id to identify jm/tm in different cluster modes

2020-03-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058362#comment-17058362 ] Yang Wang commented on FLINK-16548: --- [~karmagyz] Thanks for your response. It will be great if you

[GitHub] [flink] flinkbot commented on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink…

2020-03-12 Thread GitBox
flinkbot commented on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink… URL: https://github.com/apache/flink/pull/11395#issuecomment-598517763 ## CI report: * 43c018ea5e3be93ed538fe32165dda04138fbcf3 UNKNOWN Bot commands The

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

2020-03-12 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058359#comment-17058359 ] godfrey he commented on FLINK-16379: I think {{fromValues}} is right for running Flink Table API &

[GitHub] [flink] flinkbot commented on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink…

2020-03-12 Thread GitBox
flinkbot commented on issue #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink… URL: https://github.com/apache/flink/pull/11395#issuecomment-598515852 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-16501) Support IS JSON predication for Table API in blink planner

2020-03-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16501: --- Labels: pull-request-available (was: ) > Support IS JSON predication for Table API in

[GitHub] [flink] XuQianJin-Stars opened a new pull request #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink…

2020-03-12 Thread GitBox
XuQianJin-Stars opened a new pull request #11395: [FLINK-16501][sql] Support IS JSON predication for Table API in blink… URL: https://github.com/apache/flink/pull/11395 ## What is the purpose of the change Support IS JSON predication for Table API in blink planner

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[jira] [Comment Edited] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

2020-03-12 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057921#comment-17057921 ] godfrey he edited comment on FLINK-16533 at 3/13/20, 1:58 AM: -- [~kkl0u]

[jira] [Comment Edited] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

2020-03-12 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057921#comment-17057921 ] godfrey he edited comment on FLINK-16533 at 3/13/20, 1:58 AM: -- [~kkl0u]

[jira] [Comment Edited] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

2020-03-12 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057921#comment-17057921 ] godfrey he edited comment on FLINK-16533 at 3/13/20, 1:58 AM: -- [~kkl0u]

[jira] [Comment Edited] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

2020-03-12 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057921#comment-17057921 ] godfrey he edited comment on FLINK-16533 at 3/13/20, 1:58 AM: -- [~kkl0u]

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-12 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

2020-03-12 Thread GitBox
KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#discussion_r391989131 ## File path: flink-table/flink-sql-client/pom.xml

[jira] [Commented] (FLINK-16379) Introduce fromValues in TableEnvironment

2020-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058338#comment-17058338 ] Jark Wu commented on FLINK-16379: - +1 to have a unified {{fromValues(Object...)}} and

[jira] [Comment Edited] (FLINK-15071) YARN vcore capacity check can not pass when use large slotPerTaskManager

2020-03-12 Thread huweihua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058335#comment-17058335 ] huweihua edited comment on FLINK-15071 at 3/13/20, 1:37 AM: h4. [Chesnay

[jira] [Resolved] (FLINK-16343) Improve exception message when reading an unbounded source in batch mode

2020-03-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16343. - Resolution: Fixed > Improve exception message when reading an unbounded source in batch mode >

  1   2   3   4   5   6   >