Re: Cassandra statebackend

2016-07-24 Thread Tai Gordon
Hi Chen, AFAIK, there currently isn’t any FLIP / JIRA / work currently for a Cassandra state backend. I think it’ll definitely by interesting to have one in Flink. Regards, Gordon On July 25, 2016 at 10:24:32 AM, Chen Qin (qinnc...@gmail.com) wrote: ​Hi there, Is there any design docs or on g

Supporting Multi-tenancy in a Flink

2016-07-24 Thread Aparup Banerjee (apbanerj)
We are building a Stream processing system using Apache beam on top of Flink using the Flink Runner. Our pipelines take Kafka streams as sources , and can write to multiple sinks. The system needs to be tenant aware. Tenants can share same Kafka topic. Tenants can write their own pipelines. We a

Cassandra statebackend

2016-07-24 Thread Chen Qin
​Hi there, Is there any design docs or on going efforts there? Thanks, Chen ​