[teiid-issues] [JBoss JIRA] (TEIID-3775) HBase - GROUP BY clause returns duplicates results
Juraj Duráni (JIRA)
issues at jboss.org
Tue Oct 20 02:11:00 EDT 2015
[ https://issues.jboss.org/browse/TEIID-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13119683#comment-13119683 ]
Juraj Duráni commented on TEIID-3775:
-------------------------------------
Query plan and log:
{code:text}
08:09:33,339 DEBUG [org.teiid.TRANSPORT] (New I/O worker #1) processing message:MessageHolder: key=129 contents=Invoke interface org.teiid.client.DQP.executeRequest
08:09:33,340 TRACE [org.teiid.PROCESSOR] (New I/O worker #1) before executeRequest:org.teiid.dqp.internal.process.DQPCore at 4ac5a2ad(7,org.teiid.client.RequestMessage at 4e6be86a)
08:09:33,341 TRACE [org.teiid.PROCESSOR] (New I/O worker #1) after executeRequest : org.teiid.client.util.ResultsFuture at fafb177
08:09:33,341 TRACE [org.teiid.RUNTIME] (Worker2_QueryProcessorQueue95) Beginning work with virtual worker Worker2_QueryProcessorQueue95
08:09:33,342 TRACE [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7 start processing MORE_WORK
08:09:33,342 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) Request Thread ITdGQFQbPGVD.7 with state NEW
08:09:33,343 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7 Non-cachable command.
08:09:33,343 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7 executing SELECT StringNum FROM VQT.U8 GROUP BY StringNum
08:09:33,344 TRACE [org.teiid.PLANNER.RESOLVER] (Worker2_QueryProcessorQueue95) Resolving command SELECT StringNum FROM VQT.U8 GROUP BY StringNum
08:09:33,361 TRACE [org.teiid.PLANNER] (Worker2_QueryProcessorQueue95)
============================================================================
USER COMMAND:
SELECT VQT.U8.StringNum FROM VQT.U8 GROUP BY VQT.U8.StringNum
----------------------------------------------------------------------------
OPTIMIZE:
SELECT VQT.U8.StringNum FROM VQT.U8 GROUP BY VQT.U8.StringNum
----------------------------------------------------------------------------
GENERATE CANONICAL:
SELECT VQT.U8.StringNum FROM VQT.U8 GROUP BY VQT.U8.StringNum
CANONICAL PLAN:
Project(groups=[anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS StringNum]})
Group(groups=[VQT.U8, anon_grp0], props={GROUP_COLS=[VQT.U8.StringNum], SYMBOL_MAP={anon_grp0.gcol0=VQT.U8.StringNum}})
Source(groups=[VQT.U8], props={NESTED_COMMAND=SELECT BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue FROM BQT1.SmallA UNION SELECT BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue FROM BQT1.SmallB, SYMBOL_MAP={VQT.U8.IntKey=BQT1.SmallA.IntKey, VQT.U8.StringKey=BQT1.SmallA.StringKey, VQT.U8.IntNum=BQT1.SmallA.IntNum, VQT.U8.StringNum=BQT1.SmallA.StringNum, VQT.U8.FloatNum=BQT1.SmallA.FloatNum, VQT.U8.LongNum=BQT1.SmallA.LongNum, VQT.U8.DoubleNum=BQT1.SmallA.DoubleNum, VQT.U8.ByteNum=BQT1.SmallA.ByteNum, VQT.U8.DateValue=BQT1.SmallA.DateValue, VQT.U8.TimeValue=BQT1.SmallA.TimeValue, VQT.U8.TimestampValue=BQT1.SmallA.TimestampValue, VQT.U8.BooleanValue=BQT1.SmallA.BooleanValue, VQT.U8.CharValue=BQT1.SmallA.CharValue, VQT.U8.ShortValue=BQT1.SmallA.ShortValue, VQT.U8.BigIntegerValue=BQT1.SmallA.BigIntegerValue, VQT.U8.BigDecimalValue=BQT1.SmallA.BigDecimalValue}})
SetOperation(groups=[], props={SET_OPERATION=UNION, USE_ALL=false})
Project(groups=[BQT1.SmallA], props={PROJECT_COLS=[BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue]})
Source(groups=[BQT1.SmallA], props={NESTED_COMMAND=SELECT IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue FROM Source.smalla, SYMBOL_MAP={BQT1.SmallA.IntKey=IntKey, BQT1.SmallA.StringKey=StringKey, BQT1.SmallA.IntNum=IntNum, BQT1.SmallA.StringNum=StringNum, BQT1.SmallA.FloatNum=FloatNum, BQT1.SmallA.LongNum=LongNum, BQT1.SmallA.DoubleNum=convert(DOUBLENUM, double), BQT1.SmallA.ByteNum=ByteNum, BQT1.SmallA.DateValue=DateValue, BQT1.SmallA.TimeValue=TimeValue, BQT1.SmallA.TimestampValue=TimestampValue, BQT1.SmallA.BooleanValue=BooleanValue, BQT1.SmallA.CharValue=CharValue, BQT1.SmallA.ShortValue=ShortValue, BQT1.SmallA.BigIntegerValue=convert(BigIntegerValue, biginteger), BQT1.SmallA.BigDecimalValue=BigDecimalValue, BQT1.SmallA.ObjectValue=convert(ObjectValue, object)}})
Project(groups=[Source.smalla], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue]})
Source(groups=[Source.smalla])
Project(groups=[BQT1.SmallB], props={PROJECT_COLS=[BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue]})
Source(groups=[BQT1.SmallB], props={NESTED_COMMAND=SELECT IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue FROM Source.smallb, SYMBOL_MAP={BQT1.SmallB.IntKey=IntKey, BQT1.SmallB.StringKey=StringKey, BQT1.SmallB.IntNum=IntNum, BQT1.SmallB.StringNum=StringNum, BQT1.SmallB.FloatNum=FloatNum, BQT1.SmallB.LongNum=LongNum, BQT1.SmallB.DoubleNum=convert(DOUBLENUM, double), BQT1.SmallB.ByteNum=ByteNum, BQT1.SmallB.DateValue=DateValue, BQT1.SmallB.TimeValue=TimeValue, BQT1.SmallB.TimestampValue=TimestampValue, BQT1.SmallB.BooleanValue=BooleanValue, BQT1.SmallB.CharValue=CharValue, BQT1.SmallB.ShortValue=ShortValue, BQT1.SmallB.BigIntegerValue=convert(BigIntegerValue, biginteger), BQT1.SmallB.BigDecimalValue=BigDecimalValue, BQT1.SmallB.ObjectValue=convert(ObjectValue, object)}})
Project(groups=[Source.smallb], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue]})
Source(groups=[Source.smallb])
============================================================================
EXECUTING PlaceAccess
AFTER:
Project(groups=[anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS StringNum]})
Group(groups=[VQT.U8, anon_grp0], props={GROUP_COLS=[VQT.U8.StringNum], SYMBOL_MAP={anon_grp0.gcol0=VQT.U8.StringNum}})
Source(groups=[VQT.U8], props={NESTED_COMMAND=SELECT BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue FROM BQT1.SmallA UNION SELECT BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue FROM BQT1.SmallB, SYMBOL_MAP={VQT.U8.IntKey=BQT1.SmallA.IntKey, VQT.U8.StringKey=BQT1.SmallA.StringKey, VQT.U8.IntNum=BQT1.SmallA.IntNum, VQT.U8.StringNum=BQT1.SmallA.StringNum, VQT.U8.FloatNum=BQT1.SmallA.FloatNum, VQT.U8.LongNum=BQT1.SmallA.LongNum, VQT.U8.DoubleNum=BQT1.SmallA.DoubleNum, VQT.U8.ByteNum=BQT1.SmallA.ByteNum, VQT.U8.DateValue=BQT1.SmallA.DateValue, VQT.U8.TimeValue=BQT1.SmallA.TimeValue, VQT.U8.TimestampValue=BQT1.SmallA.TimestampValue, VQT.U8.BooleanValue=BQT1.SmallA.BooleanValue, VQT.U8.CharValue=BQT1.SmallA.CharValue, VQT.U8.ShortValue=BQT1.SmallA.ShortValue, VQT.U8.BigIntegerValue=BQT1.SmallA.BigIntegerValue, VQT.U8.BigDecimalValue=BQT1.SmallA.BigDecimalValue}})
SetOperation(groups=[], props={SET_OPERATION=UNION, USE_ALL=false})
Project(groups=[BQT1.SmallA], props={PROJECT_COLS=[BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue]})
Source(groups=[BQT1.SmallA], props={NESTED_COMMAND=SELECT IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue FROM Source.smalla, SYMBOL_MAP={BQT1.SmallA.IntKey=IntKey, BQT1.SmallA.StringKey=StringKey, BQT1.SmallA.IntNum=IntNum, BQT1.SmallA.StringNum=StringNum, BQT1.SmallA.FloatNum=FloatNum, BQT1.SmallA.LongNum=LongNum, BQT1.SmallA.DoubleNum=convert(DOUBLENUM, double), BQT1.SmallA.ByteNum=ByteNum, BQT1.SmallA.DateValue=DateValue, BQT1.SmallA.TimeValue=TimeValue, BQT1.SmallA.TimestampValue=TimestampValue, BQT1.SmallA.BooleanValue=BooleanValue, BQT1.SmallA.CharValue=CharValue, BQT1.SmallA.ShortValue=ShortValue, BQT1.SmallA.BigIntegerValue=convert(BigIntegerValue, biginteger), BQT1.SmallA.BigDecimalValue=BigDecimalValue, BQT1.SmallA.ObjectValue=convert(ObjectValue, object)}})
Project(groups=[Source.smalla], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue]})
Access(groups=[Source.smalla], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000})
Source(groups=[Source.smalla])
Project(groups=[BQT1.SmallB], props={PROJECT_COLS=[BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue]})
Source(groups=[BQT1.SmallB], props={NESTED_COMMAND=SELECT IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue FROM Source.smallb, SYMBOL_MAP={BQT1.SmallB.IntKey=IntKey, BQT1.SmallB.StringKey=StringKey, BQT1.SmallB.IntNum=IntNum, BQT1.SmallB.StringNum=StringNum, BQT1.SmallB.FloatNum=FloatNum, BQT1.SmallB.LongNum=LongNum, BQT1.SmallB.DoubleNum=convert(DOUBLENUM, double), BQT1.SmallB.ByteNum=ByteNum, BQT1.SmallB.DateValue=DateValue, BQT1.SmallB.TimeValue=TimeValue, BQT1.SmallB.TimestampValue=TimestampValue, BQT1.SmallB.BooleanValue=BooleanValue, BQT1.SmallB.CharValue=CharValue, BQT1.SmallB.ShortValue=ShortValue, BQT1.SmallB.BigIntegerValue=convert(BigIntegerValue, biginteger), BQT1.SmallB.BigDecimalValue=BigDecimalValue, BQT1.SmallB.ObjectValue=convert(ObjectValue, object)}})
Project(groups=[Source.smallb], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue]})
Access(groups=[Source.smallb], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000})
Source(groups=[Source.smallb])
============================================================================
EXECUTING AssignOutputElements
AFTER:
Project(groups=[anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS StringNum], OUTPUT_COLS=[anon_grp0.gcol0 AS StringNum]})
Group(groups=[VQT.U8, anon_grp0], props={GROUP_COLS=[VQT.U8.StringNum], SYMBOL_MAP={anon_grp0.gcol0=VQT.U8.StringNum}, OUTPUT_COLS=[anon_grp0.gcol0]})
Source(groups=[VQT.U8], props={NESTED_COMMAND=SELECT BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue FROM BQT1.SmallA UNION SELECT BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue FROM BQT1.SmallB, SYMBOL_MAP={VQT.U8.IntKey=BQT1.SmallA.IntKey, VQT.U8.StringKey=BQT1.SmallA.StringKey, VQT.U8.IntNum=BQT1.SmallA.IntNum, VQT.U8.StringNum=BQT1.SmallA.StringNum, VQT.U8.FloatNum=BQT1.SmallA.FloatNum, VQT.U8.LongNum=BQT1.SmallA.LongNum, VQT.U8.DoubleNum=BQT1.SmallA.DoubleNum, VQT.U8.ByteNum=BQT1.SmallA.ByteNum, VQT.U8.DateValue=BQT1.SmallA.DateValue, VQT.U8.TimeValue=BQT1.SmallA.TimeValue, VQT.U8.TimestampValue=BQT1.SmallA.TimestampValue, VQT.U8.BooleanValue=BQT1.SmallA.BooleanValue, VQT.U8.CharValue=BQT1.SmallA.CharValue, VQT.U8.ShortValue=BQT1.SmallA.ShortValue, VQT.U8.BigIntegerValue=BQT1.SmallA.BigIntegerValue, VQT.U8.BigDecimalValue=BQT1.SmallA.BigDecimalValue}, OUTPUT_COLS=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue]})
SetOperation(groups=[], props={SET_OPERATION=UNION, USE_ALL=false, OUTPUT_COLS=[BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue]})
Project(groups=[BQT1.SmallA], props={PROJECT_COLS=[BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue], OUTPUT_COLS=[BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue]})
Source(groups=[BQT1.SmallA], props={NESTED_COMMAND=SELECT IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue FROM Source.smalla, SYMBOL_MAP={BQT1.SmallA.IntKey=IntKey, BQT1.SmallA.StringKey=StringKey, BQT1.SmallA.IntNum=IntNum, BQT1.SmallA.StringNum=StringNum, BQT1.SmallA.FloatNum=FloatNum, BQT1.SmallA.LongNum=LongNum, BQT1.SmallA.DoubleNum=convert(DOUBLENUM, double), BQT1.SmallA.ByteNum=ByteNum, BQT1.SmallA.DateValue=DateValue, BQT1.SmallA.TimeValue=TimeValue, BQT1.SmallA.TimestampValue=TimestampValue, BQT1.SmallA.BooleanValue=BooleanValue, BQT1.SmallA.CharValue=CharValue, BQT1.SmallA.ShortValue=ShortValue, BQT1.SmallA.BigIntegerValue=convert(BigIntegerValue, biginteger), BQT1.SmallA.BigDecimalValue=BigDecimalValue}, OUTPUT_COLS=[BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue]})
Project(groups=[Source.smalla], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue], OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue]})
Access(groups=[Source.smalla], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
Source(groups=[Source.smalla], props={OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
Project(groups=[BQT1.SmallB], props={PROJECT_COLS=[BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue], OUTPUT_COLS=[BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue]})
Source(groups=[BQT1.SmallB], props={NESTED_COMMAND=SELECT IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue, convert(ObjectValue, object) AS ObjectValue FROM Source.smallb, SYMBOL_MAP={BQT1.SmallB.IntKey=IntKey, BQT1.SmallB.StringKey=StringKey, BQT1.SmallB.IntNum=IntNum, BQT1.SmallB.StringNum=StringNum, BQT1.SmallB.FloatNum=FloatNum, BQT1.SmallB.LongNum=LongNum, BQT1.SmallB.DoubleNum=convert(DOUBLENUM, double), BQT1.SmallB.ByteNum=ByteNum, BQT1.SmallB.DateValue=DateValue, BQT1.SmallB.TimeValue=TimeValue, BQT1.SmallB.TimestampValue=TimestampValue, BQT1.SmallB.BooleanValue=BooleanValue, BQT1.SmallB.CharValue=CharValue, BQT1.SmallB.ShortValue=ShortValue, BQT1.SmallB.BigIntegerValue=convert(BigIntegerValue, biginteger), BQT1.SmallB.BigDecimalValue=BigDecimalValue}, OUTPUT_COLS=[BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue]})
Project(groups=[Source.smallb], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue], OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double) AS DoubleNum, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger) AS BigIntegerValue, BigDecimalValue]})
Access(groups=[Source.smallb], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
Source(groups=[Source.smallb], props={OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
============================================================================
EXECUTING MergeVirtual
AFTER:
Project(groups=[anon_grp0])
Group(groups=[VQT.U8, anon_grp0])
Source(groups=[VQT.U8], props={NESTED_COMMAND=SELECT BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue FROM BQT1.SmallA UNION SELECT BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue FROM BQT1.SmallB, SYMBOL_MAP={VQT.U8.IntKey=IntKey, VQT.U8.StringKey=StringKey, VQT.U8.IntNum=IntNum, VQT.U8.StringNum=StringNum, VQT.U8.FloatNum=FloatNum, VQT.U8.LongNum=LongNum, VQT.U8.DoubleNum=convert(DOUBLENUM, double), VQT.U8.ByteNum=ByteNum, VQT.U8.DateValue=DateValue, VQT.U8.TimeValue=TimeValue, VQT.U8.TimestampValue=TimestampValue, VQT.U8.BooleanValue=BooleanValue, VQT.U8.CharValue=CharValue, VQT.U8.ShortValue=ShortValue, VQT.U8.BigIntegerValue=convert(BigIntegerValue, biginteger), VQT.U8.BigDecimalValue=BigDecimalValue}, OUTPUT_COLS=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue]})
SetOperation(groups=[])
Project(groups=[Source.smalla], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=[BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue]})
Access(groups=[Source.smalla], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
Source(groups=[Source.smalla])
Project(groups=[Source.smallb], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=[BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue]})
Access(groups=[Source.smallb], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
Source(groups=[Source.smallb])
============================================================================
EXECUTING CleanCriteria
AFTER:
Project(groups=[anon_grp0], props={PROJECT_COLS=[anon_grp0.gcol0 AS StringNum], OUTPUT_COLS=null})
Group(groups=[VQT.U8, anon_grp0], props={GROUP_COLS=[VQT.U8.StringNum], SYMBOL_MAP={anon_grp0.gcol0=VQT.U8.StringNum}, OUTPUT_COLS=null})
Source(groups=[VQT.U8], props={NESTED_COMMAND=SELECT BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue FROM BQT1.SmallA UNION SELECT BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue FROM BQT1.SmallB, SYMBOL_MAP={VQT.U8.IntKey=IntKey, VQT.U8.StringKey=StringKey, VQT.U8.IntNum=IntNum, VQT.U8.StringNum=StringNum, VQT.U8.FloatNum=FloatNum, VQT.U8.LongNum=LongNum, VQT.U8.DoubleNum=convert(DOUBLENUM, double), VQT.U8.ByteNum=ByteNum, VQT.U8.DateValue=DateValue, VQT.U8.TimeValue=TimeValue, VQT.U8.TimestampValue=TimestampValue, VQT.U8.BooleanValue=BooleanValue, VQT.U8.CharValue=CharValue, VQT.U8.ShortValue=ShortValue, VQT.U8.BigIntegerValue=convert(BigIntegerValue, biginteger), VQT.U8.BigDecimalValue=BigDecimalValue}, OUTPUT_COLS=null})
SetOperation(groups=[], props={SET_OPERATION=UNION, USE_ALL=false, OUTPUT_COLS=null})
Project(groups=[Source.smalla], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=null})
Access(groups=[Source.smalla], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=null})
Source(groups=[Source.smalla], props={OUTPUT_COLS=null})
Project(groups=[Source.smallb], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=null})
Access(groups=[Source.smallb], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=null})
Source(groups=[Source.smallb], props={OUTPUT_COLS=null})
============================================================================
EXECUTING PlanUnions
AFTER:
Project(groups=[anon_grp0])
Group(groups=[VQT.U8, anon_grp0])
Source(groups=[VQT.U8])
SetOperation(groups=[])
Project(groups=[Source.smalla])
Access(groups=[Source.smalla], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=null})
Source(groups=[Source.smalla])
Project(groups=[Source.smallb])
Access(groups=[Source.smallb], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=null})
Source(groups=[Source.smallb])
============================================================================
EXECUTING RaiseAccess
LOW Relational Planner convert function not supported by source Source - convert(DOUBLENUM, double) was not pushed
LOW Relational Planner convert function not supported by source Source - convert(DOUBLENUM, double) was not pushed
AFTER:
Project(groups=[anon_grp0])
Group(groups=[VQT.U8, anon_grp0])
Source(groups=[VQT.U8])
SetOperation(groups=[])
Project(groups=[Source.smalla], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=null})
Access(groups=[Source.smalla], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=null})
Source(groups=[Source.smalla])
Project(groups=[Source.smallb], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=null})
Access(groups=[Source.smallb], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=null})
Source(groups=[Source.smallb])
============================================================================
EXECUTING PushAggregates
AFTER:
Project(groups=[VQT.U8], props={PROJECT_COLS=[VQT.U8.StringNum AS StringNum], OUTPUT_COLS=null})
Source(groups=[VQT.U8], props={NESTED_COMMAND=SELECT BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue FROM BQT1.SmallA UNION SELECT BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue FROM BQT1.SmallB, SYMBOL_MAP={VQT.U8.IntKey=IntKey, VQT.U8.StringKey=StringKey, VQT.U8.IntNum=IntNum, VQT.U8.StringNum=StringNum, VQT.U8.FloatNum=FloatNum, VQT.U8.LongNum=LongNum, VQT.U8.DoubleNum=convert(DOUBLENUM, double), VQT.U8.ByteNum=ByteNum, VQT.U8.DateValue=DateValue, VQT.U8.TimeValue=TimeValue, VQT.U8.TimestampValue=TimestampValue, VQT.U8.BooleanValue=BooleanValue, VQT.U8.CharValue=CharValue, VQT.U8.ShortValue=ShortValue, VQT.U8.BigIntegerValue=convert(BigIntegerValue, biginteger), VQT.U8.BigDecimalValue=BigDecimalValue}, OUTPUT_COLS=null})
SetOperation(groups=[], props={SET_OPERATION=UNION, USE_ALL=false, OUTPUT_COLS=null})
Project(groups=[Source.smalla])
Access(groups=[Source.smalla])
Source(groups=[Source.smalla])
Project(groups=[Source.smallb])
Access(groups=[Source.smallb])
Source(groups=[Source.smallb])
============================================================================
EXECUTING AssignOutputElements
AFTER:
Project(groups=[VQT.U8], props={PROJECT_COLS=[VQT.U8.StringNum AS StringNum], OUTPUT_COLS=[VQT.U8.StringNum AS StringNum]})
Source(groups=[VQT.U8], props={NESTED_COMMAND=SELECT BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue FROM BQT1.SmallA UNION SELECT BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue FROM BQT1.SmallB, SYMBOL_MAP={VQT.U8.IntKey=IntKey, VQT.U8.StringKey=StringKey, VQT.U8.IntNum=IntNum, VQT.U8.StringNum=StringNum, VQT.U8.FloatNum=FloatNum, VQT.U8.LongNum=LongNum, VQT.U8.DoubleNum=convert(DOUBLENUM, double), VQT.U8.ByteNum=ByteNum, VQT.U8.DateValue=DateValue, VQT.U8.TimeValue=TimeValue, VQT.U8.TimestampValue=TimestampValue, VQT.U8.BooleanValue=BooleanValue, VQT.U8.CharValue=CharValue, VQT.U8.ShortValue=ShortValue, VQT.U8.BigIntegerValue=convert(BigIntegerValue, biginteger), VQT.U8.BigDecimalValue=BigDecimalValue}, OUTPUT_COLS=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue]})
SetOperation(groups=[], props={SET_OPERATION=UNION, USE_ALL=false, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue]})
Project(groups=[Source.smalla], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue]})
Access(groups=[Source.smalla], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
Source(groups=[Source.smalla], props={OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
Project(groups=[Source.smallb], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue]})
Access(groups=[Source.smallb], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
Source(groups=[Source.smallb], props={OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue]})
============================================================================
EXECUTING CalculateCost
AFTER:
Project(groups=[VQT.U8], props={PROJECT_COLS=[VQT.U8.StringNum AS StringNum], OUTPUT_COLS=[VQT.U8.StringNum AS StringNum], EST_CARDINALITY=37.5, EST_COL_STATS={VQT.U8.StringNum AS StringNum=[-1.0, -1.0]}})
Source(groups=[VQT.U8], props={NESTED_COMMAND=SELECT BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum, BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum, BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue, BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue FROM BQT1.SmallA UNION SELECT BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum, BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum, BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue, BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue FROM BQT1.SmallB, SYMBOL_MAP={VQT.U8.IntKey=IntKey, VQT.U8.StringKey=StringKey, VQT.U8.IntNum=IntNum, VQT.U8.StringNum=StringNum, VQT.U8.FloatNum=FloatNum, VQT.U8.LongNum=LongNum, VQT.U8.DoubleNum=convert(DOUBLENUM, double), VQT.U8.ByteNum=ByteNum, VQT.U8.DateValue=DateValue, VQT.U8.TimeValue=TimeValue, VQT.U8.TimestampValue=TimestampValue, VQT.U8.BooleanValue=BooleanValue, VQT.U8.CharValue=CharValue, VQT.U8.ShortValue=ShortValue, VQT.U8.BigIntegerValue=convert(BigIntegerValue, biginteger), VQT.U8.BigDecimalValue=BigDecimalValue}, OUTPUT_COLS=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue], EST_CARDINALITY=37.5, EST_COL_STATS={VQT.U8.IntKey=[-1.0, -1.0], VQT.U8.StringKey=[-1.0, -1.0], VQT.U8.IntNum=[-1.0, -1.0], VQT.U8.StringNum=[-1.0, -1.0], ...}})
SetOperation(groups=[], props={SET_OPERATION=UNION, USE_ALL=false, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], EST_CARDINALITY=37.5, EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}})
Project(groups=[Source.smalla], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], EST_CARDINALITY=50.0, EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}})
Access(groups=[Source.smalla], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue], EST_CARDINALITY=50.0, EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}})
Source(groups=[Source.smalla], props={OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue], EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}, EST_CARDINALITY=50.0})
Project(groups=[Source.smallb], props={PROJECT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], EST_CARDINALITY=50.0, EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}})
Access(groups=[Source.smallb], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue], EST_CARDINALITY=50.0, EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}})
Source(groups=[Source.smallb], props={OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue], EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}, EST_CARDINALITY=50.0})
============================================================================
EXECUTING PlanSorts
AFTER:
Project(groups=[VQT.U8])
Source(groups=[VQT.U8])
SetOperation(groups=[], props={SET_OPERATION=UNION, USE_ALL=false, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue], EST_CARDINALITY=37.5, EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}, IS_DUP_REMOVAL=true})
Project(groups=[Source.smalla])
Access(groups=[Source.smalla])
Source(groups=[Source.smalla])
Project(groups=[Source.smallb])
Access(groups=[Source.smallb])
Source(groups=[Source.smallb])
============================================================================
EXECUTING CollapseSource
AFTER:
Project(groups=[VQT.U8])
Source(groups=[VQT.U8])
SetOperation(groups=[])
Project(groups=[Source.smalla])
Access(groups=[Source.smalla], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue], EST_CARDINALITY=50.0, EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}, ATOMIC_REQUEST=SELECT IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue FROM Source.smalla})
Project(groups=[Source.smallb])
Access(groups=[Source.smallb], props={SOURCE_HINT=null, MODEL_ID=Schema name=Source, nameInSource=null, uuid=tid:06d07c309623-93f5543b-00000000, OUTPUT_COLS=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue], EST_CARDINALITY=50.0, EST_COL_STATS={IntKey=[-1.0, -1.0], StringKey=[-1.0, -1.0], IntNum=[-1.0, -1.0], StringNum=[-1.0, -1.0], ...}, ATOMIC_REQUEST=SELECT IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue FROM Source.smallb})
============================================================================
CONVERTING PLAN TREE TO PROCESS TREE
PROCESS PLAN =
ProjectNode(1) output=[VQT.U8.StringNum AS StringNum] [VQT.U8.StringNum AS StringNum]
SortNode(3) output=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue] [DUP_REMOVE]
UnionAllNode(2) output=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue]
ProjectNode(4) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue] [IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue]
AccessNode(5) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue] SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallA AS g_0
ProjectNode(6) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue] [IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue]
AccessNode(7) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue] SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallB AS g_0
============================================================================
----------------------------------------------------------------------------
OPTIMIZATION COMPLETE:
PROCESSOR PLAN:
ProjectNode(1) output=[VQT.U8.StringNum AS StringNum] [VQT.U8.StringNum AS StringNum]
SortNode(3) output=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue] [DUP_REMOVE]
UnionAllNode(2) output=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue]
ProjectNode(4) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue] [IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue]
AccessNode(5) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue] SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallA AS g_0
ProjectNode(6) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue] [IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue]
AccessNode(7) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue] SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallB AS g_0
============================================================================
08:09:33,372 DEBUG [org.teiid.PLANNER] (Worker2_QueryProcessorQueue95) [QueryAnnotation<Relational Planner, LOW,convert function not supported by source Source,convert(DOUBLENUM, double) was not pushed>, QueryAnnotation<Relational Planner, LOW,convert function not supported by source Source,convert(DOUBLENUM, double) was not pushed>]
08:09:33,372 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) ProcessTree for ITdGQFQbPGVD.7 ProjectNode(1) output=[VQT.U8.StringNum AS StringNum] [VQT.U8.StringNum AS StringNum]
SortNode(3) output=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue] [DUP_REMOVE]
UnionAllNode(2) output=[VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue]
ProjectNode(4) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue] [IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue]
AccessNode(5) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue] SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallA AS g_0
ProjectNode(6) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue] [IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, convert(DOUBLENUM, double), ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, convert(BigIntegerValue, biginteger), BigDecimalValue]
AccessNode(7) output=[IntKey, StringKey, IntNum, StringNum, FloatNum, LongNum, DOUBLENUM, ByteNum, DateValue, TimeValue, TimestampValue, BooleanValue, CharValue, ShortValue, BigIntegerValue, BigDecimalValue] SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallB AS g_0
08:09:33,373 DEBUG [org.teiid.TXN_LOG] (Worker2_QueryProcessorQueue95) before getOrCreateTransactionContext:org.teiid.dqp.internal.process.TransactionServerImpl at 7c5dfc87(ITdGQFQbPGVD)
08:09:33,373 DEBUG [org.teiid.TXN_LOG] (Worker2_QueryProcessorQueue95) after getOrCreateTransactionContext : ITdGQFQbPGVD NONE ID:NONE
08:09:33,373 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Creating TupleBuffer: 135 [anon_grp0.gcol0 AS StringNum] [class java.lang.String] batch size 1024 of type PROCESSOR
08:09:33,373 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Reserving buffer space 307200 FORCE
08:09:33,373 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Reserving buffer space 588800 FORCE
08:09:33,373 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7.5.12 Create State
08:09:33,374 TRACE [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7.5.12 no cache directive
08:09:33,374 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7.7.13 Create State
08:09:33,374 TRACE [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7.7.13 no cache directive
08:09:33,375 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Creating TupleBuffer: 136 [VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue] [class java.lang.Integer, class java.lang.String, class java.lang.Integer, class java.lang.String, class java.lang.Float, class java.lang.Long, class java.lang.Double, class java.lang.Byte, class java.sql.Date, class java.sql.Time, class java.sql.Timestamp, class java.lang.Boolean, class java.lang.Character, class java.lang.Short, class java.math.BigInteger, class java.math.BigDecimal] batch size 256 of type PROCESSOR
08:09:33,375 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) Created intermediate sort buffer 136
08:09:33,375 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7.5.12 Blocking on source query ITdGQFQbPGVD.7.5.12
08:09:33,375 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7 Blocking on source request(s).
08:09:33,375 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7.7.13 Blocking on source query ITdGQFQbPGVD.7.7.13
08:09:33,375 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7 Blocking on source request(s).
08:09:33,376 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7 Blocking on union source. 2
08:09:33,376 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Reserving buffer space 0 FORCE
08:09:33,376 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Removing TupleBuffer: 136
08:09:33,376 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Creating TupleBuffer: 137 [VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue] [class java.lang.Integer, class java.lang.String, class java.lang.Integer, class java.lang.String, class java.lang.Float, class java.lang.Long, class java.lang.Double, class java.lang.Byte, class java.sql.Date, class java.sql.Time, class java.sql.Timestamp, class java.lang.Boolean, class java.lang.Character, class java.lang.Short, class java.math.BigInteger, class java.math.BigDecimal] batch size 256 of type PROCESSOR
08:09:33,376 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) Created intermediate sort buffer 137
08:09:33,376 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Reserving buffer space 1 FORCE
08:09:33,376 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Releasing buffer space 1
08:09:33,377 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue95) Blocking on non-final TupleBuffer 137 size 0: org.teiid.common.buffer.BlockedException
at org.teiid.common.buffer.TupleBuffer$TupleBufferTupleSource.finalRow(TupleBuffer.java:61) [teiid-engine-8.7.1.6_2-redhat-6.jar:8.7.1.6_2-redhat-6]
at org.teiid.common.buffer.AbstractTupleSource.getCurrentTuple(AbstractTupleSource.java:70) [teiid-engine-8.7.1.6_2-redhat-6.jar:8.7.1.6_2-redhat-6]
at org.teiid.common.buffer.AbstractTupleSource.nextTuple(AbstractTupleSource.java:48) [teiid-engine-8.7.1.6_2-redhat-6.jar:8.7.1.6_2-redhat-6]
at org.teiid.query.processor.relational.SortNode.outputPhase(SortNode.java:133) [teiid-engine-8.7.1.6_2-redhat-6.jar:8.7.1.6_2-redhat-6]
at org.teiid.query.processor.relational.SortNode.nextBatchDirect(SortNode.java:94) [teiid-engine-8.7.1.6_2-redhat-6.jar:8.7.1.6_2-redhat-6]
at org.teiid.query.processor.relational.RelationalNode.nextBatch(RelationalNode.java:278) [teiid-engine-8.7.1.6_2-redhat-6.jar:8.7.1.6_2-redhat-6]
at org.teiid.query.processor.relational.ProjectNode.nextBatchDirect(ProjectNode.java:146) [teiid-engine-8.7.1.6_2-redhat-6.jar:8.7.1.6_2-redhat-6]
08:09:33,377 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) Request Thread ITdGQFQbPGVD.7 - processor blocked
08:09:33,378 TRACE [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue95) ITdGQFQbPGVD.7 end processing WORKING
08:09:33,378 TRACE [org.teiid.RUNTIME] (Worker3_QueryProcessorQueue96) Beginning work with virtual worker Worker3_QueryProcessorQueue96
08:09:33,379 DEBUG [org.teiid.PROCESSOR] (Worker3_QueryProcessorQueue96) Running task for parent thread Worker2_QueryProcessorQueue95
08:09:33,379 DEBUG [org.teiid.CONNECTOR] (Worker3_QueryProcessorQueue96) ITdGQFQbPGVD.7.5.12 Processing NEW request: SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallA AS g_0
08:09:33,380 DEBUG [org.teiid.CONNECTOR] (Worker3_QueryProcessorQueue96) Source-specific command: SELECT g_0.intkey, g_0.stringkey, g_0.intnum, g_0.stringnum, g_0.floatnum, g_0.longnum, g_0.doublenum, g_0.bytenum, g_0.datevalue, g_0.timevalue, g_0.timestampvalue, g_0.booleanvalue, g_0.charvalue, g_0.shortvalue, g_0.bigintegervalue, g_0.bigdecimalvalue FROM smalla AS g_0
08:09:33,381 DEBUG [org.teiid.CONNECTOR] (Worker3_QueryProcessorQueue96) ITdGQFQbPGVD.7.5.12 Obtained execution
08:09:33,378 TRACE [org.teiid.RUNTIME] (Worker4_QueryProcessorQueue97) Beginning work with virtual worker Worker4_QueryProcessorQueue97
08:09:33,383 DEBUG [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue97) Running task for parent thread Worker2_QueryProcessorQueue95
08:09:33,383 DEBUG [org.teiid.CONNECTOR] (Worker4_QueryProcessorQueue97) ITdGQFQbPGVD.7.7.13 Processing NEW request: SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallB AS g_0
08:09:33,391 DEBUG [org.teiid.CONNECTOR] (Worker4_QueryProcessorQueue97) Source-specific command: SELECT g_0.intkey, g_0.stringkey, g_0.intnum, g_0.stringnum, g_0.floatnum, g_0.longnum, g_0.doublenum, g_0.bytenum, g_0.datevalue, g_0.timevalue, g_0.timestampvalue, g_0.booleanvalue, g_0.charvalue, g_0.shortvalue, g_0.bigintegervalue, g_0.bigdecimalvalue FROM smallb AS g_0
08:09:33,391 DEBUG [org.teiid.CONNECTOR] (Worker4_QueryProcessorQueue97) ITdGQFQbPGVD.7.7.13 Obtained execution
08:09:33,526 DEBUG [org.teiid.CONNECTOR] (Worker3_QueryProcessorQueue96) ITdGQFQbPGVD.7.5.12 Executed command
08:09:33,526 DEBUG [org.teiid.CONNECTOR] (Worker4_QueryProcessorQueue97) ITdGQFQbPGVD.7.7.13 Executed command
08:09:33,526 DEBUG [org.teiid.CONNECTOR] (Worker3_QueryProcessorQueue96) ITdGQFQbPGVD.7.5.12 Processing MORE request
08:09:33,526 DEBUG [org.teiid.CONNECTOR] (Worker4_QueryProcessorQueue97) ITdGQFQbPGVD.7.7.13 Processing MORE request
08:09:33,526 DEBUG [org.teiid.CONNECTOR] (Worker3_QueryProcessorQueue96) ITdGQFQbPGVD.7.5.12 Getting results from connector
08:09:33,526 DEBUG [org.teiid.CONNECTOR] (Worker4_QueryProcessorQueue97) ITdGQFQbPGVD.7.7.13 Getting results from connector
08:09:33,924 DEBUG [org.teiid.CONNECTOR] (Worker3_QueryProcessorQueue96) ITdGQFQbPGVD.7.5.12 Obtained last batch, total row count: 50
08:09:33,926 DEBUG [org.teiid.CONNECTOR] (Worker4_QueryProcessorQueue97) ITdGQFQbPGVD.7.7.13 Obtained last batch, total row count: 50
08:09:33,927 TRACE [org.teiid.PROCESSOR] (Worker3_QueryProcessorQueue96) ITdGQFQbPGVD.7 more work IDLE
08:09:33,927 TRACE [org.teiid.RUNTIME] (Worker2_QueryProcessorQueue98) Beginning work with virtual worker Worker2_QueryProcessorQueue98
08:09:33,928 TRACE [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7 start processing MORE_WORK
08:09:33,928 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) Request Thread ITdGQFQbPGVD.7 with state PROCESSING
08:09:33,928 TRACE [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue97) ITdGQFQbPGVD.7 more work WORKING
08:09:33,928 TRACE [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue97) ITdGQFQbPGVD.7 more work MORE_WORK
08:09:33,929 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Creating TupleBuffer: 138 [VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue] [class java.lang.Integer, class java.lang.String, class java.lang.Integer, class java.lang.String, class java.lang.Float, class java.lang.Long, class java.lang.Double, class java.lang.Byte, class java.sql.Date, class java.sql.Time, class java.sql.Timestamp, class java.lang.Boolean, class java.lang.Character, class java.lang.Short, class java.math.BigInteger, class java.math.BigDecimal] batch size 256 of type PROCESSOR
08:09:33,929 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) Created intermediate sort buffer 138
08:09:33,929 TRACE [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) closed atomic-request: ITdGQFQbPGVD.7.5.12
08:09:33,930 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7.5.12 Remove State
08:09:33,930 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7.5.12 Processing Close : SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallA AS g_0
08:09:33,931 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7.5.12 Closed execution
08:09:33,931 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7.5.12 Closed connection
08:09:33,932 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Releasing buffer space 294400
08:09:33,932 TRACE [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) closed atomic-request: ITdGQFQbPGVD.7.7.13
08:09:33,933 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7.7.13 Remove State
08:09:33,933 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7.7.13 Processing Close : SELECT g_0.IntKey, g_0.StringKey, g_0.IntNum, g_0.StringNum, g_0.FloatNum, g_0.LongNum, g_0.DoubleNum, g_0.ByteNum, g_0.DateValue, g_0.TimeValue, g_0.TimestampValue, g_0.BooleanValue, g_0.CharValue, g_0.ShortValue, g_0.BigIntegerValue, g_0.BigDecimalValue FROM Source.SmallB AS g_0
08:09:33,934 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7.7.13 Closed execution
08:09:33,934 DEBUG [org.teiid.CONNECTOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7.7.13 Closed connection
08:09:33,934 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Releasing buffer space 294400
08:09:33,934 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Add batch to BufferManager 138 63 with size estimate 57758
08:09:33,935 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Reserving buffer space 57700 FORCE
08:09:33,935 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) 138 getting batch 63 total reads 55 reference hits 0
08:09:33,945 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Creating TupleBuffer: 139 [VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue] [class java.lang.Integer, class java.lang.String, class java.lang.Integer, class java.lang.String, class java.lang.Float, class java.lang.Long, class java.lang.Double, class java.lang.Byte, class java.sql.Date, class java.sql.Time, class java.sql.Timestamp, class java.lang.Boolean, class java.lang.Character, class java.lang.Short, class java.math.BigInteger, class java.math.BigDecimal] batch size 256 of type PROCESSOR
08:09:33,946 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) Created intermediate sort buffer 139
08:09:33,946 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Add batch to BufferManager 139 64 with size estimate 29516
08:09:33,946 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Releasing buffer space 57700
08:09:33,947 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Removing TupleBuffer: 138
08:09:33,947 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Reserving buffer space 295424 FORCE
08:09:33,947 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Creating TupleBuffer: 140 [VQT.U8.IntKey, VQT.U8.StringKey, VQT.U8.IntNum, VQT.U8.StringNum, VQT.U8.FloatNum, VQT.U8.LongNum, VQT.U8.DoubleNum, VQT.U8.ByteNum, VQT.U8.DateValue, VQT.U8.TimeValue, VQT.U8.TimestampValue, VQT.U8.BooleanValue, VQT.U8.CharValue, VQT.U8.ShortValue, VQT.U8.BigIntegerValue, VQT.U8.BigDecimalValue] [class java.lang.Integer, class java.lang.String, class java.lang.Integer, class java.lang.String, class java.lang.Float, class java.lang.Long, class java.lang.Double, class java.lang.Byte, class java.sql.Date, class java.sql.Time, class java.sql.Timestamp, class java.lang.Boolean, class java.lang.Character, class java.lang.Short, class java.math.BigInteger, class java.math.BigDecimal] batch size 256 of type PROCESSOR
08:09:33,947 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) Created intermediate sort buffer 140
08:09:33,947 TRACE [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) Merging 2 sublists out of 2
08:09:33,947 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) 139 getting batch 64 total reads 56 reference hits 0
08:09:33,948 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Removing TupleBuffer: 139
08:09:33,948 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Add batch to BufferManager 140 65 with size estimate 29516
08:09:33,948 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Releasing buffer space 295424
08:09:33,948 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Add batch to BufferManager 137 66 with size estimate 29516
08:09:33,948 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Removing TupleBuffer: 140
08:09:33,948 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Removing batch from BufferManager 140 65
08:09:33,948 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) 137 getting batch 66 total reads 57 reference hits 0
08:09:33,948 DEBUG [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Removing TupleBuffer: 137
08:09:33,948 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) QueryProcessor: closing processor
08:09:33,948 TRACE [org.teiid.BUFFER_MGR] (Worker2_QueryProcessorQueue98) Releasing buffer space 307200
08:09:33,948 DEBUG [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) [RequestWorkItem.sendResultsIfNeeded] requestID: ITdGQFQbPGVD.7 resultsID: 135 done: true
08:09:33,949 DEBUG [org.teiid.TRANSPORT] (Worker2_QueryProcessorQueue98) send message: MessageHolder: key=129 contents=ResultsMessage rowCount=50 finalRow=50
08:09:33,951 DEBUG [org.teiid.TRANSPORT] (New I/O worker #1) processing message:MessageHolder: key=130 contents=Invoke interface org.teiid.client.DQP.getMetadata
08:09:33,951 TRACE [org.teiid.PROCESSOR] (New I/O worker #1) before getMetadata:org.teiid.dqp.internal.process.DQPCore at 4ac5a2ad(7)
08:09:33,951 TRACE [org.teiid.PROCESSOR] (New I/O worker #1) after getMetadata : org.teiid.client.metadata.MetadataResult at f2d9ee4
08:09:33,951 DEBUG [org.teiid.TRANSPORT] (New I/O worker #1) send message: MessageHolder: key=130 contents=org.teiid.client.metadata.MetadataResult at f2d9ee4
08:09:33,959 TRACE [org.teiid.PROCESSOR] (Worker2_QueryProcessorQueue98) ITdGQFQbPGVD.7 end processing MORE_WORK
08:09:33,960 TRACE [org.teiid.RUNTIME] (Worker4_QueryProcessorQueue99) Beginning work with virtual worker Worker4_QueryProcessorQueue99
08:09:33,960 TRACE [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue99) ITdGQFQbPGVD.7 start processing MORE_WORK
08:09:33,960 DEBUG [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue99) Request Thread ITdGQFQbPGVD.7 with state PROCESSING
08:09:33,960 TRACE [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue99) ITdGQFQbPGVD.7 end processing WORKING
08:09:33,961 DEBUG [org.teiid.TRANSPORT] (New I/O worker #1) processing message:MessageHolder: key=131 contents=Invoke interface org.teiid.client.DQP.closeRequest
08:09:33,961 TRACE [org.teiid.PROCESSOR] (New I/O worker #1) before closeRequest:org.teiid.dqp.internal.process.DQPCore at 4ac5a2ad(7)
08:09:33,961 DEBUG [org.teiid.PROCESSOR] (New I/O worker #1) closeQuery for requestID=ITdGQFQbPGVD.7
08:09:33,961 TRACE [org.teiid.PROCESSOR] (New I/O worker #1) ITdGQFQbPGVD.7 more work IDLE
08:09:33,961 TRACE [org.teiid.PROCESSOR] (New I/O worker #1) after closeRequest : org.teiid.client.util.ResultsFuture at 621c192a
08:09:33,961 DEBUG [org.teiid.TRANSPORT] (New I/O worker #1) send message: MessageHolder: key=131 contents=null
08:09:33,962 TRACE [org.teiid.RUNTIME] (Worker4_QueryProcessorQueue100) Beginning work with virtual worker Worker4_QueryProcessorQueue100
08:09:33,962 TRACE [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue100) ITdGQFQbPGVD.7 start processing MORE_WORK
08:09:33,962 DEBUG [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue100) Request Thread ITdGQFQbPGVD.7 with state PROCESSING
08:09:33,962 DEBUG [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue100) Removing tuplesource for the request ITdGQFQbPGVD.7
08:09:33,962 DEBUG [org.teiid.BUFFER_MGR] (Worker4_QueryProcessorQueue100) Removing TupleBuffer: 135
08:09:33,963 TRACE [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue100) ITdGQFQbPGVD.7 end processing WORKING
08:09:33,963 TRACE [org.teiid.PROCESSOR] (Worker4_QueryProcessorQueue100) ITdGQFQbPGVD.7 done processing WORKING
{code}
> HBase - GROUP BY clause returns duplicates results
> --------------------------------------------------
>
> Key: TEIID-3775
> URL: https://issues.jboss.org/browse/TEIID-3775
> Project: Teiid
> Issue Type: Bug
> Affects Versions: 8.7.1.6_2
> Reporter: Juraj Duráni
> Assignee: Steven Hawkins
>
> I have a view defined as follows:
> {code:sql}
> CREATE VIEW U8 (IntKey integer,
> StringKey string,
> IntNum integer,
> StringNum string,
> FloatNum float,
> LongNum long,
> DoubleNum double,
> ByteNum byte,
> DateValue date,
> TimeValue time,
> TimestampValue timestamp,
> BooleanValue boolean,
> CharValue char,
> ShortValue short,
> BigIntegerValue biginteger,
> BigDecimalValue bigdecimal)
> AS
> SELECT BQT1.SmallA.IntKey, BQT1.SmallA.StringKey, BQT1.SmallA.IntNum, BQT1.SmallA.StringNum,
> BQT1.SmallA.FloatNum, BQT1.SmallA.LongNum, BQT1.SmallA.DoubleNum, BQT1.SmallA.ByteNum,
> BQT1.SmallA.DateValue, BQT1.SmallA.TimeValue, BQT1.SmallA.TimestampValue, BQT1.SmallA.BooleanValue,
> BQT1.SmallA.CharValue, BQT1.SmallA.ShortValue, BQT1.SmallA.BigIntegerValue, BQT1.SmallA.BigDecimalValue
> FROM BQT1.SmallA
> UNION
> SELECT BQT1.SmallB.IntKey, BQT1.SmallB.StringKey, BQT1.SmallB.IntNum, BQT1.SmallB.StringNum,
> BQT1.SmallB.FloatNum, BQT1.SmallB.LongNum, BQT1.SmallB.DoubleNum, BQT1.SmallB.ByteNum,
> BQT1.SmallB.DateValue, BQT1.SmallB.TimeValue, BQT1.SmallB.TimestampValue, BQT1.SmallB.BooleanValue,
> BQT1.SmallB.CharValue, BQT1.SmallB.ShortValue, BQT1.SmallB.BigIntegerValue, BQT1.SmallB.BigDecimalValue
> FROM BQT1.SmallB ORDER BY IntKey;
> {code}
> Query *SELECT StringNum FROM VQT.U8 GROUP BY StringNum* returns duplicate results (multiple null).
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
More information about the teiid-issues
mailing list