StackRating

An Elo-based rating system for Stack Overflow
Home   |   About   |   Stats and Analysis   |   Get a Badge
Rating Stats for

Dominik Wosiński

Rating
1522.86 (26,906th) 		Reputation
8 (2,188,802nd)
Page: 1 2 3 ... 4
Title Δ
Kafka offset is stuck in consumer group 0.00
Write multiple topics in Kafka by Flink dynamically Exception handl... 0.00
Best practice for Apache Flink for user defined alerts -1.89
Flink streaming parameters to tune? -1.91
How to handle FLINK window on stream data's timestamp base? 0.00
FLINK: Kafka Source - restart policy when a new topic is discovered... 0.00
Java - Flink sending empty object on kafka sink 0.00
Early firing in Flink - how to emit early window results to a diffe... -2.10
Collecting metrics for average time taken by flink flatmap function 0.00
[Apache Flink]: Where is flink-s3-fs-hadoop plugin? 0.00
Do I need to emit watermark even if I am not processing anything in... 0.00
How to simulate flink streaming job failure scenario -1.96
Flink checkpoints size are growing over 20GB and checkpoints time t... 0.00
Apache Flink load ML model from file 0.00
onTimer method, why timer state is null? 0.00
How to specify the time for which the state should be maintained in... 0.00
FLINK- Load historical data and maintain window of 30 days 0.00
flink doesn't output anything -2.00
Is it possible to read data directly from a database table for batc... 0.00
Synchronous response with Apache Flink 0.00
Apache Flink connect versus join 0.00
Unable to submit Job in Flink using post request via curl request (... -0.05
is SimpleStringSchema from the two path in jar the same? 0.00
Connecting a BroadcastConnectedStream to AsyncIO -0.01
Flink Filter Stream based on another Stream Deterministically -0.01
Does Apache Flink support using HTTP requests as input and output? -0.55
NullPointer Exception while trying to access or read ReadOnly ctx i... 0.00
Session windows flink -1.15
Is my algorithm's time complexity O(n log n)? -0.04
FlinkSQL:How to filter out wrong format JSON in SQL？ -2.03
Flink: assign watermark to FlinkKafkaConsumer 0.00
How to safely update jobs in-flight using Apache Flink on AWS EMR? 0.00
Find stream of events that are not grouped using coGroupFunction 0.00
Partition the whole dataStream in flink at the start of source and... 0.00
what's the meaning of dataport -1 in flink web UI 0.00
Flink Count of Events using metric 0.00
How to join a realtime stream and a delayed stream by event time -0.35
How to understand Window mechanism in Apache Flink 0.00
Why does JUnit not execute the whole method? -0.19
Check if all I'm receiving stream properly with all keys -0.04
While loop, for loop, flag and complexity 0.00
When is a Kafka connector preferred over a Spark streaming solution? +2.13
How to create a custom POJO for Apache Flink 0.00
What is the best method to add a list of objects to flink table in... 0.00
object FlinkKafkaConsumer010 is not a member of package org.apache.... -0.05
print flink KeyedStream 0.00
flink how to guarantee exactly once for kafka records despite retries -2.07
apache flink with Kafka: InvalidTypesException 0.00
Flink deserialize Kafka JSON +0.45
Does anyone have an example of a generic ProcessFunction in Flink? 0.00