clear query| facets| time Search criteria: .   Results from 1 to 10 from 10 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-10342] Kafka duplicate topic consumption when topic name is changed - Flink - [issue]
...In case of topic name is simply renamed for a KafkaConsumer Flink starts to consume from old and a new topic in the same time which can lead to unexpected behavior.Here is the PR with reprod...
http://issues.apache.org/jira/browse/FLINK-10342    Author: Oleksandr Nitavskyi , 2018-09-18, 07:03
[expand - 1 more] - Weird behaviour after change sources in a job. - Flink - [mail # user]
...Great !So I have created a ticket: https://issues.apache.org/jira/browse/FLINK-10342 with a test which reproduces the issue: https://github.com/apache/flink/pull/6691/filesIf it seems reason...
   Author: Oleksandr Nitavskyi , 2018-09-13, 14:54
Custom metrics in Watermark Assigner - Flink - [mail # user]
...Hello guys,In our custom AssignerWithPunctuatedWatermarks we want to have custom metrics. Unfortunately operator’s wrapping this assigner interface is hidden from user API. What do you think...
   Author: Oleksandr Nitavskyi , 2018-09-12, 13:48
Table API, custom window - Flink - [mail # user]
...Hello guys,I am curious, is there a way to define custom window (assigners/trigger/evictor) for Table/Sql Flink API? Looks like documentation keep silence about this, but is there are plans ...
   Author: Oleksandr Nitavskyi , 2018-08-09, 12:15
[FLINK-9762] CoreOptions.TMP_DIRS wrongly managed on Yarn - Flink - [issue]
...The issue on Yarn is that it is impossible to have different LOCAL_DIRS on JobManager and TaskManager, despite LOCAL_DIRS value depends on the container.The issue is that CoreOptions.TMP_DIR...
http://issues.apache.org/jira/browse/FLINK-9762    Author: Oleksandr Nitavskyi , 2018-07-24, 16:34
CoreOptions.TMP_DIRS bug - Flink - [mail # user]
...Hello guys,We have discovered minor issue with Flink 1.5 on YARN particularly which was related with the way Flink manages temp paths (io.tmp.dirs) in configuration: https://ci.apache.org/pr...
   Author: Oleksandr Nitavskyi , 2018-07-04, 07:31
CoreOptions.TMP_DIRS bug - Flink - [mail # dev]
...Hello guys,We have discovered minor issue with Flink 1.5 on YARN particularly which was related with the way Flink manages temp paths (io.tmp.dirs) in configuration: https://ci.apache.org/pr...
   Author: Oleksandr Nitavskyi , 2018-07-02, 12:31
Output batch to Kafka - Flink - [mail # user]
...Hello Squirrels,Flink has a wonderful Kafka connector. We need to move data from HDFS to Kafka. Confluent is proposing to use Kafka-connect for this, but probably it can be easier to use Fli...
   Author: Oleksandr Nitavskyi , 2018-06-04, 22:39
Flink long-running streaming job, Keytab authentication - Flink - [mail # user]
...Hello all,I have a question about Kerberos authentication in Yarn environment for long running streaming job. According to the documentation ( https://ci.apache.org/projects/flink/flink-docs...
   Author: Oleksandr Nitavskyi , 2017-12-14, 16:17