[jira] [Updated] (FLINK-1404) Add support to cache intermediate results

2015-04-07 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-1404: --- Summary: Add support to cache intermediate results (was: Trigger recycling of buffers held by

[jira] [Created] (FLINK-1831) runtime.taskmanager.RegistrationTests fails sporiously

2015-04-07 Thread JIRA
Márton Balassi created FLINK-1831: - Summary: runtime.taskmanager.RegistrationTests fails sporiously Key: FLINK-1831 URL: https://issues.apache.org/jira/browse/FLINK-1831 Project: Flink Issue

[jira] [Commented] (FLINK-1829) Conflicting Jackson version in the Flink POMs

2015-04-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14482808#comment-14482808 ] Stephan Ewen commented on FLINK-1829: - The `hbase-client` dependency should not be in

[jira] [Commented] (FLINK-967) Make intermediate results a first-class citizen in the JobGraph

2015-04-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14482816#comment-14482816 ] Maximilian Michels commented on FLINK-967: -- The intermediate results are now

[jira] [Closed] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

2015-04-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1831. --- runtime.taskmanager.RegistrationTests fails spuriously

[jira] [Resolved] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

2015-04-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1831. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen Fixed via

[jira] [Created] (FLINK-1832) start-local.bat/start-local.sh does not work if there is a white space in the file path (windows)

2015-04-07 Thread Nikolaas Steenbergen (JIRA)
Nikolaas Steenbergen created FLINK-1832: --- Summary: start-local.bat/start-local.sh does not work if there is a white space in the file path (windows) Key: FLINK-1832 URL:

[jira] [Resolved] (FLINK-1577) Misleading error messages when cancelling tasks

2015-04-07 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1577. Resolution: Fixed Misleading error messages when cancelling tasks

[jira] [Resolved] (FLINK-1469) Initialize network environment at task manager startup

2015-04-07 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1469. Resolution: Fixed Fix Version/s: 0.9 Fixed in e74521c1fe5f5842185be5c454d27adc3bd254d5.

[jira] [Created] (FLINK-1834) Is mapred.output.dir conf parameter really required?

2015-04-07 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-1834: - Summary: Is mapred.output.dir conf parameter really required? Key: FLINK-1834 URL: https://issues.apache.org/jira/browse/FLINK-1834 Project: Flink

[jira] [Commented] (FLINK-1832) start-local.bat/start-local.sh does not work if there is a white space in the file path (windows)

2015-04-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14482901#comment-14482901 ] Maximilian Michels commented on FLINK-1832: --- Thanks for reporting this. Looks

[jira] [Commented] (FLINK-1828) Impossible to output data to an HBase table

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14482898#comment-14482898 ] ASF GitHub Bot commented on FLINK-1828: --- Github user fpompermaier commented on the

[GitHub] flink pull request: Fixed Configurable HadoopOutputFormat (FLINK-1...

2015-04-07 Thread fpompermaier
Github user fpompermaier commented on the pull request: https://github.com/apache/flink/pull/571#issuecomment-90481118 Ok, I created this issue (https://issues.apache.org/jira/browse/FLINK-1834) about the mapred.output.dir --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-1822) Update Community page on website with a Getting Help section

2015-04-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14482818#comment-14482818 ] Maximilian Michels commented on FLINK-1822: --- +1 very nice idea. The path of the

[GitHub] flink pull request: Fixed Configurable HadoopOutputFormat (FLINK-1...

2015-04-07 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/571#issuecomment-90475934 Is the Hadoop configuration specified in the flink-conf.yaml loaded? If we set `mapred.output.dir` then we should check for an existing config entry beforehand. Otherwise, we

[jira] [Commented] (FLINK-1828) Impossible to output data to an HBase table

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14482834#comment-14482834 ] ASF GitHub Bot commented on FLINK-1828: --- Github user mxm commented on the pull

[jira] [Created] (FLINK-1833) Refactor partition availability notification in ExecutionGraph

2015-04-07 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1833: -- Summary: Refactor partition availability notification in ExecutionGraph Key: FLINK-1833 URL: https://issues.apache.org/jira/browse/FLINK-1833 Project: Flink

[jira] [Created] (FLINK-1835) Spurious failure of YARN tests

2015-04-07 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1835: --- Summary: Spurious failure of YARN tests Key: FLINK-1835 URL: https://issues.apache.org/jira/browse/FLINK-1835 Project: Flink Issue Type: Bug

[GitHub] flink pull request: Fix issue where Windows paths were not recogni...

2015-04-07 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/491#issuecomment-90507970 Btw, the path `file:/c:` that motivated this PR is not a valid absolute path according to Microsoft's documentation. --- If your project is set up for it, you can reply

[jira] [Created] (FLINK-1836) just test

2015-04-07 Thread zhu (JIRA)
zhu created FLINK-1836: -- Summary: just test Key: FLINK-1836 URL: https://issues.apache.org/jira/browse/FLINK-1836 Project: Flink Issue Type: Bug Reporter: zhu just test -- This message

[jira] [Commented] (FLINK-1817) ClassLoaderObjectInputStream fails with ClassNotFoundException for primitive classes

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483114#comment-14483114 ] ASF GitHub Bot commented on FLINK-1817: --- Github user asfgit closed the pull request

[jira] [Created] (FLINK-1838) Update streaming programming guide

2015-04-07 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-1838: - Summary: Update streaming programming guide Key: FLINK-1838 URL: https://issues.apache.org/jira/browse/FLINK-1838 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-1834) Is mapred.output.dir conf parameter really required?

2015-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483249#comment-14483249 ] Fabian Hueske commented on FLINK-1834: -- I totally agree. We should get rid of this

[jira] [Closed] (FLINK-1560) Add ITCases for streaming examples

2015-04-07 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1560. - Resolution: Implemented Fix Version/s: 0.9 Implemented via ed7d165, 464e782 and 954beca.

[jira] [Commented] (FLINK-1560) Add ITCases for streaming examples

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483216#comment-14483216 ] ASF GitHub Bot commented on FLINK-1560: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1834) Is mapred.output.dir conf parameter really required?

2015-04-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483258#comment-14483258 ] Maximilian Michels commented on FLINK-1834: --- +1 Is mapred.output.dir conf

[jira] [Created] (FLINK-1837) Throw an exceptions for iterative streaming programs with checkpointing enabled

2015-04-07 Thread JIRA
Márton Balassi created FLINK-1837: - Summary: Throw an exceptions for iterative streaming programs with checkpointing enabled Key: FLINK-1837 URL: https://issues.apache.org/jira/browse/FLINK-1837

[jira] [Commented] (FLINK-1834) Is mapred.output.dir conf parameter really required?

2015-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483142#comment-14483142 ] Fabian Hueske commented on FLINK-1834: -- I would be careful with this. Do we know

[GitHub] flink pull request: FLINK-1560 - Add ITCases for streaming example...

2015-04-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/519 --- 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-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483215#comment-14483215 ] Stephan Ewen commented on FLINK-1820: - Given the discussion here, I agree with Fabian.

[jira] [Commented] (FLINK-1834) Is mapred.output.dir conf parameter really required?

2015-04-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483125#comment-14483125 ] Maximilian Michels commented on FLINK-1834: --- Let's check if the user's Hadoop

[jira] [Resolved] (FLINK-1817) ClassLoaderObjectInputStream fails with ClassNotFoundException for primitive classes

2015-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1817. -- Resolution: Fixed Fixed with - 0.9: d33b44549d416c30f01ead9aacf5cf7ed30674ca - 0.8:

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483253#comment-14483253 ] Maximilian Michels commented on FLINK-1820: --- +1 for a exception message for an

[jira] [Commented] (FLINK-1839) Failures in TwitterStreamITCase

2015-04-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483441#comment-14483441 ] Stephan Ewen commented on FLINK-1839: - Okay, from my latest Travis logs, this seems to

[jira] [Created] (FLINK-1839) Failures in TwitterStreamITCase

2015-04-07 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-1839: --- Summary: Failures in TwitterStreamITCase Key: FLINK-1839 URL: https://issues.apache.org/jira/browse/FLINK-1839 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1839) Failures in TwitterStreamITCase

2015-04-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483440#comment-14483440 ] Stephan Ewen commented on FLINK-1839: - Another occurance {code} Tests run: 1,

[jira] [Updated] (FLINK-1839) Failures in TwitterStreamITCase

2015-04-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1839: Priority: Critical (was: Major) Failures in TwitterStreamITCase ---

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

2015-04-07 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483480#comment-14483480 ] Timo Walther commented on FLINK-1319: - I have integrated the analyzer in the

[jira] [Closed] (FLINK-1837) Throw an exceptions for iterative streaming programs with checkpointing enabled

2015-04-07 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1837. - Resolution: Implemented Fix Version/s: 0.9 Implemented via 52ebb29 Throw an exceptions

[GitHub] flink pull request: Fix permissions on various non-executable sour...

2015-04-07 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/574#issuecomment-90660629 Ship it :+1: --- 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

[GitHub] flink pull request: [FLINK-951] Reworking of Iteration Synchroniza...

2015-04-07 Thread markus-h
Github user markus-h commented on the pull request: https://github.com/apache/flink/pull/570#issuecomment-90694363 There seems to be a race condition somewhere in my code but I have trouble finding it since I can not reproduce it locally. I thought my last change would fix it but it

[jira] [Assigned] (FLINK-1839) Failures in TwitterStreamITCase

2015-04-07 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1839: - Assignee: Márton Balassi Failures in TwitterStreamITCase

[jira] [Commented] (FLINK-1839) Failures in TwitterStreamITCase

2015-04-07 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483537#comment-14483537 ] Márton Balassi commented on FLINK-1839: --- My bad, I thought I have fixed it already.

[jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483752#comment-14483752 ] ASF GitHub Bot commented on FLINK-951: -- Github user markus-h commented on the pull

[GitHub] flink pull request: Fix permissions on various non-executable sour...

2015-04-07 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/574 Fix permissions on various non-executable source files Not a critical fix, but threw off the search for 3rd party executables as part of my pre-release code checking... You can merge this pull

[jira] [Created] (FLINK-1840) Job execution fails on Windows (native and Cygwin)

2015-04-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1840: Summary: Job execution fails on Windows (native and Cygwin) Key: FLINK-1840 URL: https://issues.apache.org/jira/browse/FLINK-1840 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484000#comment-14484000 ] ASF GitHub Bot commented on FLINK-1758: --- GitHub user andralungu opened a pull

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-07 Thread andralungu
GitHub user andralungu opened a pull request: https://github.com/apache/flink/pull/576 [FLINK-1758][gelly] Neighborhood Methods Extensions You can merge this pull request into a Git repository by running: $ git pull https://github.com/andralungu/flink extendNeighborhood

[jira] [Commented] (FLINK-1832) start-local.bat/start-local.sh does not work if there is a white space in the file path (windows)

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483878#comment-14483878 ] ASF GitHub Bot commented on FLINK-1832: --- GitHub user fhueske opened a pull request:

[jira] [Commented] (FLINK-1741) Add Jaccard Similarity Metric Example

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483936#comment-14483936 ] ASF GitHub Bot commented on FLINK-1741: --- Github user andralungu commented on the

[GitHub] flink pull request: [FLINK-1741][gelly] Adds Jaccard Similarity Me...

2015-04-07 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/544#issuecomment-90715751 @vasia, I updated the PR with your latest suggestions. Travis seems to fail because of flink-steaming :-s; my quick refactoring couldn't have triggered that :)

[GitHub] flink pull request: [FLINK-1832] Fix start scripts for Cygwin and ...

2015-04-07 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/575 [FLINK-1832] Fix start scripts for Cygwin and paths with spaces A few fixes for the start and submission scripts. Right now they fail for: - all scripts fail on Cygwin - `./bin/flink`

[GitHub] flink pull request: [FLINK-1523][gelly] Vertex centric iteration e...

2015-04-07 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/537#issuecomment-90728415 Hi @vasia , I simply assumed that if the previous examples work, the iteration also works as before. Would you like a specific test suite for that?

[jira] [Commented] (FLINK-1523) Vertex-centric iteration extensions

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484019#comment-14484019 ] ASF GitHub Bot commented on FLINK-1523: --- Github user andralungu commented on the

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-07 Thread Felix Neutatz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483973#comment-14483973 ] Felix Neutatz commented on FLINK-1820: -- ok, I agree with you. I will add the

[jira] [Commented] (FLINK-1840) Job execution fails on Windows (native and Cygwin)

2015-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484001#comment-14484001 ] Fabian Hueske commented on FLINK-1840: -- The exception is cause by the

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484226#comment-14484226 ] ASF GitHub Bot commented on FLINK-1758: --- Github user vasia commented on the pull

[jira] [Assigned] (FLINK-1841) WindowJoinITCase fails

2015-04-07 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-1841: - Assignee: Márton Balassi WindowJoinITCase fails --

[jira] [Commented] (FLINK-1840) Job execution fails on Windows (native and Cygwin)

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484129#comment-14484129 ] ASF GitHub Bot commented on FLINK-1840: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request: [FLINK-1840] Fix BLOB manager on Windows

2015-04-07 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/578 [FLINK-1840] Fix BLOB manager on Windows - closes open `FileOutputStream` before the field is moved - replaces `java.io.File.renameTo()` by `com.google.common.io.Files.move()` to avoid

[GitHub] flink pull request: Fix permissions on various non-executable sour...

2015-04-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/574 --- 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] [Created] (FLINK-1841) WindowJoinITCase fails

2015-04-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1841: Summary: WindowJoinITCase fails Key: FLINK-1841 URL: https://issues.apache.org/jira/browse/FLINK-1841 Project: Flink Issue Type: Bug Components:

[GitHub] flink pull request: [FLINK-1813] Avoid illegalstate exception when...

2015-04-07 Thread gyfora
GitHub user gyfora opened a pull request: https://github.com/apache/flink/pull/577 [FLINK-1813] Avoid illegalstate exception when trying to broadcast on finished operators You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-1813) Barrier broadcast sometimes causes illegal state exception in source RecordWriter

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484082#comment-14484082 ] ASF GitHub Bot commented on FLINK-1813: --- GitHub user gyfora opened a pull request:

[GitHub] flink pull request: [FLINK-1694] [gelly] added IterationConfigurat...

2015-04-07 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/547#issuecomment-90745094 Hi, any opinions on this? I would like to merge it soon because it changes the api and vertex-centric related issues depend on it. Thanks! --- If your project

[GitHub] flink pull request: [FLINK-1741][gelly] Adds Jaccard Similarity Me...

2015-04-07 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/544#issuecomment-90740868 Thank you @andralungu! This looks great now ^^ --- 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

[jira] [Commented] (FLINK-1694) Change the split between create/run of a vertex-centric iteration

2015-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484173#comment-14484173 ] ASF GitHub Bot commented on FLINK-1694: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-07 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/576#issuecomment-90749788 Thanks for the PR @andralungu! The idea for this issue is to (a) use a combinable reduce for the simple (without vertex value) reduceOn* methods, because it will be

[jira] [Commented] (FLINK-1744) Change the reference of slaves to workers to match the description of the system

2015-04-07 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484648#comment-14484648 ] Henry Saputra commented on FLINK-1744: -- No worries, we could always re-open it when