clear query| facets| time Search criteria: .   Results from 1 to 10 from 10 (0.0s).
Loading phrases to help you
refine your search...
[expand - 1 more] - Loading Rules from compacted Kafka Topic - open() vs Connected Streams - Flink - [mail # user]
...What i was trying to achieve from above was similar to GlobalKTable inKafka Streams.https://cwiki.apache.org/confluence/display/KAFKA/KIP-99%3A+Add+Global+Tables+to+Kafka+StreamsAlso current...
   Author: vijayakumar palaniappan , 2018-07-13, 17:39
Task Slots allocation - Flink - [mail # user]
...I am using flink 1.4.0 in standalone cluster modeI have a job with a graph like a Source(parallelism 3) ->Filter(parallelism 3) -> Map(parallelism 1) -> sink(parallelism 3)As per th...
   Author: vijayakumar palaniappan , 2018-03-05, 02:06
[expand - 1 more] - Incremental RocksDB checkpointing - Flink - [mail # user]
...I observed the job for 18 hrs, it went from 118kb to 1.10MB.I am using version 1.3.0 flinkOn Fri, Dec 1, 2017 at 11:39 AM, Stefan Richter <[EMAIL PROTECTED]> wrote:> Maybe one more ...
   Author: vijayakumar palaniappan , 2017-12-01, 17:22
REST Endpoint for Triggering Savepoint - Flink - [mail # user]
...Hi,Is there a REST endpoint for triggering savepoint without cancelling thejob?-- Thanks,-Vijay...
   Author: vijayakumar palaniappan , 2017-11-07, 19:02
Windowed Stream Queryable State Support - Flink - [mail # user]
...What is the state of Windowed Stream Queryable State Support?Is it available in 1.3 or planned for 1.4?ThanksVijay...
   Author: vijayakumar palaniappan , 2017-10-07, 12:55
[FLINK-6297] CEP timeout does not trigger under certain conditions - Flink - [issue]
...-TimeoutPattern does not trigger under certain conditions. Following are the preconditions: -Assume a pattern of Event A followed by Event B within 2 Seconds-PeriodicWaterMarks every 1 secon...
http://issues.apache.org/jira/browse/FLINK-6297    Author: Vijayakumar Palaniappan , 2017-05-19, 15:56
CEP Pattern detection progressively slower - Flink - [mail # user]
...While trying to use Pattern detection on KeyedStream, list of unique keysencountered, keeps accumulating in AbstractKeyedCEPPatternOperator.java. Onencountering watermarks these accumulated ...
   Author: vijayakumar palaniappan , 2017-04-11, 17:57
CEP timeout does not trigger under certain conditions - Flink - [mail # user]
...-TimeoutPattern does not trigger under certain conditions. Following arethe preconditions:-Assume a pattern of Event A followed by Event B within 2 Seconds-PeriodicWaterMarks every 1 second-...
   Author: vijayakumar palaniappan , 2017-04-11, 16:06