[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221900610 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java #

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221891446 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java #

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221891681 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java #

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221901134 ## File path: flink-java/src/main/java/org/apache/flink/api/java/io/TextInputFormat.java ##

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221933227 ## File path: flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java ###

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221892538 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java #

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221890642 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java #

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221892225 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java #

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635414#comment-16635414 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221900961 ## File path: flink-java/src/main/java/org/apache/flink/api/java/io/TextInputFormat.java ##

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635419#comment-16635419 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221896574 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221898165 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221890824 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java #

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221897008 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/FileInputSplit.java ## @@ -

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635413#comment-16635413 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635412#comment-16635412 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635418#comment-16635418 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635423#comment-16635423 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635415#comment-16635415 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635425#comment-16635425 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635417#comment-16635417 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635422#comment-16635422 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635424#comment-16635424 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635421#comment-16635421 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635426#comment-16635426 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635416#comment-16635416 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635420#comment-16635420 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[GitHub] zentol commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5 URL: https://github.com/apache/flink/pull/6634#discussion_r221935270 ## File path: pom.xml ## @@ -123,8 +123,8 @@ under the License.

[jira] [Commented] (FLINK-10208) Bump mockito to 2.0+

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635428#comment-16635428 ] ASF GitHub Bot commented on FLINK-10208: zentol commented on a change in pull re

[GitHub] GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221938209 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/a

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635433#comment-16635433 ] ASF GitHub Bot commented on FLINK-10309: GJL commented on a change in pull reque

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2018-10-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635434#comment-16635434 ] Till Rohrmann commented on FLINK-9920: -- Another instance: https://api.travis-ci.org/

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Attachment: t1.log t2.log t3.log > Standalone HA -

[GitHub] GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221939603 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/A

[GitHub] GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221939603 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/A

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635436#comment-16635436 ] ASF GitHub Bot commented on FLINK-10309: GJL commented on a change in pull reque

[GitHub] GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221939470 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/j

[GitHub] zentol commented on issue #6784: [FLINK-7811] Add support for Scala 2.12

2018-10-02 Thread GitBox
zentol commented on issue #6784: [FLINK-7811] Add support for Scala 2.12 URL: https://github.com/apache/flink/pull/6784#issuecomment-426263943 API compatibility failed: ``` 11:55:19.619 [ERROR] Failed to execute goal com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp (default)

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635437#comment-16635437 ] ASF GitHub Bot commented on FLINK-10309: GJL commented on a change in pull reque

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4. Happy to see

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635440#comment-16635440 ] ASF GitHub Bot commented on FLINK-7811: --- zentol commented on issue #6784: [FLINK-78

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635438#comment-16635438 ] ASF GitHub Bot commented on FLINK-10309: GJL commented on a change in pull reque

[jira] [Commented] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635441#comment-16635441 ] Thomas Wozniakowski commented on FLINK-10475: - [~till.rohrmann] Thanks for t

[GitHub] GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221943917 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/a

[GitHub] GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221943917 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/a

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635459#comment-16635459 ] ASF GitHub Bot commented on FLINK-10309: GJL commented on a change in pull reque

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635461#comment-16635461 ] ASF GitHub Bot commented on FLINK-10309: GJL commented on a change in pull reque

[jira] [Assigned] (FLINK-9737) Allow to define Table Version Functions from SQL environment file

2018-10-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-9737: --- Assignee: Timo Walther > Allow to define Table Version Functions from SQL environment file >

[GitHub] tillrohrmann commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools URL: https://github.com/apache/flink/pull/6786#discussion_r221943598 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorE

[GitHub] tillrohrmann commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools URL: https://github.com/apache/flink/pull/6786#discussion_r221941729 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpoin

[GitHub] tillrohrmann commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools URL: https://github.com/apache/flink/pull/6786#discussion_r221944785 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorE

[GitHub] tillrohrmann commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools URL: https://github.com/apache/flink/pull/6786#discussion_r221945212 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorE

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635469#comment-16635469 ] ASF GitHub Bot commented on FLINK-10292: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635467#comment-16635467 ] ASF GitHub Bot commented on FLINK-10292: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635468#comment-16635468 ] ASF GitHub Bot commented on FLINK-10292: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635470#comment-16635470 ] ASF GitHub Bot commented on FLINK-10292: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635476#comment-16635476 ] ASF GitHub Bot commented on FLINK-10292: zentol commented on a change in pull re

[GitHub] zentol commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools URL: https://github.com/apache/flink/pull/6786#discussion_r221949410 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoin

[GitHub] zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221951599 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handle

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635483#comment-16635483 ] ASF GitHub Bot commented on FLINK-10309: zentol commented on a change in pull re

[GitHub] GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221954026 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/a

[GitHub] zentol commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools URL: https://github.com/apache/flink/pull/6786#discussion_r221954095 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoin

[GitHub] GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
GJL commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221953953 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/a

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635490#comment-16635490 ] ASF GitHub Bot commented on FLINK-10309: GJL commented on a change in pull reque

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635492#comment-16635492 ] ASF GitHub Bot commented on FLINK-10292: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635489#comment-16635489 ] ASF GitHub Bot commented on FLINK-10309: GJL commented on a change in pull reque

[GitHub] tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system URL: https://github.com/apache/flink/pull/6759#discussion_r221948861 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/Clu

[GitHub] tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system URL: https://github.com/apache/flink/pull/6759#discussion_r221951444 ## File path: flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtil

[GitHub] tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system URL: https://github.com/apache/flink/pull/6759#discussion_r221953502 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/T

[GitHub] tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system URL: https://github.com/apache/flink/pull/6759#discussion_r221952097 ## File path: flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtil

[GitHub] tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system URL: https://github.com/apache/flink/pull/6759#discussion_r221953394 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/T

[GitHub] tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system URL: https://github.com/apache/flink/pull/6759#discussion_r221954043 ## File path: flink-core/src/main/java/org/apache/flink/configuration/HighAvailab

[GitHub] tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system URL: https://github.com/apache/flink/pull/6759#discussion_r221948651 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/Clu

[GitHub] tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system URL: https://github.com/apache/flink/pull/6759#discussion_r221949524 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/T

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635494#comment-16635494 ] ASF GitHub Bot commented on FLINK-10247: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635495#comment-16635495 ] ASF GitHub Bot commented on FLINK-10247: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635499#comment-16635499 ] ASF GitHub Bot commented on FLINK-10247: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635496#comment-16635496 ] ASF GitHub Bot commented on FLINK-10247: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635501#comment-16635501 ] ASF GitHub Bot commented on FLINK-10247: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635497#comment-16635497 ] ASF GitHub Bot commented on FLINK-10247: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635498#comment-16635498 ] ASF GitHub Bot commented on FLINK-10247: tillrohrmann commented on a change in p

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635500#comment-16635500 ] ASF GitHub Bot commented on FLINK-10247: tillrohrmann commented on a change in p

[GitHub] zentol commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools URL: https://github.com/apache/flink/pull/6786#discussion_r221955504 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoin

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635505#comment-16635505 ] ASF GitHub Bot commented on FLINK-10292: zentol commented on a change in pull re

[GitHub] zentol commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools URL: https://github.com/apache/flink/pull/6786#discussion_r221956230 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoin

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635509#comment-16635509 ] ASF GitHub Bot commented on FLINK-10292: zentol commented on a change in pull re

[jira] [Created] (FLINK-10481) Wordcount end-to-end test in docker env unstable

2018-10-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10481: - Summary: Wordcount end-to-end test in docker env unstable Key: FLINK-10481 URL: https://issues.apache.org/jira/browse/FLINK-10481 Project: Flink Issue Type

[jira] [Updated] (FLINK-10481) Wordcount end-to-end test in docker env unstable

2018-10-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10481: -- Description: The {{Wordcount end-to-end test in docker env}} fails sometimes on Travis with t

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635519#comment-16635519 ] Nico Kruber commented on FLINK-10455: - The following symptom may actually be a follo

[jira] [Commented] (FLINK-10225) Cannot access state from a empty taskmanager

2018-10-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635530#comment-16635530 ] Till Rohrmann commented on FLINK-10225: --- [~PierreZ], I think we would need to exte

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Affects Version/s: 1.6.1 > Standalone HA - Leader election is not triggered on los

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4 (edit: also h

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4. Happy to see

[jira] [Commented] (FLINK-10225) Cannot access state from a empty taskmanager

2018-10-02 Thread Pierre Zemb (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635612#comment-16635612 ] Pierre Zemb commented on FLINK-10225: - Cool, thanks [~till.rohrmann]! I would love t

[GitHub] fhueske commented on a change in pull request #6741: [FLINK-9712][table, docs] Document processing time Temporal Table Joins

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6741: [FLINK-9712][table,docs] Document processing time Temporal Table Joins URL: https://github.com/apache/flink/pull/6741#discussion_r220633447 ## File path: docs/dev/table/streaming/joins.md ## @@ -0,0 +1,93 @@ +--- +title:

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635619#comment-16635619 ] ASF GitHub Bot commented on FLINK-9712: --- fhueske commented on a change in pull requ

[GitHub] aljoscha commented on issue #6704: [FLINK-10354] Revert "[FLINK-6328] [chkPts] Don't add savepoints to CompletedCheckpointStore"

2018-10-02 Thread GitBox
aljoscha commented on issue #6704: [FLINK-10354] Revert "[FLINK-6328] [chkPts] Don't add savepoints to CompletedCheckpointStore" URL: https://github.com/apache/flink/pull/6704#issuecomment-426308841 @dawidwys I looked at the code again and I think it's good to merge. It's a serious bug whe

[jira] [Commented] (FLINK-10354) Savepoints should be counted as retained checkpoints

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635651#comment-16635651 ] ASF GitHub Bot commented on FLINK-10354: aljoscha commented on issue #6704: [FLI

[jira] [Commented] (FLINK-10474) Don't translate IN to JOIN with VALUES for streaming queries

2018-10-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635666#comment-16635666 ] Rong Rong commented on FLINK-10474: --- Yes. I think having cascaded predicates are defin

<    1   2   3   >