|
|
|
FLINK-20240
|
FLINK-19316
Add setter in the environment for the `execution.runtime-mode`
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-20153
|
FLINK-19316
Add documentation for BATCH execution mode
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-20001
|
FLINK-19316
Don't use setAllVerticesInSameSlotSharingGroupByDefault in StreamGraphGenerator
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19932
|
FLINK-19316
Add "sanity-check" integration test for BATCH execution on DataStream API
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19931
|
FLINK-19316
Do not emit intermediate results for reduce operation BATCH execution mode
|
Dawid Wysakowicz
|
Dawid Wysakowicz
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19837
|
FLINK-19316
Don't emit intermediate watermarks from watermark operators in BATCH execution mode
|
Nicholas Jiang
|
Aljoscha Krettek
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19835
|
FLINK-19316
Don't emit intermediate watermarks from sources in BATCH execution mode
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19815
|
FLINK-19316
Disable CoFeedbackTransformation for BATCH mode
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19814
|
FLINK-19316
Disable FeedbackTransformation for BATCH mode
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19732
|
FLINK-19316
Disable Checkpointing when in BATCH mode
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19583
|
FLINK-19316
Expose the execution.runtime-mode to the users
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19485
|
FLINK-19316
Decouple runtime operator implementation from DataStream operations
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19479
|
FLINK-19316
Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()
|
Nicholas Jiang
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19392
|
FLINK-19316
Detect the execution mode based on the sources in the job.
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19326
|
FLINK-19316
Allow explicitly configuring time behaviour on CEP PatternStream
|
Nicholas Jiang
|
Aljoscha Krettek
|
|
Closed |
Implemented
|
|
|
|
|
|
|
|
FLINK-19319
|
FLINK-19316
Deprecate StreamExecutionEnvironment.setStreamTimeCharacteristic() and TimeCharacteristic
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19318
|
FLINK-19316
Deprecate timeWindow() operations in DataStream API
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19317
|
FLINK-19316
Make EventTime the default StreamTimeCharacteristic
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|