[GitHub] flink pull request #5898: [FLINK-9229] [table] Fix literal handling in code ...

2018-04-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5898#discussion_r183716031 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1274,30 +1276,46 @@ abstract class CodeGener

[jira] [Commented] (FLINK-9032) Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE

2018-04-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449784#comment-16449784 ] Chesnay Schepler commented on FLINK-9032: - It has disappeard from the docs since i

[jira] [Commented] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449779#comment-16449779 ] ASF GitHub Bot commented on FLINK-9179: --- Github user zentol commented on the issue:

[GitHub] flink issue #5856: [FLINK-9179] [conf] Fix deduplicate WebOptions.PORT and R...

2018-04-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5856 there are also other references: classes: * StreamExecutionEnvironment#createLocalEnvironmentWithWebUI * (scala) StreamExecutionEnvironment#createLocalEnvironmentWithWebUI * ExecutionEnv

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449774#comment-16449774 ] ASF GitHub Bot commented on FLINK-9190: --- Github user sihuazhou commented on the issu

[jira] [Commented] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449772#comment-16449772 ] ASF GitHub Bot commented on FLINK-9179: --- Github user zentol commented on the issue:

[GitHub] flink issue #5881: [FLINK-9190][yarn] fix YarnResourceManager sometimes does...

2018-04-24 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5881 +1 to wait for @tillrohrmann ---

[GitHub] flink issue #5856: [FLINK-9179] [conf] Fix deduplicate WebOptions.PORT and R...

2018-04-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5856 we should also update `flink-conf-yaml` which by default contains `web.port`. ---

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449766#comment-16449766 ] ASF GitHub Bot commented on FLINK-9190: --- Github user GJL commented on the issue:

[GitHub] flink issue #5881: [FLINK-9190][yarn] fix YarnResourceManager sometimes does...

2018-04-24 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5881 @sihuazhou I think are you right. I don't see an easy solution to this at the moment. ---

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449763#comment-16449763 ] ASF GitHub Bot commented on FLINK-8480: --- Github user florianschmidt1994 commented on

[GitHub] flink issue #5482: [FLINK-8480][DataStream] Add Java API for timebounded str...

2018-04-24 Thread florianschmidt1994
Github user florianschmidt1994 commented on the issue: https://github.com/apache/flink/pull/5482 Thanks for your comments @bowenli86 and sorry for the delay! I added some comments and some stuff I'll be addressing right away ---

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449760#comment-16449760 ] ASF GitHub Bot commented on FLINK-8480: --- Github user florianschmidt1994 commented on

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

2018-04-24 Thread florianschmidt1994
Github user florianschmidt1994 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r183712409 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java --- @@ -0,0 +1,480 @@

[jira] [Commented] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator

2018-04-24 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-8498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449749#comment-16449749 ] Julian Bauß commented on FLINK-8498: Thank you for your mail! I will be back in the o

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449751#comment-16449751 ] ASF GitHub Bot commented on FLINK-6719: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #5887: [FLINK-6719] [docs] Add details about fault-tolera...

2018-04-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5887#discussion_r183710783 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -271,9 +271,9 @@ override def onTimer(timestamp: Long, ctx: OnTimerContext, out: Collector[OUT

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449752#comment-16449752 ] ASF GitHub Bot commented on FLINK-6719: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449756#comment-16449756 ] ASF GitHub Bot commented on FLINK-6719: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449755#comment-16449755 ] ASF GitHub Bot commented on FLINK-6719: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449753#comment-16449753 ] ASF GitHub Bot commented on FLINK-6719: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449754#comment-16449754 ] ASF GitHub Bot commented on FLINK-6719: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449750#comment-16449750 ] ASF GitHub Bot commented on FLINK-6719: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #5887: [FLINK-6719] [docs] Add details about fault-tolera...

2018-04-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5887#discussion_r183708941 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -322,3 +322,26 @@ ctx.timerService.registerEventTimeTimer(coalescedTime) {% endhighlight %

[GitHub] flink pull request #5887: [FLINK-6719] [docs] Add details about fault-tolera...

2018-04-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5887#discussion_r183707625 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -322,3 +322,26 @@ ctx.timerService.registerEventTimeTimer(coalescedTime) {% endhighlight %

[GitHub] flink pull request #5887: [FLINK-6719] [docs] Add details about fault-tolera...

2018-04-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5887#discussion_r183708604 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -322,3 +322,26 @@ ctx.timerService.registerEventTimeTimer(coalescedTime) {% endhighlight %

