Hi Fabian I am also looking for this solution, could you help me with two things:
1. How this is different from Queryable state. 2. How to query this key-value state from DS2 even if its running in the same application. e.g. val keyedStream = stream.keyby(_.key) val otherStream = somekafka.createStream The final goal is to have something like: otherStream.foreach(kafkamessage => keyedStream.lookup(kafkamessage.key)) ~Pushpendra Jaiswal -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Sharing-Java-Collections-within-Flink-Cluster-tp8919p8965.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
