[jira] [Commented] (FLINK-3375) Allow Watermark Generation in the Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157377#comment-15157377 ] Shikhar Bhushan commented on FLINK-3375: We are also on Kafka 0.8 for now > Allow Watermark

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

[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15154906#comment-15154906 ] Shikhar Bhushan commented on FLINK-3398: Can this be addressed for 1.0 -- currently there is no

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

[ https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15147467#comment-15147467 ] Shikhar Bhushan commented on FLINK-3399: Compound triggers would be pretty useful, this could

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

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

[ 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

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-3375) Allow Watermark Generation in the Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15139005#comment-15139005 ] Shikhar Bhushan commented on FLINK-3375: This would be super useful for me, as I currently have to

[jira] [Created] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka

Shikhar Bhushan created FLINK-3341: -- Summary: Kafka connector's 'auto.offset.reset' inconsistent with Kafka Key: FLINK-3341 URL: https://issues.apache.org/jira/browse/FLINK-3341 Project: Flink

[jira] [Commented] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132726#comment-15132726 ] Shikhar Bhushan commented on FLINK-3338: (this is on 1.0-SNAPSHOT) > Kafka deserialization issue

[jira] [Created] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException

Shikhar Bhushan created FLINK-3338: -- Summary: Kafka deserialization issue - ClassNotFoundException Key: FLINK-3338 URL: https://issues.apache.org/jira/browse/FLINK-3338 Project: Flink Issue

[jira] [Updated] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shikhar Bhushan updated FLINK-3338: --- Description: I get this error when running a JAR submitted using the web UI on a production

[jira] [Commented] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows

[ https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15127458#comment-15127458 ] Shikhar Bhushan commented on FLINK-2870: Thanks for the info, appreciated! > Add support for

[jira] [Commented] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows

[ https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125217#comment-15125217 ] Shikhar Bhushan commented on FLINK-2870: What is the current behaviour if a late element arrives