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/07/04 03:20:34 UTC
[flink] branch master updated (6a682ff -> 0e4d4b4)

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 6a682ff  [FLINK-12876][runtime] Adapt new RestartPipelinedRegionStrategy to legacy scheduling
     add 900f74d  [hotfix][table-planner-blink] Fix boolean hashCode codegen
     add f7b164f  [hotfix][table-planner-blink] Set shuffleMode to PartitionTransformation in BatchExecExchange
     add 960ae97  [FLINK-12959][table-planner-blink] Use BoundedInput and InputSelectable in blink
     add 0e4d4b4  [FLINK-12959][table-planner-blink] Implement BatchExecHashJoin translateToPlanInternal

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/table/codegen/CodeGenUtils.scala  |   1 +
 .../table/codegen/LongHashJoinGenerator.scala      |  17 ++-
 .../table/codegen/OperatorCodeGenerator.scala      |  48 ++++++---
 .../nodes/physical/batch/BatchExecExchange.scala   |  34 +++---
 .../nodes/physical/batch/BatchExecHashJoin.scala   | 119 +++++++++++++++++++--
 .../plan/nodes/physical/batch/BatchExecSort.scala  |   4 -
 .../physical/batch/BatchExecSortMergeJoin.scala    |  27 -----
 .../flink/table/runtime/batch/sql/MiscITCase.scala |   6 +-
 .../runtime/batch/sql/agg/GroupingSetsITCase.scala |   3 +-
 .../table/runtime/batch/sql/join/JoinITCase.scala  |  87 +++++++++------
 .../flink/table/runtime/utils/BatchTestBase.scala  |   1 +
 .../apache/flink/table/api/TableConfigOptions.java |   5 +
 .../flink/table/runtime/join/HashJoinOperator.java |  37 ++++---
 .../flink/table/runtime/join/HashJoinType.java     |  17 +++
 .../table/runtime/join/SortMergeJoinOperator.java  |  17 +--
 .../runtime/over/BufferDataOverWindowOperator.java |   5 +-
 .../table/runtime/sort/SortLimitOperator.java      |  10 +-
 .../flink/table/runtime/sort/SortOperator.java     |  11 +-
 .../table/runtime/sort/StreamSortOperator.java     |   6 +-
 .../runtime/join/Int2HashJoinOperatorTest.java     |  77 +++++++------
 .../join/Int2SortMergeJoinOperatorTest.java        |   6 +-
 .../runtime/join/String2HashJoinOperatorTest.java  |  59 ++++------
 .../table/runtime/sort/StreamSortOperatorTest.java |   2 +
 23 files changed, 366 insertions(+), 233 deletions(-)