You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2019/12/05 11:39:19 UTC
[flink] branch master updated (0d72b2a -> d0fbd34)

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 0d72b2a  [FLINK-14573][python] Support TimestampType for Python UDF
     add d0fbd34  [FLINK-14063][table-planner-blink] Operators use fractions to decide how many managed memory to allocate

No new revisions were added by this update.

Summary of changes:
 .../planner/codegen/LongHashJoinGenerator.scala    |  5 +-
 .../codegen/NestedLoopJoinCodeGenerator.scala      | 13 ++---
 .../codegen/agg/batch/HashAggCodeGenHelper.scala   |  2 +-
 .../nodes/physical/batch/BatchExecHashJoin.scala   |  7 ---
 .../physical/batch/BatchExecNestedLoopJoin.scala   | 18 +++----
 .../physical/batch/BatchExecOverAggregate.scala    |  1 -
 .../plan/nodes/physical/batch/BatchExecSort.scala  | 10 ++--
 .../physical/batch/BatchExecSortMergeJoin.scala    | 11 ++--
 .../planner/codegen/LongHashJoinGeneratorTest.java |  2 +-
 .../codegen/agg/batch/BatchAggTestBase.scala       |  1 +
 .../runtime/hashtable/BaseHybridHashTable.java     | 63 ++++------------------
 .../table/runtime/hashtable/BinaryHashTable.java   | 33 ++----------
 .../runtime/hashtable/LongHybridHashTable.java     | 11 ++--
 .../runtime/operators/TableStreamOperator.java     |  7 +++
 .../runtime/operators/join/HashJoinOperator.java   | 31 ++++++-----
 .../operators/join/SortMergeJoinOperator.java      | 56 +++++++++----------
 .../over/BufferDataOverWindowOperator.java         |  6 +--
 .../table/runtime/operators/sort/SortOperator.java | 12 +++--
 .../table/runtime/hashtable/LongHashTableTest.java |  5 +-
 .../operators/join/Int2HashJoinOperatorTest.java   |  3 +-
 .../join/Int2SortMergeJoinOperatorTest.java        |  2 +-
 .../join/RandomSortMergeInnerJoinTest.java         |  1 +
 .../join/String2HashJoinOperatorTest.java          |  3 +-
 .../join/String2SortMergeJoinOperatorTest.java     |  3 +-
 .../over/BufferDataOverWindowOperatorTest.java     |  4 +-
 25 files changed, 111 insertions(+), 199 deletions(-)