[jira] [Created] (FLINK-2203) Add Support for Null-Values in RowSerializer

2015-06-10 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2203: --- Summary: Add Support for Null-Values in RowSerializer Key: FLINK-2203 URL: https://issues.apache.org/jira/browse/FLINK-2203 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1732) Add Gaussian mixture model to machine learning library

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14581080#comment-14581080 ] ASF GitHub Bot commented on FLINK-1732: --- GitHub user shakir774 opened a pull request

[GitHub] flink pull request: FLINK-1732 Gaussian Mixture Model for Flink-ml...

2015-06-10 Thread shakir774
GitHub user shakir774 opened a pull request: https://github.com/apache/flink/pull/823 FLINK-1732 Gaussian Mixture Model for Flink-ml library You can merge this pull request into a Git repository by running: $ git pull https://github.com/shakir774/flink gmm_feature Alternative

[jira] [Commented] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails.

2015-06-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580785#comment-14580785 ] Maximilian Michels commented on FLINK-2183: --- Here is the stacktrace isolated for

[GitHub] flink pull request: [scripts] remove quickstart scripts

2015-06-10 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/822 [scripts] remove quickstart scripts - we already decided to host them on the website - not really useful and they need maintenance - having the snapshot quickstart in the source is against Apache

[GitHub] flink pull request: [FLINK-2199] Escape UTF characters in Scala Sh...

2015-06-10 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/821 [FLINK-2199] Escape UTF characters in Scala Shell welcome squirrel. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fhueske/flink fixWindowsBuild

[jira] [Commented] (FLINK-2199) Build with skipped tests fails on Windows

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580684#comment-14580684 ] ASF GitHub Bot commented on FLINK-2199: --- GitHub user fhueske opened a pull request:

[jira] [Resolved] (FLINK-2202) Calling distinct() requires tuple input

2015-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2202. -- Resolution: Duplicate Duplicate of FLINK-1963 > Calling distinct() requires tuple input > -

[jira] [Created] (FLINK-2202) Calling distinct() requires tuple input

2015-06-10 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2202: -- Summary: Calling distinct() requires tuple input Key: FLINK-2202 URL: https://issues.apache.org/jira/browse/FLINK-2202 Project: Flink Issue Type:

[jira] [Closed] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

2015-06-10 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2191. - Resolution: Fixed Fix Version/s: 0.9 Implemented via e2304c4. Minor issue remains, tracked

[jira] [Commented] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580631#comment-14580631 ] ASF GitHub Bot commented on FLINK-2191: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2191] Fix inconsistent use of closure c...

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

[GitHub] flink pull request: [release-0.9] [streaming] Fixed streaming exam...

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

[jira] [Created] (FLINK-2201) Inconsistent use of ClosureCleaner in streaming window helpers

2015-06-10 Thread JIRA
Márton Balassi created FLINK-2201: - Summary: Inconsistent use of ClosureCleaner in streaming window helpers Key: FLINK-2201 URL: https://issues.apache.org/jira/browse/FLINK-2201 Project: Flink

[GitHub] flink pull request: [release-0.9] [streaming] Fixed streaming exam...

2015-06-10 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/816#issuecomment-110786927 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 enabl

[GitHub] flink pull request: [FLINK-2191] Fix inconsistent use of closure c...

2015-06-10 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/813#issuecomment-110786608 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 enabl

[jira] [Commented] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580614#comment-14580614 ] ASF GitHub Bot commented on FLINK-2191: --- Github user mbalassi commented on the pull

[jira] [Commented] (FLINK-2198) Build fails on Windows

2015-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580597#comment-14580597 ] Fabian Hueske commented on FLINK-2198: -- The problem seems to be caused by the {{File.

[GitHub] flink pull request: [streaming] Allow force-enabling checkpoints f...

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

[GitHub] flink pull request: [build] [streaming] Streaming parent's depende...

2015-06-10 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/820 [build] [streaming] Streaming parent's dependencies pushed to children You can merge this pull request into a Git repository by running: $ git pull https://github.com/mbalassi/flink deps Alte

