Number of consumers per IntermediateResult

Hi, Can someone validate the following regarding the ExecutionGraph: Each IntermediateResult can only be consumed by a single ExecutionJobVertex, i.e. if two ExecutionJobVertex consume the same tuples (same “stream") that is produced by the same ExecutionJobVertex, then the producer will have t

[jira] [Created] (FLINK-7439) Support variable arguments for UDTF

Jark Wu created FLINK-7439: -- Summary: Support variable arguments for UDTF Key: FLINK-7439 URL: https://issues.apache.org/jira/browse/FLINK-7439 Project: Flink Issue Type: Improvement Rep

[jira] [Created] (FLINK-7440) Add eager serializable checks on provided de-/serialization schemas for Kinesis consumer / producer

Tzu-Li (Gordon) Tai created FLINK-7440: -- Summary: Add eager serializable checks on provided de-/serialization schemas for Kinesis consumer / producer Key: FLINK-7440 URL: https://issues.apache.org/jira/browse