Support for daylight saving timezone changes in Flink

I want to know the behavior of flink streaming systems during daylight saving changes in multiple timezones. As streaming systems may in such timezones. Is there any built-in support is needed ? Can anybody answer ? Thanks in advance --Swapnil

Re: Flink JDBCOutputFormat - Flush last batch enhancement

ts: >> >>- There is no "batching" in Flink's streaming API, not sure what you >> are >> referring to in with the "last batch" >>- JDBC connections are not closed between windows, they remain open as >> long as the operator is o

Flink JDBCOutputFormat - Flush last batch enhancement

Hi Team, Can we handle one case in connector JDBCOutputFormat to update last batch (might be batch count is less than batch interval) without closing jdbc connection? During use case of my streaming project, I am updating jdbc sink (mysql db) after every window. Case : Say I have 450 queries to

Re: [DISCUSS] Merge batch and stream connector modules

+1 It will be good to have one module flink-connectors (union of streaming and batch connectors). Regards, Swapnil On Thu, Sep 22, 2016 at 6:35 PM, Fabian Hueske wrote: > Hi everybody, > > right now, we have two separate Maven modules for batch and streaming > connectors

[jira] [Created] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

Swapnil Chougule created FLINK-4663: --- Summary: Flink JDBCOutputFormat logs wrong WARN message Key: FLINK-4663 URL: https://issues.apache.org/jira/browse/FLINK-4663 Project: Flink Issue