See
<https://builds.apache.org/job/beam_PostCommit_Java_Nexmark_Spark/660/display/redirect?page=changes>
Changes:
[kyle.winkelman] Remove defaultParallelism when bounded.
[kyle.winkelman] Remove defaultParallelism using bundleSize.
[kyle.winkelman] Incorporate requested changes.
------------------------------------------
[...truncated 698.86 KB...]
18/10/05 09:33:21 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@12561a30;
TICK = 17/15; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#436:BeamCalcRel.BEAM_LOGICAL(input=rel#435:Subset#2.BEAM_LOGICAL,expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2267: Apply rule [BeamEnumerableConverterRule] to
[rel#436:BeamCalcRel.BEAM_LOGICAL(input=rel#435:Subset#2.BEAM_LOGICAL,expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#437 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2267 generated 1 successors: [BeamEnumerableConverter#437]
18/10/05 09:33:21 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@12561a30;
TICK = 18/16; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamAggregationRule] rels
[rel#404:LogicalAggregate.NONE(input=rel#403:Subset#4.NONE,group={0},maxprice=MAX($1)),
rel#402:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=TUMBLE($3,
10000),price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2059: Apply rule [BeamAggregationRule] to
[rel#404:LogicalAggregate.NONE(input=rel#403:Subset#4.NONE,group={0},maxprice=MAX($1)),
rel#402:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=TUMBLE($3,
10000),price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#443 via BeamAggregationRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2059 generated 1 successors:
[rel#443:BeamAggregationRel.BEAM_LOGICAL(input=rel#442:Subset#9.BEAM_LOGICAL,group={0},maxprice=MAX($1),window=FixedWindows($0,
PT10S, PT0S))]
18/10/05 09:33:21 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@12561a30;
TICK = 19/17; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#443:BeamAggregationRel.BEAM_LOGICAL(input=rel#442:Subset#9.BEAM_LOGICAL,group={0},maxprice=MAX($1),window=FixedWindows($0,
PT10S, PT0S))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2318: Apply rule [BeamEnumerableConverterRule] to
[rel#443:BeamAggregationRel.BEAM_LOGICAL(input=rel#442:Subset#9.BEAM_LOGICAL,group={0},maxprice=MAX($1),window=FixedWindows($0,
PT10S, PT0S))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#444 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2318 generated 1 successors: [BeamEnumerableConverter#444]
18/10/05 09:33:21 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@12561a30;
TICK = 20/18; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamAggregationRule] rels
[rel#398:LogicalAggregate.NONE(input=rel#397:Subset#1.NONE,group={0, 1, 2, 3,
4, 5}),
rel#396:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
10000))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1984: Apply rule [BeamAggregationRule] to
[rel#398:LogicalAggregate.NONE(input=rel#397:Subset#1.NONE,group={0, 1, 2, 3,
4, 5}),
rel#396:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
10000))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#450 via BeamAggregationRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1984 generated 1 successors:
[rel#450:BeamAggregationRel.BEAM_LOGICAL(input=rel#449:Subset#10.BEAM_LOGICAL,group={0,
1, 2, 3, 4, 5},window=FixedWindows($5, PT10S, PT0S))]
18/10/05 09:33:21 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@12561a30;
TICK = 21/19; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#450:BeamAggregationRel.BEAM_LOGICAL(input=rel#449:Subset#10.BEAM_LOGICAL,group={0,
1, 2, 3, 4, 5},window=FixedWindows($5, PT10S, PT0S))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2370: Apply rule [BeamEnumerableConverterRule] to
[rel#450:BeamAggregationRel.BEAM_LOGICAL(input=rel#449:Subset#10.BEAM_LOGICAL,group={0,
1, 2, 3, 4, 5},window=FixedWindows($5, PT10S, PT0S))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#451 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2370 generated 1 successors: [BeamEnumerableConverter#451]
18/10/05 09:33:21 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@12561a30;
TICK = 22/20; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [AggregateRemoveRule] rels
[rel#404:LogicalAggregate.NONE(input=rel#403:Subset#4.NONE,group={0},maxprice=MAX($1)),
rel#402:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=TUMBLE($3,
10000),price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2044: Apply rule [AggregateRemoveRule] to
[rel#404:LogicalAggregate.NONE(input=rel#403:Subset#4.NONE,group={0},maxprice=MAX($1)),
rel#402:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=TUMBLE($3,
10000),price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2044 generated 0 successors.
18/10/05 09:33:21 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@12561a30;
TICK = 23/21; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [AggregateRemoveRule] rels
[rel#398:LogicalAggregate.NONE(input=rel#397:Subset#1.NONE,group={0, 1, 2, 3,
4, 5}),
rel#396:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
10000))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1969: Apply rule [AggregateRemoveRule] to
[rel#398:LogicalAggregate.NONE(input=rel#397:Subset#1.NONE,group={0, 1, 2, 3,
4, 5}),
rel#396:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
10000))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1969 generated 0 successors.
18/10/05 09:33:21 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@12561a30;
TICK = 24/22; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [AggregateProjectMergeRule] rels
[rel#404:LogicalAggregate.NONE(input=rel#403:Subset#4.NONE,group={0},maxprice=MAX($1)),
rel#402:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=TUMBLE($3,
10000),price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2052: Apply rule [AggregateProjectMergeRule] to
[rel#404:LogicalAggregate.NONE(input=rel#403:Subset#4.NONE,group={0},maxprice=MAX($1)),
rel#402:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=TUMBLE($3,
10000),price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2052 generated 0 successors.
18/10/05 09:33:21 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@12561a30;
TICK = 25/23; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [AggregateProjectMergeRule] rels
[rel#398:LogicalAggregate.NONE(input=rel#397:Subset#1.NONE,group={0, 1, 2, 3,
4, 5}),
rel#396:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
10000))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1977: Apply rule [AggregateProjectMergeRule] to
[rel#398:LogicalAggregate.NONE(input=rel#397:Subset#1.NONE,group={0, 1, 2, 3,
4, 5}),
rel#396:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
10000))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1977 generated 0 successors.
18/10/05 09:33:21 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@12561a30;
TICK = 26/24; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [ProjectToCalcRule] rels
[rel#402:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=TUMBLE($3,
10000),price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2034: Apply rule [ProjectToCalcRule] to
[rel#402:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=TUMBLE($3,
10000),price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#454 via ProjectToCalcRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2034 generated 1 successors:
[rel#454:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
$t5),$f0=$t6,price=$t2)]
18/10/05 09:33:21 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@12561a30;
TICK = 27/25; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [AggregateRemoveRule] rels
[rel#404:LogicalAggregate.NONE(input=rel#403:Subset#4.NONE,group={0},maxprice=MAX($1)),
rel#454:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
$t5),$f0=$t6,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2391: Apply rule [AggregateRemoveRule] to
[rel#404:LogicalAggregate.NONE(input=rel#403:Subset#4.NONE,group={0},maxprice=MAX($1)),
rel#454:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
$t5),$f0=$t6,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2391 generated 0 successors.
18/10/05 09:33:21 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@12561a30;
TICK = 28/26; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamCalcRule] rels
[rel#454:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
$t5),$f0=$t6,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2403: Apply rule [BeamCalcRule] to
[rel#454:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
$t5),$f0=$t6,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#455 via BeamCalcRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2403 generated 1 successors:
[rel#455:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
$t5),$f0=$t6,price=$t2)]
18/10/05 09:33:21 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@12561a30;
TICK = 29/27; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [ProjectToCalcRule] rels
[rel#396:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
10000))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1959: Apply rule [ProjectToCalcRule] to
[rel#396:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
10000))]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#457 via ProjectToCalcRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1959 generated 1 successors:
[rel#457:LogicalCalc.NONE(input=rel#395: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/10/05 09:33:21 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@12561a30;
TICK = 30/28; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [AggregateRemoveRule] rels
[rel#398:LogicalAggregate.NONE(input=rel#397:Subset#1.NONE,group={0, 1, 2, 3,
4, 5}),
rel#457:LogicalCalc.NONE(input=rel#395: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/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2424: Apply rule [AggregateRemoveRule] to
[rel#398:LogicalAggregate.NONE(input=rel#397:Subset#1.NONE,group={0, 1, 2, 3,
4, 5}),
rel#457:LogicalCalc.NONE(input=rel#395: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/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2424 generated 0 successors.
18/10/05 09:33:21 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@12561a30;
TICK = 31/29; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamCalcRule] rels
[rel#457:LogicalCalc.NONE(input=rel#395: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/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2436: Apply rule [BeamCalcRule] to
[rel#457:LogicalCalc.NONE(input=rel#395: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/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#458 via BeamCalcRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2436 generated 1 successors:
[rel#458:BeamCalcRel.BEAM_LOGICAL(input=rel#395: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/10/05 09:33:21 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@12561a30;
TICK = 32/30; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#459:Subset#1.BEAM_LOGICAL]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2450: Apply rule [BeamEnumerableConverterRule] to
[rel#459:Subset#1.BEAM_LOGICAL]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#460 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2450 generated 1 successors:
[rel#460:BeamEnumerableConverter.ENUMERABLE(input=rel#459:Subset#1.BEAM_LOGICAL)]
18/10/05 09:33:21 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@12561a30;
TICK = 33/31; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#458:BeamCalcRel.BEAM_LOGICAL(input=rel#395: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/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2442: Apply rule [BeamEnumerableConverterRule] to
[rel#458:BeamCalcRel.BEAM_LOGICAL(input=rel#395: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/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#462 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2442 generated 1 successors: [BeamEnumerableConverter#462]
18/10/05 09:33:21 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@12561a30;
TICK = 34/32; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#456:Subset#4.BEAM_LOGICAL]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2417: Apply rule [BeamEnumerableConverterRule] to
[rel#456:Subset#4.BEAM_LOGICAL]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#464 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2417 generated 1 successors:
[rel#464:BeamEnumerableConverter.ENUMERABLE(input=rel#456:Subset#4.BEAM_LOGICAL)]
18/10/05 09:33:21 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@12561a30;
TICK = 35/33; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#455:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
$t5),$f0=$t6,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2409: Apply rule [BeamEnumerableConverterRule] to
[rel#455:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},expr#5=10000,expr#6=TUMBLE($t3,
$t5),$f0=$t6,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#466 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2409 generated 1 successors: [BeamEnumerableConverter#466]
18/10/05 09:33:21 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@12561a30;
TICK = 36/34; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#395:Subset#0.BEAM_LOGICAL]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1936: Apply rule [BeamEnumerableConverterRule] to
[rel#395:Subset#0.BEAM_LOGICAL]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#468 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1936 generated 1 successors:
[rel#468:BeamEnumerableConverter.ENUMERABLE(input=rel#395:Subset#0.BEAM_LOGICAL)]
18/10/05 09:33:21 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@12561a30;
TICK = 37/35; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#385:BeamIOSourceRel.BEAM_LOGICAL(table=[beam, Bid])]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1931: Apply rule [BeamEnumerableConverterRule] to
[rel#385:BeamIOSourceRel.BEAM_LOGICAL(table=[beam, Bid])]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#470 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#1931 generated 1 successors: [BeamEnumerableConverter#470]
18/10/05 09:33:21 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@12561a30;
TICK = 38/36; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [ProjectToCalcRule] rels
[rel#440:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=$3,price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2303: Apply rule [ProjectToCalcRule] to
[rel#440:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=$3,price=$2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#472 via ProjectToCalcRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2303 generated 1 successors:
[rel#472:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},$f0=$t3,price=$t2)]
18/10/05 09:33:21 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@12561a30;
TICK = 39/37; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamCalcRule] rels
[rel#472:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},$f0=$t3,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2507: Apply rule [BeamCalcRule] to
[rel#472:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},$f0=$t3,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#473 via BeamCalcRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2507 generated 1 successors:
[rel#473:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},$f0=$t3,price=$t2)]
18/10/05 09:33:21 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@12561a30;
TICK = 40/38; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#473:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},$f0=$t3,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2513: Apply rule [BeamEnumerableConverterRule] to
[rel#473:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},$f0=$t3,price=$t2)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#474 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2513 generated 1 successors: [BeamEnumerableConverter#474]
18/10/05 09:33:21 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@12561a30;
TICK = 41/39; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [ProjectToCalcRule] rels
[rel#447:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=$3)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2355: Apply rule [ProjectToCalcRule] to
[rel#447:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=$3)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#477 via ProjectToCalcRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2355 generated 1 successors:
[rel#477:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t3)]
18/10/05 09:33:21 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@12561a30;
TICK = 42/40; PHASE = OPTIMIZE; COST = {inf}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamCalcRule] rels
[rel#477:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t3)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2544: Apply rule [BeamCalcRule] to
[rel#477:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t3)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#478 via BeamCalcRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2544 generated 1 successors:
[rel#478:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t3)]
18/10/05 09:33:21 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@12561a30;
TICK = 43/41; PHASE = OPTIMIZE; COST = {445.75 rows, 2191.25 cpu, 0.0 io}
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Pop match: rule [BeamEnumerableConverterRule] rels
[rel#478:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t3)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2550: Apply rule [BeamEnumerableConverterRule] to
[rel#478:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t3)]
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Transform to: rel#479 via BeamEnumerableConverterRule
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
call#2550 generated 1 successors: [BeamEnumerableConverter#479]
18/10/05 09:33:21 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@12561a30;
TICK = 44/42; PHASE = OPTIMIZE; COST = {445.75 rows, 2191.25 cpu, 0.0 io}
18/10/05 09:33:21 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@12561a30;
TICK = 45/1; PHASE = CLEANUP; COST = {445.75 rows, 2191.25 cpu, 0.0 io}
18/10/05 09:33:21 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, 2191.25 cpu, 0.0 io}, id = 489
BeamJoinRel(condition=[AND(=($5, $7), =($1, $6))], joinType=[inner]):
rowcount = 2.25, cumulative cost = {443.5 rows, 2162.0 cpu, 0.0 io}, id = 488
BeamCalcRel(expr#0..5=[{inputs}], proj#0..5=[{exprs}]): rowcount = 10.0,
cumulative cost = {220.0 rows, 1321.0 cpu, 0.0 io}, id = 484
BeamAggregationRel(group=[{0, 1, 2, 3, 4, 5}], window=[FixedWindows($5,
PT10S, PT0S)]): rowcount = 10.0, cumulative cost = {210.0 rows, 1201.0 cpu, 0.0
io}, id = 483
BeamCalcRel(expr#0..4=[{inputs}], auction=[$t0], price=[$t2],
bidder=[$t1], dateTime=[$t3], extra=[$t4], $f5=[$t3]): rowcount = 100.0,
cumulative cost = {200.0 rows, 1201.0 cpu, 0.0 io}, id = 482
BeamIOSourceRel(table=[[beam, Bid]]): rowcount = 100.0, cumulative
cost = {100.0 rows, 101.0 cpu, 0.0 io}, id = 385
BeamCalcRel(expr#0..1=[{inputs}], maxprice=[$t1], starttime=[$t0]):
rowcount = 10.0, cumulative cost = {221.25 rows, 841.0 cpu, 0.0 io}, id = 487
BeamAggregationRel(group=[{0}], maxprice=[MAX($1)],
window=[FixedWindows($0, PT10S, PT0S)]): rowcount = 10.0, cumulative cost =
{211.25 rows, 801.0 cpu, 0.0 io}, id = 486
BeamCalcRel(expr#0..4=[{inputs}], $f0=[$t3], price=[$t2]): rowcount =
100.0, cumulative cost = {200.0 rows, 801.0 cpu, 0.0 io}, id = 485
BeamIOSourceRel(table=[[beam, Bid]]): rowcount = 100.0, cumulative
cost = {100.0 rows, 101.0 cpu, 0.0 io}, id = 385
18/10/05 09:33:21 DEBUG
org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.plan.RelOptPlanner:
Provenance:
BeamCalcRel#489
direct
rel#416:BeamCalcRel.BEAM_LOGICAL(input=rel#415:Subset#7.BEAM_LOGICAL,expr#0..7={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4)
call#2159 rule [BeamCalcRule]
rel#414:LogicalCalc.NONE(input=rel#409:Subset#7.NONE,expr#0..7={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4)
call#2131 rule [ProjectToCalcRule]
rel#410:LogicalProject.NONE(input=rel#409:Subset#7.NONE,auction=$0,price=$1,bidder=$2,dateTime=$3,extra=$4)
no parent
BeamJoinRel#488
direct
rel#422:BeamJoinRel.BEAM_LOGICAL(left=rel#420:Subset#3.BEAM_LOGICAL,right=rel#421:Subset#6.BEAM_LOGICAL,condition=AND(=($5,
$7), =($1, $6)),joinType=inner)
call#2100 rule [BeamJoinRule]
rel#408:LogicalJoin.NONE(left=rel#401:Subset#3.NONE,right=rel#407:Subset#6.NONE,condition=AND(=($5,
$7), =($1, $6)),joinType=inner)
no parent
BeamCalcRel#484
direct
rel#436:BeamCalcRel.BEAM_LOGICAL(input=rel#435:Subset#2.BEAM_LOGICAL,expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)
call#2261 rule [BeamCalcRule]
rel#434:LogicalCalc.NONE(input=rel#399:Subset#2.NONE,expr#0..5={inputs},auction=$t0,price=$t1,bidder=$t2,dateTime=$t3,extra=$t4,starttime=$t5)
call#2008 rule [ProjectToCalcRule]
rel#400:LogicalProject.NONE(input=rel#399:Subset#2.NONE,auction=$0,price=$1,bidder=$2,dateTime=$3,extra=$4,starttime=$5)
no parent
BeamAggregationRel#483
direct
rel#450:BeamAggregationRel.BEAM_LOGICAL(input=rel#449:Subset#10.BEAM_LOGICAL,group={0,
1, 2, 3, 4, 5},window=FixedWindows($5, PT10S, PT0S))
call#1984 rule [BeamAggregationRule]
rel#398:LogicalAggregate.NONE(input=rel#397:Subset#1.NONE,group={0, 1,
2, 3, 4, 5})
no parent
rel#396:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=TUMBLE($3,
10000))
no parent
BeamCalcRel#482
direct
rel#478:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t3)
call#2544 rule [BeamCalcRule]
rel#477:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},auction=$t0,price=$t2,bidder=$t1,dateTime=$t3,extra=$t4,$f5=$t3)
call#2355 rule [ProjectToCalcRule]
rel#447:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,auction=$0,price=$2,bidder=$1,dateTime=$3,extra=$4,$f5=$3)
no parent
rel#385:BeamIOSourceRel.BEAM_LOGICAL(table=[beam, Bid])
no parent
BeamCalcRel#487
direct
rel#430:BeamCalcRel.BEAM_LOGICAL(input=rel#429:Subset#5.BEAM_LOGICAL,expr#0..1={inputs},maxprice=$t1,starttime=$t0)
call#2224 rule [BeamCalcRule]
rel#428:LogicalCalc.NONE(input=rel#405:Subset#5.NONE,expr#0..1={inputs},maxprice=$t1,starttime=$t0)
call#2083 rule [ProjectToCalcRule]
rel#406:LogicalProject.NONE(input=rel#405:Subset#5.NONE,maxprice=$1,starttime=$0)
no parent
BeamAggregationRel#486
direct
rel#443:BeamAggregationRel.BEAM_LOGICAL(input=rel#442:Subset#9.BEAM_LOGICAL,group={0},maxprice=MAX($1),window=FixedWindows($0,
PT10S, PT0S))
call#2059 rule [BeamAggregationRule]
rel#404:LogicalAggregate.NONE(input=rel#403:Subset#4.NONE,group={0},maxprice=MAX($1))
no parent
rel#402:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=TUMBLE($3,
10000),price=$2)
no parent
BeamCalcRel#485
direct
rel#473:BeamCalcRel.BEAM_LOGICAL(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},$f0=$t3,price=$t2)
call#2507 rule [BeamCalcRule]
rel#472:LogicalCalc.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,expr#0..4={inputs},$f0=$t3,price=$t2)
call#2303 rule [ProjectToCalcRule]
rel#440:LogicalProject.NONE(input=rel#395:Subset#0.BEAM_LOGICAL,$f0=$3,price=$2)
no parent
rel#385 (see above)
2018-10-05T09:33:33.724Z Waiting for main pipeline to 'finish'
2018-10-05T09:33:33.724Z DONE SqlQuery7
2018-10-05T09:33:33.727Z Running query:8; exportSummaryToBigQuery:true;
streamTimeout:60
2018-10-05T09:33:33.727Z skipping since configuration is not implemented
2018-10-05T09:33:33.727Z Running query:9; exportSummaryToBigQuery:true;
numEvents:10000; streamTimeout:60
2018-10-05T09:33:33.727Z skipping since configuration is not implemented
2018-10-05T09:33:33.727Z Running query:10; exportSummaryToBigQuery:true;
streamTimeout:60
2018-10-05T09:33:33.727Z skipping since configuration is not implemented
2018-10-05T09:33:33.727Z Running query:11; exportSummaryToBigQuery:true;
streamTimeout:60
2018-10-05T09:33:33.727Z skipping since configuration is not implemented
2018-10-05T09:33:33.728Z Running query:12; exportSummaryToBigQuery:true;
streamTimeout:60
2018-10-05T09:33:33.728Z skipping since configuration is not implemented
> Task :beam-sdks-java-nexmark:run FAILED
:beam-sdks-java-nexmark:run (Thread[Task worker for ':' Thread 3,5,main])
completed. Took 47.531 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_172/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.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 2m 37s
64 actionable tasks: 15 executed, 49 up-to-date
Publishing build scan...
https://gradle.com/s/exvchzzgl655k
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
