Re: [Discuss] Proposing FLIP-25 - Support User State TTL Natively in Flink

Thank you, Fabian! I've created the FLIP-25 page . To continue our discussion points: 1. I see what you mean now. I totally agree. Since we don't completely know it now, shall we experiment or prototype

Re: [DISCUSS] Configuration for local recovery

+1 to the proposal. IMO, the current option "ENABLE_FILE_BASED" contains too much implementation details and might confuse the simple users. Having a simple on/off toggle for majority of the users and an advanced option for the experts to do the tuning will definitely make better user experience.

[DISCUSS] Adding new interfaces in [Stream]ExecutionEnvironment

Hi Flink devs, In an effort to support loading external libraries and creating UDFs from external libraries using DDL in Flink SQL, we want to use Flink’s Blob Server to distribute the external libraries in runtime and load those libraries into the user code classloader automatically. However, th

[jira] [Created] (FLINK-9351) RM stop assigning slot to Job because the TM killed before connecting to JM successfully

Sihua Zhou created FLINK-9351: - Summary: RM stop assigning slot to Job because the TM killed before connecting to JM successfully Key: FLINK-9351 URL: https://issues.apache.org/jira/browse/FLINK-9351 Proj

[jira] [Created] (FLINK-9350) Parameter baseInterval has wrong check message in CheckpointCoordinator constructor

vinoyang created FLINK-9350: --- Summary: Parameter baseInterval has wrong check message in CheckpointCoordinator constructor Key: FLINK-9350 URL: https://issues.apache.org/jira/browse/FLINK-9350 Project: Flin

Re: [DISCUSS] Configuration for local recovery

I agree with Stephan that a simple on/off configuration option for local recovery would be easier to understand and gives more flexibility wrt future changes. Cheers, Till On Sun, May 13, 2018 at 4:00 PM, sihua zhou wrote: > +1 for @Stephan's proposal, it makes the out of the box experience bet

Re: Elasticsearch Sink

Hi Gordon, Thanks for your feedback (and Flavio for your support!) About your remarks/questions: > - Maybe we can consider removing support for ES 1.x and 2.x starting from 1.6. Those are very old ES versions (considering that ES 6.x has already been out for a while). Do you think this would sim

Re: request for JIRA contributor permissions

Thanks! I have it now. Cheers, Yaz On Sun, May 13, 2018 at 12:39 PM Chesnay Schepler wrote: > I've given you contributor permissions. > > On 13.05.2018 18:25, Yaz Sh wrote: > > I would appreciate if someone grant me the JIRA contributor permissions > to be able to assign tickets to myself that

Re: request for JIRA contributor permissions

I've given you contributor permissions. On 13.05.2018 18:25, Yaz Sh wrote: I would appreciate if someone grant me the JIRA contributor permissions to be able to assign tickets to myself that I am working on them. FLINK-9348 FLINK-9343

request for JIRA contributor permissions

I would appreciate if someone grant me the JIRA contributor permissions to be able to assign tickets to myself that I am working on them. FLINK-9348 FLINK-9343 FLINK-9317

[jira] [Created] (FLINK-9349) KafkaConnector Exception while fetching from multiple kafka topics

Vishal Santoshi created FLINK-9349: -- Summary: KafkaConnector Exception while fetching from multiple kafka topics Key: FLINK-9349 URL: https://issues.apache.org/jira/browse/FLINK-9349 Project: Flink

Re: [Discuss] FLIP-26 - SSL Mutual Authentication

Throwing in some more food for thought: An alternative to the above proposed separation of internal and external SSL would be the following: - We separate channel encryption and authentication - We use one common SSL layer (internal and external) that is in both cases only responsible for est