[GitHub] flink pull request #:

2016-10-04 Thread tzulitai
Github user tzulitai commented on the pull request: https://github.com/apache/flink/commit/eece0dd05bc38b88fcb6cbcef15add7f98eab456#commitcomment-19297476 Thanks for the fix, seems like I wasn't quite concentrated on the review :/ --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15547536#comment-15547536 ] ASF GitHub Bot commented on FLINK-4723: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #2580: [FLINK-4723] [kafka-connector] Unify committed offsets to...

2016-10-04 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2580 Thanks for the review @StephanEwen. Concerning changing the contract for `commitSpecificOffsetsToKafka`: Makes sense, I don't really like excessive copying too. With proper tests on

[jira] [Updated] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream

2016-10-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4514: --- Fix Version/s: (was: 1.1.2) 1.1.3 > ExpiredIteratorException

[jira] [Updated] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown

2016-10-04 Thread Matt Zimmer (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Zimmer updated FLINK-4742: --- Description: We have a test that otherwise passed on our CI server, but failed with an NPE on the

[jira] [Created] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown

2016-10-04 Thread Matt Zimmer (JIRA)
Matt Zimmer created FLINK-4742: -- Summary: NPE in WindowOperator.trigger() on shutdown Key: FLINK-4742 URL: https://issues.apache.org/jira/browse/FLINK-4742 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4260) Allow SQL's LIKE ESCAPE

2016-10-04 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15547157#comment-15547157 ] Neelesh Srinivas Salian commented on FLINK-4260: Hey [~miaoever], do you have a chance to

[jira] [Updated] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit.

2016-10-04 Thread Joseph Sims (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joseph Sims updated FLINK-4741: --- Component/s: (was: Core) > WebRuntimeMonitor does not shut down all of it's threads

[jira] [Updated] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit.

2016-10-04 Thread Joseph Sims (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joseph Sims updated FLINK-4741: --- Priority: Minor (was: Major) > WebRuntimeMonitor does not shut down all of it's threads

[jira] [Updated] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit.

2016-10-04 Thread Joseph Sims (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joseph Sims updated FLINK-4741: --- Component/s: Webfrontend > WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups)

[jira] [Created] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit.

2016-10-04 Thread Joseph Sims (JIRA)
Joseph Sims created FLINK-4741: -- Summary: WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit. Key: FLINK-4741 URL: https://issues.apache.org/jira/browse/FLINK-4741

[jira] [Commented] (FLINK-4729) Use optional VertexCentric CombineFunction

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546531#comment-15546531 ] ASF GitHub Bot commented on FLINK-4729: --- Github user vasia commented on the issue:

[GitHub] flink issue #2587: [FLINK-4729] [gelly] Use optional VertexCentric CombineFu...

2016-10-04 Thread vasia
Github user vasia commented on the issue: https://github.com/apache/flink/pull/2587 Great cleanup! Thanks @greghogan. +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Created] (FLINK-4740) Upgrade testing libraries

2016-10-04 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4740: - Summary: Upgrade testing libraries Key: FLINK-4740 URL: https://issues.apache.org/jira/browse/FLINK-4740 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4734) Remove use of Tuple setField for fixed position

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546360#comment-15546360 ] ASF GitHub Bot commented on FLINK-4734: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2590: [FLINK-4734] [gelly] Remove use of Tuple setField for fix...

2016-10-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2590 I think that makes a lot of sense! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

2016-10-04 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546359#comment-15546359 ] Greg Hogan commented on FLINK-4735: --- Apologies for sending the PR for FLINK-4734 to this ticket. I

[jira] [Commented] (FLINK-4739) Adding packaging details for the Elasticsearch connector

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546354#comment-15546354 ] ASF GitHub Bot commented on FLINK-4739: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2591: [FLINK-4739] Adding packaging details for the Elasticsear...

2016-10-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2591 This is very helpful, thanks! Merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[GitHub] flink issue #2578: Event B should be unique.

2016-10-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2578 I think this is good. Merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-4730) Introduce CheckpointMetaData

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

[jira] [Commented] (FLINK-4730) Introduce CheckpointMetaData

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

[GitHub] flink pull request #2583: [FLINK-4730] Introduce checkpoint meta data

2016-10-04 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2583#discussion_r81829124 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java ---

[GitHub] flink pull request #2583: [FLINK-4730] Introduce checkpoint meta data

2016-10-04 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2583#discussion_r81829995 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java --- @@ -0,0 +1,140 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4739) Adding packaging details for the Elasticsearch connector

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546239#comment-15546239 ] ASF GitHub Bot commented on FLINK-4739: --- GitHub user sthm opened a pull request:

[GitHub] flink pull request #2591: [FLINK-4739] Adding packaging details for the Elas...

2016-10-04 Thread sthm
GitHub user sthm opened a pull request: https://github.com/apache/flink/pull/2591 [FLINK-4739] Adding packaging details for the Elasticsearch connector When an uber-jar containing an Elasticsearch sink is executed, an IllegalArgumentException may occur, which is caused by

[jira] [Created] (FLINK-4739) Adding packaging details for the Elasticsearch connector

2016-10-04 Thread Steffen Hausmann (JIRA)
Steffen Hausmann created FLINK-4739: --- Summary: Adding packaging details for the Elasticsearch connector Key: FLINK-4739 URL: https://issues.apache.org/jira/browse/FLINK-4739 Project: Flink

[jira] [Commented] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546180#comment-15546180 ] ASF GitHub Bot commented on FLINK-4735: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #2590: [FLINK-4735] [gelly] Remove use of Tuple setField ...

2016-10-04 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2590 [FLINK-4735] [gelly] Remove use of Tuple setField for fixed position You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81816707 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java --- @@ -0,0 +1,272 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-4738) Port TaskManager logic to TaskExecutor

2016-10-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4738: Summary: Port TaskManager logic to TaskExecutor Key: FLINK-4738 URL: https://issues.apache.org/jira/browse/FLINK-4738 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545989#comment-15545989 ] ASF GitHub Bot commented on FLINK-4723: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2580: [FLINK-4723] [kafka-connector] Unify committed offsets to...

2016-10-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2580 Looks quite good. I would suggest one change, though: Can we avoid copying the offsets in the checkpoint into a new map (with increment by one) and passing that to the ZooKeeper Offset

[GitHub] flink pull request #2589: FLINK-3932 State Backend Security

2016-10-04 Thread vijikarthi
GitHub user vijikarthi opened a pull request: https://github.com/apache/flink/pull/2589 FLINK-3932 State Backend Security This PR addresses ZK authorization (ACLs) requirement of FLINK-3932 and its dependency FLINK-4667 (Yarn session CLI not using correct ZK namespace in secure

[jira] [Commented] (FLINK-3932) Implement State Backend Security

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545908#comment-15545908 ] ASF GitHub Bot commented on FLINK-3932: --- GitHub user vijikarthi opened a pull request:

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81797332 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java --- @@ -0,0 +1,272 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-4737) Add more compression algorithms to FileInputFormat

