[jira] [Commented] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5

2015-12-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048435#comment-15048435 ] Stephan Ewen commented on FLINK-3143: - I think this is the same as [FLINK-3136] > Update Clojure

[jira] [Commented] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5

2015-12-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048465#comment-15048465 ] Stephan Ewen commented on FLINK-3143: - I think the regular ASM we use is already ASM 5. So adjusting

[jira] [Created] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap)

2015-12-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3151: - Summary: YARN kills Flink TM containers due to memory overuse (outside heap/offheap) Key: FLINK-3151 URL: https://issues.apache.org/jira/browse/FLINK-3151 Project:

[jira] [Created] (FLINK-3152) Support all comparisons for Date type

2015-12-09 Thread Timo Walther (JIRA)
Timo Walther created FLINK-3152: --- Summary: Support all comparisons for Date type Key: FLINK-3152 URL: https://issues.apache.org/jira/browse/FLINK-3152 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3138) Method References are not supported as lambda expressions

2015-12-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048430#comment-15048430 ] Stephan Ewen commented on FLINK-3138: - Try using a custom type with a getKey method(). Then the

[jira] [Commented] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048443#comment-15048443 ] ASF GitHub Bot commented on FLINK-3023: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048456#comment-15048456 ] ASF GitHub Bot commented on FLINK-3073: --- Github user StephanEwen commented on the pull request:

[jira] [Assigned] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap)

2015-12-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-3151: -- Assignee: Ufuk Celebi > YARN kills Flink TM containers due to memory overuse (outside

[jira] [Commented] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap)

2015-12-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048361#comment-15048361 ] Ufuk Celebi commented on FLINK-3151: Which fraction were you able to run after going back to the older

[GitHub] flink pull request: updated to Flink v0.10.1

2015-12-09 Thread romeokienzler
Github user romeokienzler commented on a diff in the pull request: https://github.com/apache/flink/pull/1443#discussion_r47052396 --- Diff: flink-contrib/docker-flink/flink/Dockerfile --- @@ -25,8 +25,8 @@ RUN cat ~/.ssh/id_rsa.pub >> ~/.ssh/authorized_keys && chmod 600 ~/.ssh/*

[jira] [Assigned] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import

2015-12-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3136: --- Assignee: Aljoscha Krettek (was: Stephan Ewen) > Scala Closure Cleaner uses wrong

[jira] [Resolved] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import

2015-12-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-3136. - Resolution: Fixed Fixed in

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

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

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

2015-12-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048439#comment-15048439 ] Timo Walther commented on FLINK-2099: - Cool, that you already checked out and tested my code. You

[jira] [Commented] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048438#comment-15048438 ] ASF GitHub Bot commented on FLINK-3074: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3074] Add config option to start YARN A...

2015-12-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1416#discussion_r47074199 --- Diff: flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala --- @@ -120,18 +125,76 @@ abstract class ApplicationMasterBase {

[jira] [Commented] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048451#comment-15048451 ] ASF GitHub Bot commented on FLINK-3074: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Created] (FLINK-3153) Support all comparisons for String type

2015-12-09 Thread Timo Walther (JIRA)
Timo Walther created FLINK-3153: --- Summary: Support all comparisons for String type Key: FLINK-3153 URL: https://issues.apache.org/jira/browse/FLINK-3153 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3145) Storm examples can't be run without flink-java as dependency

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048445#comment-15048445 ] ASF GitHub Bot commented on FLINK-3145: --- Github user mxm commented on the pull request:

[GitHub] flink pull request: [FLINK-3023][web-dashboard] Display version an...

2015-12-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1422#discussion_r47073802 --- Diff: flink-runtime-web/web-dashboard/app/partials/overview.jade --- @@ -22,6 +22,12 @@ nav.navbar.navbar-default.navbar-fixed-top.navbar-main

[jira] [Updated] (FLINK-2380) Allow to configure default FS for file inputs

2015-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2380: -- Labels: starter (was: ) > Allow to configure default FS for file inputs >

[jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs

2015-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048351#comment-15048351 ] Robert Metzger commented on FLINK-2380: --- Quick note: The property is not called {{fs.default.name}}

[jira] [Assigned] (FLINK-3150) Make YARN container invocation configurable

2015-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3150: - Assignee: Robert Metzger > Make YARN container invocation configurable >

[jira] [Commented] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048440#comment-15048440 ] ASF GitHub Bot commented on FLINK-3074: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

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

[GitHub] flink pull request: [FLINK-3145][storm] pin Kryo version of transi...

2015-12-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1441#issuecomment-163184620 Fair enough, let's leave it specific to storm then. Kryo beyond 2.24.0 changed maven group and artifact names... --- If your project is set up for it, you

[jira] [Commented] (FLINK-3145) Storm examples can't be run without flink-java as dependency

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048459#comment-15048459 ] ASF GitHub Bot commented on FLINK-3145: --- Github user StephanEwen commented on the pull request:

[jira] [Created] (FLINK-3150) Make YARN container invocation configurable

2015-12-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3150: - Summary: Make YARN container invocation configurable Key: FLINK-3150 URL: https://issues.apache.org/jira/browse/FLINK-3150 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-2976) Save and load checkpoints manually

2015-12-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-2976: -- Assignee: Ufuk Celebi > Save and load checkpoints manually >

[jira] [Commented] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048437#comment-15048437 ] ASF GitHub Bot commented on FLINK-3074: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3074] Add config option to start YARN A...

2015-12-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1416#discussion_r47073382 --- Diff: flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala --- @@ -120,18 +125,76 @@ abstract class ApplicationMasterBase {

[GitHub] flink pull request: [FLINK-3023][web-dashboard] Display version an...

2015-12-09 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/1422#discussion_r47076123 --- Diff: flink-runtime-web/web-dashboard/app/partials/overview.jade --- @@ -22,6 +22,12 @@ nav.navbar.navbar-default.navbar-fixed-top.navbar-main

[GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ...

2015-12-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1433#issuecomment-163177539 Any objections against me merging this now? --- 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

[GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ...

2015-12-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1433#issuecomment-163194389 is `pre-allocate` also ok? btw, we have a wild mixture of option styles, there is camelCase, under_score, and with-hyphens. --- If your project is set up for it, you

[jira] [Created] (FLINK-3155) Update Flink docker version to latest stable Flink version

2015-12-09 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3155: - Summary: Update Flink docker version to latest stable Flink version Key: FLINK-3155 URL: https://issues.apache.org/jira/browse/FLINK-3155 Project: Flink

[GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ...

2015-12-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1433#issuecomment-163192234 +1 from my side, after the switch to "preallocate" --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink pull request: [FLINK-3145][storm] pin Kryo version of transi...

2015-12-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1441#issuecomment-163181852 Not sure about the Kryo dependency in the root pom. We already pin the Kryo version via dependency management in the root pom. This eliminates most conflicts in sub

[GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ...

2015-12-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1235#issuecomment-163220976 Closing this because of the raised objections. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048625#comment-15048625 ] ASF GitHub Bot commented on FLINK-2823: --- Github user mxm closed the pull request at:

[GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ...

2015-12-09 Thread mxm
Github user mxm closed the pull request at: https://github.com/apache/flink/pull/1235 --- 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-2978) Integrate web submission interface into the new dashboard

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048480#comment-15048480 ] ASF GitHub Bot commented on FLINK-2978: --- Github user sachingoel0101 commented on the pull request:

[GitHub] flink pull request: [FLINK-3074] Add config option to start YARN A...

2015-12-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1416#discussion_r47073661 --- Diff: flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala --- @@ -120,18 +125,76 @@ abstract class ApplicationMasterBase {

[jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048534#comment-15048534 ] ASF GitHub Bot commented on FLINK-3155: --- Github user mxm commented on the pull request:

[GitHub] flink pull request: [FLINK-3143] update Closure Cleaner's ASM refe...

2015-12-09 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1445 [FLINK-3143] update Closure Cleaner's ASM references to ASM5 - This solves errors with reflectasm using Scala 2.11 and Java 8 You can merge this pull request into a Git repository by running: $

[GitHub] flink pull request: [FLINK-3023][web-dashboard] Display version an...

2015-12-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1422#issuecomment-163194318 All right, lets merge this then... --- 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

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048632#comment-15048632 ] ASF GitHub Bot commented on FLINK-3073: --- Github user mxm commented on the pull request:

[GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ...

2015-12-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1433#issuecomment-163221930 `preallocate` can be seen as one word, no? --- 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

[GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ...

2015-12-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1433#issuecomment-163184597 Can do, yes. --- 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] [Created] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3

2015-12-09 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3154: - Summary: Update Kryo version from 2.24.0 to 3.0.3 Key: FLINK-3154 URL: https://issues.apache.org/jira/browse/FLINK-3154 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5

2015-12-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048502#comment-15048502 ] Stephan Ewen commented on FLINK-3143: - Ah, got it. The opCode versions inside the Closure Cleaner

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048475#comment-15048475 ] ASF GitHub Bot commented on FLINK-3073: --- Github user mxm commented on the pull request:

[jira] [Commented] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048476#comment-15048476 ] ASF GitHub Bot commented on FLINK-3023: --- Github user sachingoel0101 commented on a diff in the pull

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

2015-12-09 Thread Ovidiu Marcu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048601#comment-15048601 ] Ovidiu Marcu commented on FLINK-2099: - Thanks, I will look into FLINK-3152. Can you please make an

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-12-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048630#comment-15048630 ] Maximilian Michels commented on FLINK-2823: --- I will open a new pull request to address this

[GitHub] flink pull request: [FLINK-3145][storm] pin Kryo version of transi...

2015-12-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1441#issuecomment-163186476 I'm not really sure about the implications of Kryo in the root pom so I try to fix it where it is a problem first. >Kryo beyond 2.24.0 changed maven group and

[jira] [Commented] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048482#comment-15048482 ] ASF GitHub Bot commented on FLINK-3077: --- Github user mxm commented on the pull request:

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048508#comment-15048508 ] ASF GitHub Bot commented on FLINK-3073: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: updated to Flink v0.10.1

2015-12-09 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1443#issuecomment-163153842 Do you have JIRA ticket filed for this? As part of ASF contribution please do file JIRA [1] and associate with the PR [2]. Thanks! [1]

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

2015-12-09 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1338#issuecomment-163188173 Hi @StephanEwen, I have modified the signature of the `handleRequest` method to separate path and query parameters. If there are any more concerns, let me

[jira] [Commented] (FLINK-3150) Make YARN container invocation configurable

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048639#comment-15048639 ] ASF GitHub Bot commented on FLINK-3150: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-3150] Make the YARN container start inv...

2015-12-09 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/1446 [FLINK-3150] Make the YARN container start invocation configurable You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink flink3150

[jira] [Commented] (FLINK-3145) Storm examples can't be run without flink-java as dependency

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048471#comment-15048471 ] ASF GitHub Bot commented on FLINK-3145: --- Github user mxm commented on the pull request:

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

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

[jira] [Assigned] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-12-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2823: - Assignee: Maximilian Michels > YARN client should report a proper exception if

[GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ...

2015-12-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1433#issuecomment-163184249 Looks good! One thing that just came to my mind is whether we should call the config flag "taskmanager.memory.preallocate" (default false). I think

[GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ...

2015-12-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1433#issuecomment-163187358 PR looks good. +1 for `taskmanager.memory.preallocate`. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request: [FLINK-3074] Add config option to start YARN A...

2015-12-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1416#discussion_r47073443 --- Diff: flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala --- @@ -120,18 +125,76 @@ abstract class ApplicationMasterBase {

[jira] [Commented] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048526#comment-15048526 ] ASF GitHub Bot commented on FLINK-3023: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: updated to Flink v0.10.1

2015-12-09 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1443#discussion_r47079200 --- Diff: flink-contrib/docker-flink/flink/Dockerfile --- @@ -25,8 +25,8 @@ RUN cat ~/.ssh/id_rsa.pub >> ~/.ssh/authorized_keys && chmod 600 ~/.ssh/*

[jira] [Commented] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048558#comment-15048558 ] ASF GitHub Bot commented on FLINK-3023: --- Github user sachingoel0101 commented on the pull request:

[GitHub] flink pull request: [FLINK-3023][web-dashboard] Display version an...

2015-12-09 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1422#issuecomment-163200275 Olrite. Great! #1418 should also be meregable with this one IMO. --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request: updated to Flink v0.10.1

2015-12-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1443#issuecomment-163196855 Thanks @hsaputra for the reminder. I've filed a JIRA: https://issues.apache.org/jira/browse/FLINK-3155 Looks good to merge otherwise. --- If your project is set

[GitHub] flink pull request: [FLINK-3074] Add config option to start YARN A...

2015-12-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1416#issuecomment-163183261 Only some minor comments left. +1 for merging after they are are addressed or discarded. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-3121) Watermark forwarding does not work for sources not producing any data

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048718#comment-15048718 ] ASF GitHub Bot commented on FLINK-3121: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request: [FLINK-3121] Emit Final Watermark in Kafka Sou...

2015-12-09 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1447 [FLINK-3121] Emit Final Watermark in Kafka Source Kafka sources that don't read from any partition never emit a watermark, thereby blocking the progress of event-time in downstream operations.

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048739#comment-15048739 ] ASF GitHub Bot commented on FLINK-3073: --- Github user aljoscha closed the pull request at:

[jira] [Reopened] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5

2015-12-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-3143: --- > Update Clojure Cleaner's ASM references to ASM5 >

[GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ...

2015-12-09 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/1433 --- 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] [Resolved] (FLINK-3073) Activate streaming mode by default

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

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

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

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

2015-12-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reopened FLINK-2769: This changed removed the address completely, but it should have been an empty string by default.

[GitHub] flink pull request: [FLINK-3145][storm] pin Kryo version of transi...

2015-12-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1441 --- 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-3143) Update Clojure Cleaner's ASM references to ASM5

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

[jira] [Commented] (FLINK-3145) Storm examples can't be run without flink-java as dependency

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

[jira] [Closed] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5

2015-12-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3143. - Resolution: Fixed Fix Version/s: 0.10.2 > Update Clojure Cleaner's ASM references

[jira] [Assigned] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program

2015-12-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2936: --- Assignee: Aljoscha Krettek > ClassCastException when using EventTimeSourceFunction

[GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ...

2015-12-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1433#issuecomment-163264394 Manually merged --- 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

[GitHub] flink pull request: [FLINK-2936] Fix ClassCastException for Event-...

2015-12-09 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1448 [FLINK-2936] Fix ClassCastException for Event-Time source Before, would throw a ClassCastException when emitting watermarks with timestamp/watermark multiplexing disabled. You can merge this

[GitHub] flink pull request: updated to Flink v0.10.1

2015-12-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1443 --- 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-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048779#comment-15048779 ] ASF GitHub Bot commented on FLINK-2936: --- GitHub user aljoscha opened a pull request:

[jira] [Closed] (FLINK-3145) Storm examples can't be run without flink-java as dependency

2015-12-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3145. - Resolution: Fixed Fix Version/s: 0.10.2 master:

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

2015-12-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048732#comment-15048732 ] Timo Walther commented on FLINK-2099: - We can use this issue as an umbrella task for all SQL

[GitHub] flink pull request: [FLINK-3143] update Closure Cleaner's ASM refe...

2015-12-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1445 --- 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] [Assigned] (FLINK-3121) Watermark forwarding does not work for sources not producing any data

2015-12-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3121: --- Assignee: Aljoscha Krettek > Watermark forwarding does not work for sources not

[GitHub] flink pull request: [FLINK-2796] [runtime-web] Add configurable jo...

2015-12-09 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1449 [FLINK-2796] [runtime-web] Add configurable job manager address to HTTP requests These changes (re-)enable testing of changes to the web frontend: - Set the `allow-origin` header in order to

[jira] [Resolved] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable

2015-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3074. --- Resolution: Fixed Fixed for 1.0 in

[GitHub] flink pull request: [FLINK-3074] Add config option to start YARN A...

2015-12-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1416 --- 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] [Created] (FLINK-3157) Web frontend json files contain author attribution

2015-12-09 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3157: -- Summary: Web frontend json files contain author attribution Key: FLINK-3157 URL: https://issues.apache.org/jira/browse/FLINK-3157 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15049556#comment-15049556 ] ASF GitHub Bot commented on FLINK-1745: --- Github user danielblazevski commented on a diff in the pull

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2015-12-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15049554#comment-15049554 ] ASF GitHub Bot commented on FLINK-1745: --- Github user danielblazevski commented on a diff in the pull

  1   2   >