[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-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-tabpanel&focusedCommentId=14643494#comment-14643494 ] ASF GitHub Bot commented on FLINK-1789: --- Github user twalthr commented on the pull r

[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 Co

[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 Compo

[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 Componen

[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-tabpanel&focusedCommentId=14643257#comment-14643257 ] ASF GitHub Bot commented on FLINK-2200: --- Github user chiwanpark commented on the pul

[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 n

[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-tabpanel&focusedCommentId=14643192#comment-14643192 ] ASF GitHub Bot commented on FLINK-2399: --- GitHub user sachingoel0101 opened a pull re

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

2015-07-27 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/945 [FLINK-2399] Version checks for Job Manager and Task Manager [Reopening #944. The travis build failed somehow. ] Both Job Manager and Task Manager now communicate their respective version

[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 Components:

[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 whe

[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-tabpanel&focusedCommentId=14643024#comment-14643024 ] ASF GitHub Bot commented on FLINK-2200: --- Github user chiwanpark commented on the pul

[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 enab

[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-tabpanel&focusedCommentId=14642994#comment-14642994 ] ASF GitHub Bot commented on FLINK-2324: --- Github user gyfora commented on the pull re

[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-tabpanel&focusedCommentId=14642972#comment-14642972 ] ASF GitHub Bot commented on FLINK-2324: --- Github user aljoscha commented on the pull

[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-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-tabpanel&focusedCommentId=14642967#comment-14642967 ] ASF GitHub Bot commented on FLINK-2405: --- Github user aljoscha 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 th

[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-tabpanel&focusedCommentId=14642943#comment-14642943 ] ASF GitHub Bot commented on FLINK-2391: --- Github user mjsax commented on the pull req

[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 en

[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-tabpanel&focusedCommentId=14642932#comment-14642932 ] ASF GitHub Bot commented on FLINK-2405: --- Github user gyfora commented on the pull re

[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

[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 e

[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 e

[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 e

[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 e

[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 e

[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 F

[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-tabpanel&focusedCommentId=14642828#comment-14642828 ] ASF GitHub Bot commented on FLINK-2399: --- Github user sachingoel0101 closed the pull

[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

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-07-27 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-125225039 Hi @shghatge, @andralungu, I built on the current state of this PR and made the proposed changes above, together with some styling changes. You can see the result o

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-07-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14642781#comment-14642781 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on the pull req

[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-tabpanel&focusedCommentId=14642743#comment-14642743 ] ASF GitHub Bot commented on FLINK-2399: --- Github user sachingoel0101 commented on the

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

2015-07-27 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/944#issuecomment-125216770 Adding these checks however already make sure the older task manager or job manager will be able to register with the new ones because the message objects have cha

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

2015-07-27 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/944 [FLINK-2399] Version checks for Job Manager and Task Manager Both Job Manager and Task Manager now communicate their respective version IDs to each other as part of registration messages.

[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-tabpanel&focusedCommentId=14642733#comment-14642733 ] ASF GitHub Bot commented on FLINK-2399: --- GitHub user sachingoel0101 opened a pull re

[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 se

[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-tabpanel&focusedCommentId=14642730#comment-14642730 ] ASF GitHub Bot commented on FLINK-2405: --- Github user gyfora commented on the pull re

[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-tabpanel&focusedCommentId=14642713#comment-14642713 ] ASF GitHub Bot commented on FLINK-2410: --- Github user twalthr commented on the pull r

[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 this

[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-tabpanel&focusedCommentId=14642702#comment-14642702 ] Robert Metzger commented on FLINK-2213: --- It does not affect the amount of CPU resour

[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-tabpanel&focusedCommentId=14642683#comment-14642683 ] ASF GitHub Bot commented on FLINK-2408: --- Github user aalexandrov commented on the pu

[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] [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 FlinkTopologyBuilder.cr

[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 FlinkTopologyBuilder.cr

[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-tabpanel&focusedCommentId=14642678#comment-14642678 ] ASF GitHub Bot commented on FLINK-2391: --- Github user ffbin commented on the pull req

[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 feat

[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-tabpanel&focusedCommentId=14642680#comment-14642680 ] ASF GitHub Bot commented on FLINK-2410: --- Github user rmetzger commented on the pull

[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 e

[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-tabpanel&focusedCommentId=14642676#comment-14642676 ] ASF GitHub Bot commented on FLINK-2410: --- Github user twalthr commented on the pull r

[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 you

[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 FlinkTopologyBuilder.cr

[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-tabpanel&focusedCommentId=14642672#comment-14642672 ] fangfengbin commented on FLINK-2391: Thank you very much! > Storm-compatibility:metho

[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-tabpanel&focusedCommentId=14642670#comment-14642670 ] ASF GitHub Bot commented on FLINK-2410: --- Github user rmetzger commented on the 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-tabpanel&focusedCommentId=14642674#comment-14642674 ] fangfengbin commented on FLINK-2391: Thank you very much! > Storm-compatibility:metho

[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-tabpanel&focusedCommentId=14642673#comment-14642673 ] fangfengbin commented on FLINK-2391: Thank you very much! > Storm-compatibility:metho

[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-tabpanel&focusedCommentId=14642675#comment-14642675 ] fangfengbin commented on FLINK-2391: Thank you very much! > Storm-compatibility:metho

[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 Git

[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-tabpanel&focusedCommentId=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 `PojoTy

[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-tabpanel&focusedCommentId=14642665#comment-14642665 ] 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-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-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 GitHu

[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-tabpanel&focusedCommentId=14642662#comment-14642662 ] ASF GitHub Bot commented on FLINK-2408: --- Github user aalexandrov commented on the pu

[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-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-tabpanel&focusedCommentId=14642658#comment-14642658 ] ASF GitHub Bot commented on FLINK-2404: --- GitHub user sachingoel0101 opened a pull re

[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-tabpanel&focusedCommentId=14642657#comment-14642657 ] ASF GitHub Bot commented on FLINK-2200: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-2404]Primitive add methods to Accumulat...

2015-07-27 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/942 [FLINK-2404]Primitive add methods to Accumulators Adds primitive add value methods to Double, Int and Long counter. Benchmark: Run independently of Flink on the LongCounter accumulator

[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:

[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-tabpanel&focusedCommentId=14642654#comment-14642654 ] ASF GitHub Bot commented on FLINK-2408: --- Github user chiwanpark commented on the pul

[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 reply

[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

[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-tabpanel&focusedCommentId=14642644#comment-14642644 ] ASF GitHub Bot commented on FLINK-2406: --- Github user gyfora commented on the pull re

[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-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-tabpanel&focusedCommentId=14642641#comment-14642641 ] ASF GitHub Bot commented on FLINK-2406: --- Github user uce commented on the pull reque

[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-tabpanel&focusedCommentId=14642634#comment-14642634 ] ASF GitHub Bot commented on FLINK-2408: --- Github user aalexandrov commented on the pu

[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-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 overwritten

[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-tabpanel&focusedCommentId=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 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 it

[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-tabpanel&focusedCommentId=14642623#comment-14642623 ] Rico Bergmann edited comment on FLINK-2325 at 7/27/15 12:02 PM:

[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-tabpanel&focusedCommentId=14642626#comment-14642626 ] ASF GitHub Bot commented on FLINK-2408: --- Github user aalexandrov commented on the pu

[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-tabpanel&focusedCommentId=14642623#comment-14642623 ] Rico Bergmann commented on FLINK-2325: -- Just checked it, but it's still the same beha

[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-tabpanel&focusedCommentId=14642622#comment-14642622 ] Maximilian Michels commented on FLINK-2404: --- Although the performance impact mig

[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-tabpanel&focusedCommentId=14642620#comment-14642620 ] ASF GitHub Bot commented on FLINK-2161: --- Github user nikste commented on the pull re

[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 t

[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, otherw

[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-tabpanel&focusedCommentId=14642619#comment-14642619 ] Maximilian Michels commented on FLINK-2404: --- I think it makes more sense to benc

[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-tabpanel&focusedCommentId=14642618#comment-14642618 ] ASF GitHub Bot commented on FLINK-2405: --- Github user gyfora commented on the pull re

[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-tabpanel&focusedCommentId=14642607#comment-14642607 ] ASF GitHub Bot commented on FLINK-2391: --- Github user rmetzger commented on the pull

[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 set

[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

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14642606#comment-14642606 ] ASF GitHub Bot commented on FLINK-2408: --- GitHub user rmetzger opened a pull request:

[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-tabpanel&focusedCommentId=14642605#comment-14642605 ] Sachin Goel commented on FLINK-2404: I'm using jdk8, specifically release 1.8.0_45 on

[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] [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-tabpanel&focusedCommentId=14642600#comment-14642600 ] Sachin Goel edited comment on FLINK-2404 at 7/27/15 11:49 AM: --

[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-tabpanel&focusedCommentId=14642602#comment-14642602 ] Maximilian Michels commented on FLINK-2404: --- The performance impact might differ

[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-tabpanel&focusedCommentId=14642600#comment-14642600 ] Sachin Goel commented on FLINK-2404: In fact, here are some detailed timings under the

[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-tabpanel&focusedCommentId=14642599#comment-14642599 ] ASF GitHub Bot commented on FLINK-2391: --- Github user mjsax commented on the pull req

  1   2   >