2016-10-04 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4737: --- Summary: Add more compression algorithms to FileInputFormat Key: FLINK-4737 URL: https://issues.apache.org/jira/browse/FLINK-4737 Project: Flink Issue Type:

[GitHub] flink issue #2002: Support for bz2 compression in flink-core

2016-10-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2002 Sorry for the delay. This looks good to me, let's merge it and add further changes separately. Will merge this... --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81787532 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteEdge.java --- @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81787458 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java --- @@ -0,0 +1,272 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-4736) Don't duplicate fields in Ordering

2016-10-04 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4736: - Summary: Don't duplicate fields in Ordering Key: FLINK-4736 URL: https://issues.apache.org/jira/browse/FLINK-4736 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545661#comment-15545661 ] ASF GitHub Bot commented on FLINK-4735: --- GitHub user KurtYoung opened a pull request:

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81779541 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java --- @@ -0,0 +1,272 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81781081 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java --- @@ -0,0 +1,272 @@ +/* + * Licensed to the

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81780392 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Projection.java --- @@ -0,0 +1,55 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81781488 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java --- @@ -0,0 +1,272 @@ +/* + * Licensed to the

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81776392 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java --- @@ -0,0 +1,272 @@ +/* + * Licensed to the

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81777101 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteEdge.java --- @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4510) Always create CheckpointCoordinator

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545579#comment-15545579 ] ASF GitHub Bot commented on FLINK-4510: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #2453: [FLINK-4510] [checkpoint] Always create CheckpointCoordin...

2016-10-04 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2453 Thanks for the nice contribution. I see one minor detail that could cause problems. Even if we do not register the `CheckpointCoordinator` as `JobStatusListener`, it might still be

[jira] [Created] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

2016-10-04 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4735: - Summary: Migrate some job execution related akka messages to rpc calls Key: FLINK-4735 URL: https://issues.apache.org/jira/browse/FLINK-4735 Project: Flink Issue

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2564 Hi @greghogan. Thank you for clarification. I'll update code accordingly. Do you have any other comments regarding the PR? --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545557#comment-15545557 ] ASF GitHub Bot commented on FLINK-2254: --- Github user mushketyk commented on the issue:

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545483#comment-15545483 ] ASF GitHub Bot commented on FLINK-2254: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2564 The advantage to joining on vertex values before the grouped cross is that the number of projected vertices is quadratic in the vertex degree. The projected graphs will usually be much larger than

[GitHub] flink pull request #2564: [FLINK-2254] Add BipartiateGraph class

2016-10-04 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2564#discussion_r81764640 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java --- @@ -0,0 +1,272 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly

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

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545423#comment-15545423 ] ASF GitHub Bot commented on FLINK-2157: --- Github user thvasilo commented on the issue:

[GitHub] flink issue #1849: [FLINK-2157] [ml] Create evaluation framework for ML libr...

2016-10-04 Thread thvasilo
Github user thvasilo commented on the issue: https://github.com/apache/flink/pull/1849 @gaborhermann In terms of missing features, documentation is definitely missing, as @rawkintrevo mentioned. For the issues mentioned in the JIRA issue you linked I've replied on the dev

[jira] [Updated] (FLINK-4311) TableInputFormat fails when reused on next split

2016-10-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4311: - Fix Version/s: 1.1.3 > TableInputFormat fails when reused on next split >

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

2016-10-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545404#comment-15545404 ] Fabian Hueske commented on FLINK-4311: -- Merged for Flink 1.1 as

[jira] [Commented] (FLINK-4732) Maven junction plugin security threat

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545403#comment-15545403 ] ASF GitHub Bot commented on FLINK-4732: --- Github user mxm commented on the issue:

[GitHub] flink issue #2586: [FLINK-4732] remove maven junction plugin

2016-10-04 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2586 Merged to `master` and `release-1.1`. @uce I also like the symbolic link. I contacted the maintainer of the plugin because it wouldn't be hard to fix this nowadays with Java 7+ which supports

[jira] [Created] (FLINK-4734) Remove use of Tuple setField for fixed position

2016-10-04 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4734: - Summary: Remove use of Tuple setField for fixed position Key: FLINK-4734 URL: https://issues.apache.org/jira/browse/FLINK-4734 Project: Flink Issue Type:

[jira] [Closed] (FLINK-4732) Maven junction plugin security threat

2016-10-04 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4732. - Resolution: Fixed master: 5a573c6bc29c313d34981336d5bfc05185d323d2 release-1.1:

[jira] [Commented] (FLINK-4732) Maven junction plugin security threat

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

[GitHub] flink pull request #2586: [FLINK-4732] remove maven junction plugin

2016-10-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2586 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4732) Maven junction plugin security threat

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545385#comment-15545385 ] ASF GitHub Bot commented on FLINK-4732: --- Github user mxm commented on the issue:

[GitHub] flink issue #2586: [FLINK-4732] remove maven junction plugin

2016-10-04 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2586 Merging to both branches. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Commented] (FLINK-4729) Use optional VertexCentric CombineFunction

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545351#comment-15545351 ] ASF GitHub Bot commented on FLINK-4729: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #2587: [FLINK-4729] [gelly] Use optional VertexCentric Co...

2016-10-04 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2587 [FLINK-4729] [gelly] Use optional VertexCentric CombineFunction Passes through the CombineFunction to VertexCentricIteration, and other code cleanup discovered via IntelliJ's code analyzer. You

[jira] [Resolved] (FLINK-4546) Remove STREAM keyword in Stream SQL

2016-10-04 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4546. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 72e6b760fd951764c3ecc6fc191dc99a42d55e0b.

[jira] [Commented] (FLINK-4546) Remove STREAM keyword in Stream SQL

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

[GitHub] flink pull request #2454: [FLINK-4546] [table] Remove STREAM keyword in Stre...

2016-10-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2454 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4546) Remove STREAM keyword in Stream SQL

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545286#comment-15545286 ] ASF GitHub Bot commented on FLINK-4546: --- Github user twalthr commented on the issue:

[GitHub] flink issue #2454: [FLINK-4546] [table] Remove STREAM keyword in Stream SQL

2016-10-04 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2454 Thanks @wuchong. Will merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Resolved] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions.

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

[jira] [Commented] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions.

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

[GitHub] flink pull request #2560: [FLINK-4068] [table] Move constant computations ou...

2016-10-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2560 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545101#comment-15545101 ] ASF GitHub Bot commented on FLINK-4709: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2581: [FLINK-4709] Fix resource leak in InputStreamFSInputWrapp...

2016-10-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2581 Good fix, thanks a lot! Merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-4728) Replace reference equality with object equality

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545093#comment-15545093 ] ASF GitHub Bot commented on FLINK-4728: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2582: [FLINK-4728] [core,optimizer] Replace reference equality ...

2016-10-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2582 Thanks, this is a great set of cleanups and fixes. Merging this! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-2157) Create evaluation framework for ML library

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15545063#comment-15545063 ] ASF GitHub Bot commented on FLINK-2157: --- Github user gaborhermann commented on the issue:

[GitHub] flink issue #1849: [FLINK-2157] [ml] Create evaluation framework for ML libr...

2016-10-04 Thread gaborhermann
Github user gaborhermann commented on the issue: https://github.com/apache/flink/pull/1849 Hi all, What is the status of this PR? It would be relevant for us, because we might like to use the evaluation framework proposed here. See

[jira] [Commented] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions.

2016-10-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544993#comment-15544993 ] ASF GitHub Bot commented on FLINK-4068: --- Github user twalthr commented on the issue:

[GitHub] flink issue #2560: [FLINK-4068] [table] Move constant computations out of co...

2016-10-04 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2560 @wuchong I heavily tested this PR again as it could introduce difficult bugs. And I also found one issue that needs to be discussed. If you have an expression like `CAST(TRUE AS VARCHAR) || 'Test'`

[jira] [Updated] (FLINK-4731) HeapKeyedStateBackend restoring broken for scale-in

2016-10-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4731: -- Summary: HeapKeyedStateBackend restoring broken for scale-in (was: HeapKeyedStateBackend

[jira] [Assigned] (FLINK-4730) Introduce CheckpointMetaData

2016-10-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4730: - Assignee: Stefan Richter > Introduce CheckpointMetaData > >

[jira] [Commented] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file are used

2016-10-04 Thread Melmoth (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15544960#comment-15544960 ] Melmoth commented on FLINK-4724: Hi [~eronwright], makes sense, that way always the log4j.properties is

  1   2   >