[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344546173 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344546013 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344545951 ## File path:

[GitHub] [flink] openinx commented on a change in pull request #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

openinx commented on a change in pull request #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#discussion_r344554821 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550309075 ## CI report: * 9817ef9c8be75fd02ccef3825e706497f3e6c1b6 :

[jira] [Created] (FLINK-14698) Refactor the SQL CLI parser to reuse flink-sql-parser

Danny Chen created FLINK-14698: -- Summary: Refactor the SQL CLI parser to reuse flink-sql-parser Key: FLINK-14698 URL: https://issues.apache.org/jira/browse/FLINK-14698 Project: Flink Issue

[jira] [Commented] (FLINK-14481) Modify the Flink valid socket port check to 0 to 65535.

[ https://issues.apache.org/jira/browse/FLINK-14481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971275#comment-16971275 ] AT-Fieldless commented on FLINK-14481: -- Thanks for pointing it out. I will check full Flink project

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344551534 ## File path:

[jira] [Created] (FLINK-14697) Connection timeout occurs while checkpointing

dmgkeke created FLINK-14697: --- Summary: Connection timeout occurs while checkpointing Key: FLINK-14697 URL: https://issues.apache.org/jira/browse/FLINK-14697 Project: Flink Issue Type: Bug

[GitHub] [flink] yanghua commented on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

yanghua commented on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-552303110 @GJL I have modified the test based on your suggestion. WDYT about the new changes?

[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550309075 ## CI report: * 9817ef9c8be75fd02ccef3825e706497f3e6c1b6 :

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344573331 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344572768 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344572884 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344577356 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344582415 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344539902 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344539915 ## File path:

[jira] [Created] (FLINK-14695) Elasticsearch 5.1.2 doesn't work on Ubuntu 18.04

wangxiyuan created FLINK-14695: -- Summary: Elasticsearch 5.1.2 doesn't work on Ubuntu 18.04 Key: FLINK-14695 URL: https://issues.apache.org/jira/browse/FLINK-14695 Project: Flink Issue Type: Bug

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344542341 ## File path:

[jira] [Commented] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time

[ https://issues.apache.org/jira/browse/FLINK-14674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971288#comment-16971288 ] Leonard Xu commented on FLINK-14674: [~lzljs3620320] I think [~ykt836] 's analysis is right， in

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344548191 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344548144 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344548105 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-550964937 ## CI report: * 13118777453ff58976b17b9aa1b7a4590ce86d5c : FAILURE

[jira] [Updated] (FLINK-14697) Connection timeout occurs while checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dmgkeke updated FLINK-14697: Environment: Flink version : 1.8.0 Yarn cluster mode 8 nodes 16 yarn containers checkpoint path :

[GitHub] [flink] flinkbot commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : UNKNOWN Bot

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344583750 ## File path:

[jira] [Updated] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?

[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Donghui Xu updated FLINK-13482: --- Affects Version/s: 1.6.4 > How can I cleanly shutdown streaming jobs in local mode? >

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344538921 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-550964937 ## CI report: * 13118777453ff58976b17b9aa1b7a4590ce86d5c : FAILURE

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344547747 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344547802 ## File path:

[jira] [Created] (FLINK-14696) Support precision of TimestampType in built-in SQL functions and operators

Zhenghua Gao created FLINK-14696: Summary: Support precision of TimestampType in built-in SQL functions and operators Key: FLINK-14696 URL: https://issues.apache.org/jira/browse/FLINK-14696 Project:

[GitHub] [flink] flinkbot commented on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject…

flinkbot commented on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject… URL: https://github.com/apache/flink/pull/10145#issuecomment-552287128 ## CI report: * fa9222c68fa3dd623180c52f5b769ed7e733676e : UNKNOWN Bot commands The

[GitHub] [flink] openinx commented on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

openinx commented on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-552298571 Update the pull request: 1. use the Files.walkFileTree to copy the

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : PENDING

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344573790 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344573698 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344580399 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344580223 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344583125 ## File path:

[jira] [Commented] (FLINK-14666) support multiple catalog in flink table sql

[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971278#comment-16971278 ] yuemeng commented on FLINK-14666: - [~dwysakowicz] I will close the issue because of your new feature in

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344539268 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344539204 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344541629 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344541629 ## File path:

[GitHub] [flink] qiuxiafei commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

qiuxiafei commented on a change in pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#discussion_r344544335 ## File path:

[GitHub] [flink] thorntree commented on issue #934: Framesize fix

thorntree commented on issue #934: Framesize fix URL: https://github.com/apache/flink/pull/934#issuecomment-552276083 @kl0u ,hi kl0u.can you tell me how increase akka.framesize? I don't know how config akka.framesize.Thanks!

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344546978 ## File path:

[jira] [Commented] (FLINK-14693) python tox checks fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971309#comment-16971309 ] Dian Fu commented on FLINK-14693: - Great thanks for reporting this issue. We have also found this issue

[GitHub] [flink] flinkbot edited a comment on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject…

flinkbot edited a comment on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject… URL: https://github.com/apache/flink/pull/10145#issuecomment-552287128 ## CI report: * fa9222c68fa3dd623180c52f5b769ed7e733676e : SUCCESS

[jira] [Closed] (FLINK-14666) support multiple catalog in flink table sql

[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng closed FLINK-14666. --- Resolution: Implemented > support multiple catalog in flink table sql >

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344539546 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344539656 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344539605 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

TisonKun commented on a change in pull request #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#discussion_r344548623 ## File path:

[GitHub] [flink] lirui-apache commented on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject…

lirui-apache commented on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject… URL: https://github.com/apache/flink/pull/10145#issuecomment-552283323 @xuefuz @bowenli86 This is to port the fix of FLINK-14673 to 1.9.x. Please take a look. Thanks.

[GitHub] [flink] flinkbot commented on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject…

flinkbot commented on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject… URL: https://github.com/apache/flink/pull/10145#issuecomment-552283313 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344549947 ## File path:

[GitHub] [flink] TisonKun commented on issue #934: Framesize fix

TisonKun commented on issue #934: Framesize fix URL: https://github.com/apache/flink/pull/934#issuecomment-552290311 @thorntree https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html#akka-framesize This is an

[GitHub] [flink] lirui-apache commented on issue #10140: [FLINK-14660][sql cli] add 'SHOW MODULES' to SQL CLI

lirui-apache commented on issue #10140: [FLINK-14660][sql cli] add 'SHOW MODULES' to SQL CLI URL: https://github.com/apache/flink/pull/10140#issuecomment-552298911 LGTM but the compile failure seems related. This is an

[GitHub] [flink] TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344571496 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344571496 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344581031 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344581143 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344541099 ## File path:

[jira] [Created] (FLINK-14699) Move ClosureCleaner to flink-core

Zili Chen created FLINK-14699: - Summary: Move ClosureCleaner to flink-core Key: FLINK-14699 URL: https://issues.apache.org/jira/browse/FLINK-14699 Project: Flink Issue Type: Improvement

[GitHub] [flink] tweise commented on issue #10138: [FLINK-14635][e2e tests] Use non-relocated imports for AWS SDK Kinesis classes in tests.

tweise commented on issue #10138: [FLINK-14635][e2e tests] Use non-relocated imports for AWS SDK Kinesis classes in tests. URL: https://github.com/apache/flink/pull/10138#issuecomment-552257775 @StephanEwen I understand the motivation to make the imports display as valid in the IDE.

[jira] [Commented] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?

[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971270#comment-16971270 ] Donghui Xu commented on FLINK-13482: Thank you for your advice. [~azagrebin] I want to kill the

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344540487 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344546570 ## File path:

[GitHub] [flink] lirui-apache opened a new pull request #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject…

lirui-apache opened a new pull request #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject… URL: https://github.com/apache/flink/pull/10145 …Exception for non-existing function ## What is the purpose of the change Always to check

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344549396 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344549642 ## File path:

[GitHub] [flink] flinkbot commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552302004 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] xintongsong opened a new pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

xintongsong opened a new pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146 ## What is the purpose of the change This PR is a subtask of FLIP-56. It makes task executor to

[jira] [Updated] (FLINK-14188) TaskExecutor derive and register with default slot resource profile

[ https://issues.apache.org/jira/browse/FLINK-14188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14188: --- Labels: pull-request-available (was: ) > TaskExecutor derive and register with default

[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550309075 ## CI report: * 9817ef9c8be75fd02ccef3825e706497f3e6c1b6 :

[jira] [Closed] (FLINK-14666) support multiple catalog in flink table sql

[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14666. -- Fix Version/s: 1.10.0 Resolution: Not A Problem > support multiple catalog in flink table sql

[jira] [Closed] (FLINK-14698) Refactor the SQL CLI parser to reuse flink-sql-parser

[ https://issues.apache.org/jira/browse/FLINK-14698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14698. -- Fix Version/s: (was: 1.10.0) Resolution: Duplicate > Refactor the SQL CLI parser to reuse

[jira] [Reopened] (FLINK-14666) support multiple catalog in flink table sql

[ https://issues.apache.org/jira/browse/FLINK-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reopened FLINK-14666: > support multiple catalog in flink table sql > --- > >

[jira] [Commented] (FLINK-14698) Refactor the SQL CLI parser to reuse flink-sql-parser

[ https://issues.apache.org/jira/browse/FLINK-14698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971335#comment-16971335 ] Kurt Young commented on FLINK-14698: I've already create this one: 

[GitHub] [flink] openinx edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

openinx edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-552298571 Update the pull request: 1. use the Files.walkFileTree to copy the

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344581857 ## File path:

[jira] [Created] (FLINK-14700) Consider to set the random listen port in e2e flink cluster.

Zheng Hu created FLINK-14700: Summary: Consider to set the random listen port in e2e flink cluster. Key: FLINK-14700 URL: https://issues.apache.org/jira/browse/FLINK-14700 Project: Flink Issue

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r344543636 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344545581 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344545581 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344545905 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-550964937 ## CI report: * 13118777453ff58976b17b9aa1b7a4590ce86d5c : FAILURE

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344550166 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344550447 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344550465 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject…

flinkbot edited a comment on issue #10145: [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObject… URL: https://github.com/apache/flink/pull/10145#issuecomment-552287128 ## CI report: * fa9222c68fa3dd623180c52f5b769ed7e733676e : PENDING

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344584416 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344590458 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550309075 ## CI report: * 9817ef9c8be75fd02ccef3825e706497f3e6c1b6 :

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344586695 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344589965 ## File path:

  1   2   >