May 2016 - teiid-issues - Jboss List Archives

[JBoss JIRA] (TEIID-4204) Examples dynamicvdb-restservice - rest client returns always empty body

by Kylin Soong (JIRA)

[ https://issues.jboss.org/browse/TEIID-4204?page=com.atlassian.jira.plugin... ] Kylin Soong reassigned TEIID-4204: ---------------------------------- Assignee: Kylin Soong (was: Van Halbert) > Examples dynamicvdb-restservice - rest client returns always empty body > ------------------------------------------------------------------------ > > Key: TEIID-4204 > URL: https://issues.jboss.org/browse/TEIID-4204 > Project: Teiid > Issue Type: Bug > Components: Quick Starts > Affects Versions: 8.12.5 > Reporter: Van Halbert > Assignee: Kylin Soong > Priority: Minor > > Description of problem: > rest-client returns always empty body for every request like follows: > [jdurani@localhost resteasy-client]$ java -cp target/dependency/*:target/dynamicvdb-resteasy-client.jar org.jboss.teiid.quickstart.PortfolioClient > JAX-RS 2.0 Client API -- This message was sent by Atlassian JIRA (v6.4.11#64026)

8 years, 7 months

1
0
0 / 0

[JBoss JIRA] (TEIID-4205) send results proactively under a cursor as it looks like the ODBC client requires a transaction.

by Steven Hawkins (JIRA)

[ https://issues.jboss.org/browse/TEIID-4205?page=com.atlassian.jira.plugin... ] Steven Hawkins commented on TEIID-4205: --------------------------------------- Issues like TEIID-14 were logged in the past, so to concurrently send results we need to make sure that lobs or other potential concurrent usage of source connections is avoided. > 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)

8 years, 7 months

1
0
0 / 0

[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: ------------------------------------- I am referring to comment "The other is to add workarounds to the original limitations with returning results concurrently with processing the results under a transaction" > 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)

8 years, 7 months

1
0
0 / 0

[JBoss JIRA] (TEIID-4205) send results proactively under a cursor as it looks like the ODBC client requires a transaction.

by Steven Hawkins (JIRA)

[ https://issues.jboss.org/browse/TEIID-4205?page=com.atlassian.jira.plugin... ] Steven Hawkins commented on TEIID-4205: --------------------------------------- I'm not sure what you are asking. > 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)

8 years, 7 months

1
0
0 / 0

[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: ------------------------------------- What would be the limitations you mention above? > 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)

8 years, 7 months

1
0
0 / 0

[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)

8 years, 7 months

1
0
0 / 0

[JBoss JIRA] (TEIID-4205) send results proactively under a cursor as it looks like the ODBC client requires a transaction.

by Steven Hawkins (JIRA)

[ https://issues.jboss.org/browse/TEIID-4205?page=com.atlassian.jira.plugin... ] Steven Hawkins commented on TEIID-4205: --------------------------------------- > Is there a reason why there is transaction wrapping? pg requires the use of a transaction (begin ... end) to use a cursor. We are simply honoring that as any other local transaction boundary. > 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)

8 years, 7 months

1
0
0 / 0

[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)

8 years, 7 months

1
0
0 / 0

[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)

8 years, 7 months

1
0
0 / 0

[JBoss JIRA] (TEIID-4205) send results proactively under a cursor as it looks like the ODBC client requires a transaction.

by Steven Hawkins (JIRA)

[ https://issues.jboss.org/browse/TEIID-4205?page=com.atlassian.jira.plugin... ] Steven Hawkins commented on TEIID-4205: --------------------------------------- There are two possible paths here. One is to add an option to ignore the wrapping transaction that is used for odbc cursors. The other is to add workarounds to the original limitations with returning results concurrently with processing the results under a transaction. It would probably be best to have both - although the first would need to be optional behavior. > 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)

8 years, 7 months

1
0
0 / 0

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

teiid-issues May 2016