[jira] [Comment Edited] (FLINK-2168) Add fromHBase() to TableEnvironment

2015-09-28 Thread Wilmer DAZA (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933174#comment-14933174 ] Wilmer DAZA edited comment on FLINK-2168 at 9/29/15 6:53 AM: -

[GitHub] flink pull request: [FLINK-2775] [CLEANUP] Cleanup code as part of...

2015-09-28 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1189#issuecomment-143916305 Looks like fail on unrelated Kafka partition error --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Commented] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes

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

[GitHub] flink pull request: [Flink-2768][Documentation] Fix wrong java ver...

2015-09-28 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1188#issuecomment-143909415 +1 Looks 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 not h

[GitHub] flink pull request: [Flink-2768][Documentation] Fix wrong java ver...

2015-09-28 Thread rerngvit
Github user rerngvit commented on the pull request: https://github.com/apache/flink/pull/1188#issuecomment-143905322 @hsaputra Thank you for reviewing this PR. I squashed the commits into one as per your comment. Please have a look. --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

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

[GitHub] flink pull request: [FLINK-2561] Adds missing Gelly scala methods ...

2015-09-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1183 --- 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 enab

[jira] [Created] (FLINK-2776) Print job id to standard out on CLI job submission

2015-09-28 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-2776: - Summary: Print job id to standard out on CLI job submission Key: FLINK-2776 URL: https://issues.apache.org/jira/browse/FLINK-2776 Project: Flink Is

[jira] [Commented] (FLINK-2773) OutOfMemoryError on YARN Session

2015-09-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933984#comment-14933984 ] Fabian Hueske commented on FLINK-2773: -- Nope, but I can easily reproduce the issue. W

[jira] [Commented] (FLINK-2774) Import Java API classes automatically in Flink's Scala shell

2015-09-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933975#comment-14933975 ] Maximilian Michels commented on FLINK-2774: --- +1 > Import Java API classes auto

[jira] [Assigned] (FLINK-2773) OutOfMemoryError on YARN Session

2015-09-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2773: - Assignee: Maximilian Michels > OutOfMemoryError on YARN Session > ---

[jira] [Commented] (FLINK-2773) OutOfMemoryError on YARN Session

2015-09-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933970#comment-14933970 ] Maximilian Michels commented on FLINK-2773: --- The maximum direct memory size appe

[jira] [Assigned] (FLINK-2762) Job Runtime: -1 ms

2015-09-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2762: - Assignee: Maximilian Michels > Job Runtime: -1 ms > -- > >

[jira] [Created] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes

2015-09-28 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-2775: Summary: [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes Key: FLINK-2775 URL: https://issues.apache.org/jira/browse/FLINK-2775 Project:

[jira] [Commented] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes

2015-09-28 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933920#comment-14933920 ] Henry Saputra commented on FLINK-2775: -- PR: https://github.com/apache/flink/pull/1189

[GitHub] flink pull request: [Flink-2768][Documentation] Fix wrong java ver...

2015-09-28 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1188#issuecomment-143862641 Could you squash the commits into one please? --- 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 pr

[GitHub] flink pull request: [Flink-2768][Documentation] Fix wrong java ver...

2015-09-28 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1188#issuecomment-143862604 +1 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 e

[GitHub] flink pull request: [CLEANUP] Cleanup code as part of theme to be ...

2015-09-28 Thread hsaputra
GitHub user hsaputra opened a pull request: https://github.com/apache/flink/pull/1189 [CLEANUP] Cleanup code as part of theme to be more consistent As part of the theme to help make the code more consistent, add cleanup to Utils classes: -) Add final class modifier to the XXXUti

[jira] [Assigned] (FLINK-2748) Accumulator fetch failure leads to duplicate job result response

2015-09-28 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2748: - Assignee: Maximilian Michels > Accumulator fetch failure leads to duplicate job r

[jira] [Updated] (FLINK-2731) Add JobManager log file access

2015-09-28 Thread Martin Liesenberg (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Liesenberg updated FLINK-2731: - Assignee: Piotr Godek (was: Martin Liesenberg) > Add JobManager log file access > ---

[jira] [Assigned] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2015-09-28 Thread Martin Liesenberg (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Liesenberg reassigned FLINK-2732: Assignee: Martin Liesenberg > Add access to the TaskManagers' log file and out file

[jira] [Commented] (FLINK-2169) Add fromParquet() to TableEnvironment

2015-09-28 Thread rerngvit yanggratoke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933817#comment-14933817 ] rerngvit yanggratoke commented on FLINK-2169: - [~fhueske] I have a question. T

[GitHub] flink pull request: [Flink-2768][Documentation] Fix wrong java ver...

2015-09-28 Thread rerngvit
GitHub user rerngvit opened a pull request: https://github.com/apache/flink/pull/1188 [Flink-2768][Documentation] Fix wrong java version requirement in quickstart Fix wrong java version requirement in quickstart (1.6 -> 1.7) You can merge this pull request into a Git repository by r

[GitHub] flink pull request: [Flink-2751][Documentation] Fix wrong java ver...

2015-09-28 Thread rerngvit
Github user rerngvit closed the pull request at: https://github.com/apache/flink/pull/1187 --- 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 en

[jira] [Commented] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page

2015-09-28 Thread rerngvit yanggratoke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933753#comment-14933753 ] rerngvit yanggratoke commented on FLINK-2768: - [~chiwanpark] I have a PR for t

[GitHub] flink pull request: [Flink-2751][Documentation] Fix wrong java ver...

2015-09-28 Thread rerngvit
GitHub user rerngvit opened a pull request: https://github.com/apache/flink/pull/1187 [Flink-2751][Documentation] Fix wrong java version requirement in quickstart Fix wrong java version requirement in quickstart (1.6 -> 1.7) You can merge this pull request into a Git repository by r

[jira] [Commented] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page

2015-09-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933746#comment-14933746 ] Fabian Hueske commented on FLINK-2768: -- Cool! I assigned the issue to you. Let us kn

[jira] [Updated] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page

2015-09-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2768: - Assignee: rerngvit yanggratoke > Wrong Java version requirements in "Quickstart: Scala API" page >

[jira] [Commented] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page

2015-09-28 Thread rerngvit yanggratoke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933730#comment-14933730 ] rerngvit yanggratoke commented on FLINK-2768: - I would like to work on this is

[jira] [Created] (FLINK-2774) Import Java API classes automatically in Flink's Scala shell

2015-09-28 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2774: Summary: Import Java API classes automatically in Flink's Scala shell Key: FLINK-2774 URL: https://issues.apache.org/jira/browse/FLINK-2774 Project: Flink I

[jira] [Resolved] (FLINK-2753) Add new window API to streaming API

2015-09-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-2753. - Resolution: Fixed Implemented in https://github.com/apache/flink/commit/dd51c97741b336d3a

[jira] [Resolved] (FLINK-2677) Add a general-purpose keyed-window operator

2015-09-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-2677. - Resolution: Fixed Resolved in https://github.com/apache/flink/commit/dd51c97741b336d3a11e

[GitHub] flink pull request: [FLINK-2677] Add a general-purpose keyed-windo...

2015-09-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1184 --- 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 enab

[jira] [Commented] (FLINK-2677) Add a general-purpose keyed-window operator

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

[jira] [Assigned] (FLINK-2712) Add some description about tests to "How to Contribute" documentation

2015-09-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2712: Assignee: Fabian Hueske (was: Chiwan Park) > Add some description about tests to "How to C

[jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case

2015-09-28 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933491#comment-14933491 ] Aljoscha Krettek commented on FLINK-2600: - This sounds good. But then we should mo

[jira] [Created] (FLINK-2773) OutOfMemoryError on YARN Session

2015-09-28 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2773: Summary: OutOfMemoryError on YARN Session Key: FLINK-2773 URL: https://issues.apache.org/jira/browse/FLINK-2773 Project: Flink Issue Type: Bug Comp

[jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case

2015-09-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933418#comment-14933418 ] Stephan Ewen commented on FLINK-2600: - How about we start a new maven project for "man

[GitHub] flink pull request: [FLINK-2677] Add a general-purpose keyed-windo...

2015-09-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1184#issuecomment-143764435 I assume global windows here means something different than the old API implied with global windows (= discretization across streams, before grouping). From

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

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

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-09-28 Thread nikste
Github user nikste closed the pull request at: https://github.com/apache/flink/pull/1106 --- 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 enab

[jira] [Commented] (FLINK-2677) Add a general-purpose keyed-window operator

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933388#comment-14933388 ] ASF GitHub Bot commented on FLINK-2677: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-2764] [WebClient] [0.10.0-milestone-1] ...

2015-09-28 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1181#issuecomment-143749079 If no objections I will merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does no

[jira] [Commented] (FLINK-2764) WebClient cannot display multiple Jobs

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

[jira] [Commented] (FLINK-2677) Add a general-purpose keyed-window operator

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

[GitHub] flink pull request: [FLINK-2677] Add a general-purpose keyed-windo...

2015-09-28 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1184#issuecomment-143735489 One thing to note here is that you cannot use the old `TriggerPolicy` and `EvictionPolicy` anymore. The old concept of windowing helpers is replaced by windowing polici

[jira] [Commented] (FLINK-2766) Bad ipv6 urls

2015-09-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933247#comment-14933247 ] Stephan Ewen commented on FLINK-2766: - All calls to create InetAddress URL representat

[jira] [Updated] (FLINK-2766) Bad ipv6 urls

2015-09-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2766: Priority: Blocker (was: Critical) > Bad ipv6 urls > - > > Key: FLINK-27

[jira] [Updated] (FLINK-2766) Bad ipv6 urls

2015-09-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2766: Priority: Critical (was: Major) > Bad ipv6 urls > - > > Key: FLINK-2766

[jira] [Commented] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-09-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933239#comment-14933239 ] Stephan Ewen commented on FLINK-2763: - If the join tries to spill a partition with onl

[GitHub] flink pull request: [FLINK-2677] Add a general-purpose keyed-windo...

2015-09-28 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1184#issuecomment-143728731 Event-time windowing is supported if you manually enable watermarks using `setWatermarkInterval` (it is still called `setAutoWatermarkInterval` but I want to change thi

[jira] [Commented] (FLINK-2677) Add a general-purpose keyed-window operator

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

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-28 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1127#issuecomment-143728302 Don't worry, everyone was once a starter in Scala. :smiley: You can also leave the `supports*` methods in if you think that they might be necessary in the fut

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1127#discussion_r40545392 --- Diff: flink-staging/flink-table/pom.xml --- @@ -37,7 +37,7 @@ under the License. com.google.guava

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1127#discussion_r40545360 --- Diff: flink-staging/flink-table/pom.xml --- @@ -59,6 +59,12 @@ under the License. + org.apac

[GitHub] flink pull request: [FLINK-2561] Adds missing Gelly scala methods ...

2015-09-28 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1183#issuecomment-143725226 Thank you for the review @StephanEwen! I'll address your comments and merge later. --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

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

[GitHub] flink pull request: [FLINK-2561] Adds missing Gelly scala methods ...

2015-09-28 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1183#discussion_r40544282 --- Diff: flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala --- @@ -0,0 +1,31 @@ +/* + * Licens

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933213#comment-14933213 ] ASF GitHub Bot commented on FLINK-2561: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-2677) Add a general-purpose keyed-window operator

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933189#comment-14933189 ] ASF GitHub Bot commented on FLINK-2677: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-2677) Add a general-purpose keyed-window operator

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933188#comment-14933188 ] ASF GitHub Bot commented on FLINK-2677: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-2677] Add a general-purpose keyed-windo...

2015-09-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1184#issuecomment-143718922 A follow-up question: How far do the implementations support event-time based windowing so far? --- If your project is set up for it, you can reply to this email an

[GitHub] flink pull request: [FLINK-2677] Add a general-purpose keyed-windo...

2015-09-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1184#issuecomment-143718845 Very nice. Just tried this out, the examples seem to work nicely. +1 to merge this! --- If your project is set up for it, you can reply to this email and ha

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-28 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1127#issuecomment-143718074 Thanks @aljoscha for reviewing my code! Sorry for the bad Scala style. This was my first really large Scala code project I wrote (not just small scripts), I'm still lear

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[jira] [Commented] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933180#comment-14933180 ] ASF GitHub Bot commented on FLINK-1719: --- Github user JonathanH5 commented on a diff

[GitHub] flink pull request: [FLINK-1719] [ml] Add Multinomial Naive Bayes ...

2015-09-28 Thread JonathanH5
Github user JonathanH5 commented on a diff in the pull request: https://github.com/apache/flink/pull/1156#discussion_r40541853 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/MultinomialNaiveBayes.scala --- @@ -0,0 +1,900 @@ +/* + * Licen

[jira] [Commented] (FLINK-2168) Add fromHBase() to TableEnvironment

2015-09-28 Thread Wilmer DAZA (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933174#comment-14933174 ] Wilmer DAZA commented on FLINK-2168: I saw this as an starter issue, and I want to sta

[GitHub] flink pull request: [FLINK-2561] Adds missing Gelly scala methods ...

2015-09-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1183#issuecomment-143714240 Looks good to me! One style comment: I think that `collect()` should be written with parenthesis. In Scala, you use parenthesis if the methods are not purely

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933167#comment-14933167 ] ASF GitHub Bot commented on FLINK-2561: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-28 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1127#discussion_r40540522 --- Diff: flink-staging/flink-table/pom.xml --- @@ -59,6 +59,12 @@ under the License. + org.apach

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933162#comment-14933162 ] ASF GitHub Bot commented on FLINK-2561: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-2561] Adds missing Gelly scala methods ...

2015-09-28 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1183#discussion_r40540447 --- Diff: flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala --- @@ -0,0 +1,31 @@ +/* + *

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[jira] [Commented] (FLINK-2769) Web dashboard port not configurable on client side

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933158#comment-14933158 ] ASF GitHub Bot commented on FLINK-2769: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-28 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1127#discussion_r40540138 --- Diff: flink-staging/flink-table/pom.xml --- @@ -37,7 +37,7 @@ under the License. com.google.guava

[GitHub] flink pull request: [FLINK-2769] [dashboard] Remove hard coded job...

2015-09-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1185#issuecomment-143713277 +1, looks good. I think the ports / URLs were in there, because originally we had two backend servers running (the old one and the new one) while gradually

[jira] [Created] (FLINK-2772) Introduce dedicated garbage collector config parameter and set default values for batch and streaming

2015-09-28 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2772: Summary: Introduce dedicated garbage collector config parameter and set default values for batch and streaming Key: FLINK-2772 URL: https://issues.apache.org/jira/browse/FLINK-277

[jira] [Created] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis

2015-09-28 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2771: Summary: IterateTest.testSimpleIteration fails on Travis Key: FLINK-2771 URL: https://issues.apache.org/jira/browse/FLINK-2771 Project: Flink Issue Type: Bug

[jira] [Reopened] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis

2015-09-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-2695: -- Doesn't seem to have made the test fully stable: https://s3.amazonaws.com/archive.travis-ci.org/job

[jira] [Commented] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library

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

[jira] [Commented] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933137#comment-14933137 ] ASF GitHub Bot commented on FLINK-1719: --- Github user JonathanH5 commented on a diff

[GitHub] flink pull request: [FLINK-1719] [ml] Add Multinomial Naive Bayes ...

2015-09-28 Thread JonathanH5
Github user JonathanH5 commented on the pull request: https://github.com/apache/flink/pull/1156#issuecomment-143705252 FYI: styling issues fixed, I will now extend my documentation and have a look at the mapWithBcSet method. --- If your project is set up for it, you can reply to this

[GitHub] flink pull request: [FLINK-1719] [ml] Add Multinomial Naive Bayes ...

2015-09-28 Thread JonathanH5
Github user JonathanH5 commented on a diff in the pull request: https://github.com/apache/flink/pull/1156#discussion_r40538554 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/MultinomialNaiveBayes.scala --- @@ -0,0 +1,900 @@ +/* + * Licen

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933135#comment-14933135 ] Till Rohrmann commented on FLINK-2392: -- Another one with the master from Friday, the

[GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod...

2015-09-28 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/1186 [FLINK-1966][ml]Add support for Predictive Model Markup Language 1. Adds an interface to allow exporting of models to PMML format. 2. Implements export methods for the existing SVM and Reg

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

2015-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933133#comment-14933133 ] ASF GitHub Bot commented on FLINK-1966: --- GitHub user sachingoel0101 opened a pull re

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-28 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1127#issuecomment-143703367 Hi, I like the work. :smile: Some remarks about Scala style. We are trying to make our Scala code more consistent. Mostly, I didn't comment everything, jus

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-09-28 Thread Chengxiang Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933125#comment-14933125 ] Chengxiang Li commented on FLINK-7: --- The sample operator has been enabled at [FLINK-1901|h

[jira] [Resolved] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class

2015-09-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2690. -- Resolution: Fixed Fixed via 501a9b0854995b3de1c293b3391eeb3048daeef0 > CsvInputFormat cannot fi

[jira] [Commented] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class

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

[GitHub] flink pull request: [FLINK-2690] [api-breaking] [scala api] [java ...

2015-09-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1141 --- 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 enab

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-28 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1127#discussion_r40536932 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/PredicateFilter.scala --- @@ -0,0 +1,88 @@ +/* +

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

  1   2   >