clear query| facets| time Search criteria: .   Results from 1 to 10 from 40 (0.0s).
Loading phrases to help you
refine your search...
Service discovery for flink-metrics-prometheus - Flink - [mail # user]
...Hi all,I also suffer from the lack of service discovery for flink-metrics-prometheus while using YARN for deployment, Prometheus for instrumentation, and Flink for stream processing.I just u...
   Author: Dongwon Kim , 2018-08-01, 09:44
Service discovery for Prometheus on YARN - Flink - [mail # user]
...Hi community,Prior to my presentation [1], I'd like to share a Python script [2] to discover Flink clusters on YARN and let Prometheus know via its file-based service discovery mechanism [3]...
   Author: Dongwon Kim , 2018-08-01, 09:10
Modify EventTimeTrigger only for event-time session windows - Flink - [mail # user]
...Hi all,I want to be sure about when EventTimeTrigger.onEventTime() method iscalled with event-time session windows.It returns TriggerResult.FIRE only when the timestamp of the registeredtime...
   Author: Dongwon Kim , 2018-07-23, 13:40
[expand - 5 more] - # of active session windows of a streaming job - Flink - [mail # user]
...Hi Fabian and Chesnay,Thank you guys.Fabian : Unfortunately, as Chesnay said, MetricGroup doesn't allow forProcessWindowFunction to access to a counter defined in Trigger.Chesnay : I'm going...
   Author: Dongwon Kim , 2018-06-21, 14:17
[expand - 1 more] - YARN per-job cluster reserves all of remaining memory in YARN - Flink - [mail # user]
...Hi Fabian and till,Below is what I've observed today.Hope it provides a strong evidence to figure out the problem.I attach another log file, jmlog2.txt, after observing the differentbehavior...
   Author: Dongwon Kim , 2018-05-07, 14:09
Wrong endpoints to cancel a job - Flink - [mail # user]
...Hi,1.5.0 needs to update its web page for rest APIs.I'm testing YARN dispatcher and had difficulty canceling jobs today.I've been sending DELETE requests to dispatcher according to https://c...
   Author: Dongwon Kim , 2018-04-25, 09:03
[expand - 1 more] - Run programs w/ params including comma via REST api - Flink - [mail # user]
...Hi Chesnay,I already modified our application to use semicolon as delimiter and now I can run a job using rest API via dispatcher.Nevertheless, though I understand the difficulty of modifyin...
   Author: Dongwon Kim , 2018-04-25, 09:03
[expand - 1 more] - rest.port is reset to 0 by YarnEntrypointUtils - Flink - [mail # user]
...Hi Gary,Thanks a lot for replay.Hope the issue is resolved soon.I have a suggestion regarding the rest port.Considering the role of dispatcher, it needs to have its own port range that is no...
   Author: Dongwon Kim , 2018-04-18, 10:13
[expand - 2 more] - Restore from a savepoint is very slow - Flink - [mail # user]
...It was due to too low parallelism.I increase parallelism large enough (actually set it to the total number of task slots on the cluster) and it makes restore from a savepoint much faster.Thi...
   Author: Dongwon Kim , 2018-04-04, 09:59
[expand - 2 more] - Kafka ProducerFencedException after checkpointing - Flink - [mail # user]
...Hi Piotr,Now my streaming pipeline is working without retries.I decreased Flink's checkpoint interval from 15min to 10min as yousuggested [see screenshot_10min_ckpt.png].I though that produc...
   Author: Dongwon Kim , 2018-03-21, 09:30