[jira] [Assigned] (FLINK-2199) Build with skipped tests fails on Windows

2015-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2199: Assignee: Fabian Hueske > Build with skipped tests fails on Windows > -

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

2015-06-10 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park updated FLINK-2200: --- Component/s: Scala API > Flink API with Scala 2.11 - Maven Repository > --

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

2015-06-10 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580540#comment-14580540 ] Chiwan Park commented on FLINK-2200: +1 for this feature > Flink API with Scala 2.11

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

2015-06-10 Thread JIRA
Philipp Götze created FLINK-2200: Summary: Flink API with Scala 2.11 - Maven Repository Key: FLINK-2200 URL: https://issues.apache.org/jira/browse/FLINK-2200 Project: Flink Issue Type: Wish

[jira] [Commented] (FLINK-2093) Add a difference method to Gelly's Graph class

2015-06-10 Thread Shivani Ghatge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580531#comment-14580531 ] Shivani Ghatge commented on FLINK-2093: --- I have done the changes suggested by [~andr

[GitHub] flink pull request: [FLINK-2191] Fix inconsistent use of closure c...

2015-06-10 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/813#issuecomment-110739702 Looks good to me :+1: --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this f

[jira] [Commented] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580491#comment-14580491 ] ASF GitHub Bot commented on FLINK-2191: --- Github user gyfora commented on the pull re

[jira] [Closed] (FLINK-2196) Missplaced Class in flink-java SortPartitionOperator

2015-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2196. Resolution: Fixed Fixed via a8e085078499319113a213575c9f057144395f98 > Missplaced Class in flink-ja

[jira] [Commented] (FLINK-2145) Median calculation for windows

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580489#comment-14580489 ] ASF GitHub Bot commented on FLINK-2145: --- Github user ggevay commented on the pull re

[GitHub] flink pull request: [release-0.9] [runtime] Logging update for che...

2015-06-10 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/819 [release-0.9] [runtime] Logging update for checkpointed streaming topologies Also adding a log message when delaying the retry of the execution graph. This change is motivated by my experien

[GitHub] flink pull request: [streaming] Fast calculation of medians of win...

2015-06-10 Thread ggevay
Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/684#issuecomment-110739389 I did the Scala part, and added a Jira (FLINK-2145). As for the placement: @StephanEwen: > I think we should put the code into a streaming operator library. The

[jira] [Commented] (FLINK-2093) Add a difference method to Gelly's Graph class

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580487#comment-14580487 ] ASF GitHub Bot commented on FLINK-2093: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-2093][gelly] Added difference Method

2015-06-10 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/818#issuecomment-110739263 Hi @shghatge, Apart from the minor cosmetic suggestions I made, everything looks well. @vasia, could you double check this? After Shivani simplifies

[GitHub] flink pull request: [release-0.9] [streaming] Fixed streaming exam...

2015-06-10 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/816#issuecomment-110739304 :+1: --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled a

[jira] [Commented] (FLINK-2196) Missplaced Class in flink-java SortPartitionOperator

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580484#comment-14580484 ] ASF GitHub Bot commented on FLINK-2196: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2196] [javaAPI] Moved misplaced SortPar...

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

[jira] [Commented] (FLINK-2099) Add a SQL API

2015-06-10 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580481#comment-14580481 ] Timo Walther commented on FLINK-2099: - I had a private discussion with [~rmetzger], [~

[GitHub] flink pull request: [FLINK-2191] Fix inconsistent use of closure c...

2015-06-10 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/813#issuecomment-110733849 I updated it, now we still have several "clean" functions but they just forward to the StreamingExEnv.scalaClean() function. --- If your project is set up for it, you

[jira] [Commented] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580465#comment-14580465 ] ASF GitHub Bot commented on FLINK-2191: --- Github user aljoscha commented on the pull

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

2015-06-10 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu updated FLINK-1520: --- Assignee: Shivani Ghatge (was: Carsten Brandt) > Read edges and vertices from CSV files > ---

