Hi all,
I have a question regarding partitioning.
Does calling the withPartitioner() method on a coGroup operation has the same
effect as performing partitionCustom on both datasets beforehand?
i.e.
Is
1. a.coGroup(b).where(…).equalTo(…).withPartitioner(…).with(…)
equivalent to:
1. Da
Chesnay Schepler created FLINK-11047:
Summary: CoGroupGroupSortTranslationTest does not compile with
scala 2.12
Key: FLINK-11047
URL: https://issues.apache.org/jira/browse/FLINK-11047
Project: Fli
Thomas Weise created FLINK-11048:
Summary: Ability to programmatically execute streaming pipeline
with savepoint restore
Key: FLINK-11048
URL: https://issues.apache.org/jira/browse/FLINK-11048
Proje
Hi all,
This post proposes unified core API for Streaming and Batch.
Currently DataStream and DataSet adopt separated compilation processes,
execution tasks
and basic programming models in the runtime layer, which complicates the system
implementation.
We think that batch jobs can be processed
Jeff Zhang created FLINK-11049:
--
Summary: Unable to execute partial DAG
Key: FLINK-11049
URL: https://issues.apache.org/jira/browse/FLINK-11049
Project: Flink
Issue Type: Bug
Component
Liu created FLINK-11050:
---
Summary: When IntervalJoin, get left or right buffer's entries
more quickly by assigning lowerBound
Key: FLINK-11050
URL: https://issues.apache.org/jira/browse/FLINK-11050
Project: Fli
