[jira] [Updated] (FLINK-1994) Add different gain calculation schemes to SGD

2015-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1994: - Assignee: Trevor Grant Add different gain calculation schemes to SGD

[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

2015-07-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649172#comment-14649172 ] Till Rohrmann commented on FLINK-1994: -- Great to hear [~rawkintrevo]. I assigned the

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/957 --- 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] [Updated] (FLINK-2248) Allow disabling of sdtout logging output

2015-07-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2248: -- Assignee: Sachin Goel Allow disabling of sdtout logging output

[GitHub] flink pull request: [FLINK-1819][core]Allow access to RuntimeConte...

2015-07-31 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/966#issuecomment-126705428 Thanks for the pull request! You did not convert all InputFormats and OutputFormats. There are a few more, e.g. HadoopInputFormatBase or JDBCInputFormat. Other than

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/957#issuecomment-126674684 Thank you for your patience :) I will merge this once the tests have passed. --- 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-1819][core]Allow access to RuntimeConte...

2015-07-31 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/966#issuecomment-126706999 Ah yes. I'll update them in a while. There's actually some problem with the unit test I've written too. Travis fails sporadically. --- If your project is set up

[jira] [Commented] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats

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

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/957#issuecomment-126672392 Yeah. I think we should remove it then. Too many entries tend to confuse people. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request: [FLINK-1819][core]Allow access to RuntimeConte...

2015-07-31 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/966 [FLINK-1819][core]Allow access to RuntimeContext from Input and Output formats 1. Introduces new Rich Input and Output formats, similar to Rich Functions. 2. Makes all existing input and

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[jira] [Commented] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats

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

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/957#issuecomment-126672811 I've updated the code to remove any changes in Configuration. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[GitHub] flink pull request: [FLINK-2409] [webserver] Replaces ActorRefs wi...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/959#issuecomment-126698555 Travis failed only in one build where the `YARNSessionFIFOITCase` did not start. I suspect that it's due to the instability of the `YARNSessionFIFOITCase` test.

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

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

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/957#issuecomment-126675074 Sure. No problem. :) --- 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

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/957#issuecomment-126695988 Travis build passes. You can merge it @mxm --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[jira] [Commented] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats

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

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35984232 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/BernoulliSampler.java --- @@ -0,0 +1,105 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35984950 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/RandomSampler.java --- @@ -0,0 +1,51 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-07-31 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649394#comment-14649394 ] Sachin Goel commented on FLINK-2449: Or rather override it in your test class to

[jira] [Created] (FLINK-2451) Cleanup Gelly examples

2015-07-31 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2451: Summary: Cleanup Gelly examples Key: FLINK-2451 URL: https://issues.apache.org/jira/browse/FLINK-2451 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: Framesize fix

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35991461 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -893,13 +1086,11 @@ public Object call() throws

[GitHub] flink pull request: Framesize fix

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35991960 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -560,53 +621,177 @@ public ExecutionContext

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35984921 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/RandomSampler.java --- @@ -0,0 +1,51 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/949#issuecomment-126740651 Thanks for your contribution @ChengXiangLi. The code is really well tested and well structured. Great work :-) I had only some minor comments. There is

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2015-07-31 Thread nltran
GitHub user nltran opened a pull request: https://github.com/apache/flink/pull/967 Stale Synchronous Parallel Iterations Here is a pull request containing our development on [Stale Synchronous Parallel (SSP)](http://reports-archive.adm.cs.cmu.edu/anon/ml2013/CMU-ML-13-103.pdf)

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35988629 --- Diff: pom.xml --- @@ -224,6 +224,12 @@ under the License. version3.2.1/version /dependency

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[jira] [Commented] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

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

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35985033 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/ReservoirSamplerWithReplacement.java --- @@ -0,0 +1,122 @@ +/* + *

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35985704 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/ReservoirSamplerWithoutReplacement.java --- @@ -0,0 +1,100 @@ +/*

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[jira] [Closed] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

2015-07-31 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2446. - Resolution: Fixed Fix Version/s: 0.10 Fixed via b0f2379. SocketTextStreamFunction has

[GitHub] flink pull request: [FLINK-2436] [streaming] Make ByteStreamStateH...

2015-07-31 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/958#issuecomment-126733653 If you could take a quick look @uce, I would like to merge this :) I think it is a safe change. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-2436) Make ByteStreamStateHandles more robust

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

[jira] [Updated] (FLINK-2452) Add a playcount threshold to the MusicProfiles example

2015-07-31 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2452: - Summary: Add a playcount threshold to the MusicProfiles example (was: Add a playcount threshold

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649444#comment-14649444 ] Chesnay Schepler commented on FLINK-2449: - fair enough, scratch the part about

[GitHub] flink pull request: Framesize fix

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35991476 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -979,8 +1174,7 @@ public void

[GitHub] flink pull request: Framesize fix

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35991467 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -918,8 +1109,7 @@ private void postRunCleanup() {

[GitHub] flink pull request: Framesize fix

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35991472 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -966,8 +1162,7 @@ public boolean

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35985116 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/ReservoirSamplerWithReplacement.java --- @@ -0,0 +1,122 @@ +/* + *

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-07-31 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649392#comment-14649392 ] Sachin Goel commented on FLINK-2449: You can call {{skipCollectionExecution}} :)

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[GitHub] flink pull request: Framesize fix

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35991266 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -75,24 +78,24 @@ * The execution graph is the

[GitHub] flink pull request: Framesize fix

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35991305 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -560,53 +621,177 @@ public ExecutionContext

[GitHub] flink pull request: Framesize fix

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/934#discussion_r35991400 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java --- @@ -619,6 +718,21 @@ public ExecutionContext

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-07-31 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649315#comment-14649315 ] Sachin Goel commented on FLINK-2449: Collection Executor runs locally without any

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649323#comment-14649323 ] Chesnay Schepler commented on FLINK-2449: - I know i can. But this means that you

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35984385 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/PoissonSampler.java --- @@ -0,0 +1,105 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35984449 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/PoissonSampler.java --- @@ -0,0 +1,105 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-31 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r35984320 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/BernoulliSampler.java --- @@ -0,0 +1,105 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-2446]Fix SocketTextStreamFunction has m...

2015-07-31 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/965 --- 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-2248) Allow disabling of sdtout logging output

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

[jira] [Closed] (FLINK-2248) Allow disabling of sdtout logging output

2015-07-31 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2248. - Resolution: Fixed Fix Version/s: 0.9.1 0.10 Allow disabling of

[GitHub] flink pull request: Framesize fix

2015-07-31 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/934#issuecomment-126752412 Hi @kl0u , Thanks for addressing my comments. I've made some new ones :) but looks much better. As for merging the different types of snapshots, the only

[jira] [Created] (FLINK-2454) Update Travis file to run build using Java7

2015-07-31 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-2454: Summary: Update Travis file to run build using Java7 Key: FLINK-2454 URL: https://issues.apache.org/jira/browse/FLINK-2454 Project: Flink Issue Type:

[jira] [Created] (FLINK-2455) Misleading I/O manager error log messages

2015-07-31 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2455: -- Summary: Misleading I/O manager error log messages Key: FLINK-2455 URL: https://issues.apache.org/jira/browse/FLINK-2455 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

2015-07-31 Thread Sheetal Parade (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649744#comment-14649744 ] Sheetal Parade commented on FLINK-2314: --- If no one is working on this issue, I would

[jira] [Created] (FLINK-2447) TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type

2015-07-31 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2447: -- Summary: TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type Key: FLINK-2447 URL: https://issues.apache.org/jira/browse/FLINK-2447

[jira] [Updated] (FLINK-2447) TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type

2015-07-31 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-2447: --- Description: Consider the following code: DataSetFooBarPojo d1 = env.fromElements(new FooBarPojo());

[jira] [Updated] (FLINK-2447) TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type

2015-07-31 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-2447: --- Component/s: Java API TypeExtractor returns wrong type info when a Tuple has two fields of the same

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/957#discussion_r35966826 --- Diff: flink-clients/src/test/java/org/apache/flink/client/CliFrontendLoggingTest.java --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/957#discussion_r35967492 --- Diff: flink-clients/src/test/java/org/apache/flink/client/CliFrontendLoggingTest.java --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/957#discussion_r35967625 --- Diff: flink-clients/src/test/java/org/apache/flink/client/CliFrontendLoggingTest.java --- @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-2452) Add a playcount threshold to the MusicProfiles example

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

[GitHub] flink pull request: [FLINK-2452] [Gelly] adds a playcount threshol...

2015-07-31 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/968 [FLINK-2452] [Gelly] adds a playcount threshold to the MusicProfiles example This PR adds a user-defined parameter to the MusicProfiles example that filters out songs that a user has listened to only

[jira] [Updated] (FLINK-2412) Race leading to IndexOutOfBoundsException when querying for buffer while releasing SpillablePartition

2015-07-31 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2412: --- Summary: Race leading to IndexOutOfBoundsException when querying for buffer while releasing

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/957#issuecomment-126612061 Thanks for adding the tests! This looks good to merge. Could you update https://ci.apache.org/projects/flink/flink-docs-master/apis/cli.html ? --- If your project is set up

[jira] [Updated] (FLINK-2361) CompactingHashTable loses entries

2015-07-31 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2361: - Summary: CompactingHashTable loses entries (was: flatMap + distinct gives erroneous results for

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/957#issuecomment-126614333 @mxm , updated. --- 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] [Updated] (FLINK-2361) CompactingHashTable loses entries

2015-07-31 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2361: - Priority: Critical (was: Major) CompactingHashTable loses entries

[jira] [Updated] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

2015-07-31 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2446: -- Affects Version/s: (was: 0.8.1) 0.10 SocketTextStreamFunction has

[GitHub] flink pull request: [FLINK-2446]Fix SocketTextStreamFunction has m...

2015-07-31 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/965#issuecomment-126619190 Good catch, if no objections I will merge this in the evening. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-31 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/957#issuecomment-126620784 Thanks. One more thing. Could you also update https://ci.apache.org/projects/flink/flink-docs-release-0.9/setup/config.html ? You introduced a new config entry. --- If

[jira] [Commented] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

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

[jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment

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

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

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

[jira] [Created] (FLINK-2450) IndexOutOfBoundsException in KryoSerializer

2015-07-31 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2450: -- Summary: IndexOutOfBoundsException in KryoSerializer Key: FLINK-2450 URL: https://issues.apache.org/jira/browse/FLINK-2450 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment

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

[GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE...

2015-07-31 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/939#issuecomment-126621482 Just my opinion, `TableEnvironment` is located under `org.apache.flink.api.java.table` because of unifying of Table API implementation. But Table API is implemented

[GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE...

2015-07-31 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/939#issuecomment-126624411 Maybe we could move the TableEnvironment to org.apache.flink.api.table to make it clear that it can be used for both languages. --- If your project is set up for it,

[jira] [Commented] (FLINK-2447) TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type

2015-07-31 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14648906#comment-14648906 ] Fabian Hueske commented on FLINK-2447: -- Thanks for the detailed report! [~twalthr],

[jira] [Created] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase

2015-07-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2448: --- Summary: registerCacheFile fails with MultipleProgramsTestbase Key: FLINK-2448 URL: https://issues.apache.org/jira/browse/FLINK-2448 Project: Flink

  1   2   >