Hi Anton,
executeOnCollection() is only meant for executing Flink Jobs in the local
machine without bringing up a local (or actual) Flink cluster. So solving
the problem there does not really solve the problem.
The underlying problem is this: in a Map-Reduce world the way to count
elements of type
Hi everybody,
Could you explain issue https://issues.apache.org/jira/browse/FLINK-4832,
please?
Simple, I chose another option for resolve this issue, unlike as described in
issue description
In the
`org.apache.flink.api.common.operators.base.MapOperatorBase#executeOnCollections`
I added next
Timo Walther created FLINK-4832:
---
Summary: Count/Sum 0 elements
Key: FLINK-4832
URL: https://issues.apache.org/jira/browse/FLINK-4832
Project: Flink
Issue Type: Improvement
Components
