clear query| facets| time Search criteria: .   Results from 1 to 10 from 244 (0.0s).
Loading phrases to help you
refine your search...
[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-04-18, 02:19
[FLINK-7687] Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts - Flink - [issue]
...It would be helpful if the documentation was clearer on the fact that the master/slaves config files are not needed when configured in high-availability mode unless you are using the provide...    Author: Elias Levy , 2019-04-15, 12:42
[expand - 1 more] - [Discuss] Semantics of event time for state TTL - Flink - [mail # user]
...Hasn't this been always the end goal?  It's certainly what we have beenwaiting on for job with very large TTLed state.  Beyond timer storage,timer processing to simply expire stale...
   Author: Elias Levy , 2019-04-08, 20:57
[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-04-03, 08:14
[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-03-27, 06:07
[expand - 1 more] - What should I take care if I enable object reuse - Flink - [mail # user]
...That's certainly the safe thing to do, but if you do not mutate the object,a copy is not strictly necessary.On Thu, Mar 14, 2019 at 9:19 PM Kurt Young  wrote:> Keep one thing in mind...
   Author: Elias Levy , 2019-03-15, 16:03
[FLINK-10493] Macro generated CaseClassSerializer considered harmful - Flink - [issue]
...The Flink Scala API uses implicits and macros to generate TypeInformation and TypeSerializer objects for types.  In the case of Scala tuple and case classes, the macro generates an anonymous...    Author: Elias Levy , 2019-03-15, 12:22
[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-03-11, 13:01
[DISCUSS] FLIP-33: Terminate/Suspend Job with Savepoint - Flink - [mail # dev]
...Apologies for the late reply.I think this is badly needed, but I fear we are adding complexity byintroducing yet two more stop commands.  We'll have: cancel, stop,terminate. and suspend...
   Author: Elias Levy , 2019-03-05, 23:27
[FLINK-11794] Allow compression of row format files created by StreamingFileSink - Flink - [issue]
...Currently, there is no mechanism to compress files created using a StreamingFileSink.  This is highly desirable when output is a text based row format such as JSON.Possible alternatives are ...    Author: Elias Levy , 2019-03-02, 07:28