- 21 2月, 2020 40 次提交
-
-
由 Chesnay Schepler 提交于
-
由 tison 提交于
This closes #11053 .
-
由 Aljoscha Krettek 提交于
The content of the concepts section was gathered from pre-existing documentation texts. This commit cleans that up a bit, removes outdated content that is not "conceptual" and updates some of the terms that we no longer use.
-
由 Aljoscha Krettek 提交于
This also adds explanation about the concepts section
-
由 Aljoscha Krettek 提交于
We move it to the development section and mention that it is a special type of state that is normally not needed in user programs.
-
由 Aljoscha Krettek 提交于
Ingestion time is a special "flavour" of event time and one that might not be too useful in practice because of inconsistencies that arise in case of failures/recovery. If users don't need event-time they can go straight to processing time.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
Also rename and reformat to get up-to-date with current naming.
-
由 Aljoscha Krettek 提交于
Also rename and reformat to get up-to-date with current naming.
-
由 Aljoscha Krettek 提交于
[FLINK-15999][doc] Move state backend and savepoint doc from runtime.md to stateful-stream-processing.md Also reformat/fix links and add TODOs.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
Also fix section formatting.
-
由 Aljoscha Krettek 提交于
This moves the conceptual parts from the development section to the concepts section. massages them to fit in well and fixes formatting and links.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
[FLINK-15999][doc] Move time and windows section from programming-model.md to timely-stream-processing.md
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
This fixes links and merges the text with the previously existing text. We also completely remove the section about actual snapshot implementations in operators.
-
由 Aljoscha Krettek 提交于
This is a straight copy without any adjustments. Follow-up commits will massage this and make sure it fits well within the concepts section.
-
由 Aljoscha Krettek 提交于
This also reorders/massages the text a bit to make it fit in better.
-
由 Aljoscha Krettek 提交于
This also reorders/massages the text a bit to make it fit in better.
-
由 Aljoscha Krettek 提交于
Users should not be using raw state, except in rare edge cases. We can just refer to managed keyed state ad keyed state and managed operator state as operator state from now on.
-
由 Aljoscha Krettek 提交于
[FLINK-15999][doc] Move batch-fault-tolerance from programming-model.md to stateful-stream-processing.md
-
由 Aljoscha Krettek 提交于
[FLINK-15999][doc] Move checkpointing introduction from programming-model.md to stateful-stream-processing.md
-
由 Aljoscha Krettek 提交于
[FLINK-15999][doc] Move state introduction from programming-model.md to stateful-stream-processing.md and clean up
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
[FLINK-15999][doc] Move explanation of DAGs/Dataflows from programming-model.md to stream-processing.md
-
由 Aljoscha Krettek 提交于
-
由 sunhaibotb 提交于
[hotfix][test] Clean up the codes in StreamTaskTestHarness, StreamTaskTimerTest and TestProcessingTimeServiceTest These cleanups include removing redundant initializer, unnecessary type parameter declarations and redundant suppression, and so on.
-
由 sunhaibotb 提交于
[FLINK-14231][task] Change StreamTask to close operators with StreamOperatorWrapper to make the endInput semantics on the chain strict
-
由 sunhaibotb 提交于
[FLINK-14231][task] Add StreamOperatorWrapper that handles the close, endInput and other related logic of an operator For each operator in the operator chain, its inputs must end completely before executing the "endInput()" method. For the operator chain in a task, such as "OP1 - > OP2 - > ...", after the (source/network) input of OP1 are finished, the operators on the chain are closed in the following order: 1. quiesce ProcessingTimeService of OP1 to prevent the pending timers from firing, but wait the timers in running to finish. 2. call OP1#close() 3. call OP2#endInput() 4. quiesce ProcessingTimeService of OP2 to prevent the pending timers from firing, but wait the timers in running to finish. 5. call OP2#close() ...
-
由 sunhaibotb 提交于
[FLINK-14231][runtime] Introduce and use ProcessingTimeServiceAware to pass ProcessingTimeService to operator
-
由 sunhaibotb 提交于
[FLINK-14231][task] Add the quiesce() method to ProcessingTimeService and remove TimerService::awaitPendingAfterQuiesce method
-
由 Rong Rong 提交于
-
由 Aljoscha Krettek 提交于
-
由 Rong Rong 提交于
-
由 Piotr Nowojski 提交于
-