[GitHub] flink pull request: [hotfix] Bring KMeansDataGenerator and KMeans ...

2015-06-10 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/815 --- 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 ena

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580433#comment-14580433 ] ASF GitHub Bot commented on FLINK-1297: --- Github user tammymendt commented on the pul

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-06-10 Thread tammymendt
Github user tammymendt commented on the pull request: https://github.com/apache/flink/pull/605#issuecomment-110720993 Sounds good! Thanks =) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have th

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-06-10 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/605#issuecomment-110715816 Hi @tammymendt thanks for the update! I'm afraid, we are already in the testing phase for the release and don't want to add new features. Since we postponed a fe

[jira] [Commented] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails.

2015-06-10 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580424#comment-14580424 ] Maximilian Michels commented on FLINK-2183: --- Thanks Chiwan, I'm also looking int

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580425#comment-14580425 ] ASF GitHub Bot commented on FLINK-1297: --- Github user fhueske commented on the pull r

[jira] [Created] (FLINK-2199) Build with skipped tests fails on Windows

2015-06-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2199: Summary: Build with skipped tests fails on Windows Key: FLINK-2199 URL: https://issues.apache.org/jira/browse/FLINK-2199 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-2093][gelly] Added difference Method

2015-06-10 Thread shghatge
GitHub user shghatge opened a pull request: https://github.com/apache/flink/pull/818 [FLINK-2093][gelly] Added difference Method Tasks given on 5th June: Add a difference function to the Graph.java Modify the docs 'gelly-guide.md' Add the test case for difference() method

[jira] [Commented] (FLINK-2093) Add a difference method to Gelly's Graph class

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580412#comment-14580412 ] ASF GitHub Bot commented on FLINK-2093: --- GitHub user shghatge opened a pull request:

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580406#comment-14580406 ] ASF GitHub Bot commented on FLINK-1297: --- Github user tammymendt commented on the pul

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-06-10 Thread tammymendt
Github user tammymendt commented on the pull request: https://github.com/apache/flink/pull/605#issuecomment-110702228 Everything seems to be OK now. Is there still a chance to merge this before the upcoming release? I have pushed two commits. The first is the original version

[jira] [Created] (FLINK-2198) Build fails on Windows

2015-06-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2198: Summary: Build fails on Windows Key: FLINK-2198 URL: https://issues.apache.org/jira/browse/FLINK-2198 Project: Flink Issue Type: Bug Components: Bu

[jira] [Commented] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails.

2015-06-10 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580387#comment-14580387 ] Chiwan Park commented on FLINK-2183: After I clear my local maven repository, the test

[GitHub] flink pull request: [release-0.9] [streaming] Fixed streaming exam...

2015-06-10 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/816#issuecomment-110691858 :+1: --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabl

[GitHub] flink pull request: [release-0.9] [streaming] Fixed streaming exam...

2015-06-10 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/816#issuecomment-110689712 LGTM --- 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 an

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580345#comment-14580345 ] ASF GitHub Bot commented on FLINK-1731: --- Github user peedeeX21 commented on the pull

[GitHub] flink pull request: [FLINK-1731] [ml] Implementation of Feature K-...

2015-06-10 Thread peedeeX21
Github user peedeeX21 commented on the pull request: https://github.com/apache/flink/pull/700#issuecomment-110681501 @tillrohrmann great. no worries. was just not sure what is going on. :) good luck with the new release! --- If your project is set up for it, you can reply to this ema

[jira] [Created] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program

2015-06-10 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2197: Summary: Scala API is not working when using batch and streaming API in the same program Key: FLINK-2197 URL: https://issues.apache.org/jira/browse/FLINK-2197 Project

[jira] [Commented] (FLINK-2196) Missplaced Class in flink-java SortPartitionOperator

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580332#comment-14580332 ] ASF GitHub Bot commented on FLINK-2196: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request: [FLINK-2196] [javaAPI] Moved misplaced SortPar...

