Skip to content

Commit

Permalink
add shuffle test
Browse files Browse the repository at this point in the history
  • Loading branch information
924060929 committed Jun 24, 2024
1 parent 3ede386 commit 6c02e6e
Showing 1 changed file with 15 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
import java.util.stream.Collectors

// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
Expand Down Expand Up @@ -82,6 +84,12 @@ suite("shuffle_left_join") {
set disable_join_reorder=true;
"""

def variables = sql "show variables"
def variableString = variables.stream()
.map { it.toString() }
.collect(Collectors.joining("\n"))
logger.info("Variables:\n${variableString}")

extractFragment(sqlStr, "INNER JOIN(PARTITIONED)") { exchangeNum ->
assertTrue(exchangeNum == 1)
}
Expand All @@ -93,5 +101,12 @@ suite("shuffle_left_join") {
}
}

def rows = sql sqlStr
def rowsString = rows.stream()
.map { it.toString() }
.collect(Collectors.joining("\n"))
logger.info("Rows:\n${rowsString}")


order_qt_shuffle_left sqlStr
}

0 comments on commit 6c02e6e

Please sign in to comment.