[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

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

[GitHub] flink issue #4665: [Flink-7611]add metrics to measure the num of data droppe...

2017-09-28 Thread Aitozi
Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/4665 is there still anything wrong @zentol ---

[jira] [Updated] (FLINK-7733) test instability in Kafa end-to-end test (RetriableCommitFailedException)

2017-09-28 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7733: --- Priority: Critical (was: Major) > test instability in Kafa end-to-end test

[jira] [Closed] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable

2017-09-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7547. --- Resolution: Fixed Fix Version/s: 1.4.0 Resolved in

[jira] [Created] (FLINK-7734) test instability in ResourceManagerTest

2017-09-28 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7734: -- Summary: test instability in ResourceManagerTest Key: FLINK-7734 URL: https://issues.apache.org/jira/browse/FLINK-7734 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7734) test instability in ResourceManagerTest

2017-09-28 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7734: --- Labels: test-stability (was: ) > test instability in ResourceManagerTest >

[jira] [Commented] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184322#comment-16184322 ] ASF GitHub Bot commented on FLINK-7547: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

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

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184393#comment-16184393 ] ASF GitHub Bot commented on FLINK-7699: --- Github user zhijiangW commented on the issue:

[jira] [Commented] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184432#comment-16184432 ] ASF GitHub Bot commented on FLINK-7708: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

2017-09-28 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141665789 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -390,7 +390,63 @@ public

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

2017-09-28 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141673902 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -390,7 +390,63 @@ public

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

2017-09-28 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141667517 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -390,7 +390,63 @@ public

[jira] [Commented] (FLINK-7412) optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184461#comment-16184461 ] ASF GitHub Bot commented on FLINK-7412: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-7700) State merging in RocksDB backend leaves old state

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

[GitHub] flink pull request #4731: [FLINK-7700] Fix RocksDB state merging

2017-09-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4731#discussion_r141639769 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1978,4

[GitHub] flink issue #4731: [FLINK-7700] Fix RocksDB state merging

2017-09-28 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4731 I think it would be good to have an abstraction for that, yes. ---

[jira] [Assigned] (FLINK-7734) test instability in ResourceManagerTest

2017-09-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7734: Assignee: Till Rohrmann > test instability in ResourceManagerTest >

[GitHub] flink pull request #4614: [FLINK-7547][build] AsyncFunction.scala extends Fu...

2017-09-28 Thread yew1eb
Github user yew1eb closed the pull request at: https://github.com/apache/flink/pull/4614 ---

[jira] [Commented] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184326#comment-16184326 ] ASF GitHub Bot commented on FLINK-7547: --- Github user yew1eb commented on the issue:

[jira] [Commented] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184327#comment-16184327 ] ASF GitHub Bot commented on FLINK-7547: --- Github user yew1eb closed the pull request at:

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

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

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

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

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

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

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

2017-09-28 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141664479 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -176,6 +176,8 @@ protected void

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

2017-09-28 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141665866 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -390,7 +390,63 @@ public

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-28 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141660332 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java --- @@ -209,31 +209,30 @@ public void

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-28 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141659141 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java --- @@ -209,31 +209,30 @@ public void

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-28 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141660623 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java --- @@ -400,6 +399,23 @@ private int

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[jira] [Closed] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x

2017-09-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7413. --- Resolution: Won't Fix Closing for now as "won't fix" based on feedback. > Release Hadoop

[jira] [Updated] (FLINK-7692) Support user-defined variables in Metrics

2017-09-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7692: Summary: Support user-defined variables in Metrics (was: Support user-defined variables)

[GitHub] flink issue #4614: [FLINK-7547][build] AsyncFunction.scala extends Function,...

2017-09-28 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4614 :ok_hand: ---

[jira] [Updated] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-7416: Description: This is a part of work for credit-based network flow control. The related works are : * We

[GitHub] flink issue #4735: [FLINK-7699][core] Define the BufferListener interface to...

2017-09-28 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4735 Already removed the tags and added the `verify` ---

[jira] [Created] (FLINK-7733) test instability in Kafa end-to-end test (RetriableCommitFailedException)

2017-09-28 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7733: -- Summary: test instability in Kafa end-to-end test (RetriableCommitFailedException) Key: FLINK-7733 URL: https://issues.apache.org/jira/browse/FLINK-7733 Project: Flink

[jira] [Updated] (FLINK-7733) test instability in Kafa end-to-end test (RetriableCommitFailedException)

2017-09-28 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7733: --- Labels: test-stability (was: ) > test instability in Kafa end-to-end test

[jira] [Updated] (FLINK-7732) test instability in Kafa end-to-end test (invalid Kafka offset)

2017-09-28 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7732: --- Labels: test-stability (was: ) > test instability in Kafa end-to-end test (invalid Kafka offset) >

[GitHub] flink issue #4518: [FLINK-7412][network] optimise NettyMessage.TaskEventRequ...

2017-09-28 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4518 Thanks for the contribution @NicoK and the review @pnowojski. Once Travis passed, I'll merge the PR. ---

[jira] [Created] (FLINK-7732) test instability in Kafa end-to-end test (invalid Kafka offset)

2017-09-28 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7732: -- Summary: test instability in Kafa end-to-end test (invalid Kafka offset) Key: FLINK-7732 URL: https://issues.apache.org/jira/browse/FLINK-7732 Project: Flink

[GitHub] flink pull request #4744: [FLINK-7708] [flip6] Add CheckpointConfigHandler f...

2017-09-28 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4744 [FLINK-7708] [flip6] Add CheckpointConfigHandler for new REST endpoint ## What is the purpose of the change This commit implements the CheckpointConfigHandler which now returns a

[GitHub] flink issue #4614: [FLINK-7547][build] AsyncFunction.scala extends Function,...

2017-09-28 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4614 Thanks a lot @yew1eb for fixing this! I merged. 😃 Could you please close this PR if it doesn't close automatically? ---

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[jira] [Commented] (FLINK-7720) Centralize creation of backends and state related resources

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184707#comment-16184707 ] ASF GitHub Bot commented on FLINK-7720: --- GitHub user StefanRRichter opened a pull request:

[jira] [Commented] (FLINK-7720) Centralize creation of backends and state related resources

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184709#comment-16184709 ] ASF GitHub Bot commented on FLINK-7720: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #4745: [FLINK-7720] [state backends] Centralize creation of back...

2017-09-28 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4745 CC @aljoscha @StephanEwen ---

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[jira] [Commented] (FLINK-7731) Trigger on GlobalWindow does not clean state completely

2017-09-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184580#comment-16184580 ] Fabian Hueske commented on FLINK-7731: -- [~aljoscha], might this issue be related to FLINK-7700? >

[jira] [Created] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

2017-09-28 Thread Ryan Hobbs (JIRA)
Ryan Hobbs created FLINK-7737: - Summary: On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss Key: FLINK-7737 URL: https://issues.apache.org/jira/browse/FLINK-7737

[jira] [Resolved] (FLINK-7734) test instability in ResourceManagerTest

2017-09-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7734. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via

[GitHub] flink pull request #4745: [FLINK-7720] [state backends] Centralize creation ...

2017-09-28 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/4745 [FLINK-7720] [state backends] Centralize creation of backends and state related resources ## What is the purpose of the change This PR combines [FLINK-7719] and [FLINK-7720], which

[jira] [Created] (FLINK-7735) Improve date/time handling in publically-facing Expressions

2017-09-28 Thread Kent Murra (JIRA)
Kent Murra created FLINK-7735: - Summary: Improve date/time handling in publically-facing Expressions Key: FLINK-7735 URL: https://issues.apache.org/jira/browse/FLINK-7735 Project: Flink Issue

[jira] [Created] (FLINK-7736) Fix some of the alerts raised by lgtm.com

2017-09-28 Thread Malcolm Taylor (JIRA)
Malcolm Taylor created FLINK-7736: - Summary: Fix some of the alerts raised by lgtm.com Key: FLINK-7736 URL: https://issues.apache.org/jira/browse/FLINK-7736 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI

2017-09-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184855#comment-16184855 ] Chesnay Schepler commented on FLINK-7525: - For the REST API this is rather trivial to implement as

[GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken...

2017-09-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4722 ---

[jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI

2017-09-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184275#comment-16184275 ] Robert Metzger commented on FLINK-7525: --- [~Zentol] What are the implications of this change in light

[jira] [Commented] (FLINK-7700) State merging in RocksDB backend leaves old state

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184279#comment-16184279 ] ASF GitHub Bot commented on FLINK-7700: --- Github user aljoscha commented on the issue:

[jira] [Updated] (FLINK-7732) Test instability in Kafka end-to-end test (invalid Kafka offset)

2017-09-28 Thread Ken Krugler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler updated FLINK-7732: --- Summary: Test instability in Kafka end-to-end test (invalid Kafka offset) (was: test instability in

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-28 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141657809 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -87,6 +88,12 @@ /** The

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

2017-09-28 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141794108 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -390,7 +390,63 @@ public

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

2017-09-28 Thread zhijiangW
Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141794461 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -390,7 +390,63 @@ public

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[GitHub] flink pull request #4696: [FLINK-7632] [document] Overhaul on Cassandra conn...

2017-09-28 Thread mcfongtw
Github user mcfongtw commented on a diff in the pull request: https://github.com/apache/flink/pull/4696#discussion_r141785837 --- Diff: docs/dev/connectors/cassandra.md --- @@ -35,37 +43,47 @@ To use this connector, add the following dependency to your project: {%

[jira] [Commented] (FLINK-7632) Better documentation and examples on C* sink usage for Pojo and Tuples data types

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185317#comment-16185317 ] ASF GitHub Bot commented on FLINK-7632: --- Github user mcfongtw commented on a diff in the pull

[GitHub] flink pull request #4746: [FLINK-7657] [Table] Adding logic to convert RexLi...

2017-09-28 Thread kmurra
GitHub user kmurra opened a pull request: https://github.com/apache/flink/pull/4746 [FLINK-7657] [Table] Adding logic to convert RexLiteral to expected SQL Date/Time/Timestamp classes ## What is the purpose of the change This change fixes handling of date, time, and

[jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185270#comment-16185270 ] ASF GitHub Bot commented on FLINK-7657: --- GitHub user kmurra opened a pull request:

[jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

2017-09-28 Thread Kent Murra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185271#comment-16185271 ] Kent Murra commented on FLINK-7657: --- Pull request has been submitted:

[GitHub] flink pull request #4572: [Flink-7243] [connectors] Add ParquetInputFormat

2017-09-28 Thread godfreyhe
Github user godfreyhe commented on a diff in the pull request: https://github.com/apache/flink/pull/4572#discussion_r141783154 --- Diff: flink-connectors/flink-parquet/pom.xml --- @@ -0,0 +1,81 @@ + + +http://maven.apache.org/POM/4.0.0;

[jira] [Created] (FLINK-7738) Create WebSocket handler (server)

2017-09-28 Thread Eron Wright (JIRA)
Eron Wright created FLINK-7738: --- Summary: Create WebSocket handler (server) Key: FLINK-7738 URL: https://issues.apache.org/jira/browse/FLINK-7738 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183719#comment-16183719 ] ASF GitHub Bot commented on FLINK-7660: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #4740: [FLINK-7660][DataStream API/Scala API] Support sid...

2017-09-28 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4740 [FLINK-7660][DataStream API/Scala API] Support sideOutput in ProcessAllWindowFunction ## What is the purpose of the change Support sideOutput in ProcessAllWindowFunction ##

[jira] [Commented] (FLINK-7312) activate checkstyle for flink/core/memory/*

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184066#comment-16184066 ] ASF GitHub Bot commented on FLINK-7312: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4698: [FLINK-7661][network] Add credit field in PartitionReques...

2017-09-28 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4698 ok, cool, then we can merge this PR as anticipated ---

[jira] [Commented] (FLINK-7312) activate checkstyle for flink/core/memory/*

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183928#comment-16183928 ] ASF GitHub Bot commented on FLINK-7312: --- Github user zentol commented on the issue:

[jira] [Closed] (FLINK-7562) uploaded jars sort by upload-time on dashboard page

2017-09-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7562. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 01b30515cd2a09ac228dd53e9905932f2eadd1f7

[jira] [Closed] (FLINK-7725) Add test base for marshalling requests

2017-09-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7725. --- Resolution: Fixed 1.4: 426137f5100d213c9c9c2f05c81f63f1f52ed33e > Add test base for

[GitHub] flink issue #4447: [FLINK-7312][checkstyle] activate checkstyle for flink/co...

2017-09-28 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4447 oh, yes - maybe I should rebase this one and exclude #4445 commits since there, we may actually investigate further ---

[jira] [Created] (FLINK-7727) Extend logging in file server handlers

2017-09-28 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7727: --- Summary: Extend logging in file server handlers Key: FLINK-7727 URL: https://issues.apache.org/jira/browse/FLINK-7727 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7727) Extend logging in file server handlers

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184078#comment-16184078 ] ASF GitHub Bot commented on FLINK-7727: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4743: [FLINK-7727] [REST] Improve error logging in Stati...

2017-09-28 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4743 [FLINK-7727] [REST] Improve error logging in StaticFileServerHandlers ## What is the purpose of the change This PR improves the logging of errors in the StateFileServerHandlers ##

[jira] [Commented] (FLINK-7725) Add test base for marshalling requests

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

[jira] [Commented] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist

2017-09-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184002#comment-16184002 ] Chesnay Schepler commented on FLINK-7675: - 1.4: 3d2f4cb09d0ead0454523c1a95643a118cc36457 >

[GitHub] flink pull request #4709: [FLINK-7675] [metrics] LatestCompletedCheckpointEx...

2017-09-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4709 ---

[GitHub] flink pull request #4739: [FLINK-7724][REST][Tests][Metrics] add extra metri...

2017-09-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4739 ---

[GitHub] flink pull request #4664: [FLINK-7562][web] Show uploaded-jars descending by...

2017-09-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4664 ---

[GitHub] flink pull request #4693: [FLINK-7645][docs] Modify system-metrics part show...

2017-09-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4693 ---

[jira] [Commented] (FLINK-7724) add extra metrics to MetricStoreTest.setupStore

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

[jira] [Commented] (FLINK-7645) Modify system-metrics part show in the document

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

[jira] [Commented] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist

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

[jira] [Commented] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest

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

[GitHub] flink pull request #4741: [FLINK-7725] [REST] Add testbase for requests / al...

2017-09-28 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/4741 ---

[jira] [Commented] (FLINK-7562) uploaded jars sort by upload-time on dashboard page

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

[GitHub] flink pull request #4703: [FLINK-7659][REST] Unprotected access to inProgres...

2017-09-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4703 ---

[jira] [Commented] (FLINK-7072) Create RESTful cluster endpoint

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184031#comment-16184031 ] ASF GitHub Bot commented on FLINK-7072: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4742: [FLINK-7072] [REST] Add Flip-6 client for submit/j...

2017-09-28 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4742 [FLINK-7072] [REST] Add Flip-6 client for submit/job/cancel This PR builds on #4730 . ## What is the purpose of the change This PR adds a new ClusterClient specifically for Flip-6

[jira] [Commented] (FLINK-7661) Add credit field in PartitionRequest message

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183912#comment-16183912 ] ASF GitHub Bot commented on FLINK-7661: --- Github user NicoK commented on the issue:

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

2017-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183942#comment-16183942 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

  1   2   3   >