[jira] [Commented] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped

[ https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577422#comment-16577422 ] ASF GitHub Bot commented on FLINK-9891: --- yanghua commented on a change in pull request #6540:

[GitHub] yanghua commented on a change in pull request #6540: [FLINK-9891] Added hook to shutdown cluster if a session was created in per-job mode.

yanghua commented on a change in pull request #6540: [FLINK-9891] Added hook to shutdown cluster if a session was created in per-job mode. URL: https://github.com/apache/flink/pull/6540#discussion_r209443483 ## File path:

[jira] [Commented] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped

[ https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577421#comment-16577421 ] ASF GitHub Bot commented on FLINK-9891: --- yanghua commented on a change in pull request #6540:

[GitHub] yanghua commented on a change in pull request #6540: [FLINK-9891] Added hook to shutdown cluster if a session was created in per-job mode.

yanghua commented on a change in pull request #6540: [FLINK-9891] Added hook to shutdown cluster if a session was created in per-job mode. URL: https://github.com/apache/flink/pull/6540#discussion_r209443343 ## File path:

[GitHub] yanghua commented on a change in pull request #6539: [FLINK-10123] Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client

yanghua commented on a change in pull request #6539: [FLINK-10123] Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client URL: https://github.com/apache/flink/pull/6539#discussion_r209443308 ## File path:

[jira] [Commented] (FLINK-10123) Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client

[ https://issues.apache.org/jira/browse/FLINK-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577420#comment-16577420 ] ASF GitHub Bot commented on FLINK-10123: yanghua commented on a change in pull request #6539:

[jira] [Commented] (FLINK-10123) Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client

[ https://issues.apache.org/jira/browse/FLINK-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577419#comment-16577419 ] ASF GitHub Bot commented on FLINK-10123: zentol commented on a change in pull request #6539:

[GitHub] zentol commented on a change in pull request #6539: [FLINK-10123] Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client

zentol commented on a change in pull request #6539: [FLINK-10123] Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client URL: https://github.com/apache/flink/pull/6539#discussion_r209443286 ## File path:

[jira] [Commented] (FLINK-9941) Flush in ScalaCsvOutputFormat before close method

[ https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577413#comment-16577413 ] ASF GitHub Bot commented on FLINK-9941: --- buptljy commented on issue #6411: [FLINK-9941][ScalaAPI]

[GitHub] buptljy commented on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before closing to ensure CI stability

buptljy commented on issue #6411: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before closing to ensure CI stability URL: https://github.com/apache/flink/pull/6411#issuecomment-412318470 +1 This is an automated

[jira] [Closed] (FLINK-9693) Possible memory leak in jobmanager retaining archived checkpoints

[ https://issues.apache.org/jira/browse/FLINK-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu closed FLINK-9693. - Resolution: Fixed close this jira since [~srichter] have addressed remaining issues in other

[jira] [Commented] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577392#comment-16577392 ] ASF GitHub Bot commented on FLINK-: --- yanghua commented on a change in pull request #6473:

[GitHub] yanghua commented on a change in pull request #6473: [FLINK-9999] [table] Add ISNUMERIC supported in Table API/SQL

yanghua commented on a change in pull request #6473: [FLINK-] [table] Add ISNUMERIC supported in Table API/SQL URL: https://github.com/apache/flink/pull/6473#discussion_r209441697 ## File path:

[jira] [Commented] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577390#comment-16577390 ] ASF GitHub Bot commented on FLINK-: --- yanghua commented on a change in pull request #6473:

[GitHub] yanghua commented on a change in pull request #6473: [FLINK-9999] [table] Add ISNUMERIC supported in Table API/SQL

yanghua commented on a change in pull request #6473: [FLINK-] [table] Add ISNUMERIC supported in Table API/SQL URL: https://github.com/apache/flink/pull/6473#discussion_r209441509 ## File path:

[jira] [Commented] (FLINK-7964) Add Apache Kafka 1.0/1.1 connectors

[ https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577387#comment-16577387 ] vinoyang commented on FLINK-7964: - hi [~yew1eb] Are you still dealing with this issue? What is the

[jira] [Commented] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped

[ https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577359#comment-16577359 ] Sebastian Klemke commented on FLINK-9891: - Thanks [~till.rohrmann] for the detailed explanation.

[jira] [Commented] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped

[ https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577358#comment-16577358 ] ASF GitHub Bot commented on FLINK-9891: --- packet23 opened a new pull request #6540: [FLINK-9891]

[jira] [Updated] (FLINK-9891) Flink cluster is not shutdown in YARN mode when Flink client is stopped

[ https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9891: -- Labels: pull-request-available (was: ) > Flink cluster is not shutdown in YARN mode when

[GitHub] packet23 opened a new pull request #6540: [FLINK-9891] Added hook to shutdown cluster if a session was created in per-job mode.

packet23 opened a new pull request #6540: [FLINK-9891] Added hook to shutdown cluster if a session was created in per-job mode. URL: https://github.com/apache/flink/pull/6540 ## What is the purpose of the change Change minimizes probability of a per-job yarn session cluster

[jira] [Commented] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577231#comment-16577231 ] ASF GitHub Bot commented on FLINK-: --- walterddr commented on a change in pull request #6473:

[jira] [Commented] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577232#comment-16577232 ] ASF GitHub Bot commented on FLINK-: --- walterddr commented on a change in pull request #6473:

[GitHub] walterddr commented on a change in pull request #6473: [FLINK-9999] [table] Add ISNUMERIC supported in Table API/SQL

walterddr commented on a change in pull request #6473: [FLINK-] [table] Add ISNUMERIC supported in Table API/SQL URL: https://github.com/apache/flink/pull/6473#discussion_r209430968 ## File path:

[GitHub] walterddr commented on a change in pull request #6473: [FLINK-9999] [table] Add ISNUMERIC supported in Table API/SQL

walterddr commented on a change in pull request #6473: [FLINK-] [table] Add ISNUMERIC supported in Table API/SQL URL: https://github.com/apache/flink/pull/6473#discussion_r209430879 ## File path:

[jira] [Commented] (FLINK-9664) FlinkML Quickstart Loading Data section example doesn't work as described

[ https://issues.apache.org/jira/browse/FLINK-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577223#comment-16577223 ] ASF GitHub Bot commented on FLINK-9664: --- walterddr commented on a change in pull request #6425:

[GitHub] walterddr commented on a change in pull request #6425: [FLINK-9664][Doc] fixing documentation in ML quick start

walterddr commented on a change in pull request #6425: [FLINK-9664][Doc] fixing documentation in ML quick start URL: https://github.com/apache/flink/pull/6425#discussion_r209430609 ## File path: docs/dev/libs/ml/quickstart.md ## @@ -129,6 +129,10 @@ and the [test set

[jira] [Commented] (FLINK-9642) Reduce the count to deal with state during a CEP process

[ https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577207#comment-16577207 ] ASF GitHub Bot commented on FLINK-9642: --- Aitozi commented on issue #6205: [FLINK-9642]Reduce the

[GitHub] Aitozi commented on issue #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process

Aitozi commented on issue #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process URL: https://github.com/apache/flink/pull/6205#issuecomment-412280321 Have fixed the place you pointed, and add a test to cover the element in state and cache's change. Please take a look

[jira] [Commented] (FLINK-9642) Reduce the count to deal with state during a CEP process

[ https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577090#comment-16577090 ] ASF GitHub Bot commented on FLINK-9642: --- Aitozi commented on a change in pull request #6205:

[GitHub] Aitozi commented on a change in pull request #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process

Aitozi commented on a change in pull request #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process URL: https://github.com/apache/flink/pull/6205#discussion_r209419821 ## File path:

[jira] [Commented] (FLINK-9642) Reduce the count to deal with state during a CEP process

[ https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577089#comment-16577089 ] ASF GitHub Bot commented on FLINK-9642: --- Aitozi commented on a change in pull request #6205:

[GitHub] Aitozi commented on a change in pull request #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process

Aitozi commented on a change in pull request #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process URL: https://github.com/apache/flink/pull/6205#discussion_r209419821 ## File path: