[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=15142456#comment-15142456 ] ASF GitHub Bot commented on FLINK-3367: --- Github user aljoscha commented on the pull request:

[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

[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=15142454#comment-15142454 ] ASF GitHub Bot commented on FLINK-3367: --- Github user fhueske commented on the pull request:

[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=15142441#comment-15142441 ] ASF GitHub Bot commented on FLINK-3332: --- Github user zentol commented on a diff in the pull request:

[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=15142443#comment-15142443 ] ASF GitHub Bot commented on FLINK-3372: --- Github user fhueske commented on the pull request:

[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 @@ +/** + *

[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

[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=15142460#comment-15142460 ] ASF GitHub Bot commented on FLINK-3270: --- Github user fhueske commented on the pull request:

[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

[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=15142446#comment-15142446 ] ASF GitHub Bot commented on FLINK-3367: --- Github user aljoscha commented on the pull request:

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

2016-02-11 Thread ramkrish86
Github user ramkrish86 commented on the pull request: https://github.com/apache/flink/pull/1553#issuecomment-183190815 @fhueske I got the problem that I was making. My bad. I was not applying the partition function on the Key ie. the String part returned from the flat map and

[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=15144128#comment-15144128 ] Dongwon Kim commented on FLINK-1502: Before deciding the design, we should take into consideration an

[jira] [Comment Edited] (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=15144128#comment-15144128 ] Dongwon Kim edited comment on FLINK-1502 at 2/12/16 6:29 AM: - Before deciding

[jira] [Comment Edited] (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=15144128#comment-15144128 ] Dongwon Kim edited comment on FLINK-1502 at 2/12/16 6:31 AM: - Before deciding

[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=15142597#comment-15142597 ] ASF GitHub Bot commented on FLINK-3160: --- Github user uce commented on a diff in the pull request:

[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

[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=15142618#comment-15142618 ] ASF GitHub Bot commented on FLINK-3226: --- Github user fhueske commented on the pull request:

[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

[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=15142637#comment-15142637 ] ASF GitHub Bot commented on FLINK-3383: --- Github user mxm commented on a diff in the pull request:

[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

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

2016-02-11 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/1517#discussion_r52608138 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java --- @@ -0,0 +1,1014 @@ +/* + * Licensed to the

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

2016-02-11 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/1517#discussion_r52608113 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java --- @@ -0,0 +1,1014 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-3391) Typo in SavepointITCase

2016-02-11 Thread Sebastian Klemke (JIRA)
Sebastian Klemke created FLINK-3391: --- Summary: Typo in SavepointITCase Key: FLINK-3391 URL: https://issues.apache.org/jira/browse/FLINK-3391 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-3391) Typo in SavepointITCase

2016-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3391. -- Resolution: Fixed Fixed in ed7d3da. > Typo in SavepointITCase > --- > >

[jira] [Created] (FLINK-3389) Add Pre-defined Options settings for RocksDB State backend

2016-02-11 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3389: --- Summary: Add Pre-defined Options settings for RocksDB State backend Key: FLINK-3389 URL: https://issues.apache.org/jira/browse/FLINK-3389 Project: Flink Issue

[jira] [Resolved] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend

2016-02-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3355. - Resolution: Fixed Fix Version/s: 1.0.0 Fixed via 9ee16794909d18aa84e8d0b738a6a447d11e6eeb

[jira] [Closed] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend

2016-02-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3355. --- > Allow passing RocksDB Option to RocksDBStateBackend >

[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=15142877#comment-15142877 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on the pull request:

[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-182915371 It seems that reverting `vendor.css` and `vendor.js` to the latest master version does the trick :-) I've tested the stop functionality locally and on yarn

[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=15142810#comment-15142810 ] ASF GitHub Bot commented on FLINK-2237: --- Github user ggevay commented on a diff in the pull request:

[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=15142809#comment-15142809 ] ASF GitHub Bot commented on FLINK-2237: --- Github user ggevay commented on a diff in the pull request:

[jira] [Commented] (FLINK-3360) Clear up StateBackend, AbstractStateBackend abstractions

2016-02-11 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15142813#comment-15142813 ] Stephan Ewen commented on FLINK-3360: - I think the {{AbstractStateBackend}} should actually implement

[jira] [Created] (FLINK-3390) Savepoint resume is not retried

2016-02-11 Thread Sebastian Klemke (JIRA)
Sebastian Klemke created FLINK-3390: --- Summary: Savepoint resume is not retried Key: FLINK-3390 URL: https://issues.apache.org/jira/browse/FLINK-3390 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-3390) Savepoint resume is not retried

2016-02-11 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Klemke updated FLINK-3390: Attachment: savepoint_restore_violates_exactly_once.patch Test case to reproduce this

[jira] [Commented] (FLINK-3364) Don't initialize SavepointStore in JobManager constructor

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

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

2016-02-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1622#issuecomment-183009153 Travis gives the green light (finally). I'm going to merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request: [FLINK-3226] Translation from and to POJOs for...

2016-02-11 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/1624 [FLINK-3226] Translation from and to POJOs for CodeGenerator This PR implements full POJO support as input and output type of the Table API. It is now possible to convert from an arbitrary type to

[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=15143300#comment-15143300 ] ASF GitHub Bot commented on FLINK-3226: --- GitHub user twalthr opened a pull request:

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

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

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

2016-02-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1622 --- 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] [Closed] (FLINK-3364) Don't initialize SavepointStore in JobManager constructor

2016-02-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3364. -- Resolution: Fixed Fixed in dcea46e. > Don't initialize SavepointStore in JobManager constructor >

[jira] [Commented] (FLINK-3187) Decouple restart strategy from ExecutionGraph

2016-02-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15143386#comment-15143386 ] ASF GitHub Bot commented on FLINK-3187: --- Github user uce commented on the 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=15142569#comment-15142569 ] Ufuk Celebi commented on FLINK-3369: Yes, for example if the connection is lost, I agree that it makes

[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=15142601#comment-15142601 ] ASF GitHub Bot commented on FLINK-3160: --- Github user uce commented on a diff in the pull request:

[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

[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: ps://issues.apache.org/jira/browse/FLINK-3386 > Kafka consumers should not

[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=15142634#comment-15142634 ] ASF GitHub Bot commented on FLINK-2428: --- Github user StephanEwen commented on the pull request:

[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

[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

[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=15142605#comment-15142605 ] Gyula Fora commented on FLINK-2824: --- You are probably right this should not block the release. >

[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

[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

[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=15142617#comment-15142617 ] ASF GitHub Bot commented on FLINK-2380: --- Github user kl0u commented on the pull request:

[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

[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=15142638#comment-15142638 ] ASF GitHub Bot commented on FLINK-3383: --- Github user mxm commented on the pull request:

[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=15142675#comment-15142675 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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=15142693#comment-15142693 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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=15142692#comment-15142692 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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=15142604#comment-15142604 ] ASF GitHub Bot commented on FLINK-3160: --- Github user uce commented on the pull request:

[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

[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

[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

[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

[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=15142625#comment-15142625 ] ASF GitHub Bot commented on FLINK-3383: --- Github user uce commented on a diff in the pull request:

[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=15142668#comment-15142668 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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( )

[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=15142690#comment-15142690 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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_r52598719 --- 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_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=15142694#comment-15142694 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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.

[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=15142554#comment-15142554 ] ASF GitHub Bot commented on FLINK-3369: --- GitHub user uce opened a pull request:

[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=15142610#comment-15142610 ] Stefano Baghino edited comment on FLINK-2609 at 2/11/16 11:28 AM: --

[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=15142610#comment-15142610 ] Stefano Baghino commented on FLINK-2609: [~rmetzger] can you elaborate on this issue in

[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=15142621#comment-15142621 ] ASF GitHub Bot commented on FLINK-3312: --- Github user StephanEwen closed the pull request at:

[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

[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=15142620#comment-15142620 ] ASF GitHub Bot commented on FLINK-3312: --- Github user StephanEwen commented on the pull request:

[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:

[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=15142635#comment-15142635 ] ASF GitHub Bot commented on FLINK-3369: --- Github user uce commented on the pull request:

[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

[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=15142681#comment-15142681 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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=15142688#comment-15142688 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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( )

[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=15142691#comment-15142691 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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=15142615#comment-15142615 ] Gyula Fora commented on FLINK-3386: --- You are right, I am closing this... > Kafka consumers should not

[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=15142614#comment-15142614 ] Robert Metzger commented on FLINK-3386: --- I think this issue is basically a duplicate of:

[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] [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

[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=15142684#comment-15142684 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on a diff in the pull

[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=15142700#comment-15142700 ] ASF GitHub Bot commented on FLINK-2991: --- Github user StephanEwen commented on a diff in the pull

[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() {

[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=15142704#comment-15142704 ] ASF GitHub Bot commented on FLINK-2111: --- Github user tillrohrmann commented on the pull request:

[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=15142710#comment-15142710 ] Maximilian Michels commented on FLINK-1502: --- [~eastcirclek] Yes, I was working on the

[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:

  1   2   3   >