[GitHub] flink pull request #5438: [FLINK-8617][TableAPI & SQL] Fix code generation b...

2018-02-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5438 ---

[jira] [Commented] (FLINK-8617) Fix code generation bug while accessing Map type

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

[jira] [Commented] (FLINK-8625) Move OutputFlusher thread to Netty scheduled executor

2018-02-12 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360533#comment-16360533 ] mingleizhang commented on FLINK-8625: - Thanks [~pnowojski] We can improve the performance and reduce

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

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

[jira] [Updated] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8042: Issue Type: Improvement (was: Bug) > Retry individual failover-strategy for some time

[jira] [Updated] (FLINK-5763) Make savepoints self-contained and relocatable

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5763: Fix Version/s: (was: 1.5.0) 1.6.0 > Make savepoints self-contained

[GitHub] flink pull request #5455: [FLINK-7711][flip6] Port JarListHandler

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5455#discussion_r167528319 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java --- @@ -0,0 +1,156 @@ +/* + *

[jira] [Updated] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8411: Issue Type: Improvement (was: Bug) > HeapListState#add(null) will wipe out entire list

[jira] [Updated] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8411: Priority: Blocker (was: Critical) > HeapListState#add(null) will wipe out entire list

[GitHub] flink pull request #5459: [FLINK-8475][config][docs] Integrate FS options

2018-02-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5459 [FLINK-8475][config][docs] Integrate FS options ## What is the purpose of the change This PR ports the fileystem ConfigConstants to `ConfigOptions` and integrates them into the

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

2018-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360573#comment-16360573 ] Till Rohrmann commented on FLINK-8459: -- Hi [~yanghua], thanks for working on this issue? How do you

[jira] [Updated] (FLINK-8630) To support JSON schema to TypeInformation conversion

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8630: Priority: Blocker (was: Major) > To support JSON schema to TypeInformation conversion >

[jira] [Updated] (FLINK-8630) To support JSON schema to TypeInformation conversion

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8630: Fix Version/s: 1.5.0 > To support JSON schema to TypeInformation conversion >

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

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

[GitHub] flink pull request #5443: [FLINK-8626] Introduce BackPressureStatsTracker in...

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5443#discussion_r167502561 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/JobVertexBackPressureHandlerTest.java --- @@ -57,7 +57,7 @@ public

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-12 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360559#comment-16360559 ] Xingcan Cui commented on FLINK-8538: Hi [~twalthr] and [~fhueske], I committed a WIP branch to my

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360606#comment-16360606 ] Timo Walther commented on FLINK-8538: - Thanks for working on this [~xccui]. I had a quick look at it.

[jira] [Updated] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8623: Priority: Blocker (was: Critical) >

[jira] [Closed] (FLINK-8172) Remove unnecessary synchronisation in RecordSerializer

2018-02-12 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-8172. - Resolution: Fixed The issue was superseded by https://issues.apache.org/jira/browse/FLINK-8178 

[GitHub] flink pull request #5455: [FLINK-7711][flip6] Port JarListHandler

2018-02-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5455#discussion_r167540798 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java --- @@ -0,0 +1,156 @@ +/* + * Licensed

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

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

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360480#comment-16360480 ] Aljoscha Krettek commented on FLINK-8543: - Also, I think it would help to have the stack trace at

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

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

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

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

[GitHub] flink pull request #5443: [FLINK-8626] Introduce BackPressureStatsTracker in...

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5443#discussion_r167501726 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/JobVertexBackPressureHandlerTest.java --- @@ -57,7 +57,7 @@ public

[GitHub] flink pull request #5443: [FLINK-8626] Introduce BackPressureStatsTracker in...

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5443#discussion_r167501690 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java --- @@ -143,7 +143,7 @@ private

