[
https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15157377#comment-15157377
]
Shikhar Bhushan commented on FLINK-3375:
We are also on Kafka 0.8 for now
> Allow
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15154906#comment-15154906
]
Shikhar Bhushan commented on FLINK-3398:
Can this be addressed for 1.0 -- currentl
[
https://issues.apache.org/jira/browse/FLINK-3399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147467#comment-15147467
]
Shikhar Bhushan commented on FLINK-3399:
Compound triggers would be pretty useful,
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
[
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
upo
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
Is
[
https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139005#comment-15139005
]
Shikhar Bhushan commented on FLINK-3375:
This would be super useful for me, as I c
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
Shikhar Bhushan created FLINK-3339:
--
Summary: Checkpointing NPE when using filterWithState
Key: FLINK-3339
URL: https://issues.apache.org/jira/browse/FLINK-3339
Project: Flink
Issue Type: Bu
[
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
s
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132726#comment-15132726
]
Shikhar Bhushan commented on FLINK-3338:
(this is on 1.0-SNAPSHOT)
> Kafka deseri
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
[
https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15127458#comment-15127458
]
Shikhar Bhushan commented on FLINK-2870:
Thanks for the info, appreciated!
> Add
[
https://issues.apache.org/jira/browse/FLINK-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125217#comment-15125217
]
Shikhar Bhushan commented on FLINK-2870:
What is the current behaviour if a late e
14 matches
Mail list logo