clear query| facets| time Search criteria: .   Results from 1 to 10 from 177 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-9495] Implement ResourceManager for Kubernetes - Flink - [issue]
...I noticed there is no issue for developing a Kubernetes specific ResourceManager under FLIP-6, so I am creating this issue....    Author: Elias Levy , 2019-06-24, 09:39
Does Flink Kafka connector has max_pending_offsets concept? - Flink - [mail # user]
...There is no such concept in Flink.  Flink tracks offsets in itscheckpoints.  It can optionally commit offsets to Kafka, but that is onlyfor reporting purposes.  If you wish to...
   Author: Elias Levy , 2019-06-05, 18:02
[KAFKA-4212] Add a key-value store that is a TTL persistent cache - Kafka - [issue]
...Some jobs needs to maintain as state a large set of key-values for some period of time.  I.e. they need to maintain a TTL cache of values potentially larger than memory. Currently Kafka...    Author: Elias Levy , 2019-05-28, 23:41
[FLINK-10098] Programmatically select timer storage backend - Flink - [issue]
...FLINK-9486 introduced timer storage on the RocksDB storage backend.  Right now it is only possible to configure RocksDB as the storage for timers by settings the state.backend.rocksdb.timer-...    Author: Elias Levy , 2019-05-27, 16:57
Flink vs KStreams - Flink - [mail # user]
...My 2c:KStreams:Pros:* Streaming as a library:  No need to submit your job to a cluster.  Easyto scale up/down the job by adding or removing workers.* Streaming durability: State is...
   Author: Elias Levy , 2019-05-21, 17:10
[KAFKA-3932] Consumer fails to consume in a round robin fashion - Kafka - [issue]
...The Java consumer fails consume messages in a round robin fashion.  This can lead to an unbalance consumption.In our use case we have a set of consumer that can take a significant amoun...    Author: Elias Levy , 2019-05-21, 13:14
[FLINK-10520] Job save points REST API fails unless parameters are specified - Flink - [issue]
...The new REST API POST endpoint, /jobs/:jobid/savepoints, returns an error unless the request includes a body with all parameters (target-directory and cancel-job)), even thought the document...    Author: Elias Levy , 2019-05-14, 10:12
[FLINK-7286] Flink Dashboard fails to display bytes/records received by sources - Flink - [issue]
...It appears Flink can't measure the number of bytes read or records produced by a source (e.g. Kafka source). This is particularly problematic for simple jobs where the job pipeline is chaine...    Author: Elias Levy , 2019-04-30, 09:10
[expand - 1 more] - [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component - Flink - [mail # dev]
...On Fri, Apr 26, 2019 at 8:58 PM vino yang  wrote:> I agree with your opinion that "*Flink jobs don't sufficiently meet these> requirements to work as a replacement for a data stor...
   Author: Elias Levy , 2019-04-29, 17:06
[FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 - Flink - [issue]
...Update the Kafka client dependency to version 2.2.0....    Author: Elias Levy , 2019-04-26, 08:18