[jira] [Resolved] (FLINK-9763) Flink SQL Client bat script

2018-07-10 Thread Pavel Shvetsov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pavel Shvetsov resolved FLINK-9763. --- Resolution: Fixed > Flink SQL Client bat script > --- > >

[jira] [Reopened] (FLINK-9763) Flink SQL Client bat script

2018-07-10 Thread Pavel Shvetsov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pavel Shvetsov reopened FLINK-9763: --- > Flink SQL Client bat script > --- > > Key: FLINK-9763

[jira] [Commented] (FLINK-9004) Cluster test: Run general purpose job with failures with Yarn session

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538459#comment-16538459 ] ASF GitHub Bot commented on FLINK-9004: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #6240: [FLINK-9004][tests] Implement Jepsen tests to test...

2018-07-10 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/6240#discussion_r201312394 --- Diff: flink-jepsen/src/jepsen/flink/db.clj --- @@ -175,7 +175,7 @@ (c/su (c/exec (c/lit (str "HADOOP_CLASSPATH=`"

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538461#comment-16538461 ] ASF GitHub Bot commented on FLINK-9013: --- GitHub user dawidwys opened a pull request:

[jira] [Updated] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9013: -- Labels: pull-request-available (was: ) > Document yarn.containers.vcores only being effective

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538462#comment-16538462 ] ASF GitHub Bot commented on FLINK-9013: --- Github user dawidwys commented on the issue:

[GitHub] flink pull request #6292: [FLINK-9789][metrics] Ensure uniqueness of waterma...

2018-07-10 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6292#discussion_r201313023 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/InterceptingTaskMetricGroup.java --- @@ -0,0 +1,53 @@ +/* + * Licensed

[GitHub] flink pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores...

