[jira] [Created] (FLINK-2582) Document how to build Flink with other Scala versions

2015-08-27 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2582: --- Summary: Document how to build Flink with other Scala versions Key: FLINK-2582 URL: https://issues.apache.org/jira/browse/FLINK-2582 Project: Flink Issue

[jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib

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

[GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ...

2015-08-27 Thread mbalassi
Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/1069#discussion_r38091104 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/partitioner/PartialPartitioner.java --- @@ -0,0 +1,60

[jira] [Commented] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

2015-08-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716659#comment-14716659 ] Márton Balassi commented on FLINK-2499: --- Good point, will act accordingly.

[jira] [Commented] (FLINK-2525) Add configuration support in Storm-compatibility

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

[jira] [Commented] (FLINK-2525) Add configuration support in Storm-compatibility

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

[GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ...

2015-08-27 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1069#issuecomment-135418178 Thanks for the fast response on your side addressing my comments. :) I generally love the idea described at

[jira] [Closed] (FLINK-2553) Example Jars not build correctly

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2553. --- Example Jars not build correctly Key: FLINK-2553

[jira] [Resolved] (FLINK-2553) Example Jars not build correctly

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2553. - Resolution: Fixed Fix Version/s: 0.10 Fixed via 824785e2689b6b56e923490d74d52dd29f5fe412

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716606#comment-14716606 ] ASF GitHub Bot commented on FLINK-1725: --- Github user mbalassi commented on a diff in

[jira] [Commented] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

2015-08-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716640#comment-14716640 ] Márton Balassi commented on FLINK-2499: --- [~airbots] correct me if I am wrong but

[jira] [Commented] (FLINK-2553) Example Jars not build correctly

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

[GitHub] flink pull request: [FLINK-2553] Example Jars not build correctly

2015-08-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1037 --- 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-2373) Add configuration parameter to createRemoteEnvironment method

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716738#comment-14716738 ] ASF GitHub Bot commented on FLINK-2373: --- Github user tillrohrmann commented on the

[jira] [Commented] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716656#comment-14716656 ] Stephan Ewen commented on FLINK-2499: - The {{taskmanager.sh}} script looks like it is

[jira] [Created] (FLINK-2584) ASM dependency is not shaded away

2015-08-27 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2584: -- Summary: ASM dependency is not shaded away Key: FLINK-2584 URL: https://issues.apache.org/jira/browse/FLINK-2584 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-2152] [bugfix] Used a concurrent list i...

2015-08-27 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/1058#issuecomment-135407258 so you mean something like `ListTuple2Integer, Long offsets = getRuntimeContext().getBroadcastVariableWithInitializer(counts, new ArrayList());`?

[jira] [Commented] (FLINK-2582) Document how to build Flink with other Scala versions

2015-08-27 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716593#comment-14716593 ] Chiwan Park commented on FLINK-2582: Maybe we can cherry-pick from

[jira] [Created] (FLINK-2583) Add Stream Sink For Rolling HDFS Files

2015-08-27 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2583: --- Summary: Add Stream Sink For Rolling HDFS Files Key: FLINK-2583 URL: https://issues.apache.org/jira/browse/FLINK-2583 Project: Flink Issue Type: New

[GitHub] flink pull request: [FLINK-2493] Simplify names of example program...

2015-08-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1068#issuecomment-135426825 Here is a reference to the CI result: https://s3.amazonaws.com/archive.travis-ci.org/jobs/77474252/log.txt You can always run `mvn clean verify` locally.

[jira] [Commented] (FLINK-2525) Add configuration support in Storm-compatibility

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

[GitHub] flink pull request: [FLINK-2525]Add configuration support in Storm...

2015-08-27 Thread ffbin
Github user ffbin commented on the pull request: https://github.com/apache/flink/pull/1046#issuecomment-135412789 Oh. you are right. Serialize the whole Map into a single byte[] is better.Thanks. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request: [FLINK-2490][FIX]Remove the retryForever check...

2015-08-27 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/992#issuecomment-135429969 @mxm Hi, I add a test that first send a message to the SocketTextStreamFunction and this is success. Then I close the server let the

[GitHub] flink pull request: [FLINK-2373] Add configuration parameter to cr...

2015-08-27 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1066#issuecomment-135448224 @uce, I think this should be addressed either in #1016 or in a separate PR once #1016 is merged. --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request: [FLINK-2493] Simplify names of example program...

2015-08-27 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1068#issuecomment-135420490 Thanks for picking up the issue. Could you make the changes for the `flink-streaming-examples` and the `flink-storm-compatibility-example` modules too, please? Also

[jira] [Commented] (FLINK-2493) Simplify names of example program JARs

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

[GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ...

2015-08-27 Thread anisnasir
Github user anisnasir commented on the pull request: https://github.com/apache/flink/pull/1069#issuecomment-135452679 Thank you very much for the feedback. 1. I have updated the constructor and removed the dependency of number of channels. Now the constructs are similar to

[jira] [Assigned] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

2015-08-27 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2499: - Assignee: Márton Balassi start-cluster.sh can start multiple TaskManager on the same

[jira] [Commented] (FLINK-2586) Unstable Storm Compatibility Tests

2015-08-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717104#comment-14717104 ] Matthias J. Sax commented on FLINK-2586: This is a know problem. The reasons why

[jira] [Updated] (FLINK-2571) Add task hooks support in Storm-compatibility

2015-08-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2571: --- Component/s: (was: flink-contrib) Storm Compatibility Add task hooks

[jira] [Commented] (FLINK-2326) Mutitenancy on Yarn

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717141#comment-14717141 ] ASF GitHub Bot commented on FLINK-2326: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716825#comment-14716825 ] Aljoscha Krettek commented on FLINK-2585: - Hi, could you please give some details

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716889#comment-14716889 ] Boyang Jerry Peng commented on FLINK-2585: -- I running using 'bin/flink'. I have

[jira] [Comment Edited] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716900#comment-14716900 ] Aljoscha Krettek edited comment on FLINK-2585 at 8/27/15 3:49 PM:

[jira] [Created] (FLINK-2586) Unstable Storm Compatibility Tests

2015-08-27 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2586: --- Summary: Unstable Storm Compatibility Tests Key: FLINK-2586 URL: https://issues.apache.org/jira/browse/FLINK-2586 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2111) Add stop signal to cleanly shutdown streaming jobs

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717067#comment-14717067 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on a diff in

[jira] [Created] (FLINK-2587) FlinkKafkaConsumer may fail with a NPE

2015-08-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2587: - Summary: FlinkKafkaConsumer may fail with a NPE Key: FLINK-2587 URL: https://issues.apache.org/jira/browse/FLINK-2587 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-2566) FlinkTopologyContext no populated completely

2015-08-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2566: --- Component/s: (was: flink-contrib) Storm Compatibility

[jira] [Commented] (FLINK-2586) Unstable Storm Compatibility Tests

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717109#comment-14717109 ] Stephan Ewen commented on FLINK-2586: - That is not really the problem here. The

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717169#comment-14717169 ] Stephan Ewen commented on FLINK-2585: - Seems that the exceptions do not propagate to

[jira] [Commented] (FLINK-2586) Unstable Storm Compatibility Tests

2015-08-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717198#comment-14717198 ] Matthias J. Sax commented on FLINK-2586: You are right. It's not the kill thing.

[GitHub] flink pull request: [FLINK-2111] Add stop signal to cleanly shut...

2015-08-27 Thread mjsax
Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r38119693 --- Diff:

[jira] [Commented] (FLINK-2582) Document how to build Flink with other Scala versions

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

[GitHub] flink pull request: [FLINK-2326] Write yarn properties file to tem...

2015-08-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1062#issuecomment-135503479 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

[jira] [Resolved] (FLINK-2584) ASM dependency is not shaded away

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2584. - Resolution: Fixed Assignee: Stephan Ewen (was: Robert Metzger) Fix Version/s:

[jira] [Closed] (FLINK-2584) ASM dependency is not shaded away

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2584. --- ASM dependency is not shaded away - Key: FLINK-2584

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717183#comment-14717183 ] Robert Metzger commented on FLINK-2585: --- [~jerrypeng]: I think the problem is that

[GitHub] flink pull request: [FLINK-2556] Refactor/Fix pre-flight Key valid...

2015-08-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1044#issuecomment-135508810 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

[jira] [Commented] (FLINK-2556) Fix/Refactor pre-flight Key validation

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717190#comment-14717190 ] ASF GitHub Bot commented on FLINK-2556: --- Github user StephanEwen commented on the

[jira] [Updated] (FLINK-2338) Shut down Storm Topologies cleanly

2015-08-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2338: --- Component/s: (was: flink-contrib) Storm Compatibility Shut down Storm

[GitHub] flink pull request: [FLINK-2582] [docs] Add documentation how to b...

2015-08-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1070#issuecomment-135501709 Looks good, +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

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717162#comment-14717162 ] Boyang Jerry Peng commented on FLINK-2585: -- I am getting this error in one of my

[jira] [Commented] (FLINK-2565) Support primitive arrays as keys

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717213#comment-14717213 ] ASF GitHub Bot commented on FLINK-2565: --- Github user StephanEwen commented on the

[jira] [Updated] (FLINK-2525) Add configuration support in Storm-compatibility

2015-08-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2525: --- Component/s: (was: flink-contrib) Storm Compatibility Add configuration

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716840#comment-14716840 ] Robert Metzger commented on FLINK-2585: --- Did you produce data into the topic? I

[GitHub] flink pull request: [FLINK-2499] [scripts] Warning message for hos...

2015-08-27 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1071#issuecomment-135489719 This actually looks good. Let's merge it and collect user feedback - whether anyone is bothered by the warnings when they start multiple TaskManager on one

[jira] [Commented] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717031#comment-14717031 ] ASF GitHub Bot commented on FLINK-2499: --- Github user StephanEwen commented on the

[jira] [Updated] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Jerry Peng updated FLINK-2585: - Description: I tried running the KafkaConsumerExample with that is subscribing to a

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716916#comment-14716916 ] Boyang Jerry Peng commented on FLINK-2585: -- I'm looking at the .out files, but I

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716917#comment-14716917 ] Stephan Ewen commented on FLINK-2585: - The {{print()}} method in the batch API prints

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717027#comment-14717027 ] Robert Metzger commented on FLINK-2585: --- if the log contains confidential

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716900#comment-14716900 ] Aljoscha Krettek commented on FLINK-2585: - I see, I think the problem is that you

[jira] [Updated] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Jerry Peng updated FLINK-2585: - Description: I tried running the KafkaConsumerExample with that is subscribing to a

[jira] [Commented] (FLINK-2584) ASM dependency is not shaded away

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716872#comment-14716872 ] Robert Metzger commented on FLINK-2584: --- The problem was that we upgraded the

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716906#comment-14716906 ] Boyang Jerry Peng commented on FLINK-2585: -- I have been monitoring the out logs

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716966#comment-14716966 ] Boyang Jerry Peng commented on FLINK-2585: -- Sounds good, but I am monitoring the

[jira] [Created] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
Boyang Jerry Peng created FLINK-2585: Summary: KafkaSource not working Key: FLINK-2585 URL: https://issues.apache.org/jira/browse/FLINK-2585 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2585: Description: I tried running the KafkaConsumerExample with that is subscribing to a console

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716876#comment-14716876 ] Boyang Jerry Peng commented on FLINK-2585: -- Thank you for your help!

[jira] [Issue Comment Deleted] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Jerry Peng updated FLINK-2585: - Comment: was deleted (was: Thank you for your help!) KafkaSource not working

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716877#comment-14716877 ] Boyang Jerry Peng commented on FLINK-2585: -- Thank you for your help!

[jira] [Commented] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node

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

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716910#comment-14716910 ] Aljoscha Krettek commented on FLINK-2585: - Sorry, this might be a stupid question

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716997#comment-14716997 ] Aljoscha Krettek commented on FLINK-2585: - Could you please post the contents of

[jira] [Commented] (FLINK-2326) Mutitenancy on Yarn

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

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717388#comment-14717388 ] Robert Metzger commented on FLINK-2585: --- [~StephanEwen]: Kafka is only logging the

[jira] [Commented] (FLINK-2111) Add stop signal to cleanly shutdown streaming jobs

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717255#comment-14717255 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on a diff in

[jira] [Commented] (FLINK-2111) Add stop signal to cleanly shutdown streaming jobs

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717245#comment-14717245 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on a diff in

[GitHub] flink pull request: [FLINK-2326] Write yarn properties file to tem...

2015-08-27 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1062#issuecomment-135518748 Confirming that with my local travis also work. +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

[GitHub] flink pull request: [FLINK-2111] Add stop signal to cleanly shut...

2015-08-27 Thread mjsax
Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r38132263 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -411,6 +411,23 @@ class TaskManager(

[jira] [Comment Edited] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717398#comment-14717398 ] Robert Metzger edited comment on FLINK-2585 at 8/27/15 7:54 PM:

[GitHub] flink pull request: [FLINK-2111] Add stop signal to cleanly shut...

2015-08-27 Thread mjsax
Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r38130678 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java --- @@ -363,7 +363,135 @@ protected void run() {

[jira] [Commented] (FLINK-2111) Add stop signal to cleanly shutdown streaming jobs

2015-08-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717286#comment-14717286 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on a diff in

[GitHub] flink pull request: [FLINK-2111] Add stop signal to cleanly shut...

2015-08-27 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-135523032 I just pushed three commits on top addressing your comment. The first two, include reworking all test cases in a whole package each, to change the test pattern from catch

[jira] [Commented] (FLINK-2111) Add stop signal to cleanly shutdown streaming jobs

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

[jira] [Resolved] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2585. --- Resolution: Not A Problem KafkaSource not working ---

[jira] [Assigned] (FLINK-2586) Unstable Storm Compatibility Tests

2015-08-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2586: -- Assignee: Matthias J. Sax Unstable Storm Compatibility Tests

[jira] [Commented] (FLINK-2582) Document how to build Flink with other Scala versions

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717592#comment-14717592 ] Stephan Ewen commented on FLINK-2582: - Ah, sorry [~chiwanpark], saw your comment too

[jira] [Commented] (FLINK-2582) Document how to build Flink with other Scala versions

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717593#comment-14717593 ] Stephan Ewen commented on FLINK-2582: - Added a description via

[GitHub] flink pull request: [FLINK-2326] Write yarn properties file to tem...

2015-08-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1062 --- 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] [Resolved] (FLINK-2565) Support primitive arrays as keys

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2565. - Resolution: Fixed Fix Version/s: 0.10 Fixed in 0807eec0cb1acf8052a77b6133387e25399fce08

[jira] [Closed] (FLINK-2565) Support primitive arrays as keys

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2565. --- Support primitive arrays as keys Key: FLINK-2565

[jira] [Closed] (FLINK-2587) FlinkKafkaConsumer may fail with a NPE

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2587. --- FlinkKafkaConsumer may fail with a NPE -- Key:

[jira] [Resolved] (FLINK-2587) FlinkKafkaConsumer may fail with a NPE

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

[jira] [Closed] (FLINK-2326) Mutitenancy on Yarn

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2326. --- Mutitenancy on Yarn --- Key: FLINK-2326 URL:

[jira] [Resolved] (FLINK-2326) Mutitenancy on Yarn

2015-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2326. - Resolution: Fixed Fix Version/s: 0.10 Fixed via 8cf8736ad99c78aa419ee2d6be4b70ac1b29d0ec

[GitHub] flink pull request: [FLINK-2582] [docs] Add documentation how to b...

2015-08-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1070 --- 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-2565) Support primitive arrays as keys

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

[jira] [Commented] (FLINK-2556) Fix/Refactor pre-flight Key validation

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

[jira] [Commented] (FLINK-2582) Document how to build Flink with other Scala versions

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

  1   2   3   >