QueryableState, unable to register KvStateRegistryListener

Hi, I was trying the QueryableState from the pull request https://github.com/apache/flink/pull/2051 I am doing the following: 1. Make the stream queryable by calling myKeyedStreamd.asQueryableState("my-state",myStateDescriptor) 2. Create a client that takes a job id, conf, query-name and key,

Re: [DISCUSS] Enhance Window Evictor in Flink

Hi, When we use RocksDB as state backend, how does the backend state get updated after some elements are evicted from the window? I don't see any update call being made to remove the element from the state stored in RocksDB. It looks like the RocksDBListState is only having get() and add()

Re: [DISCUSS] FLIP-3 - Organization of Documentation

I added to the "Application Development" Docs the Section "Types, TypeInformation, Serialization". I think that is an important enough aspect to warrant separate docs. On Mon, Jul 18, 2016 at 3:36 PM, Till Rohrmann wrote: > +1 for the FLIP and making streaming the common

[jira] [Created] (FLINK-4238) Only allow/require query for Tuple Stream in CassandraSink

Aljoscha Krettek created FLINK-4238: --- Summary: Only allow/require query for Tuple Stream in CassandraSink Key: FLINK-4238 URL: https://issues.apache.org/jira/browse/FLINK-4238 Project: Flink

Re: In AbstractRocksDBState, why write a byte 42 between key and namespace?

No, there is no issue for now. It's just not theoretically 100% safe but the way we use it for now is not problematic. On Wed, 20 Jul 2016 at 16:07 Maximilian Michels wrote: > Is there a JIRA issue for this? > > On Mon, Jul 18, 2016 at 12:15 PM, Aljoscha Krettek

Re: In AbstractRocksDBState, why write a byte 42 between key and namespace?

Is there a JIRA issue for this? On Mon, Jul 18, 2016 at 12:15 PM, Aljoscha Krettek wrote: > Ah I see, Stephan and I had a quick chat and it's for cases where there are > 42s around the edges of the key/namespace. > > On Mon, 18 Jul 2016 at 11:51 Aljoscha Krettek

Re: Flink Table & SQL doesn't work in very simple example

I will answer Radu's private e-mail here: Sorry to bother you ... I am still running in the same problem and I cannot figure out why. I have download and recompile the last branch of flink 1.1. I also tried using the jar snapshot from the website but I get the same error. What I am doing: I

[jira] [Created] (FLINK-4237) ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Timeout Futures

Kostas Kloudas created FLINK-4237: - Summary: ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Timeout Futures Key: FLINK-4237 URL: https://issues.apache.org/jira/browse/FLINK-4237

[jira] [Created] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up

Gary Yao created FLINK-4236: --- Summary: Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up Key: FLINK-4236 URL: https://issues.apache.org/jira/browse/FLINK-4236 Project:

Re: Flink Table & SQL doesn't work in very simple example

You can always find the latest nightly snapshot version here: http://flink.apache.org/contribute-code.html (at the end of the page) Am 20/07/16 um 14:08 schrieb Radu Tudoran: Hi, I am also using v1.1...with eclipse. i will re-download the source and build it again. Is there also a binary

Re: Flink Table & SQL doesn't work in very simple example

Hi, I am also using v1.1...with eclipse. i will re-download the source and build it again. Is there also a binary version for version 1.1 (i would like to test also againat that) particularly if the issue persists. otherwise i am downloading and building the version from the main git branch...

Re: Flink Table & SQL doesn't work in very simple example

I also tried it again with the latest 1.1-SNAPSHOT and everything works. This Maven issue has been solved in FLINK-4111. Am 20/07/16 um 13:43 schrieb Suneel Marthi: I am not seeing an issue with this code Radu, this is from present 1.1-Snapshot. This is what I have and it works (running

Re: Flink Table & SQL doesn't work in very simple example

I am not seeing an issue with this code Radu, this is from present 1.1-Snapshot. This is what I have and it works (running from within IntelliJ and not cli) : List> input = new ArrayList<>(); input.add(new Tuple3<>(3L,"test",1)); input.add(new

Re: [DISCUSS] FLIP-2 Extending Window Function Metadata

I think it looks like Beam rather than Hadoop :) What Stephan meant was that he wanted a dedicated output method in the ProcessWindowFunction. I agree with Aljoscha that we shouldn't expose the collector. On Tue, Jul 19, 2016 at 10:45 PM, Aljoscha Krettek wrote: > You mean