[GitHub] flink pull request #5887: [FLINK-6719] [docs] Add details about fault-tolera...

2018-04-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5887#discussion_r183707389 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -271,9 +271,9 @@ override def onTimer(timestamp: Long, ctx: OnTimerContext, out: Collector[OUT

[GitHub] flink pull request #5887: [FLINK-6719] [docs] Add details about fault-tolera...

2018-04-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5887#discussion_r183708069 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -322,3 +322,26 @@ ctx.timerService.registerEventTimeTimer(coalescedTime) {% endhighlight %

[GitHub] flink pull request #5887: [FLINK-6719] [docs] Add details about fault-tolera...

2018-04-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5887#discussion_r183710303 --- Diff: docs/dev/stream/operators/process_function.md --- @@ -322,3 +322,26 @@ ctx.timerService.registerEventTimeTimer(coalescedTime) {% endhighlight %

[jira] [Updated] (FLINK-9216) Fix comparator violation

2018-04-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9216: Fix Version/s: 1.4.3 1.5.0 > Fix comparator violation > -

[jira] [Closed] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator

2018-04-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8498. --- Resolution: Duplicate Fix Version/s: (was: 1.4.3) (was: 1.5.0

[jira] [Updated] (FLINK-9216) Fix comparator violation

2018-04-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9216: Affects Version/s: 1.5.0 1.3.3 1.4.2 > Fix com

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449741#comment-16449741 ] ASF GitHub Bot commented on FLINK-9194: --- Github user yuqi1129 commented on a diff in

[GitHub] flink pull request #5902: [FLINK-9194][history] Add HistoryServer support to...

2018-04-24 Thread yuqi1129
Github user yuqi1129 commented on a diff in the pull request: https://github.com/apache/flink/pull/5902#discussion_r183709218 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java --- @@ -211,7 +215,7 @@ public void

[jira] [Commented] (FLINK-8202) Update queryable section on configuration page

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

[GitHub] flink pull request #5905: [FLINK-8202][QS][docs] Update QS configuration pag...

2018-04-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5905 [FLINK-8202][QS][docs] Update QS configuration page ## What is the purpose of the change This PR updates the Queryable State section of the configuration page. The content was copied from

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449736#comment-16449736 ] ASF GitHub Bot commented on FLINK-9194: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5902: [FLINK-9194][history] Add HistoryServer support to...

2018-04-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5902#discussion_r183707159 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java --- @@ -211,7 +215,7 @@ public void ru

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449733#comment-16449733 ] ASF GitHub Bot commented on FLINK-8480: --- Github user florianschmidt1994 commented on

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

2018-04-24 Thread florianschmidt1994
Github user florianschmidt1994 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r183706512 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimeBoundedStreamJoinOperator.java --- @@ -0,0 +1,480 @@

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449725#comment-16449725 ] ASF GitHub Bot commented on FLINK-9194: --- Github user yuqi1129 commented on a diff in

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449726#comment-16449726 ] ASF GitHub Bot commented on FLINK-8480: --- Github user florianschmidt1994 commented on

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449724#comment-16449724 ] ASF GitHub Bot commented on FLINK-9194: --- Github user yuqi1129 commented on a diff in

[GitHub] flink pull request #5902: [FLINK-9194][history] Add HistoryServer support to...

2018-04-24 Thread yuqi1129
Github user yuqi1129 commented on a diff in the pull request: https://github.com/apache/flink/pull/5902#discussion_r183702452 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java --- @@ -211,7 +215,7 @@ public void

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

2018-04-24 Thread florianschmidt1994
Github user florianschmidt1994 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r183705882 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java --- @@ -137,6 +158,151 @@ public EqualT

[GitHub] flink pull request #5902: [FLINK-9194][history] Add HistoryServer support to...

2018-04-24 Thread yuqi1129
Github user yuqi1129 commented on a diff in the pull request: https://github.com/apache/flink/pull/5902#discussion_r183697720 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexTaskManagersHandler.java --- @@ -83,6 +90,24 @@ protected JobVerte

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449720#comment-16449720 ] ASF GitHub Bot commented on FLINK-8620: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449721#comment-16449721 ] ASF GitHub Bot commented on FLINK-8620: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449719#comment-16449719 ] ASF GitHub Bot commented on FLINK-8620: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r183700946 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -488,13 +494,36 @@ public void addJar(Path jar) {

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r183703858 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheDirectoriesTest.java --- @@ -0,0 +1,209 @@ +/* + * Licensed to the

[GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS...

2018-04-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5580#discussion_r183702885 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheDirectoriesTest.java --- @@ -0,0 +1,209 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449718#comment-16449718 ] ASF GitHub Bot commented on FLINK-8480: --- Github user florianschmidt1994 commented on

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

2018-04-24 Thread florianschmidt1994
Github user florianschmidt1994 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r183704705 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java --- @@ -137,6 +158,151 @@ public EqualT

[jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449713#comment-16449713 ] ASF GitHub Bot commented on FLINK-8480: --- Github user florianschmidt1994 commented on

[GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun...

2018-04-24 Thread florianschmidt1994
Github user florianschmidt1994 commented on a diff in the pull request: https://github.com/apache/flink/pull/5482#discussion_r183703916 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java --- @@ -137,6 +158,151 @@ public EqualT

[jira] [Commented] (FLINK-9033) Replace usages of deprecated TASK_MANAGER_NUM_TASK_SLOTS

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449685#comment-16449685 ] ASF GitHub Bot commented on FLINK-9033: --- Github user zentol commented on the issue:

[GitHub] flink issue #5731: [FLINK-9033][config] Replace usages of deprecated TASK_MA...

2018-04-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5731 merging. ---

[GitHub] flink pull request #5823: [FLINK-9008] [e2e] Implements quickstarts end to e...

2018-04-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5823#discussion_r181699682 --- Diff: flink-end-to-end-tests/test-scripts/test-class/ElasticsearchStreamingJob.java --- @@ -0,0 +1,97 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #5823: [FLINK-9008] [e2e] Implements quickstarts end to e...

2018-04-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5823#discussion_r183698160 --- Diff: flink-end-to-end-tests/run-pre-commit-tests.sh --- @@ -53,6 +53,14 @@ if [ $EXIT_CODE == 0 ]; then EXIT_CODE=$? fi +if [ $EXI

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449683#comment-16449683 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449680#comment-16449680 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5823: [FLINK-9008] [e2e] Implements quickstarts end to e...

2018-04-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5823#discussion_r181699493 --- Diff: flink-end-to-end-tests/test-scripts/test-class/ElasticsearchStreamingJob.java --- @@ -0,0 +1,97 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #5823: [FLINK-9008] [e2e] Implements quickstarts end to e...

2018-04-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5823#discussion_r181700170 --- Diff: flink-end-to-end-tests/test-scripts/test_quickstarts.sh --- @@ -0,0 +1,123 @@ +#!/usr/bin/env bash +

[GitHub] flink pull request #5823: [FLINK-9008] [e2e] Implements quickstarts end to e...

2018-04-24 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5823#discussion_r181699430 --- Diff: flink-end-to-end-tests/test-scripts/test-class/ElasticsearchStreamingJob.java --- @@ -0,0 +1,97 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449682#comment-16449682 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449679#comment-16449679 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449681#comment-16449681 ] ASF GitHub Bot commented on FLINK-9008: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

2018-04-24 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449677#comment-16449677 ] Nico Kruber commented on FLINK-9230: one more: https://travis-ci.org/NicoK/flink/jobs/

[jira] [Updated] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

2018-04-24 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9230: --- Issue Type: Bug (was: Improvement) > WebFrontendITCase.testStopYarn is unstable > ---

[jira] [Updated] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

2018-04-24 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9230: --- Labels: test-stability (was: ) > WebFrontendITCase.testStopYarn is unstable > ---

[jira] [Updated] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

2018-04-24 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9230: --- Affects Version/s: 1.6.0 1.5.0 > WebFrontendITCase.testStopYarn is unstable > -

[jira] [Commented] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449664#comment-16449664 ] ASF GitHub Bot commented on FLINK-9212: --- Github user zentol commented on the issue:

[GitHub] flink issue #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler t...

2018-04-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5893 I'll address the remaining issues myself when merging, thanks for working on this! ---

[jira] [Created] (FLINK-9250) JoinTaskExternalITCase deadlocks on travis

2018-04-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9250: --- Summary: JoinTaskExternalITCase deadlocks on travis Key: FLINK-9250 URL: https://issues.apache.org/jira/browse/FLINK-9250 Project: Flink Issue Type: Bu

[GitHub] flink pull request #5904: [FLINK-9249][build] Add convenience profile for sk...

2018-04-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5904 [FLINK-9249][build] Add convenience profile for skipping non-essential plugins ## What is the purpose of the change This PR adds a convenience profile for skipping non-essential plugins when

[jira] [Commented] (FLINK-9249) Add convenience profile for skipping non-essential plugins

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

[jira] [Closed] (FLINK-9242) LocalEnvironment - Operator threads stuck on java.lang.Thread.State: WAITING

2018-04-24 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-9242. -- Resolution: Duplicate I suspect this is a duplicate of FLINK-9144 for which a fix was just merged April

[jira] [Updated] (FLINK-9249) Add convenience profile for skipping non-essential plugins

2018-04-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9249: Description: When compiling Flink devs can already set a variety of command line options to

[jira] [Created] (FLINK-9249) Add convenience profile for skipping non-essential plugins

2018-04-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9249: --- Summary: Add convenience profile for skipping non-essential plugins Key: FLINK-9249 URL: https://issues.apache.org/jira/browse/FLINK-9249 Project: Flink

[jira] [Updated] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes

2018-04-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9211: Component/s: REST > Job submission via REST/dashboard does not work on Kubernetes >

[jira] [Assigned] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes

2018-04-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9211: --- Assignee: Chesnay Schepler (was: Aljoscha Krettek) > Job submission via REST/dashboa

[jira] [Updated] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes

2018-04-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9211: Component/s: Job-Submission > Job submission via REST/dashboard does not work on Kubernetes

[jira] [Commented] (FLINK-9234) Commons Logging is missing from shaded Flink Table library

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449576#comment-16449576 ] ASF GitHub Bot commented on FLINK-9234: --- Github user twalthr commented on the issue:

[GitHub] flink issue #5897: [FLINK-9234] [table] Fix missing dependencies for externa...

2018-04-24 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5897 The Flink code doesn't need the `jcl` dependency but if `commons` libraries want to log something we should make this possible, right? Good point @zentol. I will verify the logs again. ---

[jira] [Closed] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

2018-04-24 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5372. - Resolution: Fixed Fix Version/s: (was: 1.4.3) 1.6.0 Fixed in: maste

[jira] [Commented] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes

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

[GitHub] flink pull request #5903: [FLINK-9211][REST] JarRunHandler submits job to Di...

2018-04-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5903 [FLINK-9211][REST] JarRunHandler submits job to Dispatcher via RPC ## What is the purpose of the change This PR reworks the `JarRunHandler` to submit the job to the dispatcher via RPC, inste

[jira] [Closed] (FLINK-9244) Can't create a BucketingSink with a provided Configuration if no hadoop defaults

2018-04-24 Thread Julien Cuquemelle (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julien Cuquemelle closed FLINK-9244. Resolution: Duplicate > Can't create a BucketingSink with a provided Configuration if no had

[jira] [Commented] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy

2018-04-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449502#comment-16449502 ] Fabian Hueske commented on FLINK-7484: -- Hi [~joshlemer], thanks for reporting the iss

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

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

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449492#comment-16449492 ] ASF GitHub Bot commented on FLINK-9194: --- Github user zentol commented on the issue:

[GitHub] flink issue #5888: [FLINK-9194] [histroyserver] Finished jobs are not archiv...

2018-04-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5888 see #5902. ---

[GitHub] flink pull request #5902: [FLINK-9194][history] Add HistoryServer support to...

2018-04-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5902 [FLINK-9194][history] Add HistoryServer support to flip6 This PR subsumes #5888. ## What is the purpose of the change This PR adds HistoryServer support to Flip6, i.e. allows the Dis

[jira] [Created] (FLINK-9248) Create a SQL Client Avro format fat-jar

2018-04-24 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9248: --- Summary: Create a SQL Client Avro format fat-jar Key: FLINK-9248 URL: https://issues.apache.org/jira/browse/FLINK-9248 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9247) Allow creating table sources/sinks from an Avro schema

2018-04-24 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9247: --- Summary: Allow creating table sources/sinks from an Avro schema Key: FLINK-9247 URL: https://issues.apache.org/jira/browse/FLINK-9247 Project: Flink Issue Type

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

2018-04-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16449465#comment-16449465 ] ASF GitHub Bot commented on FLINK-8537: --- Github user asfgit closed the pull request

[GitHub] flink pull request #5610: [FLINK-8537][table]Add a Kafka table source factor...

2018-04-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5610 ---

[jira] [Resolved] (FLINK-8537) Add a Kafka table source factory with Avro format support

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

[jira] [Created] (FLINK-9246) HistoryServer job overview broken

2018-04-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9246: --- Summary: HistoryServer job overview broken Key: FLINK-9246 URL: https://issues.apache.org/jira/browse/FLINK-9246 Project: Flink Issue Type: Bug

<    1   2   3   >