[GitHub] flink pull request: [FLINK-3399] CountWithTimeoutTrigger

2016-02-14 Thread shikhar
GitHub user shikhar opened a pull request: https://github.com/apache/flink/pull/1636 [FLINK-3399] CountWithTimeoutTrigger trigger that fires once the number of elements in a pane reaches the given count or the timeout expires, whichever happens first You can merge this pull

[jira] [Commented] (FLINK-3399) Count with timeout trigger

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

[jira] [Created] (FLINK-3399) Count with timeout trigger

2016-02-14 Thread Shikhar Bhushan (JIRA)
Shikhar Bhushan created FLINK-3399: -- Summary: Count with timeout trigger Key: FLINK-3399 URL: https://issues.apache.org/jira/browse/FLINK-3399 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-02-14 Thread Shikhar Bhushan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shikhar Bhushan updated FLINK-3398: --- Description: Currently the Kafka source will commit consumer offsets to Zookeeper, either

[jira] [Created] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-02-14 Thread Shikhar Bhushan (JIRA)
Shikhar Bhushan created FLINK-3398: -- Summary: Flink Kafka consumer should support auto-commit opt-outs Key: FLINK-3398 URL: https://issues.apache.org/jira/browse/FLINK-3398 Project: Flink

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

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

[jira] [Created] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

2016-02-14 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-3397: - Summary: Failed streaming jobs should fall back to the most recent checkpoint/savepoint Key: FLINK-3397 URL: https://issues.apache.org/jira/browse/FLINK-3397 Project:

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

2016-02-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3367. Resolution: Done Done with c9db63b935725368a5750e8d4dc94e6b015a1688

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

2016-02-14 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1606#issuecomment-183988942 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 not have this feature

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

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

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

2016-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1606 --- 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-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

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

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

2016-02-14 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1632#issuecomment-183957839 Thanks for the review @twalthr! I've addressed your comments. --- 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-2237) Add hash-based Aggregation

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

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

2016-02-14 Thread ggevay
Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/1517#issuecomment-183896027 I've added some more documentation. --- 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-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode

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

[GitHub] flink pull request: FLINK-3304: Making the Avro Schema serializabl...

2016-02-14 Thread kl0u
Github user kl0u commented on the pull request: https://github.com/apache/flink/pull/1635#issuecomment-183938932 Thanks a lot @rmetzger --- 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-2719) ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFailure failed on Travis

2016-02-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15146641#comment-15146641 ] Robert Metzger commented on FLINK-2719: --- Again:

[GitHub] flink pull request: FLINK-3304: Making the Avro Schema serializabl...

2016-02-14 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1635#issuecomment-183918146 +1 to merge the change. Thank you. --- 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-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode

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

[GitHub] flink pull request: FLINK-3304: Making the Avro Schema serializabl...

2016-02-14 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/1635 FLINK-3304: Making the Avro Schema serializable. This solves the issue FLINK-3304 by making the Avro Schema serializable. This is done by having a custom serializer which transforms the Schema

[jira] [Commented] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode

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