clear query| facets| time Search criteria: .   Results from 1 to 10 from 2954 (0.0s).
Loading phrases to help you
refine your search...
[Discuss] Add JobListener (hook) in flink job lifecycle - Flink - [mail # user]
...Thanks for starting this discussion Jeff. I can see the need for additionalhooks for third party integrations.The thing I'm wondering is whether we really need/want to expose aJobListener vi...
   Author: Till Rohrmann , 2019-04-18, 12:57
[FLINK-9635] Local recovery scheduling can cause spread out of tasks - Flink - [issue]
...In order to make local recovery work, Flink's scheduling was changed such that it tries to be rescheduled to its previous location. In order to not occupy slots which have state of other tas...    Author: Till Rohrmann , 2019-04-18, 12:40
Service discovery on YARN - find out which port was dynamically assigned to the JobManager Web Interface - Flink - [mail # user]
...Hi Olivier,since version 1.8 you can set the rest bind port via `rest.bind-port` to asingle port or a range. This will now be respected by Yarn deployments.With the next bug fix release of 1...
   Author: Till Rohrmann , 2019-04-18, 11:34
[FLINK-12070] Make blocking result partitions consumable multiple times - Flink - [issue]
...In order to avoid writing produced results multiple times for multiple consumers and in order to speed up batch recoveries, we should make the blocking result partitions to be consumable mul...    Author: Till Rohrmann , 2019-04-18, 10:19
[expand - 1 more] - [DISCUSS] Adaptive Parallelism of Job Vertex - Flink - [mail # dev]
...I think this would be a good way to go. Please monitor FLINK-10429 [1] tosee when the Scheduler interface is put into place. The sub tasks to addthe interfaces should be added very soon.[1] ...
   Author: Till Rohrmann , 2019-04-17, 13:17
[expand - 3 more] - Scalaj vs akka as http client for Asyncio Flink - Flink - [mail # user]
...Check the logs what Akka is logging and verify that the port you try tobind to is free.Cheers,TillOn Wed, Apr 17, 2019 at 12:50 PM Andy Hoang  wrote:> Hi Till,>> Sorry to bothe...
   Author: Till Rohrmann , 2019-04-17, 11:27
[FLINK-12068] Backtrack fail over regions if intermediate results are unavailable - Flink - [issue]
...The batch failover strategy needs to be able to backtrack fail over regions if an intermediate result is unavailable. Either by explicitly checking whether the intermediate result partition ...    Author: Till Rohrmann , 2019-04-17, 06:17
[FLINK-10106] Include test name in temp directory of e2e test - Flink - [issue]
...For better debuggability it would help to include the name of the e2e test in the created temporary testing directory temp-test-directory-<TEST_NAME>-UUID....    Author: Till Rohrmann , 2019-04-16, 14:31
[FLINK-11813] Standby per job mode Dispatchers don't know job's JobSchedulingStatus - Flink - [issue]
...At the moment, it can happen that standby Dispatchers in per job mode will restart a terminated job after they gained leadership. The problem is that we currently clear the RunningJobsRegist...    Author: Till Rohrmann , 2019-04-16, 03:15
[FLINK-10333] Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints) - Flink - [issue]
...While going over the ZooKeeper based stores (ZooKeeperSubmittedJobGraphStore, ZooKeeperMesosWorkerStore, ZooKeeperCompletedCheckpointStore) and the underlying ZooKeeperStateHandleStore I not...    Author: Till Rohrmann , 2019-04-15, 14:58