This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 66d4d7d [FLINK-14845][runtime] Introduce data compression to reduce
disk and network IO of shuffle.
add d585346 [FLINK-15035][table-planner-blink] Use unknown managed memory
in blink planner
No new revisions were added by this update.
Summary of changes:
.../generated/execution_config_configuration.html | 8 +--
.../apache/flink/table/tpcds/TpcdsTestProgram.java | 6 ---
.../table/api/config/ExecutionConfigOptions.java | 20 ++++++--
.../plan/nodes/resource/NodeResourceUtil.java | 41 ---------------
.../flink/table/planner/utils/ExecutorUtils.java | 10 +---
.../planner/codegen/CorrelateCodeGenerator.scala | 12 ++---
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 1 -
.../codegen/agg/batch/HashAggCodeGenerator.scala | 4 +-
.../agg/batch/HashWindowCodeGenerator.scala | 6 +--
.../plan/nodes/common/CommonLookupJoin.scala | 4 +-
.../table/planner/plan/nodes/exec/ExecNode.scala | 58 ++++++++++++++++++++++
.../plan/nodes/physical/batch/BatchExecCalc.scala | 4 +-
.../nodes/physical/batch/BatchExecCorrelate.scala | 7 ++-
.../nodes/physical/batch/BatchExecExpand.scala | 3 +-
.../batch/BatchExecHashAggregateBase.scala | 19 +++----
.../nodes/physical/batch/BatchExecHashJoin.scala | 23 ++++-----
.../batch/BatchExecHashWindowAggregateBase.scala | 20 +++-----
.../plan/nodes/physical/batch/BatchExecLimit.scala | 6 +--
.../physical/batch/BatchExecNestedLoopJoin.scala | 19 +++----
.../physical/batch/BatchExecOverAggregate.scala | 21 ++++----
.../nodes/physical/batch/BatchExecPythonCalc.scala | 13 +++--
.../plan/nodes/physical/batch/BatchExecRank.scala | 6 +--
.../plan/nodes/physical/batch/BatchExecSink.scala | 11 ++--
.../plan/nodes/physical/batch/BatchExecSort.scala | 23 ++++-----
.../batch/BatchExecSortAggregateBase.scala | 3 +-
.../nodes/physical/batch/BatchExecSortLimit.scala | 6 +--
.../physical/batch/BatchExecSortMergeJoin.scala | 34 ++++++-------
.../batch/BatchExecSortWindowAggregateBase.scala | 3 +-
.../physical/batch/BatchExecTableSourceScan.scala | 3 +-
.../plan/nodes/physical/batch/BatchExecUnion.scala | 2 +-
.../nodes/physical/batch/BatchExecValues.scala | 2 +-
.../physical/stream/StreamExecCorrelate.scala | 4 +-
.../flink/table/planner/plan/utils/ScanUtil.scala | 6 +--
.../agg/batch/HashAggCodeGeneratorTest.scala | 2 +-
.../sql/agg/AggregateReduceGroupingITCase.scala | 4 +-
.../runtime/batch/sql/join/InnerJoinITCase.scala | 4 --
.../runtime/batch/sql/join/JoinITCase.scala | 2 -
.../planner/runtime/utils/BatchTestBase.scala | 4 --
.../operators/join/SortMergeJoinOperator.java | 12 +++--
.../runtime/util/ResettableExternalBuffer.java | 3 ++
.../join/Int2SortMergeJoinOperatorTest.java | 2 +-
.../join/String2SortMergeJoinOperatorTest.java | 2 +-
42 files changed, 206 insertions(+), 237 deletions(-)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/resource/NodeResourceUtil.java
