[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A + B Identically partitioned (mapBlock Checkpointing issue)

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234743#comment-15234743 ] Hudson commented on MAHOUT-1810: FAILURE: Integrated in Mahout-Quality #3324 (See

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A + B Identically partitioned (mapBlock Checkpointing issue)

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205682#comment-15205682 ] ASF GitHub Bot commented on MAHOUT-1810: Github user andrewpalumbo closed the pull request at:

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A + B Identically partitioned (mapBlock Checkpointing issue)

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205620#comment-15205620 ] ASF GitHub Bot commented on MAHOUT-1810: Github user smarthi commented on the pull request:

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A + B Identically partitioned (mapBlock Checkpointing issue)

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15205368#comment-15205368 ] ASF GitHub Bot commented on MAHOUT-1810: GitHub user andrewpalumbo opened a pull request:

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A %*% B Identically partitioned

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15200151#comment-15200151 ] Andrew Palumbo commented on MAHOUT-1810: I am not sure about how the Flink engine handles the

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A %*% B Identically partitioned

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199864#comment-15199864 ] Dmitriy Lyubimov commented on MAHOUT-1810: -- Assumption of identical partitioning depends on the

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A %*% B Identically partitioned

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15200153#comment-15200153 ] Suneel Marthi commented on MAHOUT-1810: --- There's a DataSetUtils which has methhods for zipping

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A + B Identically partitioned

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201922#comment-15201922 ] Andrew Palumbo commented on MAHOUT-1810: [~dlyubimov]I am almost positive that the failure is due

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A %*% B Identically partitioned

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15198693#comment-15198693 ] Andrew Palumbo commented on MAHOUT-1810: Flink Checkpointing seems to be working fine on other

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A %*% B Identically partitioned

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15200163#comment-15200163 ] Andrew Palumbo commented on MAHOUT-1810: >From the above tests though we can see that in the case

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A + B Identically partitioned (mapBlock Checkpointing issue)

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15202159#comment-15202159 ] Andrew Palumbo commented on MAHOUT-1810: As far as I know there is no currently no Caching in the

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A %*% B Identically partitioned

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15200134#comment-15200134 ] Andrew Palumbo commented on MAHOUT-1810: Thanks, I will check back in with you on the mapBlock

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A %*% B Identically partitioned

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199914#comment-15199914 ] Dmitriy Lyubimov commented on MAHOUT-1810: -- Another note is that checkpoint() (at least in case

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A + B Identically partitioned (mapBlock Checkpointing issue)

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15202129#comment-15202129 ] Dmitriy Lyubimov commented on MAHOUT-1810: -- so if checkpoint doesn't cache, (which is the intent

[jira] [Commented] (MAHOUT-1810) Failing test in flink-bindings: A + B Identically partitioned

[ https://issues.apache.org/jira/browse/MAHOUT-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201713#comment-15201713 ] Andrew Palumbo commented on MAHOUT-1810: Flink does cache intermediate results of a task by