[jira] [Commented] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API

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

[GitHub] flink pull request: [FLINK-2391]Fix Storm-compatibility FlinkTopol...

2015-07-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/940#issuecomment-125177948 By the way, you don't need to open another pull request for updating it. Just force-push into the branch this PR is based on (`Feature2`). --- If your project is

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642622#comment-14642622 ] Maximilian Michels commented on FLINK-2404: --- Although the performance impact

[jira] [Commented] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

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

[jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only

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

[GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi...

2015-07-27 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/941#issuecomment-125192692 I guess the s in the name is the giveaway... --- 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-2213) Configure number of vcores

2015-07-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642702#comment-14642702 ] Robert Metzger commented on FLINK-2213: --- It does not affect the amount of CPU

[jira] [Assigned] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID

2015-07-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2409: Assignee: Till Rohrmann Old JM web interface is sending cancel messages w/o leader ID

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-27 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642605#comment-14642605 ] Sachin Goel commented on FLINK-2404: I'm using jdk8, specifically release 1.8.0_45 on

[jira] [Comment Edited] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-27 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642600#comment-14642600 ] Sachin Goel edited comment on FLINK-2404 at 7/27/15 11:51 AM: --

[jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only

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

[GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi...

2015-07-27 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/941 [FLINK-2408] Define all maven properties outside build profiles See JIRA issue for details. @aalexandrov, can you take a look at this? You can merge this pull request into a Git repository

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

2015-07-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/885#issuecomment-125187262 Okay, I tried it again and you are right. It seems to create the artifacts correctly. I was confused because a) the reactor summary didn't contain the variable:

[GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi...

2015-07-27 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/941#issuecomment-125189988 If sbt can resolve profile-based dependencies this should be OK. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

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

[jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable

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

[GitHub] flink pull request: [FLINK-2391]Fix Storm-compatibility FlinkTopol...

2015-07-27 Thread ffbin
Github user ffbin commented on the pull request: https://github.com/apache/flink/pull/940#issuecomment-125192161 Thank you very much! --- 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-1815) Add methods to read and write a Graph as adjacency list

2015-07-27 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642590#comment-14642590 ] Andra Lungu commented on FLINK-1815: Sure Faye, you're added :P One first challenge I

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-27 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642589#comment-14642589 ] Sachin Goel commented on FLINK-2404: I ran a dummy filter job to test any performance

[jira] [Comment Edited] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-27 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642600#comment-14642600 ] Sachin Goel edited comment on FLINK-2404 at 7/27/15 11:49 AM: --

[jira] [Commented] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API

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

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642619#comment-14642619 ] Maximilian Michels commented on FLINK-2404: --- I think it makes more sense to

[jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only

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

[jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only

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

[jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable

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

[GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co...

2015-07-27 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/943 [FLINK-2410] [java api] PojoTypeInfo is not completely serializable The type `java.reflect.Field` is not Serializable and has to be serialized manually, which was not implemented until now in

[GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co...

2015-07-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/943#issuecomment-125191411 Thank you for the PR. Can you add a test case validating the fix? --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co...

2015-07-27 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/943#issuecomment-125203795 I have created a separate test. But the idea is good. I will create a Table API example from my current code. --- If your project is set up for it, you can reply to

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-27 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/936#issuecomment-125175011 I don't know of a better solution than the current approach if we want to support the `stateByKey` parameter. I agree with Aljoscha that `ds.mapWithState({ (x, o) =

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

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

[jira] [Commented] (FLINK-2325) PersistentKafkaSource throws ArrayIndexOutOfBoundsException if reading from a topic that is created after starting the Source

2015-07-27 Thread Rico Bergmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642623#comment-14642623 ] Rico Bergmann commented on FLINK-2325: -- Just checked it, but it's still the same

[jira] [Issue Comment Deleted] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-27 Thread fangfengbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fangfengbin updated FLINK-2391: --- Comment: was deleted (was: Thank you very much!) Storm-compatibility:method

[GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co...

2015-07-27 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/943#issuecomment-125191888 The lines are basically copied from PojoComparator but yes I can add a test case for it ;) --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642602#comment-14642602 ] Maximilian Michels commented on FLINK-2404: --- The performance impact might differ

[GitHub] flink pull request: [FLINK-2406] [FLINK-2402] Abstract the Barrier...

2015-07-27 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/938#issuecomment-125183346 From Gyulas's comment in #937, there seems to be a deadlock. @gyfora, can you provide more input? --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-2399) Fail when actor versions don't match

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

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

2015-07-27 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642600#comment-14642600 ] Sachin Goel commented on FLINK-2404: In fact, here are some detailed timings under the

[GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi...

2015-07-27 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/941#issuecomment-125182364 Then it should be good to merge. --- 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

[GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co...

2015-07-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/943#issuecomment-125192186 I would just use the Table API example you've posted in the JIRA and add another IT case for the Table API --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-2161) Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML)

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

[GitHub] flink pull request: [FLINK-2161] modified Scala shell start script...

2015-07-27 Thread nikste
Github user nikste commented on the pull request: https://github.com/apache/flink/pull/805#issuecomment-125179652 The IT case now looks for a jar inside the ml-folder which does not contain test or original. Thus the IT case should work for different flink-versions as long as the

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-27 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/936#issuecomment-125179431 You actually make a good point. Since one cannot apply multiple transformations while keeping a KeyedDataStream, we can assume stateByKey true on a keyedDataStream,

[jira] [Commented] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler

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

[jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only

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

[GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi...

2015-07-27 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/941#issuecomment-125185305 Hi, pom.xml file of flink-scala module has also profile based dependency setting. Is it okay without modification? --- If your project is set up for it, you can

[jira] [Created] (FLINK-2410) PojoTypeInfo is not completely serializable

2015-07-27 Thread Timo Walther (JIRA)
Timo Walther created FLINK-2410: --- Summary: PojoTypeInfo is not completely serializable Key: FLINK-2410 URL: https://issues.apache.org/jira/browse/FLINK-2410 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only

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

[jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only

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

[GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi...

2015-07-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/941#issuecomment-125181480 I don't think that I'm removing the activation of the `scala-2.11` profile. If the `scala-2.11` property is set, the default value of the property will be

[GitHub] flink pull request: [FLINK-2406] [FLINK-2402] Abstract the Barrier...

2015-07-27 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/938#issuecomment-125184157 This is the same issue as in Stephan's build: https://travis-ci.org/apache/flink/jobs/72752909 --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi...

2015-07-27 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/941#issuecomment-125191075 sbt can't do that. We are lucky here because the `maven-shade-plugin` is generating a dependency-reduced pom with the effective settings. (Take a look in your

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-27 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/936#issuecomment-125212680 I updated the PR according to the comments, and added an IT case that tests all 3 functions. (map-localstate, flatmap-localstate, filter-partitionedstate) Let's

[jira] [Commented] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API

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

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

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

[jira] [Comment Edited] (FLINK-2325) PersistentKafkaSource throws ArrayIndexOutOfBoundsException if reading from a topic that is created after starting the Source

2015-07-27 Thread Rico Bergmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642623#comment-14642623 ] Rico Bergmann edited comment on FLINK-2325 at 7/27/15 12:02 PM:

[GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi...

2015-07-27 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/941#issuecomment-125180542 Is the removal of the property-based activation (`-Dscala-2.11`) also intentional? I think this might be used in the travis.yml. --- If your project is set up for

[jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only

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

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

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

[jira] [Commented] (FLINK-2404) LongCounters should have an addValue() method for primitive longs

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

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-27 Thread fangfengbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642674#comment-14642674 ] fangfengbin commented on FLINK-2391: Thank you very much! Storm-compatibility:method

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-27 Thread fangfengbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642672#comment-14642672 ] fangfengbin commented on FLINK-2391: Thank you very much! Storm-compatibility:method

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-27 Thread fangfengbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642675#comment-14642675 ] fangfengbin commented on FLINK-2391: Thank you very much! Storm-compatibility:method

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-27 Thread fangfengbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642673#comment-14642673 ] fangfengbin commented on FLINK-2391: Thank you very much! Storm-compatibility:method

[jira] [Issue Comment Deleted] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-27 Thread fangfengbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fangfengbin updated FLINK-2391: --- Comment: was deleted (was: Thank you very much!) Storm-compatibility:method

[jira] [Issue Comment Deleted] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

2015-07-27 Thread fangfengbin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fangfengbin updated FLINK-2391: --- Comment: was deleted (was: Thank you very much!) Storm-compatibility:method

[jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable

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

[jira] [Commented] (FLINK-2399) Fail when actor versions don't match

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

[jira] [Created] (FLINK-2411) Add basic graph summarization algorithm

2015-07-27 Thread Martin Junghanns (JIRA)
Martin Junghanns created FLINK-2411: --- Summary: Add basic graph summarization algorithm Key: FLINK-2411 URL: https://issues.apache.org/jira/browse/FLINK-2411 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-2411) Add basic graph summarization algorithm

2015-07-27 Thread Martin Junghanns (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2411: Description: Graph summarization determines a structural grouping of similar vertices and

[jira] [Updated] (FLINK-2411) Add basic graph summarization algorithm

2015-07-27 Thread Martin Junghanns (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2411: Description: Graph summarization determines a structural grouping of similar vertices and

[jira] [Updated] (FLINK-2411) Add basic graph summarization algorithm

2015-07-27 Thread Martin Junghanns (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2411: Description: Graph summarization determines a structural grouping of similar vertices and

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-27 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/936#issuecomment-125259161 Travis apparently passes (there was some unrelated Kafka error), so if no objections I will merge this tomorrow :) --- If your project is set up for it, you can reply to

[GitHub] flink pull request: [FLINK-2399] Version checks for Job Manager an...

2015-07-27 Thread sachingoel0101
Github user sachingoel0101 closed the pull request at: https://github.com/apache/flink/pull/944 --- 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

[jira] [Commented] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API

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

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

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

[GitHub] flink pull request: [FLINK-2391]Fix Storm-compatibility FlinkTopol...

2015-07-27 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/940#issuecomment-125261373 +1 for merging --- 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-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

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

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-27 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/936#issuecomment-125265963 Sure, go ahead. :smile: --- 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] [Created] (FLINK-2412) Index Out of Bounds Exception

2015-07-27 Thread Andra Lungu (JIRA)
Andra Lungu created FLINK-2412: -- Summary: Index Out of Bounds Exception Key: FLINK-2412 URL: https://issues.apache.org/jira/browse/FLINK-2412 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-27 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125268029 Definitely. --- 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-2200) Flink API with Scala 2.11 - Maven Repository

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

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

2015-07-27 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/885#issuecomment-125271970 There is wrong description in building documentation. Because Scala 2.11 profile activation is determined by property scala-2.11, Scala 2.10 profile is activated when

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-27 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125266560 We should try to find out what the problem was in the beginning, let's wait for @StephanEwen. I think @rmetzger is also investigating the issue. --- If your project is

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

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

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

2015-07-27 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/885#issuecomment-125319617 When we upgrade version of maven-shade-plugin to 2.4.1, the property in current project artifactId is interpolated properly. But the property in parent artifactId is

[jira] [Created] (FLINK-2414) Extend job data in job list

2015-07-27 Thread Piotr Godek (JIRA)
Piotr Godek created FLINK-2414: -- Summary: Extend job data in job list Key: FLINK-2414 URL: https://issues.apache.org/jira/browse/FLINK-2414 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2415) Link nodes in plan to vertices

2015-07-27 Thread Piotr Godek (JIRA)
Piotr Godek created FLINK-2415: -- Summary: Link nodes in plan to vertices Key: FLINK-2415 URL: https://issues.apache.org/jira/browse/FLINK-2415 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2413) Provide real vertex data

2015-07-27 Thread Piotr Godek (JIRA)
Piotr Godek created FLINK-2413: -- Summary: Provide real vertex data Key: FLINK-2413 URL: https://issues.apache.org/jira/browse/FLINK-2413 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

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

[GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow...

2015-07-27 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-125359065 I have rebased the PR and added commits of @aalexandrov that introduce a CLI option `--classpath`. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API

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

[jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list

2015-07-27 Thread Faye Beligianni (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642522#comment-14642522 ] Faye Beligianni commented on FLINK-1815: Nice! I will maybe pink you for any

[GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi...

2015-07-27 Thread gyfora
Github user gyfora commented on a diff in the pull request: https://github.com/apache/flink/pull/936#discussion_r35521195 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala --- @@ -332,13 +359,23

[jira] [Created] (FLINK-2408) Some maven properties are defined in build profiles only

2015-07-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2408: - Summary: Some maven properties are defined in build profiles only Key: FLINK-2408 URL: https://issues.apache.org/jira/browse/FLINK-2408 Project: Flink

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-27 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-125156345 So far it seems to work rebased on #938 (but I am getting some test failures due to some deadlock in that PR). --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

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

[jira] [Created] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID

2015-07-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2409: - Summary: Old JM web interface is sending cancel messages w/o leader ID Key: FLINK-2409 URL: https://issues.apache.org/jira/browse/FLINK-2409 Project: Flink

[jira] [Commented] (FLINK-2243) Add finite spout functionality to Storm compatibility layer

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

[jira] [Commented] (FLINK-2127) The GSA Documentation has trailing /p s

2015-07-27 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14642411#comment-14642411 ] Vasia Kalavri commented on FLINK-2127: -- Is this one still a problem? The GSA

[jira] [Commented] (FLINK-1962) Add Gelly Scala API

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

  1   2   >