[JBoss JIRA] (TEIID-4130) Prevent blocked exceptions from being thrown in AccessNode open
by RH Bugzilla Integration (JIRA)
[ https://issues.jboss.org/browse/TEIID-4130?page=com.atlassian.jira.plugin... ]
RH Bugzilla Integration commented on TEIID-4130:
------------------------------------------------
Juraj Duráni <jdurani(a)redhat.com> changed the Status of [bug 1326832|https://bugzilla.redhat.com/show_bug.cgi?id=1326832] from ON_QA to VERIFIED
> Prevent blocked exceptions from being thrown in AccessNode open
> ---------------------------------------------------------------
>
> Key: TEIID-4130
> URL: https://issues.jboss.org/browse/TEIID-4130
> Project: Teiid
> Issue Type: Bug
> Components: Query Engine
> Affects Versions: 8.7
> Reporter: Steven Hawkins
> Assignee: Steven Hawkins
> Fix For: 9.0, 8.12.5, 8.7.6.6_2, 8.13.4
>
>
> Having the access node block in open can lead to unintended consequences in parent nodes. For example with tuplesource caching it can create additional tuplesource instances such the cached source is closed prematurely (as it thinks that all readers have been satisfied). This results in exceptions similar to:
> TEIID30019 Unexpected exception for request 2TLgULsEBZvO.8: java.lang.AssertionError: ASSERTION FAILED: expected reference to be not null
> ...
> at org.teiid.common.buffer.TupleBuffer.getBatch(TupleBuffer.java:286) \[teiid-engine-8.7.5.6_2-redhat-1.jar:8.7.5.6_2-redhat-1]
> at org.teiid.dqp.internal.process.TupleSourceCache$CopyOnReadTupleSource.nextTuple(TupleSourceCache.java:103) \[teiid-engine-8.7.5.6_2-redhat-1.jar:8.7.5.6_2-redhat-1]
> ...
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months
[JBoss JIRA] (TEIID-4179) Update the documentation of the ODBC with connection properties
by Ramesh Reddy (JIRA)
[ https://issues.jboss.org/browse/TEIID-4179?page=com.atlassian.jira.plugin... ]
Ramesh Reddy resolved TEIID-4179.
---------------------------------
Fix Version/s: 9.0
Resolution: Done
> Update the documentation of the ODBC with connection properties
> ----------------------------------------------------------------
>
> Key: TEIID-4179
> URL: https://issues.jboss.org/browse/TEIID-4179
> Project: Teiid
> Issue Type: Task
> Components: Documentation
> Reporter: Ramesh Reddy
> Assignee: Ramesh Reddy
> Fix For: 9.0
>
>
> ConnSettings =SET resultSetCacheMode TO 'true'
> That will set the connection property. Please this applies any connection property. If there are multiple, you delimit them by ; Similarly in Windows DSN wizard too.
> In the vdb.xml, you can add a vdb level property like
> <vdb name="...">
> <property name="connection.resultSetCacheMode" value="true"/>
> ...
> </vdb>
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months
[JBoss JIRA] (TEIID-4205) send results proactively under a cursor as it looks like the ODBC client requires a transaction.
by Ramesh Reddy (JIRA)
[ https://issues.jboss.org/browse/TEIID-4205?page=com.atlassian.jira.plugin... ]
Ramesh Reddy commented on TEIID-4205:
-------------------------------------
[~shawkins] As I remember "UseDeclareFetch=1" will do automatic cursor based walking of the results, but did not see any transaction wrapping before. It may be correct that Teiid ignored the transaction calls in earlier versions. Is there a reason why there is transaction wrapping?
When UseDelcareFetch=0 or not available, the odbc driver (used to) download all the rows before returning the first row back to the user.
> send results proactively under a cursor as it looks like the ODBC client requires a transaction.
> ------------------------------------------------------------------------------------------------
>
> Key: TEIID-4205
> URL: https://issues.jboss.org/browse/TEIID-4205
> Project: Teiid
> Issue Type: Feature Request
> Components: ODBC, Server
> Affects Versions: 8.7.5.6_2
> Reporter: Debbie Steigner
> Assignee: Steven Hawkins
>
> Currently when querying large resultsets with ODBC the results are not sent as soon as the batch is logically available (like we do for JDBC)
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months
[JBoss JIRA] (TEIID-4181) Accumulo translator: AccumuloDataTypeManager various data types issues
by Ramesh Reddy (JIRA)
[ https://issues.jboss.org/browse/TEIID-4181?page=com.atlassian.jira.plugin... ]
Ramesh Reddy resolved TEIID-4181.
---------------------------------
Resolution: Done
Reverted the lexicoder based key column encoding to match up with other tools like sqoop, accumulo shell. The downside is to filter based on ROWID (PK) in comparative situations (>, >=, <, <=) the scan iterators will be used which will have less performance compare to the range based selection.
> Accumulo translator: AccumuloDataTypeManager various data types issues
> ----------------------------------------------------------------------
>
> Key: TEIID-4181
> URL: https://issues.jboss.org/browse/TEIID-4181
> Project: Teiid
> Issue Type: Bug
> Components: Misc. Connectors
> Affects Versions: 8.12.5
> Reporter: Jan Stastny
> Assignee: Ramesh Reddy
> Priority: Blocker
> Fix For: 9.0, 8.12.5
>
>
> When using Accumulo 1.6.5 as datasource I experience problem when querying accumulo tables using accumulo translator. It seems to be data type related issue.
> Vdb used:
> {code:plain}
> <vdb name="accumulo" version="1">
> <model name="accumulo">
> <property name="importer.ColumnNamePattern" value="{CQ}" />
> <source name="node-one" translator-name="accumulo" connection-jndi-name="java:/accumulo-ds"/>
> <metadata type="DDL">
> <![CDATA[
> CREATE FOREIGN TABLE "SmallA" (
> rowid integer OPTIONS (UPDATABLE FALSE, SEARCHABLE 'All_Except_Like'),
> BigDecimalValue bigdecimal OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'BIGDECIMALVALUE', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> IntNum integer OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'INTNUM', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> BigIntegerValue biginteger OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'BIGINTEGERVALUE', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> BooleanValue boolean OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'BOOLEANVALUE', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> ByteNum byte OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'BYTENUM', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> CharValue char OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'CHARVALUE', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> DateValue date OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'DATEVALUE', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> DoubleNum double OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'DOUBLENUM', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> FloatNum float OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'FLOATNUM', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> LongNum long OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'LONGNUM', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> ShortValue short OPTIONS(SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'SHORTVALUE', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> StringKey string OPTIONS (SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'STRINGKEY', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> StringNum string OPTIONS (SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'STRINGNUM', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> TimestampValue timestamp OPTIONS (SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'TIMESTAMPVALUE', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> TimeValue time OPTIONS (SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'TIMEVALUE', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> ObjectValue object OPTIONS (SEARCHABLE 'All_Except_Like', "teiid_accumulo:CF" 'name', "teiid_accumulo:CQ" 'objectvalue', "teiid_accumulo:VALUE-IN" '{VALUE}'),
> CONSTRAINT PK0 PRIMARY KEY(rowid)
> );
> ]]>
> </metadata>
> </model>
> </vdb>
> {code}
> * rowid of type integer:
> {code:plain}
> 09:09:52,927 DEBUG [org.teiid.TRANSPORT] (New I/O worker #2) processing message:MessageHolder: key=47 contents=Invoke interface org.teiid.client.DQP.executeRequest
> 09:09:52,930 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue9) Request Thread V4Nk+ZmH4VoM.3 with state NEW
> 09:09:52,930 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue9) V4Nk+ZmH4VoM.3 Command has no cache hint and result set cache mode is not on.
> 09:09:52,930 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue9) V4Nk+ZmH4VoM.3 executing SELECT rowid FROM accumulo.SMallA
> 09:09:52,932 DEBUG [org.teiid.PLANNER] (Worker0_QueryProcessorQueue9) [LOW [Relational Planner] limit not supported by source accumulo - limit node not pushed TupleLimit(groups=[], props={MAX_TUPLE_LIMIT=100}, LOW [Relational Planner] limit not supported by source accumulo - limit node not pushed TupleLimit(groups=[], props={MAX_TUPLE_LIMIT=100, OUTPUT_COLS=[accumulo.SmallA.rowid]}]
> 09:09:52,933 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue9) ProcessTree for V4Nk+ZmH4VoM.3 LimitNode(0) output=[accumulo.SmallA.rowid] limit 100
> AccessNode(1) output=[accumulo.SmallA.rowid] SELECT accumulo.SmallA.rowid FROM accumulo.SmallA
> 09:09:52,933 DEBUG [org.teiid.TXN_LOG] (Worker0_QueryProcessorQueue9) before getOrCreateTransactionContext:org.teiid.dqp.internal.process.TransactionServerImpl@748e7221(V4Nk+ZmH4VoM)
> 09:09:52,933 DEBUG [org.teiid.TXN_LOG] (Worker0_QueryProcessorQueue9) after getOrCreateTransactionContext : V4Nk+ZmH4VoM NONE ID:NONE
> 09:09:52,933 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue9) Creating TupleBuffer: 3 [accumulo.SmallA.rowid] [class java.lang.Integer] batch size 2048 of type PROCESSOR
> 09:09:52,933 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue9) V4Nk+ZmH4VoM.3.1.3 Create State
> 09:09:52,934 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue9) V4Nk+ZmH4VoM.3.1.3 Blocking on source query V4Nk+ZmH4VoM.3.1.3
> 09:09:52,934 DEBUG [org.teiid.PROCESSOR] (Worker1_QueryProcessorQueue10) Running task for parent thread Worker0_QueryProcessorQueue9
> 09:09:52,934 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue9) V4Nk+ZmH4VoM.3 Blocking on source request(s).
> 09:09:52,934 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue10) V4Nk+ZmH4VoM.3.1.3 Processing NEW request: SELECT accumulo.SmallA.rowid FROM accumulo.SmallA
> 09:09:52,934 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue9) Request Thread V4Nk+ZmH4VoM.3 - processor blocked
> 09:09:52,934 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue10) V4Nk+ZmH4VoM.3.1.3 Obtained execution
> 09:09:52,935 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue10) V4Nk+ZmH4VoM.3.1.3 Executed command
> 09:09:52,935 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue10) V4Nk+ZmH4VoM.3.1.3 Processing MORE request
> 09:09:52,935 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue10) V4Nk+ZmH4VoM.3.1.3 Getting results from connector
> 09:09:53,679 ERROR [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue10) Connector worker process failed for atomic-request=V4Nk+ZmH4VoM.3.1.3: java.lang.IllegalArgumentException: Unexpected length 48
> at org.apache.accumulo.core.client.lexicoder.UIntegerLexicoder.decode(UIntegerLexicoder.java:58) [accumulo-core-1.6.4.jar:1.6.4]
> at org.apache.accumulo.core.client.lexicoder.IntegerLexicoder.decode(IntegerLexicoder.java:36) [accumulo-core-1.6.4.jar:1.6.4]
> at org.teiid.translator.accumulo.AccumuloDataTypeManager.fromLexiCode(AccumuloDataTypeManager.java:257) [translator-accumulo-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.translator.accumulo.AccumuloQueryExecution.nextRow(AccumuloQueryExecution.java:193) [translator-accumulo-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.translator.accumulo.AccumuloQueryExecution.next(AccumuloQueryExecution.java:171) [translator-accumulo-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.handleBatch(ConnectorWorkItem.java:429) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.more(ConnectorWorkItem.java:229) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [rt.jar:1.8.0_51]
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) [rt.jar:1.8.0_51]
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.8.0_51]
> at java.lang.reflect.Method.invoke(Method.java:497) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.datamgr.ConnectorManager$1.invoke(ConnectorManager.java:211) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at com.sun.proxy.$Proxy125.more(Unknown Source)
> at org.teiid.dqp.internal.process.DataTierTupleSource.getResults(DataTierTupleSource.java:309) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:112) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:108) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.process.FutureWork.run(FutureWork.java:65) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:276) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51]
> 09:09:53,689 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue11) Request Thread V4Nk+ZmH4VoM.3 with state PROCESSING
> 09:09:53,690 ERROR [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue11) TEIID30019 Unexpected exception for request V4Nk+ZmH4VoM.3: java.lang.IllegalArgumentException: Unexpected length 48
> at org.apache.accumulo.core.client.lexicoder.UIntegerLexicoder.decode(UIntegerLexicoder.java:58)
> at org.apache.accumulo.core.client.lexicoder.IntegerLexicoder.decode(IntegerLexicoder.java:36)
> at org.teiid.translator.accumulo.AccumuloDataTypeManager.fromLexiCode(AccumuloDataTypeManager.java:257)
> at org.teiid.translator.accumulo.AccumuloQueryExecution.nextRow(AccumuloQueryExecution.java:193)
> at org.teiid.translator.accumulo.AccumuloQueryExecution.next(AccumuloQueryExecution.java:171)
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.handleBatch(ConnectorWorkItem.java:429) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.more(ConnectorWorkItem.java:229) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [rt.jar:1.8.0_51]
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) [rt.jar:1.8.0_51]
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.8.0_51]
> at java.lang.reflect.Method.invoke(Method.java:497) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.datamgr.ConnectorManager$1.invoke(ConnectorManager.java:211) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at com.sun.proxy.$Proxy125.more(Unknown Source)
> at org.teiid.dqp.internal.process.DataTierTupleSource.getResults(DataTierTupleSource.java:309) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:112) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:108) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.process.FutureWork.run(FutureWork.java:65) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:276) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51]
> 09:09:53,694 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue11) QueryProcessor: closing processor
> 09:09:53,694 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue11) V4Nk+ZmH4VoM.3.1.3 Remove State
> 09:09:53,695 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue11) V4Nk+ZmH4VoM.3.1.3 Processing Close : SELECT accumulo.SmallA.rowid FROM accumulo.SmallA
> 09:09:53,695 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue11) V4Nk+ZmH4VoM.3.1.3 Closed execution
> 09:09:53,695 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue11) V4Nk+ZmH4VoM.3.1.3 Closed connection
> 09:09:53,698 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue11) Removing tuplesource for the request V4Nk+ZmH4VoM.3
> 09:09:53,699 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue11) Removing TupleBuffer: 3
> 09:09:53,699 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue11) V4Nk+ZmH4VoM.3 Finished Processing
> 09:09:53,700 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue11) java.lang.IllegalArgumentException: Unexpected length 48 Sending error to client V4Nk+ZmH4VoM.3
> 09:09:53,701 DEBUG [org.teiid.TRANSPORT] (Worker0_QueryProcessorQueue11) send message: MessageHolder: key=47 contents=ResultsMessage rowCount=0 finalRow=-1
> {code}
> * column of type string/char/bigdecimal/long/integer:
> {code:plain}
> 09:11:28,927 DEBUG [org.teiid.TRANSPORT] (New I/O worker #2) processing message:MessageHolder: key=50 contents=Invoke interface org.teiid.client.DQP.executeRequest
> 09:11:28,928 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue12) Request Thread V4Nk+ZmH4VoM.4 with state NEW
> 09:11:28,928 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue12) V4Nk+ZmH4VoM.4 Command has no cache hint and result set cache mode is not on.
> 09:11:28,928 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue12) V4Nk+ZmH4VoM.4 executing SELECT Stringkey FROM accumulo.SMallA
> 09:11:28,929 DEBUG [org.teiid.PLANNER] (Worker0_QueryProcessorQueue12) [LOW [Relational Planner] limit not supported by source accumulo - limit node not pushed TupleLimit(groups=[], props={MAX_TUPLE_LIMIT=100}, LOW [Relational Planner] limit not supported by source accumulo - limit node not pushed TupleLimit(groups=[], props={MAX_TUPLE_LIMIT=100, OUTPUT_COLS=[accumulo.SmallA.StringKey]}]
> 09:11:28,929 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue12) ProcessTree for V4Nk+ZmH4VoM.4 LimitNode(0) output=[accumulo.SmallA.StringKey] limit 100
> AccessNode(1) output=[accumulo.SmallA.StringKey] SELECT accumulo.SmallA.StringKey FROM accumulo.SmallA
> 09:11:28,929 DEBUG [org.teiid.TXN_LOG] (Worker0_QueryProcessorQueue12) before getOrCreateTransactionContext:org.teiid.dqp.internal.process.TransactionServerImpl@748e7221(V4Nk+ZmH4VoM)
> 09:11:28,929 DEBUG [org.teiid.TXN_LOG] (Worker0_QueryProcessorQueue12) after getOrCreateTransactionContext : V4Nk+ZmH4VoM NONE ID:NONE
> 09:11:28,929 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue12) Creating TupleBuffer: 4 [accumulo.SmallA.StringKey] [class java.lang.String] batch size 1024 of type PROCESSOR
> 09:11:28,929 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue12) V4Nk+ZmH4VoM.4.1.4 Create State
> 09:11:28,929 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue12) V4Nk+ZmH4VoM.4.1.4 Blocking on source query V4Nk+ZmH4VoM.4.1.4
> 09:11:28,930 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue12) V4Nk+ZmH4VoM.4 Blocking on source request(s).
> 09:11:28,930 DEBUG [org.teiid.PROCESSOR] (Worker1_QueryProcessorQueue13) Running task for parent thread Worker0_QueryProcessorQueue12
> 09:11:28,930 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue12) Request Thread V4Nk+ZmH4VoM.4 - processor blocked
> 09:11:28,930 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue13) V4Nk+ZmH4VoM.4.1.4 Processing NEW request: SELECT accumulo.SmallA.StringKey FROM accumulo.SmallA
> 09:11:28,930 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue13) V4Nk+ZmH4VoM.4.1.4 Obtained execution
> 09:11:28,931 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue13) V4Nk+ZmH4VoM.4.1.4 Executed command
> 09:11:28,931 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue13) V4Nk+ZmH4VoM.4.1.4 Processing MORE request
> 09:11:28,932 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue13) V4Nk+ZmH4VoM.4.1.4 Getting results from connector
> 09:11:29,462 ERROR [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue13) Connector worker process failed for atomic-request=V4Nk+ZmH4VoM.4.1.4: java.io.EOFException
> at java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2335) [rt.jar:1.8.0_51]
> at java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2804) [rt.jar:1.8.0_51]
> at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:802) [rt.jar:1.8.0_51]
> at java.io.ObjectInputStream.<init>(ObjectInputStream.java:299) [rt.jar:1.8.0_51]
> at org.teiid.translator.accumulo.AccumuloDataTypeManager.deserialize(AccumuloDataTypeManager.java:164) [translator-accumulo-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.translator.accumulo.AccumuloQueryExecution.nextRow(AccumuloQueryExecution.java:196) [translator-accumulo-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.translator.accumulo.AccumuloQueryExecution.next(AccumuloQueryExecution.java:171) [translator-accumulo-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.handleBatch(ConnectorWorkItem.java:429) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.more(ConnectorWorkItem.java:229) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [rt.jar:1.8.0_51]
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) [rt.jar:1.8.0_51]
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.8.0_51]
> at java.lang.reflect.Method.invoke(Method.java:497) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.datamgr.ConnectorManager$1.invoke(ConnectorManager.java:211) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at com.sun.proxy.$Proxy125.more(Unknown Source)
> at org.teiid.dqp.internal.process.DataTierTupleSource.getResults(DataTierTupleSource.java:309) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:112) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:108) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.process.FutureWork.run(FutureWork.java:65) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:276) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51]
> 09:11:29,468 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue14) Request Thread V4Nk+ZmH4VoM.4 with state PROCESSING
> 09:11:29,469 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue14) V4Nk+ZmH4VoM.4.1.4 Remove State
> 09:11:29,469 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue14) V4Nk+ZmH4VoM.4.1.4 Processing Close : SELECT accumulo.SmallA.StringKey FROM accumulo.SmallA
> 09:11:29,470 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue14) V4Nk+ZmH4VoM.4.1.4 Closed execution
> 09:11:29,470 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue14) V4Nk+ZmH4VoM.4.1.4 Closed connection
> 09:11:29,472 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue14) QueryProcessor: closing processor
> 09:11:29,473 WARN [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue14) TEIID30020 Processing exception for request V4Nk+ZmH4VoM.4 'TEIID30504 node-one: null'. Originally TeiidProcessingException ObjectInputStream.java:2335.: org.teiid.core.TeiidProcessingException: TEIID30504 node-one: null
> at org.teiid.dqp.internal.process.DataTierTupleSource.exceptionOccurred(DataTierTupleSource.java:401) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource.nextTuple(DataTierTupleSource.java:161) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.AccessNode.nextBatchDirect(AccessNode.java:374) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.RelationalNode.nextBatch(RelationalNode.java:282) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.LimitNode.nextBatchDirect(LimitNode.java:102) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.RelationalNode.nextBatch(RelationalNode.java:282) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.RelationalPlan.nextBatch(RelationalPlan.java:145) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.QueryProcessor.nextBatchDirect(QueryProcessor.java:151) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.QueryProcessor.nextBatch(QueryProcessor.java:114) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:164) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:146) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.RequestWorkItem.processMore(RequestWorkItem.java:470) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.RequestWorkItem.process(RequestWorkItem.java:348) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.AbstractWorkItem.run(AbstractWorkItem.java:51) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.RequestWorkItem.run(RequestWorkItem.java:274) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:276) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51]
> Caused by: org.teiid.translator.TranslatorException
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.handleError(ConnectorWorkItem.java:303) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.more(ConnectorWorkItem.java:231) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [rt.jar:1.8.0_51]
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) [rt.jar:1.8.0_51]
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.8.0_51]
> at java.lang.reflect.Method.invoke(Method.java:497) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.datamgr.ConnectorManager$1.invoke(ConnectorManager.java:211) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at com.sun.proxy.$Proxy125.more(Unknown Source)
> at org.teiid.dqp.internal.process.DataTierTupleSource.getResults(DataTierTupleSource.java:309) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:112) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:108) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.process.FutureWork.run(FutureWork.java:65) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> ... 6 more
> Caused by: java.io.EOFException
> at java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2335) [rt.jar:1.8.0_51]
> at java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2804) [rt.jar:1.8.0_51]
> at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:802) [rt.jar:1.8.0_51]
> at java.io.ObjectInputStream.<init>(ObjectInputStream.java:299) [rt.jar:1.8.0_51]
> at org.teiid.translator.accumulo.AccumuloDataTypeManager.deserialize(AccumuloDataTypeManager.java:164)
> at org.teiid.translator.accumulo.AccumuloQueryExecution.nextRow(AccumuloQueryExecution.java:196)
> at org.teiid.translator.accumulo.AccumuloQueryExecution.next(AccumuloQueryExecution.java:171)
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.handleBatch(ConnectorWorkItem.java:429) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.more(ConnectorWorkItem.java:229) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> ... 17 more
> 09:11:29,481 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue14) Removing tuplesource for the request V4Nk+ZmH4VoM.4
> 09:11:29,481 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue14) Removing TupleBuffer: 4
> 09:11:29,482 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue14) V4Nk+ZmH4VoM.4 Finished Processing
> 09:11:29,482 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue14) org.teiid.core.TeiidProcessingException: TEIID30504 node-one: null Sending error to client V4Nk+ZmH4VoM.4
> 09:11:29,486 DEBUG [org.teiid.TRANSPORT] (Worker0_QueryProcessorQueue14) send message: MessageHolder: key=50 contents=ResultsMessage rowCount=0 finalRow=-1
> {code}
> * timestamp/time/date/boolean/short/float/double column (the streamheader values differ for each type)
> {code:plain}
> 09:12:25,270 DEBUG [org.teiid.TRANSPORT] (New I/O worker #2) processing message:MessageHolder: key=51 contents=Invoke interface org.teiid.client.DQP.executeRequest
> 09:12:25,272 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue15) Request Thread V4Nk+ZmH4VoM.5 with state NEW
> 09:12:25,272 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue15) V4Nk+ZmH4VoM.5 Command has no cache hint and result set cache mode is not on.
> 09:12:25,272 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue15) V4Nk+ZmH4VoM.5 executing SELECT Timestampvalue FROM accumulo.SMallA
> 09:12:25,273 DEBUG [org.teiid.PLANNER] (Worker0_QueryProcessorQueue15) [LOW [Relational Planner] limit not supported by source accumulo - limit node not pushed TupleLimit(groups=[], props={MAX_TUPLE_LIMIT=100}, LOW [Relational Planner] limit not supported by source accumulo - limit node not pushed TupleLimit(groups=[], props={MAX_TUPLE_LIMIT=100, OUTPUT_COLS=[accumulo.SmallA.TimestampValue]}]
> 09:12:25,273 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue15) ProcessTree for V4Nk+ZmH4VoM.5 LimitNode(0) output=[accumulo.SmallA.TimestampValue] limit 100
> AccessNode(1) output=[accumulo.SmallA.TimestampValue] SELECT accumulo.SmallA.TimestampValue FROM accumulo.SmallA
> 09:12:25,273 DEBUG [org.teiid.TXN_LOG] (Worker0_QueryProcessorQueue15) before getOrCreateTransactionContext:org.teiid.dqp.internal.process.TransactionServerImpl@748e7221(V4Nk+ZmH4VoM)
> 09:12:25,273 DEBUG [org.teiid.TXN_LOG] (Worker0_QueryProcessorQueue15) after getOrCreateTransactionContext : V4Nk+ZmH4VoM NONE ID:NONE
> 09:12:25,273 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue15) Creating TupleBuffer: 5 [accumulo.SmallA.TimestampValue] [class java.sql.Timestamp] batch size 2048 of type PROCESSOR
> 09:12:25,273 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue15) V4Nk+ZmH4VoM.5.1.5 Create State
> 09:12:25,274 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue15) V4Nk+ZmH4VoM.5.1.5 Blocking on source query V4Nk+ZmH4VoM.5.1.5
> 09:12:25,274 DEBUG [org.teiid.PROCESSOR] (Worker1_QueryProcessorQueue16) Running task for parent thread Worker0_QueryProcessorQueue15
> 09:12:25,274 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue15) V4Nk+ZmH4VoM.5 Blocking on source request(s).
> 09:12:25,274 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue15) Request Thread V4Nk+ZmH4VoM.5 - processor blocked
> 09:12:25,274 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue16) V4Nk+ZmH4VoM.5.1.5 Processing NEW request: SELECT accumulo.SmallA.TimestampValue FROM accumulo.SmallA
> 09:12:25,274 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue16) V4Nk+ZmH4VoM.5.1.5 Obtained execution
> 09:12:25,275 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue16) V4Nk+ZmH4VoM.5.1.5 Executed command
> 09:12:25,275 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue16) V4Nk+ZmH4VoM.5.1.5 Processing MORE request
> 09:12:25,275 DEBUG [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue16) V4Nk+ZmH4VoM.5.1.5 Getting results from connector
> 09:12:25,930 ERROR [org.teiid.CONNECTOR] (Worker1_QueryProcessorQueue16) Connector worker process failed for atomic-request=V4Nk+ZmH4VoM.5.1.5: java.io.StreamCorruptedException: invalid stream header: 32303030
> at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:806) [rt.jar:1.8.0_51]
> at java.io.ObjectInputStream.<init>(ObjectInputStream.java:299) [rt.jar:1.8.0_51]
> at org.teiid.translator.accumulo.AccumuloDataTypeManager.deserialize(AccumuloDataTypeManager.java:164) [translator-accumulo-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.translator.accumulo.AccumuloQueryExecution.nextRow(AccumuloQueryExecution.java:196) [translator-accumulo-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.translator.accumulo.AccumuloQueryExecution.next(AccumuloQueryExecution.java:171) [translator-accumulo-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.handleBatch(ConnectorWorkItem.java:429) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.more(ConnectorWorkItem.java:229) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [rt.jar:1.8.0_51]
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) [rt.jar:1.8.0_51]
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.8.0_51]
> at java.lang.reflect.Method.invoke(Method.java:497) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.datamgr.ConnectorManager$1.invoke(ConnectorManager.java:211) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at com.sun.proxy.$Proxy125.more(Unknown Source)
> at org.teiid.dqp.internal.process.DataTierTupleSource.getResults(DataTierTupleSource.java:309) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:112) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:108) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.process.FutureWork.run(FutureWork.java:65) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:276) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51]
> 09:12:25,934 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue17) Request Thread V4Nk+ZmH4VoM.5 with state PROCESSING
> 09:12:25,935 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue17) V4Nk+ZmH4VoM.5.1.5 Remove State
> 09:12:25,935 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue17) V4Nk+ZmH4VoM.5.1.5 Processing Close : SELECT accumulo.SmallA.TimestampValue FROM accumulo.SmallA
> 09:12:25,935 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue17) V4Nk+ZmH4VoM.5.1.5 Closed execution
> 09:12:25,935 DEBUG [org.teiid.CONNECTOR] (Worker0_QueryProcessorQueue17) V4Nk+ZmH4VoM.5.1.5 Closed connection
> 09:12:25,936 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue17) QueryProcessor: closing processor
> 09:12:25,937 WARN [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue17) TEIID30020 Processing exception for request V4Nk+ZmH4VoM.5 'TEIID30504 node-one: invalid stream header: 32303030'. Originally TeiidProcessingException ObjectInputStream.java:806.: org.teiid.core.TeiidProcessingException: TEIID30504 node-one: invalid stream header: 32303030
> at org.teiid.dqp.internal.process.DataTierTupleSource.exceptionOccurred(DataTierTupleSource.java:401) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource.nextTuple(DataTierTupleSource.java:161) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.AccessNode.nextBatchDirect(AccessNode.java:374) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.RelationalNode.nextBatch(RelationalNode.java:282) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.LimitNode.nextBatchDirect(LimitNode.java:102) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.RelationalNode.nextBatch(RelationalNode.java:282) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.relational.RelationalPlan.nextBatch(RelationalPlan.java:145) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.QueryProcessor.nextBatchDirect(QueryProcessor.java:151) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.QueryProcessor.nextBatch(QueryProcessor.java:114) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:164) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.query.processor.BatchCollector.collectTuples(BatchCollector.java:146) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.RequestWorkItem.processMore(RequestWorkItem.java:470) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.RequestWorkItem.process(RequestWorkItem.java:348) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.AbstractWorkItem.run(AbstractWorkItem.java:51) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.RequestWorkItem.run(RequestWorkItem.java:274) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DQPWorkContext.runInContext(DQPWorkContext.java:276) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$RunnableWrapper.run(ThreadReuseExecutor.java:119) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.ThreadReuseExecutor$3.run(ThreadReuseExecutor.java:210) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_51]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_51]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_51]
> Caused by: org.teiid.translator.TranslatorException: invalid stream header: 32303030
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.handleError(ConnectorWorkItem.java:303) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.more(ConnectorWorkItem.java:231) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [rt.jar:1.8.0_51]
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) [rt.jar:1.8.0_51]
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.8.0_51]
> at java.lang.reflect.Method.invoke(Method.java:497) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.datamgr.ConnectorManager$1.invoke(ConnectorManager.java:211) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at com.sun.proxy.$Proxy125.more(Unknown Source)
> at org.teiid.dqp.internal.process.DataTierTupleSource.getResults(DataTierTupleSource.java:309) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:112) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.process.DataTierTupleSource$1.call(DataTierTupleSource.java:108) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) [rt.jar:1.8.0_51]
> at org.teiid.dqp.internal.process.FutureWork.run(FutureWork.java:65) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> ... 6 more
> Caused by: java.io.StreamCorruptedException: invalid stream header: 32303030
> at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:806) [rt.jar:1.8.0_51]
> at java.io.ObjectInputStream.<init>(ObjectInputStream.java:299) [rt.jar:1.8.0_51]
> at org.teiid.translator.accumulo.AccumuloDataTypeManager.deserialize(AccumuloDataTypeManager.java:164)
> at org.teiid.translator.accumulo.AccumuloQueryExecution.nextRow(AccumuloQueryExecution.java:196)
> at org.teiid.translator.accumulo.AccumuloQueryExecution.next(AccumuloQueryExecution.java:171)
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.handleBatch(ConnectorWorkItem.java:429) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> at org.teiid.dqp.internal.datamgr.ConnectorWorkItem.more(ConnectorWorkItem.java:229) [teiid-engine-8.12.5.redhat-3.jar:8.12.5.redhat-3]
> ... 17 more
> 09:12:25,941 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue17) Removing tuplesource for the request V4Nk+ZmH4VoM.5
> 09:12:25,941 DEBUG [org.teiid.BUFFER_MGR] (Worker0_QueryProcessorQueue17) Removing TupleBuffer: 5
> 09:12:25,941 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue17) V4Nk+ZmH4VoM.5 Finished Processing
> 09:12:25,942 DEBUG [org.teiid.PROCESSOR] (Worker0_QueryProcessorQueue17) org.teiid.core.TeiidProcessingException: TEIID30504 node-one: invalid stream header: 32303030 Sending error to client V4Nk+ZmH4VoM.5
> 09:12:25,942 DEBUG [org.teiid.TRANSPORT] (Worker0_QueryProcessorQueue17) send message: MessageHolder: key=51 contents=ResultsMessage rowCount=0 finalRow=-1
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months