Matthias J. Sax created FLINK-3406:
--
Summary: Extend RabbitMQ source with interface StoppableFunction
Key: FLINK-3406
URL: https://issues.apache.org/jira/browse/FLINK-3406
Project: Flink
Hi everybody,
I started to sketch the syntax of the streaming Table API.
-->
https://docs.google.com/document/d/19kSOAOINKCSWLBCKRq2WvNtmuaA9o3AyCh2ePqr3V5E/edit?usp=sharing
The draft is of course inspired by the current Table API but also from
Calcite's StreamingSQL draft [1].
In the the
Hi,
sorry about not answering but I wanted to wait since I already voiced my
opinion on the PR.
I think it is better to assume an already running redis because it is easier to
work around clashes in running redis instances (ports, data directory, and
such). Then, however, care needs to be
Anyone?
Otherwise, I will suggest to move forward with the PR using the
assumption that Redis must be started manually.
-Matthias
On 02/11/2016 08:28 PM, Matthias J. Sax wrote:
> Hi,
>
> In Flink it is possible to have different backends for operator state. I
> am wondering what the best
Aljoscha Krettek created FLINK-3400:
---
Summary: RocksDB Backend does not work when not in Flink lib folder
Key: FLINK-3400
URL: https://issues.apache.org/jira/browse/FLINK-3400
Project: Flink
