[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

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: * cfc11390372b44884342

[GitHub] [flink] flinkbot edited a comment on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

flinkbot edited a comment on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * af989737355782ef4cdd038fb173991567064522 Travis: [PENDING](https://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

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: * b3dea1922d35f3a023fd1f70e8dfe5a13fb3f14a Travis

[GitHub] [flink] flinkbot commented on issue #11398: [FLINK-16413]Reduce hive source parallelism when limit push down

flinkbot commented on issue #11398: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11398#issuecomment-598579739 ## CI report: * 4fe5672c65d62cb5e1854db4bf3404d1f4a5fdec UNKNOWN Bot commands The @flinkbot

[jira] [Comment Edited] (FLINK-16526) Fix exception when computed column expression references a keyword column name

[ https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058464#comment-17058464 ] YufeiLiu edited comment on FLINK-16526 at 3/13/20, 6:53 AM:

[jira] [Comment Edited] (FLINK-16526) Fix exception when computed column expression references a keyword column name

[ https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058464#comment-17058464 ] YufeiLiu edited comment on FLINK-16526 at 3/13/20, 6:53 AM:

[jira] [Commented] (FLINK-16526) Fix exception when computed column expression references a keyword column name

[ https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058464#comment-17058464 ] YufeiLiu commented on FLINK-16526: -- [~jark] Hi, I tried cherrypick to my branch, but UT

[jira] [Created] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

hiliuxg created FLINK-16585: --- Summary: Table program cannot be compiled.Cannot determine simple type name "com" Key: FLINK-16585 URL: https://issues.apache.org/jira/browse/FLINK-16585 Project: Flink

[jira] [Assigned] (FLINK-16413) Reduce hive source parallelism when limit push down

[ https://issues.apache.org/jira/browse/FLINK-16413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16413: Assignee: Jun Zhang > Reduce hive source parallelism when limit push down > -

[jira] [Created] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long

hehuiyuan created FLINK-16584: - Summary: Whether to support the long type field in table planner when the source is kafka and event time field's type is long Key: FLINK-16584 URL: https://issues.apache.org/jira/brows

[GitHub] [flink] JingsongLi commented on a change in pull request #11398: [FLINK-16413]Reduce hive source parallelism when limit push down

JingsongLi commented on a change in pull request #11398: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11398#discussion_r392055291 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connect

[jira] [Commented] (FLINK-16413) Reduce hive source parallelism when limit push down

[ https://issues.apache.org/jira/browse/FLINK-16413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058460#comment-17058460 ] Jun Zhang commented on FLINK-16413: --- when limit push down ,we set the min(limit,parall

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

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: [SUCCESS](https://travis-ci.c

[jira] [Updated] (FLINK-16413) Reduce hive source parallelism when limit push down

[ https://issues.apache.org/jira/browse/FLINK-16413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16413: --- Labels: pull-request-available (was: ) > Reduce hive source parallelism when limit push dow

[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

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: * cfc11390372b44884342

[GitHub] [flink] zhangjun888 opened a new pull request #11398: [FLINK-16413]Reduce hive source parallelism when limit push down

zhangjun888 opened a new pull request #11398: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11398 ## What is the purpose of the change Reduce hive source parallelism when limit push down ## Brief change l

[GitHub] [flink] flinkbot commented on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

flinkbot commented on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * af989737355782ef4cdd038fb173991567064522 UNKNOWN Bot commands The

[GitHub] [flink] zhangjun888 closed pull request #11398: [FLINK-16413]Reduce hive source parallelism when limit push down

zhangjun888 closed pull request #11398: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11398 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on issue #11398: [FLINK-16413]Reduce hive source parallelism when limit push down

flinkbot commented on issue #11398: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11398#issuecomment-598575006 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058455#comment-17058455 ] Zhijiang commented on FLINK-16572: -- Another same failure case in  [https://dev.azure.co

[GitHub] [flink] zhangjun888 opened a new pull request #11398: Reduce hive source parallelism when limit push down

zhangjun888 opened a new pull request #11398: Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11398 ## What is the purpose of the change Reduce hive source parallelism when limit push down ## Brief change log Red

[jira] [Closed] (FLINK-16538) Restructure Python Table API documentation

[ https://issues.apache.org/jira/browse/FLINK-16538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16538. --- Resolution: Resolved > Restructure Python Table API documentation >

[jira] [Commented] (FLINK-16538) Restructure Python Table API documentation

[ https://issues.apache.org/jira/browse/FLINK-16538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058454#comment-17058454 ] Hequn Cheng commented on FLINK-16538: - Resolved in 1.11.0 via 242430199e7fa58ac8d528

[GitHub] [flink] hequn8128 merged pull request #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation

hequn8128 merged pull request #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation URL: https://github.com/apache/flink/pull/11375 This is an automated message from the Apache Git Service. To respon

[jira] [Created] (FLINK-16583) SQLClientKafkaITCase.testKafka failed in SqlClientException

Zhijiang created FLINK-16583: Summary: SQLClientKafkaITCase.testKafka failed in SqlClientException Key: FLINK-16583 URL: https://issues.apache.org/jira/browse/FLINK-16583 Project: Flink Issue Ty

[jira] [Updated] (FLINK-16583) SQLClientKafkaITCase.testKafka failed with SqlClientException

[ https://issues.apache.org/jira/browse/FLINK-16583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16583: - Summary: SQLClientKafkaITCase.testKafka failed with SqlClientException (was: SQLClientKafkaITCase.testK

[jira] [Assigned] (FLINK-16217) SQL Client crashed when any uncatched exception is thrown

[ https://issues.apache.org/jira/browse/FLINK-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16217: --- Assignee: godfrey he > SQL Client crashed when any uncatched exception is thrown >

[GitHub] [flink] flinkbot edited a comment on issue #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation

flinkbot edited a comment on issue #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation URL: https://github.com/apache/flink/pull/11375#issuecomment-597513098 ## CI report: * 9ead4de4598165918be24d85c9e5a1c50ab82cbb Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] godfreyhe commented on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

godfreyhe commented on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed URL: https://github.com/apache/flink/pull/11397#issuecomment-598570340 cc @docete @twalthr This is an automated

[GitHub] [flink] flinkbot commented on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

flinkbot commented on issue #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed URL: https://github.com/apache/flink/pull/11397#issuecomment-598570171 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-16217) SQL Client crashed when any uncatched exception is thrown

[ https://issues.apache.org/jira/browse/FLINK-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16217: --- Labels: pull-request-available (was: ) > SQL Client crashed when any uncatched exception is

[GitHub] [flink] godfreyhe opened a new pull request #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

godfreyhe opened a new pull request #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed URL: https://github.com/apache/flink/pull/11397 ## What is the purpose of the change *catch all exceptions to avoid SQL client crashed* ## Brief

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

[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-16582: Assignee: Yun Gao > NettyBufferPoolTest may have warns on NettyBuffer leak > ---

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

[ https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16581: Assignee: dalongliu > Minibatch deduplication lack state TTL > --

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

[ https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058448#comment-17058448 ] Jingsong Lee commented on FLINK-16581: -- Assigned to you. [~lsy] > Minibatch dedupl

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

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 * f38af5e48e36464e94a14cb7b10e7fc74008

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

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: [CANCELED](https://travis-ci.com/github/fl

[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

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: * cfc11390372b44884342

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

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] dianfu commented on issue #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation

dianfu commented on issue #11375: [FLINK-16538][python][docs] Restructure Python Table API documentation URL: https://github.com/apache/flink/pull/11375#issuecomment-598566686 @hequn8128 Thanks a lot for the review. Have updated the PR. -

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

[ https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058446#comment-17058446 ] dalongliu commented on FLINK-16581: --- [~lzljs3620320] I want to fix this bug > Minibat

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

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: Bug

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

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: [CANCELED](https://travis-ci.com/github/fl

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

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: [PENDING](

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

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 * f38af5e48e36464e94a14cb7b10e7fc74008

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

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

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` end-to

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

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 te

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

[ https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058437#comment-17058437 ] Jingsong Lee commented on FLINK-16581: -- CC: [~jark] > Minibatch deduplication lack

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

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

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

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: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/pl

[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

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 Travis

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

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: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/15

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

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: * 28221f8d9b90211026689

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

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: * 28221f8d9b902110266893c9f403

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

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: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/15

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

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: [SUCCESS](https://travis-ci.c

[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

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 Travis

[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

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: * ef45405e3baca296b9ac

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

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

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

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

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 @@ +--- +title

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

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

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 ClassN

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

[ 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

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

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

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: * ef45405e3baca296b9ac

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

[ 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 ident

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

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 t

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

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: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/LocalStateForwardingTest.java

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

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

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

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

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

李开青 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: Connec

[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

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: flink-python/pyf

[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

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: flink-python/pyf

[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

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: flink-python/pyf

[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

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: flink-python/pyf

[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

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: flink-python/pyf

[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

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: flink-python/pyf

[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

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: flink-python/pyf

[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

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: flink-python/pyf

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

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: [FAILURE](https://travis-ci.c

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

[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058401#comment-17058401 ] Shuo Cheng edited comment on FLINK-16578 at 3/13/20, 3:35 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058401#comment-17058401 ] Shuo Cheng edited comment on FLINK-16578 at 3/13/20, 3:34 AM:

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

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: [FAILURE](https://travis-ci.c

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

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

[ https://issues.apache.org/jira/browse/FLINK-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058402#comment-17058402 ] godfrey he commented on FLINK-16577: as [~icshuo] [~jark] said, maybe using `broad t

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

[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058401#comment-17058401 ] Shuo Cheng commented on FLINK-16578: One hack way is copy `RelDecorrelator` from Cal

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

[ 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 testJoinTableFunction():

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

[ https://issues.apache.org/jira/browse/FLINK-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058398#comment-17058398 ] Forward Xu commented on FLINK-16579: hi, [~jark] I noticed that the current calcite

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

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

[ https://issues.apache.org/jira/browse/FLINK-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058395#comment-17058395 ] Jark Wu commented on FLINK-16578: - Do we have to wait Calcite 1.23? Is that possible to

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

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: [FAILURE](https://travis-ci.c

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

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

[ 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 buff

  1   2   3   4   5   6   >