[JBoss JIRA] (TEIID-4348) Querying with the OVER clause throws NPE
by Steven Hawkins (JIRA)
[ https://issues.jboss.org/browse/TEIID-4348?page=com.atlassian.jira.plugin... ]
Steven Hawkins resolved TEIID-4348.
-----------------------------------
Resolution: Duplicate Issue
Duplicate of TEIID-3751
> Querying with the OVER clause throws NPE
> ----------------------------------------
>
> Key: TEIID-4348
> URL: https://issues.jboss.org/browse/TEIID-4348
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Steve Tran
>
> I'm not sure if the OVER clause is valid syntax in the ANSI dialect of Teiid, but trying so gives me a NullPointerException. It looks like it almost runs though.
> {code}
> select DERVD_COT_ID D_COT , SUPPLIER_PAR_ID, SUM(AVG_DDD_DOL_AMT) TOT_dollars,
> SUM(AVG_DDD_DOL_AMT) OVER (partition by DERVD_COT_ID)
> from PBI_ZIP_DCOT_CNFDTY_2
> GROUP BY DERVD_COT_ID,SUPPLIER_PAR_ID;
> {code}
> Here's the stack trace
> {code}
> 17:11:00,775 INFO [org.teiid.PLANNER] (Worker45_QueryProcessorQueue654)
> ============================================================================
> USER COMMAND:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> OPTIMIZE:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> GENERATE CANONICAL:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> CANONICAL PLAN:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PlaceAccess
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING RaiseAccess
> LOW Relational Planner Aggregate function pushdown not supported by source PBIPR - SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) was not pushed
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PushAggregates
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING AssignOutputElements
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> ============================================================================
> EXECUTING CalculateCost
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0 AS D_COT=[21806.0, -1.0], anon_grp0.gcol1 AS SUPPLIER_PAR_ID=[21806.0, -1.0], anon_grp0.agg0 AS TOT_dollars=[21806.0, -1.0], SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)=[-1.0, -1.0]}})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, EST_CARDINALITY=130836.0})
> ============================================================================
> EXECUTING PlanSorts
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING CollapseSource
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, ATOMIC_REQUEST=SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2})
> ============================================================================
> CONVERTING PLAN TREE TO PROCESS TREE
> PROCESS PLAN =
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> ----------------------------------------------------------------------------
> OPTIMIZATION COMPLETE:
> PROCESSOR PLAN:
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> 17:11:00,785 ERROR [org.teiid.PROCESSOR] (Worker45_QueryProcessorQueue654) TEIID30019 Unexpected exception for request Z87J+n4LbJTu.0: java.lang.NullPointerException
> at org.teiid.query.processor.relational.GroupingNode.initialize(GroupingNode.java:192) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:94) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.initialize(RelationalPlan.java:89) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.init(QueryProcessor.java:226) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatchDirect(QueryProcessor.java:138) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatch(QueryProcessor.java:114) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:159) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:141) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.processMore(RequestWorkItem.java:444) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.process(RequestWorkItem.java:326) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.AbstractWorkItem.run(AbstractWorkItem.java:51) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.run(RequestWorkItem.java:254) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:274) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_66]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_66]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_66]
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0
[JBoss JIRA] (TEIID-4348) Querying with the OVER clause throws NPE
by Marc Shirley (JIRA)
[ https://issues.jboss.org/browse/TEIID-4348?page=com.atlassian.jira.plugin... ]
Marc Shirley updated TEIID-4348:
--------------------------------
> Querying with the OVER clause throws NPE
> ----------------------------------------
>
> Key: TEIID-4348
> URL: https://issues.jboss.org/browse/TEIID-4348
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Steve Tran
>
> I'm not sure if the OVER clause is valid syntax in the ANSI dialect of Teiid, but trying so gives me a NullPointerException. It looks like it almost runs though.
> {code}
> select DERVD_COT_ID D_COT , SUPPLIER_PAR_ID, SUM(AVG_DDD_DOL_AMT) TOT_dollars,
> SUM(AVG_DDD_DOL_AMT) OVER (partition by DERVD_COT_ID)
> from PBI_ZIP_DCOT_CNFDTY_2
> GROUP BY DERVD_COT_ID,SUPPLIER_PAR_ID;
> {code}
> Here's the stack trace
> {code}
> 17:11:00,775 INFO [org.teiid.PLANNER] (Worker45_QueryProcessorQueue654)
> ============================================================================
> USER COMMAND:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> OPTIMIZE:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> GENERATE CANONICAL:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> CANONICAL PLAN:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PlaceAccess
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING RaiseAccess
> LOW Relational Planner Aggregate function pushdown not supported by source PBIPR - SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) was not pushed
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PushAggregates
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING AssignOutputElements
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> ============================================================================
> EXECUTING CalculateCost
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0 AS D_COT=[21806.0, -1.0], anon_grp0.gcol1 AS SUPPLIER_PAR_ID=[21806.0, -1.0], anon_grp0.agg0 AS TOT_dollars=[21806.0, -1.0], SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)=[-1.0, -1.0]}})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, EST_CARDINALITY=130836.0})
> ============================================================================
> EXECUTING PlanSorts
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING CollapseSource
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, ATOMIC_REQUEST=SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2})
> ============================================================================
> CONVERTING PLAN TREE TO PROCESS TREE
> PROCESS PLAN =
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> ----------------------------------------------------------------------------
> OPTIMIZATION COMPLETE:
> PROCESSOR PLAN:
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> 17:11:00,785 ERROR [org.teiid.PROCESSOR] (Worker45_QueryProcessorQueue654) TEIID30019 Unexpected exception for request Z87J+n4LbJTu.0: java.lang.NullPointerException
> at org.teiid.query.processor.relational.GroupingNode.initialize(GroupingNode.java:192) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:94) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.initialize(RelationalPlan.java:89) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.init(QueryProcessor.java:226) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatchDirect(QueryProcessor.java:138) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatch(QueryProcessor.java:114) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:159) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:141) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.processMore(RequestWorkItem.java:444) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.process(RequestWorkItem.java:326) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.AbstractWorkItem.run(AbstractWorkItem.java:51) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.run(RequestWorkItem.java:254) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:274) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_66]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_66]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_66]
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0
[JBoss JIRA] (TEIID-4348) Querying with the OVER clause throws NPE
by Steve Tran (JIRA)
[ https://issues.jboss.org/browse/TEIID-4348?page=com.atlassian.jira.plugin... ]
Steve Tran updated TEIID-4348:
------------------------------
Summary: Querying with the OVER clause throws NPE (was: Stored Procedure OVER clause throws NPE)
> Querying with the OVER clause throws NPE
> ----------------------------------------
>
> Key: TEIID-4348
> URL: https://issues.jboss.org/browse/TEIID-4348
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Steve Tran
> Priority: Minor
>
> I'm not sure if the OVER clause is valid syntax in the ANSI dialect of Teiid, but trying so gives me a NullPointerException. It looks like it almost runs though.
> {code}
> select DERVD_COT_ID D_COT , SUPPLIER_PAR_ID, SUM(AVG_DDD_DOL_AMT) TOT_dollars,
> SUM(AVG_DDD_DOL_AMT) OVER (partition by DERVD_COT_ID)
> from PBI_ZIP_DCOT_CNFDTY_2
> GROUP BY DERVD_COT_ID,SUPPLIER_PAR_ID;
> {code}
> Here's the stack trace
> {code}
> 17:11:00,775 INFO [org.teiid.PLANNER] (Worker45_QueryProcessorQueue654)
> ============================================================================
> USER COMMAND:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> OPTIMIZE:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> GENERATE CANONICAL:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> CANONICAL PLAN:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PlaceAccess
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING RaiseAccess
> LOW Relational Planner Aggregate function pushdown not supported by source PBIPR - SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) was not pushed
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PushAggregates
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING AssignOutputElements
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> ============================================================================
> EXECUTING CalculateCost
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0 AS D_COT=[21806.0, -1.0], anon_grp0.gcol1 AS SUPPLIER_PAR_ID=[21806.0, -1.0], anon_grp0.agg0 AS TOT_dollars=[21806.0, -1.0], SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)=[-1.0, -1.0]}})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, EST_CARDINALITY=130836.0})
> ============================================================================
> EXECUTING PlanSorts
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING CollapseSource
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, ATOMIC_REQUEST=SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2})
> ============================================================================
> CONVERTING PLAN TREE TO PROCESS TREE
> PROCESS PLAN =
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> ----------------------------------------------------------------------------
> OPTIMIZATION COMPLETE:
> PROCESSOR PLAN:
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> 17:11:00,785 ERROR [org.teiid.PROCESSOR] (Worker45_QueryProcessorQueue654) TEIID30019 Unexpected exception for request Z87J+n4LbJTu.0: java.lang.NullPointerException
> at org.teiid.query.processor.relational.GroupingNode.initialize(GroupingNode.java:192) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:94) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.initialize(RelationalPlan.java:89) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.init(QueryProcessor.java:226) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatchDirect(QueryProcessor.java:138) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatch(QueryProcessor.java:114) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:159) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:141) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.processMore(RequestWorkItem.java:444) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.process(RequestWorkItem.java:326) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.AbstractWorkItem.run(AbstractWorkItem.java:51) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.run(RequestWorkItem.java:254) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:274) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_66]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_66]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_66]
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0
[JBoss JIRA] (TEIID-4348) Querying with the OVER clause throws NPE
by Steve Tran (JIRA)
[ https://issues.jboss.org/browse/TEIID-4348?page=com.atlassian.jira.plugin... ]
Steve Tran updated TEIID-4348:
------------------------------
Priority: Major (was: Minor)
> Querying with the OVER clause throws NPE
> ----------------------------------------
>
> Key: TEIID-4348
> URL: https://issues.jboss.org/browse/TEIID-4348
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Steve Tran
>
> I'm not sure if the OVER clause is valid syntax in the ANSI dialect of Teiid, but trying so gives me a NullPointerException. It looks like it almost runs though.
> {code}
> select DERVD_COT_ID D_COT , SUPPLIER_PAR_ID, SUM(AVG_DDD_DOL_AMT) TOT_dollars,
> SUM(AVG_DDD_DOL_AMT) OVER (partition by DERVD_COT_ID)
> from PBI_ZIP_DCOT_CNFDTY_2
> GROUP BY DERVD_COT_ID,SUPPLIER_PAR_ID;
> {code}
> Here's the stack trace
> {code}
> 17:11:00,775 INFO [org.teiid.PLANNER] (Worker45_QueryProcessorQueue654)
> ============================================================================
> USER COMMAND:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> OPTIMIZE:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> GENERATE CANONICAL:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> CANONICAL PLAN:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PlaceAccess
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING RaiseAccess
> LOW Relational Planner Aggregate function pushdown not supported by source PBIPR - SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) was not pushed
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PushAggregates
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING AssignOutputElements
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> ============================================================================
> EXECUTING CalculateCost
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0 AS D_COT=[21806.0, -1.0], anon_grp0.gcol1 AS SUPPLIER_PAR_ID=[21806.0, -1.0], anon_grp0.agg0 AS TOT_dollars=[21806.0, -1.0], SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)=[-1.0, -1.0]}})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, EST_CARDINALITY=130836.0})
> ============================================================================
> EXECUTING PlanSorts
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING CollapseSource
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, ATOMIC_REQUEST=SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2})
> ============================================================================
> CONVERTING PLAN TREE TO PROCESS TREE
> PROCESS PLAN =
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> ----------------------------------------------------------------------------
> OPTIMIZATION COMPLETE:
> PROCESSOR PLAN:
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> 17:11:00,785 ERROR [org.teiid.PROCESSOR] (Worker45_QueryProcessorQueue654) TEIID30019 Unexpected exception for request Z87J+n4LbJTu.0: java.lang.NullPointerException
> at org.teiid.query.processor.relational.GroupingNode.initialize(GroupingNode.java:192) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:94) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.initialize(RelationalPlan.java:89) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.init(QueryProcessor.java:226) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatchDirect(QueryProcessor.java:138) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatch(QueryProcessor.java:114) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:159) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:141) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.processMore(RequestWorkItem.java:444) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.process(RequestWorkItem.java:326) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.AbstractWorkItem.run(AbstractWorkItem.java:51) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.run(RequestWorkItem.java:254) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:274) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_66]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_66]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_66]
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0
[JBoss JIRA] (TEIID-4348) Stored Procedure OVER clause throws NPE
by Steve Tran (JIRA)
[ https://issues.jboss.org/browse/TEIID-4348?page=com.atlassian.jira.plugin... ]
Steve Tran updated TEIID-4348:
------------------------------
Description:
I'm not sure if the OVER clause is valid syntax in the ANSI dialect of Teiid, but trying so gives me a NullPointerException. It looks like it almost runs though.
{code}
select DERVD_COT_ID D_COT , SUPPLIER_PAR_ID, SUM(AVG_DDD_DOL_AMT) TOT_dollars,
SUM(AVG_DDD_DOL_AMT) OVER (partition by DERVD_COT_ID)
from PBI_ZIP_DCOT_CNFDTY_2
GROUP BY DERVD_COT_ID,SUPPLIER_PAR_ID;
{code}
Here's the stack trace
{code}
17:11:00,775 INFO [org.teiid.PLANNER] (Worker45_QueryProcessorQueue654)
============================================================================
USER COMMAND:
SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
----------------------------------------------------------------------------
OPTIMIZE:
SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
----------------------------------------------------------------------------
GENERATE CANONICAL:
SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
CANONICAL PLAN:
Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
============================================================================
EXECUTING PlaceAccess
AFTER:
Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
============================================================================
EXECUTING RaiseAccess
LOW Relational Planner Aggregate function pushdown not supported by source PBIPR - SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) was not pushed
AFTER:
Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
============================================================================
EXECUTING PushAggregates
AFTER:
Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
============================================================================
EXECUTING AssignOutputElements
AFTER:
Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]})
Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
============================================================================
EXECUTING CalculateCost
AFTER:
Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0 AS D_COT=[21806.0, -1.0], anon_grp0.gcol1 AS SUPPLIER_PAR_ID=[21806.0, -1.0], anon_grp0.agg0 AS TOT_dollars=[21806.0, -1.0], SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)=[-1.0, -1.0]}})
Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, EST_CARDINALITY=130836.0})
============================================================================
EXECUTING PlanSorts
AFTER:
Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
============================================================================
EXECUTING CollapseSource
AFTER:
Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, ATOMIC_REQUEST=SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2})
============================================================================
CONVERTING PLAN TREE TO PROCESS TREE
PROCESS PLAN =
ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
============================================================================
----------------------------------------------------------------------------
OPTIMIZATION COMPLETE:
PROCESSOR PLAN:
ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
============================================================================
17:11:00,785 ERROR [org.teiid.PROCESSOR] (Worker45_QueryProcessorQueue654) TEIID30019 Unexpected exception for request Z87J+n4LbJTu.0: java.lang.NullPointerException
at org.teiid.query.processor.relational.GroupingNode.initialize(GroupingNode.java:192) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:94) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.query.processor.relational.RelationalPlan.initialize(RelationalPlan.java:89) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.query.processor.QueryProcessor.init(QueryProcessor.java:226) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.query.processor.QueryProcessor.nextBatchDirect(QueryProcessor.java:138) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.query.processor.QueryProcessor.nextBatch(QueryProcessor.java:114) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:159) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:141) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.dqp.internal.process.RequestWorkItem.processMore(RequestWorkItem.java:444) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.dqp.internal.process.RequestWorkItem.process(RequestWorkItem.java:326) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.dqp.internal.process.AbstractWorkItem.run(AbstractWorkItem.java:51) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.dqp.internal.process.RequestWorkItem.run(RequestWorkItem.java:254) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:274) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_66]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_66]
at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_66]
{code}
> Stored Procedure OVER clause throws NPE
> ---------------------------------------
>
> Key: TEIID-4348
> URL: https://issues.jboss.org/browse/TEIID-4348
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Steve Tran
> Priority: Minor
>
> I'm not sure if the OVER clause is valid syntax in the ANSI dialect of Teiid, but trying so gives me a NullPointerException. It looks like it almost runs though.
> {code}
> select DERVD_COT_ID D_COT , SUPPLIER_PAR_ID, SUM(AVG_DDD_DOL_AMT) TOT_dollars,
> SUM(AVG_DDD_DOL_AMT) OVER (partition by DERVD_COT_ID)
> from PBI_ZIP_DCOT_CNFDTY_2
> GROUP BY DERVD_COT_ID,SUPPLIER_PAR_ID;
> {code}
> Here's the stack trace
> {code}
> 17:11:00,775 INFO [org.teiid.PLANNER] (Worker45_QueryProcessorQueue654)
> ============================================================================
> USER COMMAND:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> OPTIMIZE:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> ----------------------------------------------------------------------------
> GENERATE CANONICAL:
> SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID AS D_COT, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID) FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2 GROUP BY PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID
> CANONICAL PLAN:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PlaceAccess
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING RaiseAccess
> LOW Relational Planner Aggregate function pushdown not supported by source PBIPR - SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) was not pushed
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING PushAggregates
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING AssignOutputElements
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]})
> ============================================================================
> EXECUTING CalculateCost
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], HAS_WINDOW_FUNCTIONS=true, OUTPUT_COLS=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0 AS D_COT=[21806.0, -1.0], anon_grp0.gcol1 AS SUPPLIER_PAR_ID=[21806.0, -1.0], anon_grp0.agg0 AS TOT_dollars=[21806.0, -1.0], SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)=[-1.0, -1.0]}})
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, EST_CARDINALITY=130836.0})
> ============================================================================
> EXECUTING PlanSorts
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0], props={GROUP_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID], SYMBOL_MAP={anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}, OUTPUT_COLS=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=65418.0, EST_COL_STATS={anon_grp0.gcol0=[21806.0, -1.0], anon_grp0.gcol1=[21806.0, -1.0], anon_grp0.agg0=[21806.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}})
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> Source(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2])
> ============================================================================
> EXECUTING CollapseSource
> AFTER:
> Project(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Group(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2, anon_grp0])
> Access(groups=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2], props={SOURCE_HINT=null, MODEL_ID=Schema name=PBIPR, nameInSource=null, uuid=mmuuid:eecf1a36-0a54-430f-a51c-e3839c8abd29, OUTPUT_COLS=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT], EST_CARDINALITY=130836.0, EST_COL_STATS={PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID=[-1.0, -1.0], PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT=[-1.0, -1.0]}, ATOMIC_REQUEST=SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2})
> ============================================================================
> CONVERTING PLAN TREE TO PROCESS TREE
> PROCESS PLAN =
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> ----------------------------------------------------------------------------
> OPTIMIZATION COMPLETE:
> PROCESSOR PLAN:
> ProjectNode(1) output=[anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)] [anon_grp0.gcol0 AS D_COT, anon_grp0.gcol1 AS SUPPLIER_PAR_ID, anon_grp0.agg0 AS TOT_dollars, SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0)]
> WindowFunctionProjectNode(2) output=[SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT) OVER (PARTITION BY anon_grp0.gcol0), anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT]
> GroupingNode(3) output=[anon_grp0.gcol0, anon_grp0.gcol1, anon_grp0.agg0, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] [PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID]{anon_grp0.gcol0=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, anon_grp0.gcol1=PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, anon_grp0.agg0=SUM(PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT)}
> AccessNode(4) output=[PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT] SELECT PBIPR.PBI_ZIP_DCOT_CNFDTY_2.DERVD_COT_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.SUPPLIER_PAR_ID, PBIPR.PBI_ZIP_DCOT_CNFDTY_2.AVG_DDD_DOL_AMT FROM PBIPR.PBI_ZIP_DCOT_CNFDTY_2
> ============================================================================
> 17:11:00,785 ERROR [org.teiid.PROCESSOR] (Worker45_QueryProcessorQueue654) TEIID30019 Unexpected exception for request Z87J+n4LbJTu.0: java.lang.NullPointerException
> at org.teiid.query.processor.relational.GroupingNode.initialize(GroupingNode.java:192) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:94) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.connectExternal(RelationalPlan.java:100) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.relational.RelationalPlan.initialize(RelationalPlan.java:89) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.init(QueryProcessor.java:226) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatchDirect(QueryProcessor.java:138) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.QueryProcessor.nextBatch(QueryProcessor.java:114) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:159) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:141) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.processMore(RequestWorkItem.java:444) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.process(RequestWorkItem.java:326) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.AbstractWorkItem.run(AbstractWorkItem.java:51) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.RequestWorkItem.run(RequestWorkItem.java:254) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:274) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.7.5.6_2-redhat-2.jar:8.7.5.6_2-redhat-2]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_66]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_66]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_66]
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0
[JBoss JIRA] (TEIID-4348) Stored Procedure OVER clause throws NPE
by Steve Tran (JIRA)
Steve Tran created TEIID-4348:
---------------------------------
Summary: Stored Procedure OVER clause throws NPE
Key: TEIID-4348
URL: https://issues.jboss.org/browse/TEIID-4348
Project: Teiid
Issue Type: Bug
Affects Versions: 8.7.1.6_2
Reporter: Steve Tran
Assignee: Ramesh Reddy
Priority: Minor
Fix For: 9.1
Might be obvious, but the file extension of a VDB must be all lowercase. The web console looked like it deployed and enabled it, but if you go into the Runtime tab, the VDB is not there.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0
[JBoss JIRA] (TEIID-4348) Stored Procedure OVER clause throws NPE
by Steve Tran (JIRA)
[ https://issues.jboss.org/browse/TEIID-4348?page=com.atlassian.jira.plugin... ]
Steve Tran updated TEIID-4348:
------------------------------
Labels: (was: Alpha1)
> Stored Procedure OVER clause throws NPE
> ---------------------------------------
>
> Key: TEIID-4348
> URL: https://issues.jboss.org/browse/TEIID-4348
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Steve Tran
> Assignee: Ramesh Reddy
> Priority: Minor
>
> Might be obvious, but the file extension of a VDB must be all lowercase. The web console looked like it deployed and enabled it, but if you go into the Runtime tab, the VDB is not there.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0
[JBoss JIRA] (TEIID-4348) Stored Procedure OVER clause throws NPE
by Steve Tran (JIRA)
[ https://issues.jboss.org/browse/TEIID-4348?page=com.atlassian.jira.plugin... ]
Steve Tran updated TEIID-4348:
------------------------------
Fix Version/s: (was: 9.1)
> Stored Procedure OVER clause throws NPE
> ---------------------------------------
>
> Key: TEIID-4348
> URL: https://issues.jboss.org/browse/TEIID-4348
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Steve Tran
> Assignee: Ramesh Reddy
> Priority: Minor
>
> Might be obvious, but the file extension of a VDB must be all lowercase. The web console looked like it deployed and enabled it, but if you go into the Runtime tab, the VDB is not there.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0
[JBoss JIRA] (TEIID-4348) Stored Procedure OVER clause throws NPE
by Steve Tran (JIRA)
[ https://issues.jboss.org/browse/TEIID-4348?page=com.atlassian.jira.plugin... ]
Steve Tran reassigned TEIID-4348:
---------------------------------
Assignee: (was: Ramesh Reddy)
> Stored Procedure OVER clause throws NPE
> ---------------------------------------
>
> Key: TEIID-4348
> URL: https://issues.jboss.org/browse/TEIID-4348
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Steve Tran
> Priority: Minor
>
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0
[JBoss JIRA] (TEIID-4348) Stored Procedure OVER clause throws NPE
by Steve Tran (JIRA)
[ https://issues.jboss.org/browse/TEIID-4348?page=com.atlassian.jira.plugin... ]
Steve Tran updated TEIID-4348:
------------------------------
Steps to Reproduce: (was: 1) Create a mytest.vdb VDB file
2) Rename to mytest.VDB
3) Deploy, Assign, and Enable.)
> Stored Procedure OVER clause throws NPE
> ---------------------------------------
>
> Key: TEIID-4348
> URL: https://issues.jboss.org/browse/TEIID-4348
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Steve Tran
> Assignee: Ramesh Reddy
> Priority: Minor
>
> Might be obvious, but the file extension of a VDB must be all lowercase. The web console looked like it deployed and enabled it, but if you go into the Runtime tab, the VDB is not there.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
8 years, 5 months
- 1
- 0