What's the meaning of "namespace" in KeyedStateBackend

2019-05-06 Thread Shi Quan
Hi, Few documentation mention “namespace” when talking about state. What’s the meaning of this properties and how to use it ? Best Quan Shi

IllegalArgumentException when using state with TTL enable and kryoSerializer as field Serializer

2019-05-05 Thread Shi Quan
Hi, Recently we encounter with IllegalArgumentException when using state with TTL enable and kryoSerializer as field Serializer. Test code description: 1. Use heap state backend 2. Create MapSateDescription by Class(String.class and HashMap.class) 3. Enable state TTL 4. Flink version:

RE: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component

2019-04-25 Thread Shi Quan
Hi, How about take states from RocksDB directly, in this case, TM host is unnecessary. Best Quan Shi From: vino yang Sent: Thursday, April 25, 2019 10:18:20 PM To: dev; user Cc: Stefan Richter; Aljoscha Krettek; kklou...@gmail.com Subject: [DISCUSS] Improve Qu

Apply for contributor permission

2019-04-24 Thread Shi Quan
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is quan Best regards