[GitHub] flink pull request: [FLINK-3761] Introduction of key groups

2016-05-24 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1988#issuecomment-221312885 Yes definitely: better be safe than sorry. Will remove the `createPartitionedStateBackend` method from `AbstractStateBackend`. --- If your project is set up for

[GitHub] flink pull request: [FLINK-3761] Introduction of key groups

2016-05-24 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1988#issuecomment-221309557 Thanks for the initial feedback @aljoscha :-) The introduction of `PartitionedState` is indeed not strictly necessary for this PR. The idea was that we

[jira] [Commented] (FLINK-3761) Introduce key group state backend

2016-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298371#comment-15298371 ] ASF GitHub Bot commented on FLINK-3761: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request: [FLINK-2915] Fix for JobManagerProcessFailureB...

2016-05-24 Thread rekhajoshm
GitHub user rekhajoshm opened a pull request: https://github.com/apache/flink/pull/2027 [FLINK-2915] Fix for JobManagerProcessFailureBatchRecoveryITCase Test [FLINK-2915] Fix for JobManagerProcessFailureBatchRecoveryITCase Test You can merge this pull request into a Git repository

[jira] [Commented] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase

2016-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298665#comment-15298665 ] ASF GitHub Bot commented on FLINK-2915: --- GitHub user rekhajoshm opened a pull request:

[jira] [Created] (FLINK-3966) AvroTypeInfo does not work with readonly avro specific records

2016-05-24 Thread Matthew Burghoffer (JIRA)
Matthew Burghoffer created FLINK-3966: - Summary: AvroTypeInfo does not work with readonly avro specific records Key: FLINK-3966 URL: https://issues.apache.org/jira/browse/FLINK-3966 Project:

[jira] [Assigned] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis

2016-05-24 Thread Rekha Joshi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rekha Joshi reassigned FLINK-2771: -- Assignee: Rekha Joshi > IterateTest.testSimpleIteration fails on Travis >

[GitHub] flink pull request: [FLINK-2771] Fix for IterateTest.testSimpleIte...

2016-05-24 Thread rekhajoshm
GitHub user rekhajoshm opened a pull request: https://github.com/apache/flink/pull/2028 [FLINK-2771] Fix for IterateTest.testSimpleIteration fail on Travis [FLINK-2771] Fix for IterateTest.testSimpleIteration fail on Travis You can merge this pull request into a Git repository by

[jira] [Commented] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis

2016-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298692#comment-15298692 ] ASF GitHub Bot commented on FLINK-2771: --- GitHub user rekhajoshm opened a pull request:

[jira] [Assigned] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase

2016-05-24 Thread Rekha Joshi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rekha Joshi reassigned FLINK-2915: -- Assignee: Rekha Joshi > JobManagerProcessFailureBatchRecoveryITCase >

[jira] [Created] (FLINK-3965) Delegating GraphAlgorithm

2016-05-24 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3965: - Summary: Delegating GraphAlgorithm Key: FLINK-3965 URL: https://issues.apache.org/jira/browse/FLINK-3965 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode

2016-05-24 Thread Rekha Joshi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rekha Joshi reassigned FLINK-2814: -- Assignee: Rekha Joshi > DeltaIteration: DualInputPlanNode cannot be cast to

[GitHub] flink pull request: [FLINK-2814] Fix for DualInputPlanNode cannot ...

2016-05-24 Thread rekhajoshm
GitHub user rekhajoshm opened a pull request: https://github.com/apache/flink/pull/2029 [FLINK-2814] Fix for DualInputPlanNode cannot be cast to SingleInputPlanNode [FLINK-2814] Fix for DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode You can merge this pull

[jira] [Commented] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode

2016-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298739#comment-15298739 ] ASF GitHub Bot commented on FLINK-2814: --- GitHub user rekhajoshm opened a pull request:

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-24 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1956#issuecomment-221394386 Hey @gallenvara, I had a private chat with @greghogan about this PR. We think that we should change the label type to a boolean instead of string. It should make a

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298855#comment-15298855 ] ASF GitHub Bot commented on FLINK-2044: --- Github user vasia commented on the pull request:

<    1   2