Uploaded image for project: 'Teiid'
  1. Teiid
  2. TEIID-4181

Accumulo translator: AccumuloDataTypeManager various data types issues

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Blocker
    • 9.0, 8.12.5
    • 8.12.5
    • Misc. Connectors
    • None

    Description

      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:

      Unable to find source-code formatter for language: plain. Available languages are: actionscript, ada, applescript, bash, c, c#, c++, cpp, css, erlang, go, groovy, haskell, html, java, javascript, js, json, lua, none, nyan, objc, perl, php, python, r, rainbow, ruby, scala, sh, sql, swift, visualbasic, xml, yaml
      <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>
      • rowid of type integer:
        Unable to find source-code formatter for language: plain. Available languages are: actionscript, ada, applescript, bash, c, c#, c++, cpp, css, erlang, go, groovy, haskell, html, java, javascript, js, json, lua, none, nyan, objc, perl, php, python, r, rainbow, ruby, scala, sh, sql, swift, visualbasic, xml, yaml
        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
      • column of type string/char/bigdecimal/long/integer:
        Unable to find source-code formatter for language: plain. Available languages are: actionscript, ada, applescript, bash, c, c#, c++, cpp, css, erlang, go, groovy, haskell, html, java, javascript, js, json, lua, none, nyan, objc, perl, php, python, r, rainbow, ruby, scala, sh, sql, swift, visualbasic, xml, yaml
        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
      • timestamp/time/date/boolean/short/float/double column (the streamheader values differ for each type)
        Unable to find source-code formatter for language: plain. Available languages are: actionscript, ada, applescript, bash, c, c#, c++, cpp, css, erlang, go, groovy, haskell, html, java, javascript, js, json, lua, none, nyan, objc, perl, php, python, r, rainbow, ruby, scala, sh, sql, swift, visualbasic, xml, yaml
        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

      Attachments

        Activity

          People

            rhn-engineering-rareddy Ramesh Reddy
            jstastny@redhat.com Jan Stastny
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: