clear query| facets| time Search criteria: .   Results from 1 to 10 from 81 (0.0s).
Loading phrases to help you
refine your search...
Flink drops messages? - Flink - [mail # user]
...Hi, I'm running a Flink application where data are retrieved from a Kafka brokerand forwarded to a Cassandra sink.I've implemented the following watermark emitter:public class CustomTimestam...
   Author: AndreaKinn , 2017-11-12, 20:29
[expand - 2 more] - Flink memory usage - Flink - [mail # user]
...Anyway, If I understood how system metrics works (the results seems to beshowed in browser) I can't use it because my cluster is accessible only withterminal via ssh --Sent from: http://apac...
   Author: AndreaKinn , 2017-11-04, 15:19
[expand - 5 more] - StreamTransformation<T> object - Flink - [mail # user]
...Thanks for your help, I solved the issue refactoring HTMStream adding newapi's--Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/...
   Author: AndreaKinn , 2017-10-29, 11:55
Set heap size - Flink - [mail # user]
...About task manager heap size Flink doc says:... If the cluster is exclusively running Flink, the total amount ofavailable memory per machine minus some memory for the operating system(maybe ...
   Author: AndreaKinn , 2017-10-19, 08:15
[expand - 2 more] - Unbalanced job scheduling - Flink - [mail # user]
...I'm in contact with the founder of the library to deal with the problem. I'mtrying also to understand how implement myself slotSharingGroups--Sent from: http://apache-flink-user-mailing-list...
   Author: AndreaKinn , 2017-10-17, 09:00
[expand - 1 more] - Problems with window function - Flink - [mail # user]
...KeySelector was exactly what I need. Thank you a lot.I modified my code in this way and now it works:DataStream LCxAccStream = env .addSource(new FlinkKafkaConsumer010("LCacc", newCustomD...
   Author: AndreaKinn , 2017-10-15, 08:37
Doubts about parallelism - Flink - [mail # user]
...Hi,I read the doc about parallelism, parallel execution and job scheduling buthowever I have some doubts about parallelism.1. In my first try I unset parallelism in my code and commentedpara...
   Author: AndreaKinn , 2017-10-14, 18:56
[expand - 9 more] - NoResourceAvailable exception - Flink - [mail # user]
...the program is composed by:6 Kafka /source/ connector with custom timestamp and watermark /extractor/and /map/ function each.then I use 6 instance of an external library called flink-htm (qu...
   Author: AndreaKinn , 2017-10-11, 19:59
[expand - 2 more] - Load distribution through the cluster - Flink - [mail # user]
...If I apply a sharing slot as in the example:DataStream LTzAccStream = env .addSource(new FlinkKafkaConsumer010("topic", newCustomDeserializer(), properties)) .assignTimestampsAndWaterm...
   Author: AndreaKinn , 2017-09-19, 15:38
JobManager shows TaskManager was lost/killed while TaskManger Process is still running and the network is OK. - Flink - [mail # user]
...Hi, sorry for re-vive this old conversation.I have exactly the same problem, can you provide more details about yoursolution?Have you used another garbage collector as G1? How can I set it?I...
   Author: AndreaKinn , 2017-09-15, 17:36