2018-07-10 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/6294 [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe… Added required configuration documentation on the cluster side for the parameter `yarn.containers.vcores` to take

[GitHub] flink issue #6294: [FLINK-9013][docs] Document yarn.containers.vcores only b...

2018-07-10 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6294 @NicoK Could you have a look, as you were the one that created this issue? ---

[jira] [Commented] (FLINK-9779) Remove SlotRequest timeout

2018-07-10 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538463#comment-16538463 ] 陈梓立 commented on FLINK-9779: [~aljoscha] yes, current behavior is replace internal timeout with external

[jira] [Commented] (FLINK-9222) Add a Gradle Quickstart

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538465#comment-16538465 ] ASF GitHub Bot commented on FLINK-9222: --- Github user NicoK commented on the issue:

[GitHub] flink issue #5900: [FLINK-9222][docs] add documentation for setting up Gradl...

2018-07-10 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5900 Hi @twalthr, I just created a fixup commit for this PR and the one for `flink-web`. Can you have a second look? ---

[jira] [Commented] (FLINK-9789) Watermark metrics for an operator shadow each other

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538464#comment-16538464 ] ASF GitHub Bot commented on FLINK-9789: --- Github user yanghua commented on a diff in the pull

[jira] [Updated] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

2018-07-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9340: -- Labels: runtime (was: ) > ScheduleOrUpdateConsumersTest may fail with Address already in use >

[jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2018-07-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281 ] Ted Yu edited comment on FLINK-6105 at 7/10/18 11:55 AM: - In

[jira] [Commented] (FLINK-9789) Watermark metrics for an operator shadow each other

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538476#comment-16538476 ] ASF GitHub Bot commented on FLINK-9789: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6292: [FLINK-9789][metrics] Ensure uniqueness of waterma...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6292#discussion_r201315827 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/util/InterceptingTaskMetricGroup.java --- @@ -0,0 +1,53 @@ +/* + * Licensed

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538499#comment-16538499 ] ASF GitHub Bot commented on FLINK-9743: --- Github user zentol commented on a diff in the pull

[GitHub] flink issue #6263: [FLINK-9743][Client] Use correct zip/jar path separator

2018-07-10 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6263 If it work I'll fix the issue I found and merge it afterwards. ---

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538500#comment-16538500 ] ASF GitHub Bot commented on FLINK-9743: --- Github user zentol commented on the issue:

[GitHub] flink pull request #6090: [FLINK-8863] [SQL] Add user-defined function suppo...

2018-07-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6090 ---

[jira] [Resolved] (FLINK-8863) Add user-defined function support in SQL Client

2018-07-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8863. - Resolution: Fixed Fix Version/s: 1.6.0 Fixed in 1.6.0: 

[jira] [Commented] (FLINK-8863) Add user-defined function support in SQL Client

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538510#comment-16538510 ] ASF GitHub Bot commented on FLINK-8863: --- Github user asfgit closed the pull request at:

[jira] [Created] (FLINK-9790) Add documentation for UDF in SQL Client

2018-07-10 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9790: --- Summary: Add documentation for UDF in SQL Client Key: FLINK-9790 URL: https://issues.apache.org/jira/browse/FLINK-9790 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #6264: [FLINK-8558] [table] Add unified format interfaces...

2018-07-10 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6264#discussion_r201308428 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/formats/TableFormatFactoryService.scala --- @@ -0,0 +1,245 @@ +/* + *

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538430#comment-16538430 ] ASF GitHub Bot commented on FLINK-8558: --- Github user twalthr commented on a diff in the pull

[GitHub] flink issue #6231: [FLINK-9694] Potentially NPE in CompositeTypeSerializerCo...

2018-07-10 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6231 @pnowojski can you review this? ---

[GitHub] flink pull request #6264: [FLINK-8558] [table] Add unified format interfaces...

2018-07-10 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6264#discussion_r201309003 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/DefinedFieldMapping.scala --- @@ -50,7 +50,8 @@ trait

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538435#comment-16538435 ] ASF GitHub Bot commented on FLINK-8558: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-9694) Potentially NPE in CompositeTypeSerializerConfigSnapshot constructor

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538432#comment-16538432 ] ASF GitHub Bot commented on FLINK-9694: --- Github user yanghua commented on the issue:

[GitHub] flink issue #6286: [FLINK-9754][release] Remove references to scala profiles

2018-07-10 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6286 +1 ---

[jira] [Commented] (FLINK-9754) Release scripts refers to non-existing profile

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538434#comment-16538434 ] ASF GitHub Bot commented on FLINK-9754: --- Github user yanghua commented on the issue:

[GitHub] flink issue #6285: [FLINK-9768][release] Speed up binary release

2018-07-10 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6285 +1 ---

[jira] [Commented] (FLINK-9768) Only build flink-dist for binary releases

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538441#comment-16538441 ] ASF GitHub Bot commented on FLINK-9768: --- Github user yanghua commented on the issue:

[GitHub] flink issue #6284: [FLINK-9762] CoreOptions.TMP_DIRS ('io.tmp.dirs') wrongly...

2018-07-10 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6284 find related test error, please recheck~ ---

[jira] [Commented] (FLINK-9762) CoreOptions.TMP_DIRS wrongly managed on Yarn

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538442#comment-16538442 ] ASF GitHub Bot commented on FLINK-9762: --- Github user yanghua commented on the issue:

[jira] [Commented] (FLINK-9222) Add a Gradle Quickstart

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538444#comment-16538444 ] ASF GitHub Bot commented on FLINK-9222: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #5900: [FLINK-9222][docs] add documentation for setting u...

2018-07-10 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/5900#discussion_r201310579 --- Diff: docs/quickstart/java_api_quickstart.md --- @@ -108,16 +118,201 @@ In Eclipse, choose box: `-Xmx800m`. In IntelliJ IDEA recommended way to

[jira] [Updated] (FLINK-9789) Watermark metrics for an operator shadow each other

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9789: -- Labels: pull-request-available (was: ) > Watermark metrics for an operator shadow each other

[jira] [Commented] (FLINK-9789) Watermark metrics for an operator shadow each other

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538446#comment-16538446 ] ASF GitHub Bot commented on FLINK-9789: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #6292: [FLINK-9789][metrics] Ensure uniqueness of waterma...

2018-07-10 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/6292 [FLINK-9789][metrics] Ensure uniqueness of watermark metrics ## What is the purpose of the change This PR ensures that all registered watermark metric objects are only registered once;

[GitHub] flink pull request #6293: [FLINK-9763] [Startup Shell Scripts] Flink SQL Cli...

2018-07-10 Thread pavel-shvetsov-git
GitHub user pavel-shvetsov-git opened a pull request: https://github.com/apache/flink/pull/6293 [FLINK-9763] [Startup Shell Scripts] Flink SQL Client bat script ## What is the purpose of the change This PR adds a bat script for launching SQL client under Windows. See

[jira] [Updated] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering

2018-07-10 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9788: - Fix Version/s: 1.6.0 > ExecutionGraph Inconsistency prevents Job from recovering >

[jira] [Commented] (FLINK-9763) Flink SQL Client bat script

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538448#comment-16538448 ] ASF GitHub Bot commented on FLINK-9763: --- GitHub user pavel-shvetsov-git opened a pull request:

[jira] [Updated] (FLINK-9763) Flink SQL Client bat script

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9763: -- Labels: pull-request-available (was: ) > Flink SQL Client bat script >

[jira] [Updated] (FLINK-9782) BucketingSink E2E test fails on travis

2018-07-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9782: Labels: test-stability (was: ) > BucketingSink E2E test fails on travis >

[jira] [Commented] (FLINK-9779) Remove SlotRequest timeout

2018-07-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538453#comment-16538453 ] Aljoscha Krettek commented on FLINK-9779: - Is this still relevant? I saw you closed the other

[GitHub] flink pull request #6263: [FLINK-9743][Client] Use correct zip/jar path sepa...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6263#discussion_r201322209 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/PackagedProgramTest.java --- @@ -21,16 +21,24 @@ import

[jira] [Updated] (FLINK-9790) Add documentation for UDF in SQL Client

2018-07-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9790: Issue Type: Sub-task (was: Improvement) Parent: FLINK-7594 > Add documentation for UDF in

[jira] [Updated] (FLINK-9790) Add documentation for UDF in SQL Client

2018-07-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9790: Description: UDF support for the SQL client has been merge in FLINK-8863. Documentation is missing

[jira] [Updated] (FLINK-9790) Add documentation for UDF in SQL Client

2018-07-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9790: Description: UDF support for the SQL client has been merge in  > Add documentation for UDF in SQL

[jira] [Commented] (FLINK-9222) Add a Gradle Quickstart

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538345#comment-16538345 ] ASF GitHub Bot commented on FLINK-9222: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #5900: [FLINK-9222][docs] add documentation for setting u...

2018-07-10 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/5900#discussion_r201286036 --- Diff: docs/quickstart/java_api_quickstart.md --- @@ -108,16 +118,201 @@ In Eclipse, choose box: `-Xmx800m`. In IntelliJ IDEA recommended way to

[jira] [Updated] (FLINK-9787) Change ExecutionConfig#getGlobalJobParameters to return an instance of GlobalJobParameters instead of null if no custom globalJobParameters are set yet

2018-07-10 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-9787: --- Fix Version/s: 2.0.0 Description: Currently when accessing 

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538366#comment-16538366 ] ASF GitHub Bot commented on FLINK-9743: --- Github user zentol commented on a diff in the pull

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538364#comment-16538364 ] ASF GitHub Bot commented on FLINK-9743: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6263: [FLINK-9743][Client] Use correct zip/jar path sepa...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6263#discussion_r201291422 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/PackagedProgramTest.java --- @@ -56,6 +63,54 @@ public void testGetPreviewPlan() {

[GitHub] flink pull request #6263: [FLINK-9743][Client] Use correct zip/jar path sepa...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6263#discussion_r201291547 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/PackagedProgramTest.java --- @@ -56,6 +63,54 @@ public void testGetPreviewPlan() {

[GitHub] flink pull request #6263: [FLINK-9743][Client] Use correct zip/jar path sepa...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6263#discussion_r201291704 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/PackagedProgramTest.java --- @@ -56,6 +63,54 @@ public void testGetPreviewPlan() {

[GitHub] flink pull request #6263: [FLINK-9743][Client] Use correct zip/jar path sepa...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6263#discussion_r201291316 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/PackagedProgramTest.java --- @@ -56,6 +63,54 @@ public void testGetPreviewPlan() {

[GitHub] flink pull request #6263: [FLINK-9743][Client] Use correct zip/jar path sepa...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6263#discussion_r201291489 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/PackagedProgramTest.java --- @@ -56,6 +63,54 @@ public void testGetPreviewPlan() {

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538362#comment-16538362 ] ASF GitHub Bot commented on FLINK-9743: --- Github user zentol commented on a diff in the pull

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538361#comment-16538361 ] ASF GitHub Bot commented on FLINK-9743: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6263: [FLINK-9743][Client] Use correct zip/jar path sepa...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6263#discussion_r201291273 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/PackagedProgramTest.java --- @@ -56,6 +63,54 @@ public void testGetPreviewPlan() {

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538365#comment-16538365 ] ASF GitHub Bot commented on FLINK-9743: --- Github user zentol commented on a diff in the pull

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538371#comment-16538371 ] ASF GitHub Bot commented on FLINK-9676: --- Github user zhijiangW commented on a diff in the pull

[GitHub] flink pull request #6254: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-10 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/6254#discussion_r201293862 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -594,22 +626,22 @@ public

[jira] [Created] (FLINK-9789) Watermark metrics for an operator shadow each other

2018-07-10 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9789: --- Summary: Watermark metrics for an operator shadow each other Key: FLINK-9789 URL: https://issues.apache.org/jira/browse/FLINK-9789 Project: Flink

[jira] [Updated] (FLINK-9789) Watermark metrics for an operator shadow each other

2018-07-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9789: Description: In FLINK-4812 we reworked the watermark metrics to be exposed for each

[GitHub] flink pull request #6291: [FLINK-9785][network] add remote address informati...

2018-07-10 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6291#discussion_r201304267 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandler.java --- @@ -164,7 +164,9 @@ public void

[jira] [Commented] (FLINK-9785) Add remote addresses to LocalTransportException instances

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538413#comment-16538413 ] ASF GitHub Bot commented on FLINK-9785: --- Github user yanghua commented on a diff in the pull

[jira] [Commented] (FLINK-9785) Add remote addresses to LocalTransportException instances

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538414#comment-16538414 ] ASF GitHub Bot commented on FLINK-9785: --- Github user yanghua commented on a diff in the pull

[GitHub] flink pull request #6291: [FLINK-9785][network] add remote address informati...

2018-07-10 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6291#discussion_r201303678 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java --- @@ -167,7 +167,8 @@

[GitHub] flink pull request #6264: [FLINK-8558] [table] Add unified format interfaces...

2018-07-10 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6264#discussion_r201307506 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala --- @@ -110,16 +111,44 @@ abstract class

[GitHub] flink issue #6277: [FLINK-9511] Implement TTL config

2018-07-10 Thread azagrebin
Github user azagrebin commented on the issue: https://github.com/apache/flink/pull/6277 LGTM cc @StefanRRichter ---

[jira] [Commented] (FLINK-9511) Implement TTL config

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538349#comment-16538349 ] ASF GitHub Bot commented on FLINK-9511: --- Github user azagrebin commented on the issue:

[jira] [Updated] (FLINK-9741) Register JVM metrics for each JM separately

2018-07-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9741: Fix Version/s: (was: 1.6.0) 1.7.0 > Register JVM metrics for each

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-07-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6053: Fix Version/s: (was: 1.6.0) 1.7.0 > Gauge should only take

[jira] [Updated] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2018-07-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6900: Fix Version/s: (was: 1.6.0) 1.7.0 > Limit size of indiivual

[jira] [Commented] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538367#comment-16538367 ] ASF GitHub Bot commented on FLINK-9755: --- Github user zhijiangW commented on a diff in the pull

[jira] [Commented] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538368#comment-16538368 ] ASF GitHub Bot commented on FLINK-9755: --- Github user zhijiangW commented on the issue:

[GitHub] flink pull request #6272: [FLINK-9755][network] forward exceptions in Remote...

2018-07-10 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/6272#discussion_r201292263 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -360,32 +360,45 @@ public

[GitHub] flink issue #6272: [FLINK-9755][network] forward exceptions in RemoteInputCh...

2018-07-10 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/6272 LGTM! ---

[jira] [Commented] (FLINK-9743) PackagedProgram.extractContainedLibraries fails on Windows

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538363#comment-16538363 ] ASF GitHub Bot commented on FLINK-9743: --- Github user zentol commented on a diff in the pull

[jira] [Created] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering

2018-07-10 Thread Gary Yao (JIRA)
Gary Yao created FLINK-9788: --- Summary: ExecutionGraph Inconsistency prevents Job from recovering Key: FLINK-9788 URL: https://issues.apache.org/jira/browse/FLINK-9788 Project: Flink Issue Type:

[GitHub] flink pull request #6254: [FLINK-9676][network] clarify contracts of BufferL...

2018-07-10 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/6254#discussion_r201293052 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -479,6 +508,9 @@ void

[jira] [Commented] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538374#comment-16538374 ] ASF GitHub Bot commented on FLINK-9676: --- Github user zhijiangW commented on a diff in the pull

[jira] [Updated] (FLINK-9789) Watermark metrics for an operator shadow each other

2018-07-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9789: Fix Version/s: 1.6.0 1.5.2 > Watermark metrics for an operator shadow

[jira] [Updated] (FLINK-9789) Watermark metrics for an operator shadow each other

2018-07-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9789: Affects Version/s: (was: 1.5.1) 1.5.0 > Watermark metrics for

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538426#comment-16538426 ] ASF GitHub Bot commented on FLINK-8558: --- Github user twalthr commented on a diff in the pull

[GitHub] flink issue #6290: [Flink-9691] [Kinesis Connector] Attempt to call getRecor...

2018-07-10 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6290 +1, from my side~ ---

[GitHub] flink issue #6272: [FLINK-9755][network] forward exceptions in RemoteInputCh...

2018-07-10 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/6272 actually, I forgot to adapt the unit test which relied on the previous order of the calls and assumed that the buffer got recycled. With the changes from the fixup, the buffer is not recycled by the

[GitHub] flink pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6294#discussion_r201329612 --- Diff: docs/ops/deployment/yarn_setup.md --- @@ -132,7 +132,10 @@ Stop the YARN session by stopping the unix process (using CTRL+C) or by entering

[jira] [Commented] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538520#comment-16538520 ] ASF GitHub Bot commented on FLINK-9755: --- Github user NicoK commented on the issue:

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538523#comment-16538523 ] ASF GitHub Bot commented on FLINK-9013: --- Github user zentol commented on a diff in the pull

[jira] [Commented] (FLINK-9703) Mesos does not expose TM Prometheus port

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538529#comment-16538529 ] ASF GitHub Bot commented on FLINK-9703: --- Github user zentol commented on a diff in the pull

[GitHub] flink pull request #6288: [FLINK-9703] [flink-mesos] Expose Prometheus port ...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6288#discussion_r201331084 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java --- @@ -332,6 +334,22 @@ public String

[GitHub] flink pull request #6288: [FLINK-9703] [flink-mesos] Expose Prometheus port ...

2018-07-10 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6288#discussion_r201331518 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java --- @@ -332,6 +334,22 @@ public String

[jira] [Commented] (FLINK-9703) Mesos does not expose TM Prometheus port

2018-07-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538530#comment-16538530 ] ASF GitHub Bot commented on FLINK-9703: --- Github user zentol commented on a diff in the pull

  1   2   3   4   >