2015-06-10 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/817 [FLINK-2196] [javaAPI] Moved misplaced SortPartitionOperator class `SortPartitionOperator` is API facing and misplaced. It should be in the `org.apache.flink.api.java.operators` package. You can

[jira] [Commented] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580331#comment-14580331 ] ASF GitHub Bot commented on FLINK-2191: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-2191] Fix inconsistent use of closure c...

2015-06-10 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/813#discussion_r32103307 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala --- @@ -45

[jira] [Commented] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580319#comment-14580319 ] ASF GitHub Bot commented on FLINK-2191: --- Github user mbalassi commented on a diff in

[GitHub] flink pull request: [FLINK-2191] Fix inconsistent use of closure c...

2015-06-10 Thread mbalassi
Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/813#discussion_r32102485 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala --- @@ -45

[jira] [Commented] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580316#comment-14580316 ] ASF GitHub Bot commented on FLINK-2191: --- Github user mbalassi commented on a diff in

[jira] [Commented] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails

2015-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580318#comment-14580318 ] Fabian Hueske commented on FLINK-2192: -- I see. Thanks for the explanation! > Comple

[GitHub] flink pull request: [FLINK-2191] Fix inconsistent use of closure c...

2015-06-10 Thread mbalassi
Github user mbalassi commented on a diff in the pull request: https://github.com/apache/flink/pull/813#discussion_r32102450 --- Diff: flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala --- @@ -781,11 +780,24 @@

[GitHub] flink pull request: [streaming] Fixed streaming example jars packa...

2015-06-10 Thread mbalassi
GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/816 [streaming] Fixed streaming example jars packaging and termination Now all the streaming java examples are packaged into self-contained jars and finish. You can merge this pull request into a Git r

[GitHub] flink pull request: [release-0.9] Fixed a few trivial issues:

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

[GitHub] flink pull request: [hotfix] Bring KMeansDataGenerator and KMeans ...

2015-06-10 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/815#issuecomment-110670779 LGTM --- 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 an

[jira] [Commented] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails

2015-06-10 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580293#comment-14580293 ] Márton Balassi commented on FLINK-2192: --- It is a duplicate, because the failing part

[jira] [Commented] (FLINK-2188) Reading from big HBase Tables

2015-06-10 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580282#comment-14580282 ] Ufuk Celebi commented on FLINK-2188: You can try it with this branch: https://github.

[jira] [Commented] (FLINK-2194) Type extractor does not support Writable type

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580280#comment-14580280 ] ASF GitHub Bot commented on FLINK-2194: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2194] [type extractor] Treats Writable ...

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

[jira] [Closed] (FLINK-2194) Type extractor does not support Writable type

2015-06-10 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2194. Resolution: Fixed Fixed via d81f4cf92d7a7d78082c7997c0d1a802f4358617 > Type extractor does not supp

[jira] [Closed] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails

2015-06-10 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2192. - Resolution: Duplicate This is a duplicate of FLINK-2180. > ComplexIntegrationTest.complexIntegrat

[GitHub] flink pull request: [FLINK-2194] [type extractor] Treats Writable ...

2015-06-10 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/814#issuecomment-110664983 Travis gives green light. Will merge since it's a trivial fix. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

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

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580272#comment-14580272 ] ASF GitHub Bot commented on FLINK-1962: --- Github user aljoscha commented on the pull

[jira] [Commented] (FLINK-2194) Type extractor does not support Writable type

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580277#comment-14580277 ] ASF GitHub Bot commented on FLINK-2194: --- Github user tillrohrmann commented on the p

[jira] [Assigned] (FLINK-2194) Type extractor does not support Writable type

2015-06-10 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2194: Assignee: Till Rohrmann > Type extractor does not support Writable type > -

[GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API

2015-06-10 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/808#issuecomment-110664776 I will thoroughly check it once the release that is currently happening is done. Then people can check it out and it will have had some expose before releasing it in 0.1

[GitHub] flink pull request: [scripts] cleanup release script and make it m...

2015-06-10 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/811#discussion_r32099679 --- Diff: tools/create_release_files.sh --- @@ -36,57 +58,59 @@ if [[ `basename $CURR_DIR` != "tools" ]] ; then exit 1 fi +## +## Variable

[jira] [Created] (FLINK-2196) Missplaced Class in flink-java SortPartitionOperator

2015-06-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2196: Summary: Missplaced Class in flink-java SortPartitionOperator Key: FLINK-2196 URL: https://issues.apache.org/jira/browse/FLINK-2196 Project: Flink Issue Type

[GitHub] flink pull request: [hotfix] Bring KMeansDataGenerator and KMeans ...

2015-06-10 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/815 [hotfix] Bring KMeansDataGenerator and KMeans quickstart in sync You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink fix-kmeans-data-

[GitHub] flink pull request: [FLINK-1731] [ml] Implementation of Feature K-...

2015-06-10 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/700#issuecomment-110658920 Will do @peedeeX21. Currently I'm busy with the upcoming release, but once we're done with it, I'll work on this PR. --- If your project is set up for it, you can r

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580249#comment-14580249 ] ASF GitHub Bot commented on FLINK-1731: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [scripts] cleanup release script and make it m...

2015-06-10 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/811#discussion_r32098664 --- Diff: tools/create_release_files.sh --- @@ -36,57 +58,59 @@ if [[ `basename $CURR_DIR` != "tools" ]] ; then exit 1 fi +## +## Variable

[jira] [Created] (FLINK-2195) Set Configuration for Configurable Hadoop InputFormats

2015-06-10 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2195: -- Summary: Set Configuration for Configurable Hadoop InputFormats Key: FLINK-2195 URL: https://issues.apache.org/jira/browse/FLINK-2195 Project: Flink Issue Type:

[GitHub] flink pull request: [FLINK-2150][gelly] Added library method for a...

2015-06-10 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/801#issuecomment-110656116 +1 as well. On Wed, Jun 10, 2015 at 10:38 AM Fabian Hueske wrote: > +1 for adding both methods in a utility class as suggested in FLINK-2152.

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580238#comment-14580238 ] ASF GitHub Bot commented on FLINK-2150: --- Github user tillrohrmann commented on the p

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580235#comment-14580235 ] ASF GitHub Bot commented on FLINK-2150: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2150][gelly] Added library method for a...

2015-06-10 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/801#issuecomment-110655024 +1 for adding both methods in a utility class as suggested in FLINK-2152. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2140) Access the number of vertices from within the GSA functions

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580232#comment-14580232 ] ASF GitHub Bot commented on FLINK-2140: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-2150][gelly] Added library method for a...

2015-06-10 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/801#issuecomment-110654447 I agree, it makes sense to offer that externally. There is a JIRA for zipWithIndex (FLINK-2152). zipWithUniqueID could be added correspondingly. --- If your project

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580231#comment-14580231 ] ASF GitHub Bot commented on FLINK-2150: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-2150][gelly] Added library method for a...

2015-06-10 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/801#issuecomment-110653949 If I'm not mistaken then something like ``` int log2(long value){ if(value & 0x > 0) { 64 - Integer.numberOfLeadingZeros((int)(v

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580233#comment-14580233 ] ASF GitHub Bot commented on FLINK-2150: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2140][gelly] Allowed access to the numb...

2015-06-10 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/779#issuecomment-110654021 If no objections, I'd like to merge this one within the next week. There is a direction issue for GSA(FLINK-2141) that will actually touch the same files. --- If you

[jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly

2015-06-10 Thread PJ Van Aeken (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580225#comment-14580225 ] PJ Van Aeken commented on FLINK-2033: - If the PR for FLINK-1962 gets accepted, this ca

[jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices

2015-06-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580207#comment-14580207 ] ASF GitHub Bot commented on FLINK-2150: --- Github user andralungu commented on the pul

  1   2   >