- 29 2月, 2020 15 次提交
-
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
- introduce timestamp factory instead of relying on static method - introduce static package-private non-final flag for skipping api validation
-
由 Zhu Zhu 提交于
-
由 Zhu Zhu 提交于
Fixup! [FLINK-16276][tests] Introduce a builder and factory methods to create DefaultScheduler for testing
-
由 Zhu Zhu 提交于
-
由 Zhu Zhu 提交于
[hotfix][runtime] Remove slotProvider and slotRequestTimeout param from DefaultScheduler constructor This makes it easier to understand that the slot allocation is conducted via ExecutionSlotAllocatorFactory but not those two legacy params.
-
由 Zhu Zhu 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
- 28 2月, 2020 25 次提交
-
-
由 testfixer 提交于
-
由 Lining Jing 提交于
Fix incorrect Javadoc in MemoryManager#availableMemory(MemoryType)
-
由 Niels Basjes 提交于
This closes #11226.
-
由 Yangze Guo 提交于
-
由 Zhu Zhu 提交于
[FLINK-16180][runtime] Replace the nullable vertexExecution in ScheduledUnit with a non-null executionVertexId
-
由 Zhu Zhu 提交于
-
由 Zhu Zhu 提交于
-
由 dianfu 提交于
[FLINK-16271][python] Introduce ArrowPythonScalarFunctionOperator for vectorized Python UDF execution
-
由 Robert Metzger 提交于
This closes #11241
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
-
由 Piotr Nowojski 提交于
This doesn't fully support input selection, watermarks, latency markers and keyed contextes yet
-
由 Piotr Nowojski 提交于
This creates new hierarchy of task harnesses that could be used for other tasks as well.
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
This is going to be used for runtime support of MultipleInputStreamOperator
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
[FLINK-16060][checkpointing] Generalize LinkedBufferStorage to support arbitrary number of linked buffer storages
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
This interface is still not complete - it's missing for example watermark and latency markers support.
-
由 Jark Wu 提交于
-