clear query| facets| time Search criteria: .   Results from 1 to 10 from 469 (0.0s).
Loading phrases to help you
refine your search...
Watermark alignment during unit tests - Flink - [mail # dev]
...Hi Eugen,It is true that for ITcases this can be difficult and this should be improved in Flink’s testing infrastructure,but for this specific PR, what you need to check is if the allowedLat...
   Author: Kostas Kloudas , 2018-09-18, 10:27
Setting a custom Kryo serializer in Flink-Python - Flink - [mail # user]
...Hi Joe,Probably Chesnay (cc’ed) may have a better idea on why this is happening.Cheers,Kostas> On Sep 14, 2018, at 7:30 PM, Joe Malt  wrote:> > Hi,> > I'm trying to write...
   Author: Kostas Kloudas , 2018-09-17, 15:40
Question regarding state cleaning using timer - Flink - [mail # user]
...Hi Bhaskar,If you want different TTLs per key, then you should use timers with a process function as shown in [1]. This is though an old presentation, so now the RichProcessFunction is a Key...
   Author: Kostas Kloudas , 2018-09-17, 15:35
questions about YARN deployment and HDFS integration - Flink - [mail # user]
...Hi Chiang,Some of the answers you can find in line:> On Sep 17, 2018, at 3:47 PM, Chang Liu  wrote:> > Dear All,> > I am helping my team setup a Flink cluster and we woul...
   Author: Kostas Kloudas , 2018-09-17, 15:25
[expand - 1 more] - ListState<T> - elements order - Flink - [mail # user]
...Oops,Sorry but I lost part of the discussion that had already been made.Please ignore my previous answer.Kostas> On Sep 17, 2018, at 4:37 PM, Kostas Kloudas  wrote:> > Hi all,&...
   Author: Kostas Kloudas , 2018-09-17, 14:39
Lookup from state - Flink - [mail # user]
...Hi Taher,To understand your use case, you have something like the following:stream1.keyBy(…) .connect(stream2.keyBy(…)) .window(…).apply(MyWindowFunction)and you want from within the MyWindo...
   Author: Kostas Kloudas , 2018-09-17, 14:29
Flink 1.3.2 RocksDB map segment fail if configured as state backend - Flink - [mail # user]
...Hi Andrea,I think that Andrey and Stefan (cc’ed) may be able to help.Kostas> On Sep 17, 2018, at 11:37 AM, Andrea Spina  wrote:> > Hi everybody,> > I run with a Flink 1.3...
   Author: Kostas Kloudas , 2018-09-17, 14:09
[FLINK-10097] More tests to increase StreamingFileSink test coverage - Flink - [issue]    Author: Kostas Kloudas , 2018-09-15, 21:29
[FLINK-8073] Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint() - Flink - [issue]
...Travis log:    Author: Kostas Kloudas , 2018-09-15, 21:29
[FLINK-9046] Improve error messages when receiving unexpected messages. - Flink - [issue]
...Currently, in many cases, when a Rest Handler received an unexpected messages, e.g. for a job that it does not exist, it logs the full stack trace often with misguiding messages. This can ha...    Author: Kostas Kloudas , 2018-09-15, 21:21