g that, is there any more abstract streaming test
framework implemented in Flink ?
Thanks
Chenguang He
Chenguang He created FLINK-3802:
---
Summary: Add Very Fast Reservoir Sampling
Key: FLINK-3802
URL: https://issues.apache.org/jira/browse/FLINK-3802
Project: Flink
Issue Type: Improvement
Chenguang He created FLINK-3782:
---
Summary: ByteArrayOutputStream and ObjectOutputStream should close
Key: FLINK-3782
URL: https://issues.apache.org/jira/browse/FLINK-3782
Project: Flink
Issue
may throw exceptions. Throwing an
exception will cause the operation
* to fail and may trigger recovery.
*/
T reduce(T value1, T value2) throws Exception;
}
Thanks
Chenguang He
Graduate Student
Department of Computer Science
Iowa State University
On Ap
