[GitHub] flink issue #6129: [FLINK-9503] Migrate integration tests for iterative aggr...

2018-06-12 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6129 +1 ---

[jira] [Commented] (FLINK-9503) Migrate integration tests for iterative aggregators

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

[GitHub] flink pull request #6129: [FLINK-9503] Migrate integration tests for iterati...

2018-06-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6129#discussion_r194694357 --- Diff: flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/AggregatorsITCase.java --- @@ -170,12 +162,12 @@ public void

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6071#discussion_r194718801 --- Diff: flink-tests/src/test/java/org/apache/flink/test/runtime/NettyEpollITCase.java --- @@ -0,0 +1,103 @@ +/* + * Licensed to the Apache

[jira] [Closed] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-06-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8946. --- Resolution: Fixed master: 0f5cf7b15592dd5d9a9303bf7a806d553e679d17 1.5:

[GitHub] flink issue #6083: [FLINK-8983] End-to-end test: Confluent schema registry

2018-06-12 Thread dmpour23
Github user dmpour23 commented on the issue: https://github.com/apache/flink/pull/6083 Hi would this work for KeyedDeserialization/KeyedSerializationSchema. Should the import be: > org.apache.flink.api.common.serialization.DeserializationSchema ---

[GitHub] flink pull request #6151: [FLINK-9569] [avro] Fix confusing construction of ...

2018-06-12 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/6151 [FLINK-9569] [avro] Fix confusing construction of GenericRecord AvroSerializers ## What is the purpose of the change The `AvroSerializer` previously had a `AvroSerializer(Class type,

[jira] [Commented] (FLINK-9565) Evaluating scalar UDFs in parallel

2018-06-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509361#comment-16509361 ] Timo Walther commented on FLINK-9565: - [~fhueske] we could also just introduce a new method in

[jira] [Closed] (FLINK-9568) Wrong error handling for batch input formats with invalid paths

2018-06-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9568. --- Resolution: Duplicate > Wrong error handling for batch input formats with invalid paths >

[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6071#discussion_r194671209 --- Diff: flink-tests/src/test/java/org/apache/flink/test/runtime/NettyEpollITCase.java --- @@ -0,0 +1,103 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[GitHub] flink issue #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6071 Changes look good to me @pnowojski. I had some minor comments. After addressing them, we should rebase and remove the unnecessary commits. Ping me once you have done it. I will then merge this

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[jira] [Closed] (FLINK-9566) Support listing all jobs in CliFrontend#list

2018-06-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9566. --- Resolution: Fixed master: 25d277e16970c6a1755f5050f7bc419b158f17aa > Support listing all

[GitHub] flink issue #6134: [FLINK-9538] Make KeyedStateFunction an interface

2018-06-12 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6134 cc @dawidwys ---

[jira] [Commented] (FLINK-9503) Migrate integration tests for iterative aggregators

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

[GitHub] flink pull request #6129: [FLINK-9503] Migrate integration tests for iterati...

2018-06-12 Thread yanghua
Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6129#discussion_r194696659 --- Diff: flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/AggregatorsITCase.java --- @@ -170,12 +162,12 @@ public void

[jira] [Commented] (FLINK-9366) Distribute Cache only works for client-accessible files

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

[jira] [Assigned] (FLINK-8307) org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler logging improvments

2018-06-12 Thread blues zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] blues zheng reassigned FLINK-8307: -- Assignee: (was: blues zheng) > org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler

[jira] [Commented] (FLINK-9570) SQL Client merging environments uses AbstractMap

2018-06-12 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509519#comment-16509519 ] Dominik Wosiński commented on FLINK-9570: - Sadly, I can't assign it, so probably I need

[jira] [Commented] (FLINK-9570) SQL Client merging environments uses AbstractMap

2018-06-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509560#comment-16509560 ] Timo Walther commented on FLINK-9570: - [~Wosinsan] you should have contributor permissions now :) >

[jira] [Commented] (FLINK-9503) Migrate integration tests for iterative aggregators

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

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

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

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

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

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

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

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

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

