[GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for...

2015-03-03 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/440#issuecomment-76914047 The failure in TaskManagerFailsITCase should be unrelated to your PR. This should be fixed once the proper shading is in place. So don't worry and go ahead

[GitHub] flink pull request: [FLINK-999] Configurability of LocalExecutor

2015-03-03 Thread jkirsch
GitHub user jkirsch opened a pull request: https://github.com/apache/flink/pull/448 [FLINK-999] Configurability of LocalExecutor Add also the global configuration to the minicluster. This is an attempt to bring in the ability to pass configuration parameters to the

[GitHub] flink pull request: Streaming cancellation + exception handling re...

2015-03-03 Thread gyfora
GitHub user gyfora opened a pull request: https://github.com/apache/flink/pull/449 Streaming cancellation + exception handling rework This PR reworks the way runtime exceptions are handled in the streaming runtime. User code and other types of exceptions thrown during the

[GitHub] flink pull request: [FLINK-1350][FLINK-1359][Distributed runtime] ...

2015-03-03 Thread uce
Github user uce closed the pull request at: https://github.com/apache/flink/pull/356 --- 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 enabled

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-03-03 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-76973194 Yes, this sounds good? Another thing: it has probably already come up but I just want to make sure, you implement CoGroup and Reduce the way you do because of

[jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6

2015-03-03 Thread Max Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14344927#comment-14344927 ] Max Michels commented on FLINK-1637: There are tools like ProGuard which can reduce

[jira] [Created] (FLINK-1636) Misleading exception during concurrent partition release and remote request

2015-03-03 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1636: -- Summary: Misleading exception during concurrent partition release and remote request Key: FLINK-1636 URL: https://issues.apache.org/jira/browse/FLINK-1636 Project: Flink

[GitHub] flink pull request: Add auto-parallelism to Jobs (0.8 branch)

2015-03-03 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/410#issuecomment-76974155 Ping ... --- 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-1555] Add serializer hierarchy debug ut...

2015-03-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/415 --- 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

[GitHub] flink pull request: Add auto-parallelism to Jobs (0.8 branch)

2015-03-03 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/410#issuecomment-76978687 @rmetzger I don't see a reason why this should not go to master as well. After all, it's optional and quite useful if you want to run a job on the full cluster with as many

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

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

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345300#comment-14345300 ] Robert Metzger commented on FLINK-1577: --- Thank you! Misleading error messages when

[jira] [Commented] (FLINK-1555) Add utility to log the serializers of composite types

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

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

2015-03-03 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 Fixed in 9255594fb3b9b7c00d9088c3b630af9ecbdf22f4. Misleading error messages

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-03-03 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-76981299 You could call it CoGroupRaw, just an idea... Once that and the split into the python and generic part is done I vote for merging this. The API looks good and

[jira] [Resolved] (FLINK-1555) Add utility to log the serializers of composite types

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1555. --- Resolution: Fixed Fix Version/s: 0.9 This has been resolved in

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

[jira] [Commented] (FLINK-1628) Strange behavior of where function during a join

2015-03-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345350#comment-14345350 ] Aljoscha Krettek commented on FLINK-1628: - [~fhueske] and I found the bug in the

[jira] [Commented] (FLINK-1628) Strange behavior of where function during a join

2015-03-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345353#comment-14345353 ] Aljoscha Krettek commented on FLINK-1628: - This is the fix, line 128 in

[jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6

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

[jira] [Commented] (FLINK-1616) Action list -r gives IOException when there are running jobs

2015-03-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345457#comment-14345457 ] Stephan Ewen commented on FLINK-1616: - There are a few issues with the CLI frontend.

[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples

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

[GitHub] flink pull request: [FLINK-1522][FLINK-1576] Updated LabelPropagat...

2015-03-03 Thread balidani
Github user balidani commented on the pull request: https://github.com/apache/flink/pull/441#issuecomment-76998835 Hi @vasia! Thanks for the ideas! I tried to add more test cases that reflect them. However, I'm not sure about the last bullet-point. Do you think my last

[jira] [Comment Edited] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release

2015-03-03 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345637#comment-14345637 ] Henry Saputra edited comment on FLINK-1639 at 3/3/15 8:04 PM: --

[jira] [Updated] (FLINK-1637) Flink uberjar does not work with Java 6

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1637: -- Component/s: Build System Flink uberjar does not work with Java 6

[jira] [Assigned] (FLINK-1633) Add getTriplets() Gelly method

2015-03-03 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu reassigned FLINK-1633: -- Assignee: Andra Lungu Add getTriplets() Gelly method --

[jira] [Commented] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release

2015-03-03 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345634#comment-14345634 ] Márton Balassi commented on FLINK-1639: --- I do agree that a documentation is needed

[GitHub] flink pull request: [FLINK-1522][FLINK-1576] Updated LabelPropagat...

2015-03-03 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/441#issuecomment-77013031 Hi @balidani! You're right, there is no way to check this without modifying the library method. You can ignore my last bullet point for now :) --- If your project is set

[jira] [Commented] (FLINK-1522) Add tests for the library methods and examples

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

[jira] [Commented] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release

2015-03-03 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345637#comment-14345637 ] Henry Saputra commented on FLINK-1639: -- Cool! Thanks [~ mbalassi], no good goes

[GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for...

2015-03-03 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/440#issuecomment-77004964 perfect, thanks! --- 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-1587) coGroup throws NoSuchElementException on iterator.next()

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

[GitHub] flink pull request: [FLINK-1633][gelly] Added getTriplets() method...

2015-03-03 Thread andralungu
GitHub user andralungu opened a pull request: https://github.com/apache/flink/pull/452 [FLINK-1633][gelly] Added getTriplets() method and test A convenience Gelly method that generates a DataSet of srcVertexId, trgVertexId, srcVertexVal, trgVertexVal, edgeValue from the input

[jira] [Resolved] (FLINK-1631) Port collisions in ProcessReaping tests

2015-03-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1631. - Resolution: Fixed Fixed via 94a66d570e4bb40824813911a4f1bb47a8bf8b90 Port collisions in

[jira] [Created] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

2015-03-03 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1640: Summary: FileOutputFormat writes to wrong path if path ends with '/' Key: FLINK-1640 URL: https://issues.apache.org/jira/browse/FLINK-1640 Project: Flink

[jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings

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

[GitHub] flink pull request: [FLINK-1616] [client] Overhaul of the client.

2015-03-03 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/451 [FLINK-1616] [client] Overhaul of the client. - Fix bugs with non-serializable messages - Separate parser and action logic - Clean up tests - Vastly improve logging in CLI client

[jira] [Assigned] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

2015-03-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1640: Assignee: Fabian Hueske FileOutputFormat writes to wrong path if path ends with '/'

[GitHub] flink pull request: [FLINK-1637] Reduce number of files in uberjar...

2015-03-03 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/450#issuecomment-77031055 Damn. The good news is, my test is working, the bad news is, that the hadoop 2.6.0 version is causing an oversized uberjar: The number of files in the uberjar

[GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for...

2015-03-03 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/440#issuecomment-77068115 Hi, I was about to merge this one, but I have two doubts: - the tests print all execution output, including the exceptions, in standard output. Is this OK or should

[jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next()

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

[jira] [Commented] (FLINK-1627) Netty channel connect deadlock

2015-03-03 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14344837#comment-14344837 ] Ufuk Celebi commented on FLINK-1627: I couldn't yet reproduce the problem (I did 10

[jira] [Created] (FLINK-1637) Flink uberjar does not work with Java 6

2015-03-03 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1637: - Summary: Flink uberjar does not work with Java 6 Key: FLINK-1637 URL: https://issues.apache.org/jira/browse/FLINK-1637 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1637) Flink uberjar does not work with Java 6

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14344918#comment-14344918 ] Robert Metzger commented on FLINK-1637: --- The issue is that Java 6 can not load jar

[GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...

2015-03-03 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/202#issuecomment-76935408 @aljoscha Im quite undecided on that one. What i would like the most is having the language binding module remain where it is, with 2 submodules: flink-generic and

[jira] [Commented] (FLINK-1635) Remove Apache Thrift dependency from Flink

2015-03-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14344841#comment-14344841 ] Stephan Ewen commented on FLINK-1635: - I agree, let's remove this. The way that it

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

2015-03-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345169#comment-14345169 ] Robert Metzger commented on FLINK-1577: --- Another user was affected by this. Would be