[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577422#comment-16577422
]
ASF GitHub Bot commented on FLINK-9891:
---
yanghua commented on a change in pull requ
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:
flink-clients/src/main/java/org/apache/flink/client/cli/CliF
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577421#comment-16577421
]
ASF GitHub Bot commented on FLINK-9891:
---
yanghua commented on a change in pull requ
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:
flink-clients/src/main/java/org/apache/flink/client/cli/CliF
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: flink-runtime/src/main/scala/akka/actor/RobustActorSys
[
https://issues.apache.org/jira/browse/FLINK-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577420#comment-16577420
]
ASF GitHub Bot commented on FLINK-10123:
yanghua commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577419#comment-16577419
]
ASF GitHub Bot commented on FLINK-10123:
zentol commented on a change in pull re
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: flink-runtime/src/main/scala/akka/actor/RobustActorSyst
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577413#comment-16577413
]
ASF GitHub Bot commented on FLINK-9941:
---
buptljy commented on issue #6411: [FLINK-9
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 messag
[
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
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577392#comment-16577392
]
ASF GitHub Bot commented on FLINK-:
---
yanghua commented on a change in pull requ
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:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/Scalar
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577390#comment-16577390
]
ASF GitHub Bot commented on FLINK-:
---
yanghua commented on a change in pull requ
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:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/string
[
https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577387#comment-16577387
]
vinoyang commented on FLINK-7964:
-
hi [~yew1eb] Are you still dealing with this issue? Wh
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577359#comment-16577359
]
Sebastian Klemke commented on FLINK-9891:
-
Thanks [~till.rohrmann] for the detail
[
https://issues.apache.org/jira/browse/FLINK-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577358#comment-16577358
]
ASF GitHub Bot commented on FLINK-9891:
---
packet23 opened a new pull request #6540:
[
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 Flink
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 surviving
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577231#comment-16577231
]
ASF GitHub Bot commented on FLINK-:
---
walterddr commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577232#comment-16577232
]
ASF GitHub Bot commented on FLINK-:
---
walterddr commented on a change in pull re
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:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/Scal
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:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/stri
[
https://issues.apache.org/jira/browse/FLINK-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577223#comment-16577223
]
ASF GitHub Bot commented on FLINK-9664:
---
walterddr commented on a change in pull re
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
here
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577207#comment-16577207
]
ASF GitHub Bot commented on FLINK-9642:
---
Aitozi commented on issue #6205: [FLINK-96
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
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577090#comment-16577090
]
ASF GitHub Bot commented on FLINK-9642:
---
Aitozi commented on a change in pull reque
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:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577089#comment-16577089
]
ASF GitHub Bot commented on FLINK-9642:
---
Aitozi commented on a change in pull reque
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:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/
32 matches
Mail list logo