StackRating

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

Mikalai Lushchytski

Rating
1505.85 (125,334th) 		Reputation
427 (310,148th)
Page: 1 2
Title Δ
StreamingFileSink forBulkFormat vs forRowFormat with avro encoder 0.00
Flink Savepoint Timeout 0.00
Any equivalent feature of Spark RDD.persist(..) in Flink? 0.00
Apache Flink Mapping at Runtime 0.00
How to increase number of taskmanagers in flink 1.9.0 or latest ver... 0.00
multiple FlinkKinesisProducer as sink for a datastream 0.00
PyFlink - JSON file sink? 0.00
Apache Flink - is it possible to evenly distribute slot sharing gro... +3.84
Are `stream.addSink(new PrintSinkFunction<>())` and `stream.p... 0.00
Flink How to use - FasterXML / jackson-dataformats-text - To conver... 0.00
Flink migration: BucketingSink[T] to StreamingFileSink[T] 0.00
Flink Checkpointing mode ExactlyOnce is not working as expected 0.00
Apache Flink - How to implement custom Deserializer implementing De... 0.00
In flink how to verify if same user data is not received in the giv... 0.00
Flink job with CassandrSink fails with Error writing -2.58
how to configure some external jars library to the flink docker con... 0.00
Is it possible to capture output of a flink datastream to a list 0.00
How to reduce or disable checkpoint logs in Flink 0.00
Is there a way to read a parquet file with apache flink? 0.00
How does LATEST position in stream works in Kinesis, KCL? 0.00
Can I use one lease table for multiple KCL applications? 0.00
Flink, could a slot have multiple threads or only one thread? 0.00
Flink - Insufficient number of Network buffers with high parallelism 0.00
SpringBoot Kafka: Bean method 'kafkaTemplate' in 'Kafka... -0.05
Which shard iterator type should I use, if I have to read messages... 0.00
What should you do to gracefully release all the resources when res... 0.00
Why every processing slots in Flink 1.4 use separate core? 0.00
Unable to import compiled java avro files into Scala codebase 0.00
Kafka Connection Problem with Docker Compose 0.00
How to recover a KeyedStream from different filters applied after b... +0.39
spring boot kafka generic JSON templateSender +4.09
Flink SerializationSchema: Could not serialize row error 0.00
How to use Cassandra sink with TestContainers in Flink +4.04
Flink workflow parallelism with custom source -0.13
Flink taskmanager stucks (100% cpu usage) after failing to make a c... -4.00
Upgrade Flink 1.10 to Flink 1.11 (Log4j on kubernetes deployment) 0.00
Use postgresql as flink sink, And the connection can't serializ... 0.00
Accessing Kafka broker in Docker container 0.00
KCL 2.x Enhanced Fan Out CloudWatch Metrics (MillisBehindLatest vs... 0.00
Kafka Avro Deserializer is not able to deserialize the Kafka messag... 0.00
Two instances consuming from topic -0.02
How to specify the number of cores for task manager/task slot in fl... 0.00
Is there a way to write data to parquet files if I don't know t... 0.00
How does parallelism work in Apache Flink? -3.63
How could flink pass environment variable to job or cluster? 0.00
Could Flink different task share same variable in the same task man... -0.06
Flink Not Emitting Value to Store in Cassandra 0.00
Flink Collector Issue While ReadValue from FasterXML 0.00
My FlinkKafkaProducer011 needs fewer arguments than is supposed to 0.00
Kinesis 2.2.11 java unable to create consumer 0.00