Hi Folks,
I added a section about "Implementation Details" to the doc, it is still
very rough but I'm afraid this is somewhat tricky and might require some
changes to how we handle state.
As always, feedback is very welcome!
Cheers,
Aljoscha
On Mon, 2 May 2016 at 11:28 Aljoscha Krettek wrote:
Timo Walther created FLINK-3859:
---
Summary: Add BigDecimal/BigInteger support to Table API
Key: FLINK-3859
URL: https://issues.apache.org/jira/browse/FLINK-3859
Project: Flink
Issue Type: New Fe
Timo Walther created FLINK-3858:
---
Summary: Date is wrongly serialized
Key: FLINK-3858
URL: https://issues.apache.org/jira/browse/FLINK-3858
Project: Flink
Issue Type: Bug
Components:
Fabian Hueske created FLINK-3857:
Summary: Add reconnect attempt to Elasticsearch host
Key: FLINK-3857
URL: https://issues.apache.org/jira/browse/FLINK-3857
Project: Flink
Issue Type: Improve
The lazy split assignment design goes back to the very early days of Flink
and has not been changed since.
It was initially motivated by the pipelined data exchange of Flink which
was easier to realize with a fixed set of source tasks which request file
splits than with new tasks being spawned for
Hi,
I've put down some words about how we would go about adding support for
side inputs to the streaming API. People are increasingly asking for such a
feature, which would allow joining a main stream with some slowly changing
inputs that can be used for enriching data, among other things.
The des
Timo Walther created FLINK-3856:
---
Summary: Create types for java.sql.Date/Time/Timestamp
Key: FLINK-3856
URL: https://issues.apache.org/jira/browse/FLINK-3856
Project: Flink
Issue Type: New Fea