[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6071#discussion_r194713008 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/router/RoutedRequest.java --- @@ -97,11 +98,17 @@ public ReferenceCounted

[jira] [Commented] (FLINK-8983) End-to-end test: Confluent schema registry

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

[jira] [Updated] (FLINK-8759) Prepare LengthFieldBasedFrameDecoder for Netty upgrade

2018-06-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8759: - Summary: Prepare LengthFieldBasedFrameDecoder for Netty upgrade (was: Bump Netty to 4.0.56) >

[jira] [Reopened] (FLINK-8759) Bump Netty to 4.0.56

2018-06-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-8759: -- Requirement for FLINK-3952. > Bump Netty to 4.0.56 > > >

[jira] [Updated] (FLINK-8759) Prepare LengthFieldBasedFrameDecoder for Netty upgrade

2018-06-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8759: - Fix Version/s: 1.6.0 > Prepare LengthFieldBasedFrameDecoder for Netty upgrade >

[jira] [Created] (FLINK-9569) Confusing construction of AvroSerializers for generic records

2018-06-12 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-9569: -- Summary: Confusing construction of AvroSerializers for generic records Key: FLINK-9569 URL: https://issues.apache.org/jira/browse/FLINK-9569 Project:

[jira] [Created] (FLINK-9570) SQL Client merging environments uses AbstractMap

2018-06-12 Thread JIRA
Dominik Wosiński created FLINK-9570: --- Summary: SQL Client merging environments uses AbstractMap Key: FLINK-9570 URL: https://issues.apache.org/jira/browse/FLINK-9570 Project: Flink Issue

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[GitHub] flink issue #6127: [FLINK-9368][py][tests] Add Python API E2E test

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

[jira] [Commented] (FLINK-9564) Expose end-to-end module directory to test scripts

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

[jira] [Commented] (FLINK-9564) Expose end-to-end module directory to test scripts

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

[GitHub] flink pull request #6146: [FLINK-9564][tests] Expose flink-end-to-end module...

2018-06-12 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/6146 ---

[GitHub] flink issue #6146: [FLINK-9564][tests] Expose flink-end-to-end module direct...

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

[GitHub] flink pull request #5570: [FLINK-8768][network] Let NettyMessageDecoder inhe...

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

[GitHub] flink pull request #5571: [FLINK-8759][network] preparations for the update ...

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

[jira] [Commented] (FLINK-8759) Prepare LengthFieldBasedFrameDecoder for Netty upgrade

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

[GitHub] flink issue #6119: [FLINK-9458] Ignore SharedSlot in CoLocationConstraint wh...

2018-06-12 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6119 Thanks for the review @StefanRRichter. Merging this PR. ---

[jira] [Resolved] (FLINK-8768) Change NettyMessageDecoder to inherit from LengthFieldBasedFrameDecoder

2018-06-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8768. -- Resolution: Fixed Fix Version/s: (was: 1.5.1) 1.6.0 Fixed via

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

2018-06-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509320#comment-16509320 ] Fabian Hueske commented on FLINK-9528: -- I think we can provide efficient implementations for all

[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6071#discussion_r194663296 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/router/RoutedRequest.java --- @@ -97,11 +98,17 @@ public ReferenceCounted

[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6071#discussion_r19412 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/AbstractByteBufTest.java --- @@ -64,12 +69,13 @@ import static

[jira] [Commented] (FLINK-9276) Improve error message when TaskManager fails

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

[jira] [Commented] (FLINK-9368) End-to-end test: Python API

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

[jira] [Resolved] (FLINK-8759) Prepare LengthFieldBasedFrameDecoder for Netty upgrade

2018-06-12 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8759. -- Resolution: Fixed Fixed via 7cad1d33a6e82dd1b7255dcb3671c719da43097d > Prepare

[GitHub] flink issue #5954: [FLINK-9276] Improve error message when TaskManager fails

2018-06-12 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5954 @tillrohrmann can you merge this? ---

[jira] [Commented] (FLINK-9569) Confusing construction of AvroSerializers for generic records

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

[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6071#discussion_r194652733 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/ChunkedByteBuf.java --- @@

[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6071#discussion_r194660815 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/ReadOnlySlicedNetworkBuffer.java --- @@ -75,12 +75,12 @@ private

[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6071#discussion_r194652495 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/ChunkedByteBuf.java --- @@

[jira] [Commented] (FLINK-9368) End-to-end test: Python API

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

[GitHub] flink pull request #6127: [FLINK-9368][py][tests] Add Python API E2E test

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

[jira] [Closed] (FLINK-9368) End-to-end test: Python API

2018-06-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9368. --- Resolution: Fixed Fix Version/s: 1.6.0 master:

[jira] [Updated] (FLINK-9368) End-to-end test: Python API

2018-06-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9368: Affects Version/s: (was: 1.5.0) > End-to-end test: Python API >

[jira] [Commented] (FLINK-9570) SQL Client merging environments uses AbstractMap

2018-06-12 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509348#comment-16509348 ] Dominik Wosiński commented on FLINK-9570: - I've just created that but I can take care of this as

[jira] [Commented] (FLINK-9570) SQL Client merging environments uses AbstractMap

2018-06-12 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509352#comment-16509352 ] Timo Walther commented on FLINK-9570: - [~Wosinsan] feel free to assign this issue to you. I can give

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[jira] [Commented] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

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

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

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

[GitHub] flink pull request #6049: [FLINK-9398][Client] Fix CLI list running job retu...

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

[jira] [Closed] (FLINK-9564) Expose end-to-end module directory to test scripts

2018-06-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9564. --- Resolution: Fixed master: 89ab475ccc1fb3ae199236546b25f79a27685529 1.5:

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

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

[GitHub] flink pull request #6089: [FLINK-9451]End-to-end test: Scala Quickstarts

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

[jira] [Commented] (FLINK-9565) Evaluating scalar UDFs in parallel

2018-06-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509306#comment-16509306 ] Fabian Hueske commented on FLINK-9565: -- One option to add such a feature could be to provide an

[GitHub] flink pull request #6060: [FLINK-8946] TaskManager stop sending metrics afte...

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

[jira] [Commented] (FLINK-9564) Expose end-to-end module directory to test scripts

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

[GitHub] flink issue #6129: [FLINK-9503] Migrate integration tests for iterative aggr...

2018-06-12 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6129 hi @zentol does this PR look good to you? ---

[GitHub] flink pull request #6145: [FLINK-9564][tests] Expose flink-end-to-end module...

2018-06-12 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/6145 ---

[GitHub] flink issue #6145: [FLINK-9564][tests] Expose flink-end-to-end module direct...

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

[jira] [Closed] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

2018-06-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9398. --- Resolution: Fixed master: a2a85bcb3cdb5202055984604f45809260787fd5 1.5:

[jira] [Commented] (FLINK-9538) Make KeyedStateFunction an interface

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

[jira] [Commented] (FLINK-9564) Expose end-to-end module directory to test scripts

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

[jira] [Commented] (FLINK-9503) Migrate integration tests for iterative aggregators

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

[jira] [Closed] (FLINK-9451) End-to-end test: Scala Quickstarts

2018-06-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9451. --- Resolution: Fixed Fix Version/s: 1.6.0 master:

[jira] [Commented] (FLINK-9458) Unable to recover from job failure on YARN with NPE

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

[jira] [Commented] (FLINK-8768) Change NettyMessageDecoder to inherit from LengthFieldBasedFrameDecoder

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

[GitHub] flink pull request #6152: 9467

2018-06-12 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/6152 9467 ## What is the purpose of the change This PR fixes the watermark display in the WebUI. When we reworked the watermark metrics we renamed the metrics and moved them to the

[GitHub] flink pull request #6076: [hotfix][docs] Specify operators behaviour on proc...

2018-06-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6076#discussion_r194702812 --- Diff: docs/dev/event_time.md --- @@ -213,10 +213,36 @@ arrive after the system's event time clock (as signaled by the watermarks) has a timestamp.

[GitHub] flink pull request #6076: [hotfix][docs] Specify operators behaviour on proc...

2018-06-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6076#discussion_r194702541 --- Diff: docs/dev/event_time.md --- @@ -213,10 +213,36 @@ arrive after the system's event time clock (as signaled by the watermarks) has a timestamp.

[GitHub] flink pull request #6076: [hotfix][docs] Specify operators behaviour on proc...

2018-06-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6076#discussion_r194702106 --- Diff: docs/dev/event_time.md --- @@ -213,10 +213,36 @@ arrive after the system's event time clock (as signaled by the watermarks) has a timestamp.

[GitHub] flink pull request #6076: [hotfix][docs] Specify operators behaviour on proc...

2018-06-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6076#discussion_r194702199 --- Diff: docs/dev/event_time.md --- @@ -213,10 +213,36 @@ arrive after the system's event time clock (as signaled by the watermarks) has a timestamp.

[GitHub] flink pull request #6076: [hotfix][docs] Specify operators behaviour on proc...

2018-06-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6076#discussion_r194702405 --- Diff: docs/dev/event_time.md --- @@ -213,10 +213,36 @@ arrive after the system's event time clock (as signaled by the watermarks) has a timestamp.

[GitHub] flink pull request #6107: [FLINK-9366] DistributedCache works with Distribut...

2018-06-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6107#discussion_r194703701 --- Diff: flink-fs-tests/src/test/java/org/apache/flink/hdfstests/DistributedCacheDfsTest.java --- @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #6107: [FLINK-9366] DistributedCache works with Distribut...

2018-06-12 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6107#discussion_r194705137 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -584,17 +584,25 @@ public void

[jira] [Commented] (FLINK-9366) Distribute Cache only works for client-accessible files

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

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

[GitHub] flink pull request #6071: [FLINK-3952][runtine] Upgrade to Netty 4.1

2018-06-12 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/6071#discussion_r194711763 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/ChunkedByteBuf.java --- @@ -88,6

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

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

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

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

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

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

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

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

  1   2   >