577 messages

org.apache.flink.user [All Lists]

2017 January [All Months]

Page 20 (Messages 476 to 500): 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24

Hi, There is possibly an issue with EventTimeSessionWindows where a gap is specified for considering items in the same session. Here the logic is, if two adjacent items have a difference in event timestamps of more than the gap then the items are considered to be in separate session. The issue is, what happens if the gap between streaming records is never (or for a very long time) less than the session gap. This is likely to lead to a race condition. Is this a bug? How do we deal with this to process windows in finite time? Please could you suggest. Thanks. - Sujit Sakre
Speedup of Flink Applications - Hanna Prinz
Question about Scheduling of Batch Jobs - Konstantin Knauf
Re: Flink streaming questions - Fabian Hueske
Sequential/ordered map - Sebastian Neef
Kafka KeyedStream source - Niels Basjes
Re: Queryable State - Dawid Wysakowicz
Fault tolerance guarantees of Elasticsearch sink in flink-elasticsearch2? - Andrew Roberts
Re: Making batches of small messages - Kostas Kloudas
Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) - Till Rohrmann
Re: Objects accessible from all Flink nodes - Matt
Re: Strategies for Complex Event Processing with guaranteed data consistency - Fabian Hueske
Re: Apache Flink 1.1.4 - Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - Vasiliki Kalavri
Re: How to read from a Kafka topic from the beginning - Matthias J. Sax
Re: Restart the job from a checkpoint - Ufuk Celebi
Help using HBase with Flink 1.1.4 - Giuliano Caliari
Re: Help using HBase with Flink 1.1.4 - Flavio Pompermaier
Re: How to get help on ClassCastException when re-submitting a job - Yury Ruchin
Re: Count window on partition - Kostas Kloudas
Re: Why is IdentityObjectIntMap.get called so often? - Stephan Ewen
Re: Improving Flink Performance - Aljoscha Krettek
Issues while restarting a job on HA cluster - ani.desh1512
Re: Improving Flink Performance - drom...@gmail.com
Re: Events are assigned to wrong window - Aljoscha Krettek
Re: setParallelism() for addSource() in streaming - Jonas

Page 20 (Messages 476 to 500): 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24