See 
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Spark/187/display/redirect?page=changes>

Changes:

[yifanzou] [BEAM-4963] update org.apache.httpcomponents

[yifanzou] [BEAM-4906] upgrade org.apache.derby

[apilloud] [BEAM-4761] Run Nexmark in thread pool

[aaltay] Automate "Run validation tests" step (#6081)

------------------------------------------
[...truncated 670.54 KB...]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#411 via BeamEnumerableConverterRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2007 generated 1 successors: [BeamEnumerableConverter#411]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 8/6; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [JoinPushExpressionsRule] rels 
[rel#410:BeamJoinRel.BEAM_LOGICAL.[](left=rel#408:Subset#3.BEAM_LOGICAL.[],right=rel#409:Subset#6.BEAM_LOGICAL.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2010: Apply rule [JoinPushExpressionsRule] to 
[rel#410:BeamJoinRel.BEAM_LOGICAL.[](left=rel#408:Subset#3.BEAM_LOGICAL.[],right=rel#409:Subset#6.BEAM_LOGICAL.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2010 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 9/7; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [FilterJoinRule:FilterJoinRule:no-filter] rels 
[rel#410:BeamJoinRel.BEAM_LOGICAL.[](left=rel#408:Subset#3.BEAM_LOGICAL.[],right=rel#409:Subset#6.BEAM_LOGICAL.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2000: Apply rule [FilterJoinRule:FilterJoinRule:no-filter] to 
[rel#410:BeamJoinRel.BEAM_LOGICAL.[](left=rel#408:Subset#3.BEAM_LOGICAL.[],right=rel#409:Subset#6.BEAM_LOGICAL.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2000 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 10/8; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [JoinPushExpressionsRule] rels 
[rel#396:LogicalJoin.NONE.[](left=rel#389:Subset#3.NONE.[],right=rel#395:Subset#6.NONE.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1924: Apply rule [JoinPushExpressionsRule] to 
[rel#396:LogicalJoin.NONE.[](left=rel#389:Subset#3.NONE.[],right=rel#395:Subset#6.NONE.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1924 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 11/9; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [FilterJoinRule:FilterJoinRule:no-filter] rels 
[rel#396:LogicalJoin.NONE.[](left=rel#389:Subset#3.NONE.[],right=rel#395:Subset#6.NONE.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1913: Apply rule [FilterJoinRule:FilterJoinRule:no-filter] to 
[rel#396:LogicalJoin.NONE.[](left=rel#389:Subset#3.NONE.[],right=rel#395:Subset#6.NONE.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1913 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 12/10; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [ProjectToCalcRule] rels 
[rel#394:LogicalProject.NONE.[](input=rel#393:Subset#5.NONE.[],maxprice=$1,starttime=$0)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1902: Apply rule [ProjectToCalcRule] to 
[rel#394:LogicalProject.NONE.[](input=rel#393:Subset#5.NONE.[],maxprice=$1,starttime=$0)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#416 via ProjectToCalcRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1902 generated 1 successors: 
[rel#416:LogicalCalc.NONE.[[]](input=rel#393:Subset#5.NONE.[],expr#0..1={inputs},maxprice=$t1,starttime=$t0)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 13/11; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamCalcRule] rels 
[rel#416:LogicalCalc.NONE.[[]](input=rel#393:Subset#5.NONE.[],expr#0..1={inputs},maxprice=$t1,starttime=$t0)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2036: Apply rule [BeamCalcRule] to 
[rel#416:LogicalCalc.NONE.[[]](input=rel#393:Subset#5.NONE.[],expr#0..1={inputs},maxprice=$t1,starttime=$t0)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#418 via BeamCalcRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2036 generated 1 successors: 
[rel#418:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#417:Subset#5.BEAM_LOGICAL.[],expr#0..1={inputs},maxprice=$t1,starttime=$t0)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 14/12; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamEnumerableConverterRule] rels 
[rel#418:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#417:Subset#5.BEAM_LOGICAL.[],expr#0..1={inputs},maxprice=$t1,starttime=$t0)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2042: Apply rule [BeamEnumerableConverterRule] to 
[rel#418:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#417:Subset#5.BEAM_LOGICAL.[],expr#0..1={inputs},maxprice=$t1,starttime=$t0)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#419 via BeamEnumerableConverterRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2042 generated 1 successors: [BeamEnumerableConverter#419]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 15/13; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [ProjectToCalcRule] rels 
[rel#388:LogicalProject.NONE.[](input=rel#387:Subset#2.NONE.[],auction=$0,price=$1,bidder=$2,dateTime=$3,extra=$4,starttime=$5)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1830: Apply rule [ProjectToCalcRule] to 
[rel#388:LogicalProject.NONE.[](input=rel#387:Subset#2.NONE.[],auction=$0,price=$1,bidder=$2,dateTime=$3,extra=$4,starttime=$5)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#422 via ProjectToCalcRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1830 generated 1 successors: 
[rel#422:LogicalCalc.NONE.[[]](input=rel#387:Subset#2.NONE.[],expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 16/14; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamCalcRule] rels 
[rel#422:LogicalCalc.NONE.[[]](input=rel#387:Subset#2.NONE.[],expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2070: Apply rule [BeamCalcRule] to 
[rel#422:LogicalCalc.NONE.[[]](input=rel#387:Subset#2.NONE.[],expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#424 via BeamCalcRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2070 generated 1 successors: 
[rel#424:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#423:Subset#2.BEAM_LOGICAL.[],expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 17/15; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamEnumerableConverterRule] rels 
[rel#424:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#423:Subset#2.BEAM_LOGICAL.[],expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2076: Apply rule [BeamEnumerableConverterRule] to 
[rel#424:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#423:Subset#2.BEAM_LOGICAL.[],expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#425 via BeamEnumerableConverterRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2076 generated 1 successors: [BeamEnumerableConverter#425]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 18/16; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamAggregationRule] rels 
[rel#392:LogicalAggregate.NONE.[](input=rel#391:Subset#4.NONE.[],group={0},maxprice=MAX($1)),
 
rel#390:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],$f0=TUMBLE($3,
 10000),price=$2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1879: Apply rule [BeamAggregationRule] to 
[rel#392:LogicalAggregate.NONE.[](input=rel#391:Subset#4.NONE.[],group={0},maxprice=MAX($1)),
 
rel#390:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],$f0=TUMBLE($3,
 10000),price=$2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#429 via BeamAggregationRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1879 generated 1 successors: 
[rel#429:BeamAggregationRel.BEAM_LOGICAL.[](input=rel#428:Subset#4.BEAM_LOGICAL.[],group={0},maxprice=MAX($1))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 19/17; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamEnumerableConverterRule] rels 
[rel#429:BeamAggregationRel.BEAM_LOGICAL.[](input=rel#428:Subset#4.BEAM_LOGICAL.[],group={0},maxprice=MAX($1))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2099: Apply rule [BeamEnumerableConverterRule] to 
[rel#429:BeamAggregationRel.BEAM_LOGICAL.[](input=rel#428:Subset#4.BEAM_LOGICAL.[],group={0},maxprice=MAX($1))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#430 via BeamEnumerableConverterRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2099 generated 1 successors: [BeamEnumerableConverter#430]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 20/18; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamAggregationRule] rels 
[rel#386:LogicalAggregate.NONE.[](input=rel#385:Subset#1.NONE.[],group={0, 1, 
2, 3, 4, 5}), 
rel#384:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
 10000))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1807: Apply rule [BeamAggregationRule] to 
[rel#386:LogicalAggregate.NONE.[](input=rel#385:Subset#1.NONE.[],group={0, 1, 
2, 3, 4, 5}), 
rel#384:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
 10000))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#434 via BeamAggregationRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1807 generated 1 successors: 
[rel#434:BeamAggregationRel.BEAM_LOGICAL.[](input=rel#433:Subset#1.BEAM_LOGICAL.[],group={0,
 1, 2, 3, 4, 5})]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 21/19; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamEnumerableConverterRule] rels 
[rel#434:BeamAggregationRel.BEAM_LOGICAL.[](input=rel#433:Subset#1.BEAM_LOGICAL.[],group={0,
 1, 2, 3, 4, 5})]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2123: Apply rule [BeamEnumerableConverterRule] to 
[rel#434:BeamAggregationRel.BEAM_LOGICAL.[](input=rel#433:Subset#1.BEAM_LOGICAL.[],group={0,
 1, 2, 3, 4, 5})]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#435 via BeamEnumerableConverterRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2123 generated 1 successors: [BeamEnumerableConverter#435]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 22/20; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [AggregateRemoveRule] rels 
[rel#392:LogicalAggregate.NONE.[](input=rel#391:Subset#4.NONE.[],group={0},maxprice=MAX($1)),
 
rel#390:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],$f0=TUMBLE($3,
 10000),price=$2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1865: Apply rule [AggregateRemoveRule] to 
[rel#392:LogicalAggregate.NONE.[](input=rel#391:Subset#4.NONE.[],group={0},maxprice=MAX($1)),
 
rel#390:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],$f0=TUMBLE($3,
 10000),price=$2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1865 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 23/21; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [AggregateRemoveRule] rels 
[rel#386:LogicalAggregate.NONE.[](input=rel#385:Subset#1.NONE.[],group={0, 1, 
2, 3, 4, 5}), 
rel#384:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
 10000))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1793: Apply rule [AggregateRemoveRule] to 
[rel#386:LogicalAggregate.NONE.[](input=rel#385:Subset#1.NONE.[],group={0, 1, 
2, 3, 4, 5}), 
rel#384:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
 10000))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1793 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 24/22; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [AggregateProjectMergeRule] rels 
[rel#392:LogicalAggregate.NONE.[](input=rel#391:Subset#4.NONE.[],group={0},maxprice=MAX($1)),
 
rel#390:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],$f0=TUMBLE($3,
 10000),price=$2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1873: Apply rule [AggregateProjectMergeRule] to 
[rel#392:LogicalAggregate.NONE.[](input=rel#391:Subset#4.NONE.[],group={0},maxprice=MAX($1)),
 
rel#390:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],$f0=TUMBLE($3,
 10000),price=$2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1873 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 25/23; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [AggregateProjectMergeRule] rels 
[rel#386:LogicalAggregate.NONE.[](input=rel#385:Subset#1.NONE.[],group={0, 1, 
2, 3, 4, 5}), 
rel#384:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
 10000))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1801: Apply rule [AggregateProjectMergeRule] to 
[rel#386:LogicalAggregate.NONE.[](input=rel#385:Subset#1.NONE.[],group={0, 1, 
2, 3, 4, 5}), 
rel#384:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
 10000))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1801 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 26/24; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [ProjectToCalcRule] rels 
[rel#390:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],$f0=TUMBLE($3,
 10000),price=$2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1855: Apply rule [ProjectToCalcRule] to 
[rel#390:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],$f0=TUMBLE($3,
 10000),price=$2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#438 via ProjectToCalcRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1855 generated 1 successors: 
[rel#438:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 27/25; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [AggregateRemoveRule] rels 
[rel#392:LogicalAggregate.NONE.[](input=rel#391:Subset#4.NONE.[],group={0},maxprice=MAX($1)),
 
rel#438:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2142: Apply rule [AggregateRemoveRule] to 
[rel#392:LogicalAggregate.NONE.[](input=rel#391:Subset#4.NONE.[],group={0},maxprice=MAX($1)),
 
rel#438:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2142 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 28/26; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamCalcRule] rels 
[rel#438:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2153: Apply rule [BeamCalcRule] to 
[rel#438:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#439 via BeamCalcRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2153 generated 1 successors: 
[rel#439:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 29/27; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [ProjectToCalcRule] rels 
[rel#384:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
 10000))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1783: Apply rule [ProjectToCalcRule] to 
[rel#384:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
 10000))]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#440 via ProjectToCalcRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1783 generated 1 successors: 
[rel#440:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 30/28; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [AggregateRemoveRule] rels 
[rel#386:LogicalAggregate.NONE.[](input=rel#385:Subset#1.NONE.[],group={0, 1, 
2, 3, 4, 5}), 
rel#440:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2165: Apply rule [AggregateRemoveRule] to 
[rel#386:LogicalAggregate.NONE.[](input=rel#385:Subset#1.NONE.[],group={0, 1, 
2, 3, 4, 5}), 
rel#440:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2165 generated 0 successors.
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 31/29; PHASE = OPTIMIZE; COST = {inf}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamCalcRule] rels 
[rel#440:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2176: Apply rule [BeamCalcRule] to 
[rel#440:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#441 via BeamCalcRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2176 generated 1 successors: 
[rel#441:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 32/30; PHASE = OPTIMIZE; COST = {445.75 rows, 2591.25 cpu, 0.0 io}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamEnumerableConverterRule] rels 
[rel#441:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2182: Apply rule [BeamEnumerableConverterRule] to 
[rel#441:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#442 via BeamEnumerableConverterRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2182 generated 1 successors: [BeamEnumerableConverter#442]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 33/31; PHASE = OPTIMIZE; COST = {445.75 rows, 2591.25 cpu, 0.0 io}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamEnumerableConverterRule] rels 
[rel#439:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2159: Apply rule [BeamEnumerableConverterRule] to 
[rel#439:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#445 via BeamEnumerableConverterRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#2159 generated 1 successors: [BeamEnumerableConverter#445]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 34/32; PHASE = OPTIMIZE; COST = {445.75 rows, 2591.25 cpu, 0.0 io}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamEnumerableConverterRule] rels 
[rel#383:Subset#0.BEAM_LOGICAL.[]]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1761: Apply rule [BeamEnumerableConverterRule] to 
[rel#383:Subset#0.BEAM_LOGICAL.[]]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#448 via BeamEnumerableConverterRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1761 generated 1 successors: 
[rel#448:BeamEnumerableConverter.ENUMERABLE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[])]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 35/33; PHASE = OPTIMIZE; COST = {445.75 rows, 2591.25 cpu, 0.0 io}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Pop match: rule [BeamEnumerableConverterRule] rels 
[rel#373:BeamIOSourceRel.BEAM_LOGICAL.[](table=[beam, Bid])]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1756: Apply rule [BeamEnumerableConverterRule] to 
[rel#373:BeamIOSourceRel.BEAM_LOGICAL.[](table=[beam, Bid])]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Transform to: rel#450 via BeamEnumerableConverterRule
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 call#1756 generated 1 successors: [BeamEnumerableConverter#450]
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 36/34; PHASE = OPTIMIZE; COST = {445.75 rows, 2591.25 cpu, 0.0 io}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 PLANNER = 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.volcano.VolcanoPlanner@85aabb4;
 TICK = 37/1; PHASE = CLEANUP; COST = {445.75 rows, 2591.25 cpu, 0.0 io}
18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Cheapest plan:
BeamCalcRel(expr#0..7=[{inputs}], proj#0..4=[{exprs}]): rowcount = 2.25, 
cumulative cost = {445.75 rows, 2591.25 cpu, 0.0 io}, id = 459
  BeamJoinRel(condition=[AND(=($5, $7), =($1, $6))], joinType=[inner]): 
rowcount = 2.25, cumulative cost = {443.5 rows, 2562.0 cpu, 0.0 io}, id = 458
    BeamCalcRel(expr#0..5=[{inputs}], proj#0..5=[{exprs}]): rowcount = 10.0, 
cumulative cost = {220.0 rows, 1521.0 cpu, 0.0 io}, id = 454
      BeamAggregationRel(group=[{0, 1, 2, 3, 4, 5}]): rowcount = 10.0, 
cumulative cost = {210.0 rows, 1401.0 cpu, 0.0 io}, id = 453
        BeamCalcRel(expr#0..4=[{inputs}], expr#5=[10000], expr#6=[TUMBLE($t3, 
$t5)], auction=[$t0], price=[$t2], bidder=[$t1], dateTime=[$t3], extra=[$t4], 
$f5=[$t6]): rowcount = 100.0, cumulative cost = {200.0 rows, 1401.0 cpu, 0.0 
io}, id = 452
          BeamIOSourceRel(table=[[beam, Bid]]): rowcount = 100.0, cumulative 
cost = {100.0 rows, 101.0 cpu, 0.0 io}, id = 373
    BeamCalcRel(expr#0..1=[{inputs}], maxprice=[$t1], starttime=[$t0]): 
rowcount = 10.0, cumulative cost = {221.25 rows, 1041.0 cpu, 0.0 io}, id = 457
      BeamAggregationRel(group=[{0}], maxprice=[MAX($1)]): rowcount = 10.0, 
cumulative cost = {211.25 rows, 1001.0 cpu, 0.0 io}, id = 456
        BeamCalcRel(expr#0..4=[{inputs}], expr#5=[10000], expr#6=[TUMBLE($t3, 
$t5)], $f0=[$t6], price=[$t2]): rowcount = 100.0, cumulative cost = {200.0 
rows, 1001.0 cpu, 0.0 io}, id = 455
          BeamIOSourceRel(table=[[beam, Bid]]): rowcount = 100.0, cumulative 
cost = {100.0 rows, 101.0 cpu, 0.0 io}, id = 373

18/08/03 23:26:27 DEBUG 
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
 Provenance:
BeamCalcRel#459
  direct
    
rel#404:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#403:Subset#7.BEAM_LOGICAL.[],expr#0..7={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4)
      call#1975 rule [BeamCalcRule]
        
rel#402:LogicalCalc.NONE.[[]](input=rel#397:Subset#7.NONE.[],expr#0..7={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4)
          call#1949 rule [ProjectToCalcRule]
            
rel#398:LogicalProject.NONE.[](input=rel#397:Subset#7.NONE.[],auction=$0,price=$1,bidder=$2,dateTime=$3,extra=$4)
              no parent
BeamJoinRel#458
  direct
    
rel#410:BeamJoinRel.BEAM_LOGICAL.[](left=rel#408:Subset#3.BEAM_LOGICAL.[],right=rel#409:Subset#6.BEAM_LOGICAL.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)
      call#1919 rule [BeamJoinRule]
        
rel#396:LogicalJoin.NONE.[](left=rel#389:Subset#3.NONE.[],right=rel#395:Subset#6.NONE.[],condition=AND(=($5,
 $7), =($1, $6)),joinType=inner)
          no parent
BeamCalcRel#454
  direct
    
rel#424:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#423:Subset#2.BEAM_LOGICAL.[],expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)
      call#2070 rule [BeamCalcRule]
        
rel#422:LogicalCalc.NONE.[[]](input=rel#387:Subset#2.NONE.[],expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)
          call#1830 rule [ProjectToCalcRule]
            
rel#388:LogicalProject.NONE.[](input=rel#387:Subset#2.NONE.[],auction=$0,price=$1,bidder=$2,dateTime=$3,extra=$4,starttime=$5)
              no parent
BeamAggregationRel#453
  direct
    
rel#434:BeamAggregationRel.BEAM_LOGICAL.[](input=rel#433:Subset#1.BEAM_LOGICAL.[],group={0,
 1, 2, 3, 4, 5})
      call#1807 rule [BeamAggregationRule]
        
rel#386:LogicalAggregate.NONE.[](input=rel#385:Subset#1.NONE.[],group={0, 1, 2, 
3, 4, 5})
          no parent
        
rel#384:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
 10000))
          no parent
BeamCalcRel#452
  direct
    
rel#441:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)
      call#2176 rule [BeamCalcRule]
        
rel#440:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t6)
          call#1783 rule [ProjectToCalcRule]
            rel#384 (see above)
rel#373:BeamIOSourceRel.BEAM_LOGICAL.[](table=[beam, Bid])
  no parent
BeamCalcRel#457
  direct
    
rel#418:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#417:Subset#5.BEAM_LOGICAL.[],expr#0..1={inputs},maxprice=$t1,starttime=$t0)
      call#2036 rule [BeamCalcRule]
        
rel#416:LogicalCalc.NONE.[[]](input=rel#393:Subset#5.NONE.[],expr#0..1={inputs},maxprice=$t1,starttime=$t0)
          call#1902 rule [ProjectToCalcRule]
            
rel#394:LogicalProject.NONE.[](input=rel#393:Subset#5.NONE.[],maxprice=$1,starttime=$0)
              no parent
BeamAggregationRel#456
  direct
    
rel#429:BeamAggregationRel.BEAM_LOGICAL.[](input=rel#428:Subset#4.BEAM_LOGICAL.[],group={0},maxprice=MAX($1))
      call#1879 rule [BeamAggregationRule]
        
rel#392:LogicalAggregate.NONE.[](input=rel#391:Subset#4.NONE.[],group={0},maxprice=MAX($1))
          no parent
        
rel#390:LogicalProject.NONE.[](input=rel#383:Subset#0.BEAM_LOGICAL.[],$f0=TUMBLE($3,
 10000),price=$2)
          no parent
BeamCalcRel#455
  direct
    
rel#439:BeamCalcRel.BEAM_LOGICAL.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)
      call#2153 rule [BeamCalcRule]
        
rel#438:LogicalCalc.NONE.[[]](input=rel#383:Subset#0.BEAM_LOGICAL.[],expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
 $t5),$f0=$t6,price=$t2)
          call#1855 rule [ProjectToCalcRule]
            rel#390 (see above)
rel#373 (see above)

2018-08-03T23:26:42.583Z Waiting for main pipeline to 'finish'
2018-08-03T23:26:42.583Z DONE SqlQuery7
2018-08-03T23:26:42.586Z Running query:8; exportSummaryToBigQuery:true; 
streamTimeout:60
2018-08-03T23:26:42.586Z skipping since configuration is not implemented
2018-08-03T23:26:42.586Z Running query:9; exportSummaryToBigQuery:true; 
numEvents:10000; streamTimeout:60
2018-08-03T23:26:42.586Z skipping since configuration is not implemented
2018-08-03T23:26:42.586Z Running query:10; exportSummaryToBigQuery:true; 
streamTimeout:60
2018-08-03T23:26:42.586Z skipping since configuration is not implemented
2018-08-03T23:26:42.586Z Running query:11; exportSummaryToBigQuery:true; 
streamTimeout:60
2018-08-03T23:26:42.587Z skipping since configuration is not implemented
2018-08-03T23:26:42.587Z Running query:12; exportSummaryToBigQuery:true; 
streamTimeout:60
2018-08-03T23:26:42.587Z skipping since configuration is not implemented

> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 8,5,main]) 
completed. Took 1 mins 8.733 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-sdks-java-nexmark:run'.
> Process 'command '/usr/local/asfpackages/java/jdk1.8.0_152/bin/java'' 
> finished with non-zero exit value 1

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to 
get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with 
Gradle 5.0.
See 
https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 3m 6s
64 actionable tasks: 15 executed, 49 up-to-date

Publishing build scan...
https://gradle.com/s/txvxor6pm5jmm

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

Reply via email to