- 29 2月, 2020 5 次提交
-
-
由 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 提交于
-
- 27 2月, 2020 10 次提交
-
-
由 wangyang0918 提交于
The warning log should show up when the JobManager/TaskManager memory is not a multiple of YARN minimum allocation memory. Because YARN will always normalize the resource request by insuring that the requested memory is a multiple of minimum allocation. The minimum allocation could be configured in YARN ResourceManager via 'yarn.scheduler.minimum-allocation-mb'. This closes #11176.
-
由 Zhijiang 提交于
The method SingleInputGate#getConsumedResultId is never used, so remove it to cleanup the codes.
-
由 Zhijiang 提交于
The ResultPartitionID in AddCredit message is never used on upstream side, so we can remove it to cleanup the codes. There would have another two benefits to do so: 1. Reduce the total message size from previous 52 bytes to 20 bytes. 2. Decouple the dependency with InputChannel#getPartitionId.
-
由 Hequn Cheng 提交于
-
由 ptmagic 提交于
The option was deprecated in 1.10 in favour of `taskmanager.memory.process.size`. This closes #10890.
-
由 Yangze Guo 提交于
-
由 Yangze Guo 提交于
-
由 huangxingbo 提交于
[FLINK-15972][python][table-planner][table-planner-blink] Add Python building blocks to make sure the basic functionality of Python TableFunction could work This close #11130.
-
由 huangxingbo 提交于
-
由 huangxingbo 提交于
-