Questions on flink

2016-09-24 Thread Govindarajan Srinivasaraghavan
Hi, I'm working on apache flink for data streaming and I have few questions. Any help is greatly appreciated. Thanks. 1) Are there any restrictions on creating tumbling windows. For example, if I want to create a tumbling window per user id for 2 secs and let’s say if I have more than 10 million

JDBC connection in Flink using Scala

2016-09-24 Thread ram kumar
Hi Team, I am wondering is that possible to add JDBC connection or url as a source or target in Flink using Scala. Could you kindly some one help on this? if you have sample code please share it here. *Thanks* *Ram*

[jira] [Created] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger()

2016-09-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4675: --- Summary: Remove Parameter from WindowAssigner.getDefaultTrigger() Key: FLINK-4675 URL: https://issues.apache.org/jira/browse/FLINK-4675 Project: Flink

[jira] [Created] (FLINK-4674) File Descriptors not being released after Completion of Flink Job Run via Flink Web Portal

2016-09-24 Thread Abey Sam Alex (JIRA)
Abey Sam Alex created FLINK-4674: Summary: File Descriptors not being released after Completion of Flink Job Run via Flink Web Portal Key: FLINK-4674 URL: https://issues.apache.org/jira/browse/FLINK-4674