[GitHub] flink pull request: [FLINK-3332] Cassandra connector

2016-02-11 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1620#discussion_r52575628 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java --- @@ -0,0 +1,173 @@ +/** + * L

[GitHub] flink pull request: [FLINK-3372] Setting custom YARN application n...

2016-02-11 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1607#issuecomment-182773179 Hi @ndimiduk, the ASF bot only closes PRs which are merged into master. Can you manually close this one? Thanks --- If your project is set up for it, you can reply t

[jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142441#comment-15142441 ] ASF GitHub Bot commented on FLINK-3332: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-3372) Setting custom YARN application name is ignored

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

[GitHub] flink pull request: [FLINK-3367] Add PublicEvolving and Internal a...

2016-02-11 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1606#issuecomment-182776315 Some of the internal sinks sources, such as File* Socket are Internal while others are PublicEvolving. Is there a reason behind this? --- If your project is set up for

[jira] [Commented] (FLINK-3367) Annotate all user-facing API classes with @Public or @PublicEvolving

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

[GitHub] flink pull request: [FLINK-3367] Add PublicEvolving and Internal a...

2016-02-11 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1606#issuecomment-182778295 The motivation for this was to to make those Internal which can be added via the ExecutionEnvironment. Sources that offer configuration parameters which are not accessib

[GitHub] flink pull request: [FLINK-3367] Add PublicEvolving and Internal a...

2016-02-11 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1606#issuecomment-182778504 I see. Might seem inconsistent, though. :smile: So maybe we should make all of them PublicEvolving. --- If your project is set up for it, you can reply to this email a

[jira] [Commented] (FLINK-3367) Annotate all user-facing API classes with @Public or @PublicEvolving

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

[jira] [Commented] (FLINK-3367) Annotate all user-facing API classes with @Public or @PublicEvolving

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

[GitHub] flink pull request: [FLINK-3270] Add Kafka example

2016-02-11 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1533#issuecomment-182779503 I think Robert has a good point. The examples should follow the implementations of the other examples after the rework in PR #1581. --- If your project is set up f

[jira] [Commented] (FLINK-3270) Add example for reading and writing to Kafka

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

[GitHub] flink pull request: [FLINK-3369] [runtime] Make RemoteTransportExc...

2016-02-11 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1621 [FLINK-3369] [runtime] Make RemoteTransportException instance of CancelTaskException Problem: RemoteTransportException (RTE) is thrown on data transfer failures when the remote data producer fails. Bec

[jira] [Commented] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142554#comment-15142554 ] ASF GitHub Bot commented on FLINK-3369: --- GitHub user uce opened a pull request:

[jira] [Commented] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException

2016-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142569#comment-15142569 ] Ufuk Celebi commented on FLINK-3369: Yes, for example if the connection is lost, I agr

[GitHub] flink pull request: [FLINK-3377] Remove final flag from ResultPart...

2016-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1609#issuecomment-182809855 We also have `CommonTestUtils`, which you can use to create the temporary directory. --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (FLINK-3377) Remove final flag from ResultPartitionWriter class

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142574#comment-15142574 ] ASF GitHub Bot commented on FLINK-3377: --- Github user uce commented on the pull reque

[jira] [Commented] (FLINK-2824) Iteration feedback partitioning does not work as expected

2016-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142576#comment-15142576 ] Ufuk Celebi commented on FLINK-2824: Is this really a blocker? In my opinion, the stre

[GitHub] flink pull request: [FLINK-3160] [web-dashboard] Aggregate operato...

2016-02-11 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1564#discussion_r52588212 --- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.jade --- @@ -22,7 +22,10 @@ nav.navbar.navbar-default.navbar-secondary-additional

[jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142597#comment-15142597 ] ASF GitHub Bot commented on FLINK-3160: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-3160] [web-dashboard] Aggregate operato...

2016-02-11 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1564#discussion_r52588713 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java --- @@ -203,6 +204,27 @@ public JobVertexID getJobVertexId(

[jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142601#comment-15142601 ] ASF GitHub Bot commented on FLINK-3160: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-3160] [web-dashboard] Aggregate operato...

2016-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1564#issuecomment-182814031 Changes and screenshots look very good! I have a minor inline comment regarding the added method. After addressing it, I think that this is good to merge. --- If y

[jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142604#comment-15142604 ] ASF GitHub Bot commented on FLINK-3160: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-3369] [runtime] Make RemoteTransportExc...

2016-02-11 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1621#issuecomment-182813990 Do the exceptions still have information about which connection failed? I see that the network address parameter is removed from the exceptions and also not included

[jira] [Commented] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException

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

[jira] [Commented] (FLINK-2824) Iteration feedback partitioning does not work as expected

2016-02-11 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142605#comment-15142605 ] Gyula Fora commented on FLINK-2824: --- You are probably right this should not block the re

[jira] [Updated] (FLINK-2824) Iteration feedback partitioning does not work as expected

2016-02-11 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-2824: -- Priority: Major (was: Blocker) > Iteration feedback partitioning does not work as expected > --

[jira] [Commented] (FLINK-2609) Automatic type registration is only called from the batch execution environment

2016-02-11 Thread Stefano Baghino (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142610#comment-15142610 ] Stefano Baghino commented on FLINK-2609: [~rmetzger] can you elaborate on this iss

[jira] [Comment Edited] (FLINK-2609) Automatic type registration is only called from the batch execution environment

2016-02-11 Thread Stefano Baghino (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142610#comment-15142610 ] Stefano Baghino edited comment on FLINK-2609 at 2/11/16 11:28 AM: --

[jira] [Created] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data

2016-02-11 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-3386: - Summary: Kafka consumers should not necessarily fail on expiring data Key: FLINK-3386 URL: https://issues.apache.org/jira/browse/FLINK-3386 Project: Flink Issue T

[jira] [Updated] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data

2016-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3386: -- Component/s: ps://issues.apache.org/jira/browse/FLINK-3386 > Kafka consumers should not necessar

[jira] [Updated] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data

2016-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3386: -- Component/s: Kafka Connector > Kafka consumers should not necessarily fail on expiring data > --

[jira] [Updated] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data

2016-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3386: -- Component/s: (was: ps://issues.apache.org/jira/browse/FLINK-3386) > Kafka consumers should n

[jira] [Commented] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data

2016-02-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142614#comment-15142614 ] Robert Metzger commented on FLINK-3386: --- I think this issue is basically a duplicate

[jira] [Commented] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data

2016-02-11 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142615#comment-15142615 ] Gyula Fora commented on FLINK-3386: --- You are right, I am closing this... > Kafka consum

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

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142617#comment-15142617 ] ASF GitHub Bot commented on FLINK-2380: --- Github user kl0u commented on the pull requ

[GitHub] flink pull request: FLINK-2380: allow to specify the default files...

2016-02-11 Thread kl0u
Github user kl0u commented on the pull request: https://github.com/apache/flink/pull/1524#issuecomment-182817638 Thanks @rmetzger for the comment. Will fix it! --- 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 proje

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

2016-02-11 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1600#issuecomment-182817751 Looks pretty good. Can you check the `@Ignore` annotations? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[jira] [Closed] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data

2016-02-11 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-3386. - Resolution: Duplicate Duplicate of: FLINK-3264 > Kafka consumers should not necessarily fail on expiring

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

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

[GitHub] flink pull request: [FLINK-3312] State enhancements convenience me...

2016-02-11 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/1571 --- 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

[GitHub] flink pull request: [FLINK-3312] State enhancements convenience me...

2016-02-11 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1571#issuecomment-182818412 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 fe

[jira] [Commented] (FLINK-3312) Add convenience accessor methods for extended state interface

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142621#comment-15142621 ] ASF GitHub Bot commented on FLINK-3312: --- Github user StephanEwen closed the pull req

[jira] [Commented] (FLINK-3312) Add convenience accessor methods for extended state interface

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

[GitHub] flink pull request: FLINK-3271: Include jetty-util in the dist jar

2016-02-11 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1543#issuecomment-182821560 Adjusting and merging 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

[GitHub] flink pull request: [FLINK-3383] remove Maven deployment from Trav...

2016-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1619#issuecomment-182821639 Changes look good. Do we have another way of deploying the snapshots then? --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

[jira] [Commented] (FLINK-3383) Separate Maven deployment from CI testing

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142625#comment-15142625 ] ASF GitHub Bot commented on FLINK-3383: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-3383] remove Maven deployment from Trav...

2016-02-11 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1619#discussion_r52590661 --- Diff: .travis.yml --- @@ -17,9 +17,9 @@ language: java matrix: include: - jdk: "oraclejdk8" - env: PROFILE="-Dhadoop.version=2.7.

[jira] [Commented] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception

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

[jira] [Commented] (FLINK-3383) Separate Maven deployment from CI testing

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142627#comment-15142627 ] ASF GitHub Bot commented on FLINK-3383: --- Github user uce commented on the pull reque

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-02-11 Thread Dongwon Kim (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142628#comment-15142628 ] Dongwon Kim commented on FLINK-1502: [~mxm] Could you elaborate more on the above expl

[jira] [Commented] (FLINK-3299) Remove ApplicationID from Environment

2016-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142631#comment-15142631 ] Ufuk Celebi commented on FLINK-3299: I think you raise valid points. But as long as we

[GitHub] flink pull request: [FLINK-2428] Clean up unused properties in Str...

2016-02-11 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1554#issuecomment-182824952 I think this breaks the code. The `setOutEdges()` method is actually used (even though the call site can probably be removes as well, given that they are not read an

[jira] [Commented] (FLINK-2428) Clean up unused properties in StreamConfig

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

[GitHub] flink pull request: [FLINK-3369] [runtime] Make RemoteTransportExc...

2016-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1621#issuecomment-182825136 Thanks for looking into it. The remote address is actually part of all the messages, but I've readded it as an explicit argument. For the local variant, the address is known

[GitHub] flink pull request: [FLINK-3383] remove Maven deployment from Trav...

2016-02-11 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1619#discussion_r52591570 --- Diff: .travis.yml --- @@ -17,9 +17,9 @@ language: java matrix: include: - jdk: "oraclejdk8" - env: PROFILE="-Dhadoop.version=2.7.

[jira] [Commented] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142635#comment-15142635 ] ASF GitHub Bot commented on FLINK-3369: --- Github user uce commented on the pull reque

[jira] [Commented] (FLINK-3383) Separate Maven deployment from CI testing

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142637#comment-15142637 ] ASF GitHub Bot commented on FLINK-3383: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-3383] remove Maven deployment from Trav...

2016-02-11 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1619#issuecomment-182825715 Thanks for the comment. Yes, as stated above, I would like to migrate snapshot deployment to the a nightly Buildbot job at Apache's infrastructure (like we also do for the d

[jira] [Commented] (FLINK-3383) Separate Maven deployment from CI testing

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142638#comment-15142638 ] ASF GitHub Bot commented on FLINK-3383: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52597099 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/StoppableFunction.java --- @@ -0,0 +1,33 @@ +/* + * Licensed to the Apac

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142668#comment-15142668 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52597604 --- Diff: docs/apis/cli.md --- @@ -248,6 +252,16 @@ Action "cancel" cancels a running program. configuration.

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142675#comment-15142675 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52598106 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/StoppableTask.java --- @@ -0,0 +1,25 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142681#comment-15142681 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52598306 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -464,6 +464,33 @@ class JobManager( )

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142684#comment-15142684 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[jira] [Created] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

2016-02-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3387: --- Summary: Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer Key: FLINK-3387 URL: https://issues.apache.org/jira/browse/FLINK-3387

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52598511 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -417,6 +417,28 @@ class TaskManager(

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142688#comment-15142688 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52598636 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -464,6 +464,33 @@ class JobManager( )

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142691#comment-15142691 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52598649 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -464,6 +464,33 @@ class JobManager( )

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142690#comment-15142690 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52598725 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -464,6 +464,33 @@ class JobManager( )

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52598713 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -464,6 +464,33 @@ class JobManager( )

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52598719 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -464,6 +464,33 @@ class JobManager( )

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142694#comment-15142694 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142692#comment-15142692 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142693#comment-15142693 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation

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

[GitHub] flink pull request: [FLINK-2991] Add Folding State and use in Wind...

2016-02-11 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1605#discussion_r52599200 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java --- @@ -148,6 +150,18 @@ public void dispose() { a

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-182859453 Really good work @mjsax. I had a couple of minor inline comments with respect to the latest commit and some with respect to the overall changes (especially c

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

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

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-02-11 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142710#comment-15142710 ] Maximilian Michels commented on FLINK-1502: --- [~eastcirclek] Yes, I was working o

[jira] [Closed] (FLINK-3170) Expose task manager metrics via JMX

2016-02-11 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3170. - Resolution: Duplicate > Expose task manager metrics via JMX >

[jira] [Created] (FLINK-3388) Expose task accumulators via JMX

2016-02-11 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3388: - Summary: Expose task accumulators via JMX Key: FLINK-3388 URL: https://issues.apache.org/jira/browse/FLINK-3388 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142727#comment-15142727 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2016-02-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r52601121 --- Diff: flink-runtime-web/web-dashboard/web/css/vendor.css --- @@ -7704,6 +7704,7 @@ button.close { .modal-header { padding: 15px; bor

[jira] [Closed] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException

2016-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3369. -- Resolution: Fixed Fixed in cf3ae88. > RemoteTransportException should be instance of CancelTaskExceptio

[GitHub] flink pull request: [FLINK-3369] [runtime] Make RemoteTransportExc...

2016-02-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1621 --- 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-3369) RemoteTransportException should be instance of CancelTaskException

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

[jira] [Commented] (FLINK-3283) Failed Kafka 0.9 test on duplicate message

2016-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142745#comment-15142745 ] Ufuk Celebi commented on FLINK-3283: Do you think we can close this issue? > Failed

[GitHub] flink pull request: [FLINK-2237] [runtime] Add hash-based combiner...

2016-02-11 Thread ggevay
Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/1517#issuecomment-182872207 I'm thinking about partitioning, but again, I'm finding it too difficult to imagine how this algorithm behaves, when we emit/rebuild only some part of the table at a time

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

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

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

2016-02-11 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1600#issuecomment-182872698 @fhueske I fixed the aggregation hashCode and enables the ignored tests. Let me know if it's OK now! --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

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

[GitHub] flink pull request: [FLINK-3364] [runtime, yarn] Move SavepointSto...

2016-02-11 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1622 [FLINK-3364] [runtime, yarn] Move SavepointStore initialization out of JobManager constructor Initializing the `SavepointStore` can fail. Doing this in the `JobManager` constructor is bad, because it i

  1   2   3   >