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
[
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:
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
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
[
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:
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:
[
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 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
[
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 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
[
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 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
[
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 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
[
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 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
[
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 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
[
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 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
[
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:
22 matches
Mail list logo