Okay, it seems that we agree on the Shepherd name.
Also, it seems that everyone agrees to the proposed shepherds so far.
The "Client" component still needs a shepherd. Are there any volunteers?
On Fri, Jun 3, 2016 at 12:07 PM, Chiwan Park wrote:
> Hi all,
>
> +1 for shepherd
> I would like to
Sorry i think i misunderstand the issue. But it seams DataStream partition
the data by some field and when i select that field only one taskmanager
processing the data. I can achieve same result when i use filter.Below is
the code piece:
import org.apache.flink.api.java.io.TextInputFormat
import
Hello everyone,
When i use DataStream split/select,it always send all selected records to
same taskmanager. Is there any reason for this behaviour? Also is it
possible to implement same split/select behaviour for DataSet api(without
using a different filter for every output )? I found this
https:
Aljoscha Krettek created FLINK-4028:
---
Summary: AbstractAlignedProcessingTimeWindowOperator creates wrong
TimeWindow
Key: FLINK-4028
URL: https://issues.apache.org/jira/browse/FLINK-4028
Project: Fli