[jira] [Resolved] (FLINK-8617) Fix code generation bug while accessing Map type

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

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167523546 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167525322 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java --- @@ -207,6 +215,53 @@ public static WebMonitor

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167520629 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java --- @@ -0,0 +1,103 @@ +/* + *

[jira] [Commented] (FLINK-8625) Move OutputFlusher thread to Netty scheduled executor

2018-02-12 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360611#comment-16360611 ] Piotr Nowojski commented on FLINK-8625: --- I have found one more thing. After fixing the current

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167522151 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167523095 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167525118 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java --- @@ -207,6 +215,53 @@ public static WebMonitor

[GitHub] flink pull request #5460: [FLINK-8475][config][docs] Integrate Algorithm opt...

2018-02-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5460 [FLINK-8475][config][docs] Integrate Algorithm options ## What is the purpose of the change This PR ports the runtime algorithm ConfigConstants to `ConfigOptions` and integrates them into

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

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

[jira] [Commented] (FLINK-8212) Pull EnvironmentInformation out of TaskManagerServices

2018-02-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360577#comment-16360577 ] Till Rohrmann commented on FLINK-8212: -- Hi [~mingleizhang], I think the proper way to solve this

[jira] [Assigned] (FLINK-8630) To support JSON schema to TypeInformation conversion

2018-02-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-8630: --- Assignee: Timo Walther > To support JSON schema to TypeInformation conversion >

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167542881 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java --- @@ -0,0 +1,103 @@ +/* + *

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360470#comment-16360470 ] Aljoscha Krettek commented on FLINK-8543: - There is no other failure or anything suspicious in the

[jira] [Commented] (FLINK-8617) Fix code generation bug while accessing Map type

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

[GitHub] flink pull request #5438: [FLINK-8617][TableAPI & SQL] Fix code generation b...

2018-02-12 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/5438#discussion_r167503729 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -351,7 +351,7 @@ object

[jira] [Updated] (FLINK-8621) PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8621: Priority: Blocker (was: Critical) >

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360477#comment-16360477 ] Aljoscha Krettek commented on FLINK-8543: - And was there a failure/restore cycle before that error

[jira] [Commented] (FLINK-8212) Pull EnvironmentInformation out of TaskManagerServices

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360482#comment-16360482 ] ASF GitHub Bot commented on FLINK-8212: --- GitHub user zhangminglei opened a pull request:

[GitHub] flink pull request #5458: [FLINK-8212] [network] Pull EnvironmentInformation...

2018-02-12 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5458 [FLINK-8212] [network] Pull EnvironmentInformation out of TaskManager… ## What is the purpose of the change Pull EnvironmentInformation out of TaskManagerServices ## Brief

[jira] [Updated] (FLINK-8614) Enable Flip-6 per default

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8614: Priority: Blocker (was: Critical) > Enable Flip-6 per default > -

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360630#comment-16360630 ] Fabian Hueske commented on FLINK-8538: -- Hi, I agree with [~twalthr]. This looks mostly good, but we

[jira] [Commented] (FLINK-7952) Add metrics for counting logging events

2018-02-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360646#comment-16360646 ] Chesnay Schepler commented on FLINK-7952: - I question the value of having this counter as part of

[GitHub] flink pull request #5455: [FLINK-7711][flip6] Port JarListHandler

2018-02-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5455#discussion_r167542075 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java --- @@ -0,0 +1,156 @@ +/* + * Licensed

[GitHub] flink pull request #5455: [FLINK-7711][flip6] Port JarListHandler

2018-02-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5455#discussion_r167541843 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java --- @@ -0,0 +1,103 @@ +/* + *

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[GitHub] flink pull request #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5461 [FLINK-8475][config][docs] Integrate Mesos options ## What is the purpose of the change This PR integrates the Mesos `ConfigOptions` into the configuration docs generator. ## Brief

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

2018-02-12 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360758#comment-16360758 ] vinoyang commented on FLINK-8459: - Hi [~till.rohrmann] , my idea is like yours in a way, refer to the

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-8639) Fix always need to seek multiple times when iterator RocksDBMapState

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360825#comment-16360825 ] ASF GitHub Bot commented on FLINK-8639: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5461 The current documentation has `high-availability.zookeeper.path.mesos-workers: The ZooKeeper root path for persisting the Mesos worker information.` Do you know why this is not there anymore?

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5461 That option is defined in the `HighAvailabilityOptions`, far away from the mesos option classes.. ---

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360943#comment-16360943 ] ASF GitHub Bot commented on FLINK-8530: --- GitHub user tillrohrmann opened a pull request:

[jira] [Assigned] (FLINK-8640) Disable japicmp on java 9

2018-02-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-8640: --- Assignee: Chesnay Schepler > Disable japicmp on java 9 > - >

[GitHub] flink pull request #5466: [FLINK-8530] [flip6] Enable detached job mode subm...

2018-02-12 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5466 [FLINK-8530] [flip6] Enable detached job mode submission to session cluster ## What is the purpose of the change This commit makes the RestClusterClient aware whether the user wishes

[jira] [Created] (FLINK-8640) Disable japicmp on java 9

2018-02-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8640: --- Summary: Disable japicmp on java 9 Key: FLINK-8640 URL: https://issues.apache.org/jira/browse/FLINK-8640 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #5460: [FLINK-8475][config][docs] Integrate Algorithm options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5460 Ah, nevermind that last comment, we can't remove them because it's `@Public` api. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5461 Currently we assign each `ConfigOption` to exactly one table, so there's little we can do at the moment about this option. ---

[GitHub] flink issue #5391: [FLINK-8475][config][docs] Integrate BlobServer options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5391 yes, this wasn't in there at all :) merging. ---

[GitHub] flink issue #5390: [FLINK-8475][config][docs] Integrate SlotManager options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5390 merging. ---

[jira] [Updated] (FLINK-8621) PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8621: Fix Version/s: 1.4.2 > PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed

[jira] [Updated] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8402: Fix Version/s: 1.4.2 > HadoopS3FileSystemITCase.testDirectoryListing fails on Travis >

[jira] [Updated] (FLINK-8337) GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled instable

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8337: Fix Version/s: 1.4.2 > GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled

[jira] [Updated] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8521: Fix Version/s: 1.4.2 > FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out

[jira] [Updated] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8623: Fix Version/s: 1.4.2 > ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics

[jira] [Updated] (FLINK-8336) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8336: Fix Version/s: 1.4.2 > YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test

[jira] [Updated] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis

2018-02-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8408: Fix Version/s: 1.4.2 > YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5461 And I like how the options where not sorted before and also related options where not next to each other ... 😅 ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360881#comment-16360881 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5461 Looks good except for the one question I had! 👍 ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360882#comment-16360882 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360884#comment-16360884 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360894#comment-16360894 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-12 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360725#comment-16360725 ] Xingcan Cui commented on FLINK-8538: Thanks for the comments, [~twalthr] and [~fhueske]. Yes, the

[GitHub] flink pull request #5462: [FLINK-8475][config][docs] Integrate HA-ZK options

2018-02-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5462 [FLINK-8475][config][docs] Integrate HA-ZK options ## What is the purpose of the change This PR integrates the Zookeeper HA `ConfigOptions` into the configuration docs generator.

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

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

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

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

[GitHub] flink issue #5461: [FLINK-8475][config][docs] Integrate Mesos options

2018-02-12 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5461 So when we get to the HA options this will show up again? If yes, please go ahead. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

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

[GitHub] flink issue #5389: [FLINK-8475][config][docs] Integrate REST options

2018-02-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5389 merging. ---

  1   2   3   >