[JBoss JIRA] (TEIID-4479) Teiid Exception on multiple values criteria
by Ramesh Reddy (JIRA)
[ https://issues.jboss.org/browse/TEIID-4479?page=com.atlassian.jira.plugin... ]
Ramesh Reddy commented on TEIID-4479:
-------------------------------------
Is there more to that exception you posted? (you can attach rather then posting)
> Teiid Exception on multiple values criteria
> -------------------------------------------
>
> Key: TEIID-4479
> URL: https://issues.jboss.org/browse/TEIID-4479
> Project: Teiid
> Issue Type: Bug
> Reporter: Mark Tawk
> Assignee: Steven Hawkins
>
> I'm using Teiid 9.0.0 with mysql
> I'm getting an exception on the query below when putting more then one value in the criteria : ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2))
> if the criteria is on one value, the query executes with success;
> The case is specifically related to the query.
> {code}
> select SUM("JPVPricedSecurities"."ContractLine_Cost") as
> "JPVPricedSecurities_Contract",
> year("SRequestPerVendor"."SRequest_DateTime") as
> "DAYOFMONTHSRequestPerVendor_"
> from "DataMarketBusinessModel"."SRequestPerVendor" "SRequestPerVendor"
> LEFT JOIN "DataMarketBusinessModel"."JPVPricedSecurities" "JPVPricedSecurities" ON "SRequestPerVendor"."SRequest_AssetID" = "JPVPricedSecurities"."Reply_AssetID"
> LEFT JOIN "datamarketModel_MM"."datamarket"."Vendor" "Vendor" ON "JPVPricedSecurities"."Reply_VendorID" = "Vendor"."VendorID"
> where ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2) )
> AND ("Vendor"."Vendor" IS NOT null )
> group by
> year("SRequestPerVendor"."SRequest_DateTime")
> {code}
> Here is the exception stack:
> {code}
> Daemon Thread [http-bio-8080-exec-2] (Suspended (exception NullPointerException))
> owns: Object (id=23929)
> owns: SocketWrapper<E> (id=23848)
> LanguageBridgeFactory.translate(DependentSetCriteria) line: 426
> LanguageBridgeFactory.translate(Criteria) line: 418
> LanguageBridgeFactory.translate(CompoundCriteria) line: 494
> LanguageBridgeFactory.translate(Criteria) line: 402
> LanguageBridgeFactory.translate(Query) line: 281
> LanguageBridgeFactory.translate(QueryCommand) line: 226
> LanguageBridgeFactory.translate(SubqueryFromClause) line: 386
> LanguageBridgeFactory.translate(FromClause) line: 344
> LanguageBridgeFactory.translate(Query) line: 276
> LanguageBridgeFactory.translate(Command) line: 184
> ConnectorWorkItem.<init>(AtomicRequestMessage, ConnectorManager) line: 175
> EmbeddedServer$ProviderAwareConnectorManagerRepository$1(ConnectorManager).registerRequest(AtomicRequestMessage) line: 203
> DataTierManagerImpl.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 1011
> TempTableDataManager.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 179
> DependentAccessNode(AccessNode).registerRequest(Command) line: 500
> DependentAccessNode(AccessNode).openInternal() line: 268
> DependentAccessNode(AccessNode).open() line: 171
> EnhancedSortMergeJoinStrategy(JoinStrategy).openRight() line: 105
> JoinNode.nextBatchDirect() line: 223
> JoinNode(RelationalNode).nextBatch() line: 282
> GroupingNode$ProjectingTupleSource(BatchCollector$BatchProducerTupleSource).nextTuple() line: 94
> GroupingNode.groupSortPhase() line: 490
> GroupingNode.nextBatchDirect() line: 366
> GroupingNode(RelationalNode).nextBatch() line: 282
> ProjectNode.nextBatchDirect() line: 150
> ProjectNode(RelationalNode).nextBatch() line: 282
> RelationalPlan.nextBatch() line: 145
> QueryProcessor.nextBatchDirect() line: 151
> QueryProcessor.nextBatch() line: 114
> RequestWorkItem$1(BatchCollector).collectTuples(boolean) line: 164
> RequestWorkItem$1(BatchCollector).collectTuples() line: 146
> RequestWorkItem.processMore() line: 472
> RequestWorkItem.process() line: 348
> RequestWorkItem(AbstractWorkItem).run() line: 51
> RequestWorkItem.run() line: 274
> DQPCore.executeRequest(long, RequestMessage, Long) line: 313
> DQPCore.executeRequest(long, RequestMessage) line: 245
> GeneratedMethodAccessor393.invoke(Object, Object[]) line: not available
> DelegatingMethodAccessorImpl.invoke(Object, Object[]) line: 43
> Method.invoke(Object, Object...) line: 606
> LocalServerConnection$1$1.call() line: 177
> FutureTask<V>.run() line: 262
> DQPWorkContext.runInContext(Runnable) line: 276
> DQPWorkContext.runInContext(Callable<V>) line: 260
> LocalServerConnection$1.invoke(Object, Method, Object[]) line: 175
> $Proxy29.executeRequest(long, RequestMessage) line: not available
> StatementImpl.execute(RequestMessage, boolean) line: 673
> StatementImpl.executeSql(String[], boolean, ResultsMode, boolean, RequestOptions, boolean) line: 539
> StatementImpl.execute(String, int) line: 1060
> StatementImpl.execute(String) line: 323
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
7 years, 9 months
[JBoss JIRA] (TEIID-4479) Teiid Exception on multiple values criteria
by Ramesh Reddy (JIRA)
[ https://issues.jboss.org/browse/TEIID-4479?page=com.atlassian.jira.plugin... ]
Ramesh Reddy updated TEIID-4479:
--------------------------------
Description:
I'm using Teiid 9.0.0 with mysql
I'm getting an exception on the query below when putting more then one value in the criteria : ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2))
if the criteria is on one value, the query executes with success;
The case is specifically related to the query.
{code}
select SUM("JPVPricedSecurities"."ContractLine_Cost") as
"JPVPricedSecurities_Contract",
year("SRequestPerVendor"."SRequest_DateTime") as
"DAYOFMONTHSRequestPerVendor_"
from "DataMarketBusinessModel"."SRequestPerVendor" "SRequestPerVendor"
LEFT JOIN "DataMarketBusinessModel"."JPVPricedSecurities" "JPVPricedSecurities" ON "SRequestPerVendor"."SRequest_AssetID" = "JPVPricedSecurities"."Reply_AssetID"
LEFT JOIN "datamarketModel_MM"."datamarket"."Vendor" "Vendor" ON "JPVPricedSecurities"."Reply_VendorID" = "Vendor"."VendorID"
where ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2) )
AND ("Vendor"."Vendor" IS NOT null )
group by
year("SRequestPerVendor"."SRequest_DateTime")
{code}
Here is the exception stack:
{code}
Daemon Thread [http-bio-8080-exec-2] (Suspended (exception NullPointerException))
owns: Object (id=23929)
owns: SocketWrapper<E> (id=23848)
LanguageBridgeFactory.translate(DependentSetCriteria) line: 426
LanguageBridgeFactory.translate(Criteria) line: 418
LanguageBridgeFactory.translate(CompoundCriteria) line: 494
LanguageBridgeFactory.translate(Criteria) line: 402
LanguageBridgeFactory.translate(Query) line: 281
LanguageBridgeFactory.translate(QueryCommand) line: 226
LanguageBridgeFactory.translate(SubqueryFromClause) line: 386
LanguageBridgeFactory.translate(FromClause) line: 344
LanguageBridgeFactory.translate(Query) line: 276
LanguageBridgeFactory.translate(Command) line: 184
ConnectorWorkItem.<init>(AtomicRequestMessage, ConnectorManager) line: 175
EmbeddedServer$ProviderAwareConnectorManagerRepository$1(ConnectorManager).registerRequest(AtomicRequestMessage) line: 203
DataTierManagerImpl.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 1011
TempTableDataManager.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 179
DependentAccessNode(AccessNode).registerRequest(Command) line: 500
DependentAccessNode(AccessNode).openInternal() line: 268
DependentAccessNode(AccessNode).open() line: 171
EnhancedSortMergeJoinStrategy(JoinStrategy).openRight() line: 105
JoinNode.nextBatchDirect() line: 223
JoinNode(RelationalNode).nextBatch() line: 282
GroupingNode$ProjectingTupleSource(BatchCollector$BatchProducerTupleSource).nextTuple() line: 94
GroupingNode.groupSortPhase() line: 490
GroupingNode.nextBatchDirect() line: 366
GroupingNode(RelationalNode).nextBatch() line: 282
ProjectNode.nextBatchDirect() line: 150
ProjectNode(RelationalNode).nextBatch() line: 282
RelationalPlan.nextBatch() line: 145
QueryProcessor.nextBatchDirect() line: 151
QueryProcessor.nextBatch() line: 114
RequestWorkItem$1(BatchCollector).collectTuples(boolean) line: 164
RequestWorkItem$1(BatchCollector).collectTuples() line: 146
RequestWorkItem.processMore() line: 472
RequestWorkItem.process() line: 348
RequestWorkItem(AbstractWorkItem).run() line: 51
RequestWorkItem.run() line: 274
DQPCore.executeRequest(long, RequestMessage, Long) line: 313
DQPCore.executeRequest(long, RequestMessage) line: 245
GeneratedMethodAccessor393.invoke(Object, Object[]) line: not available
DelegatingMethodAccessorImpl.invoke(Object, Object[]) line: 43
Method.invoke(Object, Object...) line: 606
LocalServerConnection$1$1.call() line: 177
FutureTask<V>.run() line: 262
DQPWorkContext.runInContext(Runnable) line: 276
DQPWorkContext.runInContext(Callable<V>) line: 260
LocalServerConnection$1.invoke(Object, Method, Object[]) line: 175
$Proxy29.executeRequest(long, RequestMessage) line: not available
StatementImpl.execute(RequestMessage, boolean) line: 673
StatementImpl.executeSql(String[], boolean, ResultsMode, boolean, RequestOptions, boolean) line: 539
StatementImpl.execute(String, int) line: 1060
StatementImpl.execute(String) line: 323
{code}
was:
I'm using Teiid 9.0.0 with mysql
I'm getting an exception on the query below when putting more then one value in the criteria : ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2))
if the criteria is on one value, the query executes with success;
The case is specifically related to the query.
select SUM("JPVPricedSecurities"."ContractLine_Cost") as
"JPVPricedSecurities_Contract",
year("SRequestPerVendor"."SRequest_DateTime") as
"DAYOFMONTHSRequestPerVendor_"
from "DataMarketBusinessModel"."SRequestPerVendor" "SRequestPerVendor"
LEFT JOIN "DataMarketBusinessModel"."JPVPricedSecurities" "JPVPricedSecurities" ON "SRequestPerVendor"."SRequest_AssetID" = "JPVPricedSecurities"."Reply_AssetID"
LEFT JOIN "datamarketModel_MM"."datamarket"."Vendor" "Vendor" ON "JPVPricedSecurities"."Reply_VendorID" = "Vendor"."VendorID"
where ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2) )
AND ("Vendor"."Vendor" IS NOT null )
group by
year("SRequestPerVendor"."SRequest_DateTime")
Here is the exception stack:
Daemon Thread [http-bio-8080-exec-2] (Suspended (exception NullPointerException))
owns: Object (id=23929)
owns: SocketWrapper<E> (id=23848)
LanguageBridgeFactory.translate(DependentSetCriteria) line: 426
LanguageBridgeFactory.translate(Criteria) line: 418
LanguageBridgeFactory.translate(CompoundCriteria) line: 494
LanguageBridgeFactory.translate(Criteria) line: 402
LanguageBridgeFactory.translate(Query) line: 281
LanguageBridgeFactory.translate(QueryCommand) line: 226
LanguageBridgeFactory.translate(SubqueryFromClause) line: 386
LanguageBridgeFactory.translate(FromClause) line: 344
LanguageBridgeFactory.translate(Query) line: 276
LanguageBridgeFactory.translate(Command) line: 184
ConnectorWorkItem.<init>(AtomicRequestMessage, ConnectorManager) line: 175
EmbeddedServer$ProviderAwareConnectorManagerRepository$1(ConnectorManager).registerRequest(AtomicRequestMessage) line: 203
DataTierManagerImpl.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 1011
TempTableDataManager.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 179
DependentAccessNode(AccessNode).registerRequest(Command) line: 500
DependentAccessNode(AccessNode).openInternal() line: 268
DependentAccessNode(AccessNode).open() line: 171
EnhancedSortMergeJoinStrategy(JoinStrategy).openRight() line: 105
JoinNode.nextBatchDirect() line: 223
JoinNode(RelationalNode).nextBatch() line: 282
GroupingNode$ProjectingTupleSource(BatchCollector$BatchProducerTupleSource).nextTuple() line: 94
GroupingNode.groupSortPhase() line: 490
GroupingNode.nextBatchDirect() line: 366
GroupingNode(RelationalNode).nextBatch() line: 282
ProjectNode.nextBatchDirect() line: 150
ProjectNode(RelationalNode).nextBatch() line: 282
RelationalPlan.nextBatch() line: 145
QueryProcessor.nextBatchDirect() line: 151
QueryProcessor.nextBatch() line: 114
RequestWorkItem$1(BatchCollector).collectTuples(boolean) line: 164
RequestWorkItem$1(BatchCollector).collectTuples() line: 146
RequestWorkItem.processMore() line: 472
RequestWorkItem.process() line: 348
RequestWorkItem(AbstractWorkItem).run() line: 51
RequestWorkItem.run() line: 274
DQPCore.executeRequest(long, RequestMessage, Long) line: 313
DQPCore.executeRequest(long, RequestMessage) line: 245
GeneratedMethodAccessor393.invoke(Object, Object[]) line: not available
DelegatingMethodAccessorImpl.invoke(Object, Object[]) line: 43
Method.invoke(Object, Object...) line: 606
LocalServerConnection$1$1.call() line: 177
FutureTask<V>.run() line: 262
DQPWorkContext.runInContext(Runnable) line: 276
DQPWorkContext.runInContext(Callable<V>) line: 260
LocalServerConnection$1.invoke(Object, Method, Object[]) line: 175
$Proxy29.executeRequest(long, RequestMessage) line: not available
StatementImpl.execute(RequestMessage, boolean) line: 673
StatementImpl.executeSql(String[], boolean, ResultsMode, boolean, RequestOptions, boolean) line: 539
StatementImpl.execute(String, int) line: 1060
StatementImpl.execute(String) line: 323
> Teiid Exception on multiple values criteria
> -------------------------------------------
>
> Key: TEIID-4479
> URL: https://issues.jboss.org/browse/TEIID-4479
> Project: Teiid
> Issue Type: Bug
> Reporter: Mark Tawk
> Assignee: Steven Hawkins
>
> I'm using Teiid 9.0.0 with mysql
> I'm getting an exception on the query below when putting more then one value in the criteria : ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2))
> if the criteria is on one value, the query executes with success;
> The case is specifically related to the query.
> {code}
> select SUM("JPVPricedSecurities"."ContractLine_Cost") as
> "JPVPricedSecurities_Contract",
> year("SRequestPerVendor"."SRequest_DateTime") as
> "DAYOFMONTHSRequestPerVendor_"
> from "DataMarketBusinessModel"."SRequestPerVendor" "SRequestPerVendor"
> LEFT JOIN "DataMarketBusinessModel"."JPVPricedSecurities" "JPVPricedSecurities" ON "SRequestPerVendor"."SRequest_AssetID" = "JPVPricedSecurities"."Reply_AssetID"
> LEFT JOIN "datamarketModel_MM"."datamarket"."Vendor" "Vendor" ON "JPVPricedSecurities"."Reply_VendorID" = "Vendor"."VendorID"
> where ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2) )
> AND ("Vendor"."Vendor" IS NOT null )
> group by
> year("SRequestPerVendor"."SRequest_DateTime")
> {code}
> Here is the exception stack:
> {code}
> Daemon Thread [http-bio-8080-exec-2] (Suspended (exception NullPointerException))
> owns: Object (id=23929)
> owns: SocketWrapper<E> (id=23848)
> LanguageBridgeFactory.translate(DependentSetCriteria) line: 426
> LanguageBridgeFactory.translate(Criteria) line: 418
> LanguageBridgeFactory.translate(CompoundCriteria) line: 494
> LanguageBridgeFactory.translate(Criteria) line: 402
> LanguageBridgeFactory.translate(Query) line: 281
> LanguageBridgeFactory.translate(QueryCommand) line: 226
> LanguageBridgeFactory.translate(SubqueryFromClause) line: 386
> LanguageBridgeFactory.translate(FromClause) line: 344
> LanguageBridgeFactory.translate(Query) line: 276
> LanguageBridgeFactory.translate(Command) line: 184
> ConnectorWorkItem.<init>(AtomicRequestMessage, ConnectorManager) line: 175
> EmbeddedServer$ProviderAwareConnectorManagerRepository$1(ConnectorManager).registerRequest(AtomicRequestMessage) line: 203
> DataTierManagerImpl.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 1011
> TempTableDataManager.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 179
> DependentAccessNode(AccessNode).registerRequest(Command) line: 500
> DependentAccessNode(AccessNode).openInternal() line: 268
> DependentAccessNode(AccessNode).open() line: 171
> EnhancedSortMergeJoinStrategy(JoinStrategy).openRight() line: 105
> JoinNode.nextBatchDirect() line: 223
> JoinNode(RelationalNode).nextBatch() line: 282
> GroupingNode$ProjectingTupleSource(BatchCollector$BatchProducerTupleSource).nextTuple() line: 94
> GroupingNode.groupSortPhase() line: 490
> GroupingNode.nextBatchDirect() line: 366
> GroupingNode(RelationalNode).nextBatch() line: 282
> ProjectNode.nextBatchDirect() line: 150
> ProjectNode(RelationalNode).nextBatch() line: 282
> RelationalPlan.nextBatch() line: 145
> QueryProcessor.nextBatchDirect() line: 151
> QueryProcessor.nextBatch() line: 114
> RequestWorkItem$1(BatchCollector).collectTuples(boolean) line: 164
> RequestWorkItem$1(BatchCollector).collectTuples() line: 146
> RequestWorkItem.processMore() line: 472
> RequestWorkItem.process() line: 348
> RequestWorkItem(AbstractWorkItem).run() line: 51
> RequestWorkItem.run() line: 274
> DQPCore.executeRequest(long, RequestMessage, Long) line: 313
> DQPCore.executeRequest(long, RequestMessage) line: 245
> GeneratedMethodAccessor393.invoke(Object, Object[]) line: not available
> DelegatingMethodAccessorImpl.invoke(Object, Object[]) line: 43
> Method.invoke(Object, Object...) line: 606
> LocalServerConnection$1$1.call() line: 177
> FutureTask<V>.run() line: 262
> DQPWorkContext.runInContext(Runnable) line: 276
> DQPWorkContext.runInContext(Callable<V>) line: 260
> LocalServerConnection$1.invoke(Object, Method, Object[]) line: 175
> $Proxy29.executeRequest(long, RequestMessage) line: not available
> StatementImpl.execute(RequestMessage, boolean) line: 673
> StatementImpl.executeSql(String[], boolean, ResultsMode, boolean, RequestOptions, boolean) line: 539
> StatementImpl.execute(String, int) line: 1060
> StatementImpl.execute(String) line: 323
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
7 years, 9 months
[JBoss JIRA] (TEIID-4284) Implement Salesforce Bulk API for SELECTS to Salesforce Connector
by Ramesh Reddy (JIRA)
[ https://issues.jboss.org/browse/TEIID-4284?page=com.atlassian.jira.plugin... ]
Ramesh Reddy commented on TEIID-4284:
-------------------------------------
[~sameerp] If you are using the "salesforce" translator and not "salesforce-34" translator then per the exception you need a version => 28. The "salesforce" translator uses version 22, salesforce-34 uses version 34 of the Salesforce API. So you should update your VDB and Resource Adapter configuration to 34 version of it, and try again. I will see if I can document this.
> Implement Salesforce Bulk API for SELECTS to Salesforce Connector
> -----------------------------------------------------------------
>
> Key: TEIID-4284
> URL: https://issues.jboss.org/browse/TEIID-4284
> Project: Teiid
> Issue Type: Feature Request
> Components: Salesforce Connector
> Affects Versions: 8.13.5
> Environment: With Salesforce datasource
> Reporter: sameer P
> Assignee: Steven Hawkins
> Fix For: 9.1
>
>
> There is some huge data (many GBs) in the Salesforce which has around 1.5 million rows and doing some simple select * on it fails with QUERY_TIMEOUT.
> The salesforce guys suggested to try Bulk API for select with PK chunking as stated in https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asy... .
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
7 years, 9 months
[JBoss JIRA] (TEIID-4479) Teiid Exception on multiple values criteria
by Mark Tawk (JIRA)
[ https://issues.jboss.org/browse/TEIID-4479?page=com.atlassian.jira.plugin... ]
Mark Tawk commented on TEIID-4479:
----------------------------------
Query plan:
<?xml version='1.0' encoding='UTF-8'?><node name="ProjectNode"><property name="Relational Node ID"><value>2</value></property><property name="Output Columns"><value>JPVPricedSecurities_Contract (bigdecimal)</value><value>DAYOFMONTHSRequestPerVendor_ (integer)</value></property><property name="Statistics"><value>Node Output Rows: 0</value><value>Node Next Batch Process Time: 0</value><value>Node Cumulative Next Batch Process Time: 16</value><value>Node Cumulative Process Time: 0</value><value>Node Next Batch Calls: 1</value><value>Node Blocks: 1</value></property><property name="Cost Estimates"><value>Estimated Node Cardinality: -1.0</value></property><property name="Child 0"><node name="GroupingNode"><property name="Relational Node ID"><value>3</value></property><property name="Output Columns"><value>agg0 (bigdecimal)</value><value>gcol0 (integer)</value></property><property name="Statistics"><value>Node Output Rows: 0</value><value>Node Next Batch Process Time: 0</value><value>Node Cumulative Next Batch Process Time: 16</value><value>Node Cumulative Process Time: 0</value><value>Node Next Batch Calls: 1</value><value>Node Blocks: 1</value></property><property name="Cost Estimates"><value>Estimated Node Cardinality: -1.0</value></property><property name="Child 0"><node name="JoinNode"><property name="Relational Node ID"><value>4</value></property><property name="Output Columns"><value>gcol1 (integer)</value><value>agg0 (bigdecimal)</value></property><property name="Statistics"><value>Node Output Rows: 0</value><value>Node Next Batch Process Time: 0</value><value>Node Cumulative Next Batch Process Time: 16</value><value>Node Cumulative Process Time: 0</value><value>Node Next Batch Calls: 1</value><value>Node Blocks: 1</value></property><property name="Cost Estimates"><value>Estimated Node Cardinality: -1.0</value></property><property name="Child 0"><node name="AccessNode"><property name="Relational Node ID"><value>5</value></property><property name="Output Columns"><value>VendorID (integer)</value></property><property name="Statistics"><value>Node Output Rows: 2</value><value>Node Next Batch Process Time: 0</value><value>Node Cumulative Next Batch Process Time: 0</value><value>Node Cumulative Process Time: 16</value><value>Node Next Batch Calls: 2</value><value>Node Blocks: 1</value></property><property name="Cost Estimates"><value>Estimated Node Cardinality: 1.0</value></property><property name="Query"><value>SELECT g_0.VendorID AS c_0 FROM datamarketModel_MM.datamarket.Vendor AS g_0 WHERE (g_0.Vendor IS NOT NULL) AND (g_0.VendorID IN (10, 2)) ORDER BY c_0</value></property><property name="Model Name"><value>datamarketModel_MM</value></property></node></property><property name="Child 1"><node name="DependentAccessNode"><property name="Relational Node ID"><value>6</value></property><property name="Output Columns"><value>gcol0 (integer)</value><value>gcol1 (integer)</value><value>agg0 (bigdecimal)</value></property><property name="Statistics"><value>Node Output Rows: 0</value><value>Node Next Batch Process Time: 0</value><value>Node Cumulative Next Batch Process Time: 0</value><value>Node Cumulative Process Time: 0</value><value>Node Next Batch Calls: 0</value><value>Node Blocks: 0</value></property><property name="Cost Estimates"><value>Estimated Node Cardinality: -1.0</value></property><property name="Query"><value>SELECT v_0.c_0, v_0.c_1, SUM(v_0.c_2) FROM (SELECT g_1.Reply_VendorID AS c_0, year(g_0.SRequest_DateTime) AS c_1, g_1.ContractLine_Cost AS c_2 FROM datamarketModel_jX.datamarket.SRequestPerVendor AS g_0, datamarketModel_jX.datamarket.JPVPricedSecurities AS g_1 WHERE (g_0.SRequest_AssetID = g_1.Reply_AssetID) AND (g_1.Reply_VendorID IN (10, 2)) AND (g_1.Reply_VendorID IN (<dependent values>))) AS v_0 GROUP BY v_0.c_0, v_0.c_1</value></property><property name="Model Name"><value>datamarketModel_jX</value></property></node></property><property name="Dependent Join"><value>true</value></property><property name="Join Strategy"><value>ENHANCED SORT JOIN [SEMI] RAN AS SORT MERGE (ALREADY_SORTED/SORT)</value></property><property name="Join Type"><value>INNER JOIN</value></property><property name="Join Criteria"><value>Vendor.VendorID=anon_grp1.gcol0</value></property></node></property><property name="Grouping Columns"><value>anon_grp1.gcol1</value></property><property name="Grouping Mapping"><value>anon_grp0.gcol0=anon_grp1.gcol1</value><value>anon_grp0.agg0=SUM(anon_grp1.agg0)</value></property><property name="Sort Mode"><value>false</value></property></node></property><property name="Select Columns"><value>anon_grp0.agg0 AS JPVPricedSecurities_Contract</value><value>anon_grp0.gcol0 AS DAYOFMONTHSRequestPerVendor_</value></property><property name="Data Bytes Sent"><value>0</value></property><property name="Planning Time"><value>15</value></property></node>
> Teiid Exception on multiple values criteria
> -------------------------------------------
>
> Key: TEIID-4479
> URL: https://issues.jboss.org/browse/TEIID-4479
> Project: Teiid
> Issue Type: Bug
> Reporter: Mark Tawk
> Assignee: Steven Hawkins
>
> I'm using Teiid 9.0.0 with mysql
> I'm getting an exception on the query below when putting more then one value in the criteria : ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2))
> if the criteria is on one value, the query executes with success;
> The case is specifically related to the query.
> select SUM("JPVPricedSecurities"."ContractLine_Cost") as
> "JPVPricedSecurities_Contract",
> year("SRequestPerVendor"."SRequest_DateTime") as
> "DAYOFMONTHSRequestPerVendor_"
> from "DataMarketBusinessModel"."SRequestPerVendor" "SRequestPerVendor"
> LEFT JOIN "DataMarketBusinessModel"."JPVPricedSecurities" "JPVPricedSecurities" ON "SRequestPerVendor"."SRequest_AssetID" = "JPVPricedSecurities"."Reply_AssetID"
> LEFT JOIN "datamarketModel_MM"."datamarket"."Vendor" "Vendor" ON "JPVPricedSecurities"."Reply_VendorID" = "Vendor"."VendorID"
> where ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2) )
> AND ("Vendor"."Vendor" IS NOT null )
> group by
> year("SRequestPerVendor"."SRequest_DateTime")
> Here is the exception stack:
> Daemon Thread [http-bio-8080-exec-2] (Suspended (exception NullPointerException))
> owns: Object (id=23929)
> owns: SocketWrapper<E> (id=23848)
> LanguageBridgeFactory.translate(DependentSetCriteria) line: 426
> LanguageBridgeFactory.translate(Criteria) line: 418
> LanguageBridgeFactory.translate(CompoundCriteria) line: 494
> LanguageBridgeFactory.translate(Criteria) line: 402
> LanguageBridgeFactory.translate(Query) line: 281
> LanguageBridgeFactory.translate(QueryCommand) line: 226
> LanguageBridgeFactory.translate(SubqueryFromClause) line: 386
> LanguageBridgeFactory.translate(FromClause) line: 344
> LanguageBridgeFactory.translate(Query) line: 276
> LanguageBridgeFactory.translate(Command) line: 184
> ConnectorWorkItem.<init>(AtomicRequestMessage, ConnectorManager) line: 175
> EmbeddedServer$ProviderAwareConnectorManagerRepository$1(ConnectorManager).registerRequest(AtomicRequestMessage) line: 203
> DataTierManagerImpl.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 1011
> TempTableDataManager.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 179
> DependentAccessNode(AccessNode).registerRequest(Command) line: 500
> DependentAccessNode(AccessNode).openInternal() line: 268
> DependentAccessNode(AccessNode).open() line: 171
> EnhancedSortMergeJoinStrategy(JoinStrategy).openRight() line: 105
> JoinNode.nextBatchDirect() line: 223
> JoinNode(RelationalNode).nextBatch() line: 282
> GroupingNode$ProjectingTupleSource(BatchCollector$BatchProducerTupleSource).nextTuple() line: 94
> GroupingNode.groupSortPhase() line: 490
> GroupingNode.nextBatchDirect() line: 366
> GroupingNode(RelationalNode).nextBatch() line: 282
> ProjectNode.nextBatchDirect() line: 150
> ProjectNode(RelationalNode).nextBatch() line: 282
> RelationalPlan.nextBatch() line: 145
> QueryProcessor.nextBatchDirect() line: 151
> QueryProcessor.nextBatch() line: 114
> RequestWorkItem$1(BatchCollector).collectTuples(boolean) line: 164
> RequestWorkItem$1(BatchCollector).collectTuples() line: 146
> RequestWorkItem.processMore() line: 472
> RequestWorkItem.process() line: 348
> RequestWorkItem(AbstractWorkItem).run() line: 51
> RequestWorkItem.run() line: 274
> DQPCore.executeRequest(long, RequestMessage, Long) line: 313
> DQPCore.executeRequest(long, RequestMessage) line: 245
> GeneratedMethodAccessor393.invoke(Object, Object[]) line: not available
> DelegatingMethodAccessorImpl.invoke(Object, Object[]) line: 43
> Method.invoke(Object, Object...) line: 606
> LocalServerConnection$1$1.call() line: 177
> FutureTask<V>.run() line: 262
> DQPWorkContext.runInContext(Runnable) line: 276
> DQPWorkContext.runInContext(Callable<V>) line: 260
> LocalServerConnection$1.invoke(Object, Method, Object[]) line: 175
> $Proxy29.executeRequest(long, RequestMessage) line: not available
> StatementImpl.execute(RequestMessage, boolean) line: 673
> StatementImpl.executeSql(String[], boolean, ResultsMode, boolean, RequestOptions, boolean) line: 539
> StatementImpl.execute(String, int) line: 1060
> StatementImpl.execute(String) line: 323
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
7 years, 9 months
[JBoss JIRA] (TEIID-4479) Teiid Exception on multiple values criteria
by Mark Tawk (JIRA)
Mark Tawk created TEIID-4479:
--------------------------------
Summary: Teiid Exception on multiple values criteria
Key: TEIID-4479
URL: https://issues.jboss.org/browse/TEIID-4479
Project: Teiid
Issue Type: Bug
Reporter: Mark Tawk
Assignee: Steven Hawkins
I'm using Teiid 9.0.0 with mysql
I'm getting an exception on the query below when putting more then one value in the criteria : ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2))
if the criteria is on one value, the query executes with success;
The case is specifically related to the query.
select SUM("JPVPricedSecurities"."ContractLine_Cost") as
"JPVPricedSecurities_Contract",
year("SRequestPerVendor"."SRequest_DateTime") as
"DAYOFMONTHSRequestPerVendor_"
from "DataMarketBusinessModel"."SRequestPerVendor" "SRequestPerVendor"
LEFT JOIN "DataMarketBusinessModel"."JPVPricedSecurities" "JPVPricedSecurities" ON "SRequestPerVendor"."SRequest_AssetID" = "JPVPricedSecurities"."Reply_AssetID"
LEFT JOIN "datamarketModel_MM"."datamarket"."Vendor" "Vendor" ON "JPVPricedSecurities"."Reply_VendorID" = "Vendor"."VendorID"
where ("JPVPricedSecurities"."Reply_VendorID" IN (10, 2) )
AND ("Vendor"."Vendor" IS NOT null )
group by
year("SRequestPerVendor"."SRequest_DateTime")
Here is the exception stack:
Daemon Thread [http-bio-8080-exec-2] (Suspended (exception NullPointerException))
owns: Object (id=23929)
owns: SocketWrapper<E> (id=23848)
LanguageBridgeFactory.translate(DependentSetCriteria) line: 426
LanguageBridgeFactory.translate(Criteria) line: 418
LanguageBridgeFactory.translate(CompoundCriteria) line: 494
LanguageBridgeFactory.translate(Criteria) line: 402
LanguageBridgeFactory.translate(Query) line: 281
LanguageBridgeFactory.translate(QueryCommand) line: 226
LanguageBridgeFactory.translate(SubqueryFromClause) line: 386
LanguageBridgeFactory.translate(FromClause) line: 344
LanguageBridgeFactory.translate(Query) line: 276
LanguageBridgeFactory.translate(Command) line: 184
ConnectorWorkItem.<init>(AtomicRequestMessage, ConnectorManager) line: 175
EmbeddedServer$ProviderAwareConnectorManagerRepository$1(ConnectorManager).registerRequest(AtomicRequestMessage) line: 203
DataTierManagerImpl.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 1011
TempTableDataManager.registerRequest(CommandContext, Command, String, RegisterRequestParameter) line: 179
DependentAccessNode(AccessNode).registerRequest(Command) line: 500
DependentAccessNode(AccessNode).openInternal() line: 268
DependentAccessNode(AccessNode).open() line: 171
EnhancedSortMergeJoinStrategy(JoinStrategy).openRight() line: 105
JoinNode.nextBatchDirect() line: 223
JoinNode(RelationalNode).nextBatch() line: 282
GroupingNode$ProjectingTupleSource(BatchCollector$BatchProducerTupleSource).nextTuple() line: 94
GroupingNode.groupSortPhase() line: 490
GroupingNode.nextBatchDirect() line: 366
GroupingNode(RelationalNode).nextBatch() line: 282
ProjectNode.nextBatchDirect() line: 150
ProjectNode(RelationalNode).nextBatch() line: 282
RelationalPlan.nextBatch() line: 145
QueryProcessor.nextBatchDirect() line: 151
QueryProcessor.nextBatch() line: 114
RequestWorkItem$1(BatchCollector).collectTuples(boolean) line: 164
RequestWorkItem$1(BatchCollector).collectTuples() line: 146
RequestWorkItem.processMore() line: 472
RequestWorkItem.process() line: 348
RequestWorkItem(AbstractWorkItem).run() line: 51
RequestWorkItem.run() line: 274
DQPCore.executeRequest(long, RequestMessage, Long) line: 313
DQPCore.executeRequest(long, RequestMessage) line: 245
GeneratedMethodAccessor393.invoke(Object, Object[]) line: not available
DelegatingMethodAccessorImpl.invoke(Object, Object[]) line: 43
Method.invoke(Object, Object...) line: 606
LocalServerConnection$1$1.call() line: 177
FutureTask<V>.run() line: 262
DQPWorkContext.runInContext(Runnable) line: 276
DQPWorkContext.runInContext(Callable<V>) line: 260
LocalServerConnection$1.invoke(Object, Method, Object[]) line: 175
$Proxy29.executeRequest(long, RequestMessage) line: not available
StatementImpl.execute(RequestMessage, boolean) line: 673
StatementImpl.executeSql(String[], boolean, ResultsMode, boolean, RequestOptions, boolean) line: 539
StatementImpl.execute(String, int) line: 1060
StatementImpl.execute(String) line: 323
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
7 years, 9 months
[JBoss JIRA] (TEIID-4284) Implement Salesforce Bulk API for SELECTS to Salesforce Connector
by sameer P (JIRA)
[ https://issues.jboss.org/browse/TEIID-4284?page=com.atlassian.jira.plugin... ]
sameer P commented on TEIID-4284:
---------------------------------
One quick question here [~shawkins]. I am using the translator-salesforce and not translator-salesforce-34 which uses the salesforce API version 22 (afaik). And with this, after this fix, when I run the select * with the source hint for the second time, I get the following error:
{code:java}
org.teiid.jdbc.TeiidSQLException: TEIID30504 Remote org.teiid.core.TeiidProcessingException: TEIID30504 TEIID30020 Processing exception for request me0+yW5oaU1h.3 'TEIID30504 dss_opt_VDB_ID_1SOU: [AsyncApiException exceptionCode='InvalidJob'
exceptionMessage='PKChunking is only supported in version 28.0 and above.'
]
'. Originally TeiidProcessingException 'InvalidJob : PKChunking is only supported in version 28.0 and above.' BulkConnection.java:108.
{code}
Any idea why this could happen? Am I missing out something here?.
> Implement Salesforce Bulk API for SELECTS to Salesforce Connector
> -----------------------------------------------------------------
>
> Key: TEIID-4284
> URL: https://issues.jboss.org/browse/TEIID-4284
> Project: Teiid
> Issue Type: Feature Request
> Components: Salesforce Connector
> Affects Versions: 8.13.5
> Environment: With Salesforce datasource
> Reporter: sameer P
> Assignee: Steven Hawkins
> Fix For: 9.1
>
>
> There is some huge data (many GBs) in the Salesforce which has around 1.5 million rows and doing some simple select * on it fails with QUERY_TIMEOUT.
> The salesforce guys suggested to try Bulk API for select with PK chunking as stated in https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asy... .
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
7 years, 9 months
[JBoss JIRA] (TEIID-4456) Enable the abiltiy to support nested and non-nested message descriptors
by Van Halbert (JIRA)
[ https://issues.jboss.org/browse/TEIID-4456?page=com.atlassian.jira.plugin... ]
Work on TEIID-4456 stopped by Van Halbert.
------------------------------------------
> Enable the abiltiy to support nested and non-nested message descriptors
> -----------------------------------------------------------------------
>
> Key: TEIID-4456
> URL: https://issues.jboss.org/browse/TEIID-4456
> Project: Teiid
> Issue Type: Enhancement
> Components: Misc. Connectors
> Affects Versions: 9.2
> Reporter: Van Halbert
> Assignee: Van Halbert
>
> Protobuf definition files can have messages defined in a nested and non-nested form.
> Nested:
> {code}
> package bigdata;
> message DataEntity {
> ..
> optional MetaData context = 6;
> message MetaData {
> ...
> }
> }
> {code}
> Non-nested:
> {code}
> package bigdata;
> message DataEntity {
> ..
> optional MetaData context = 6;
> }
> message MetaData {
> ...
> }
> {code}
> The ProtobufMetadataProcessor needs to be changed to so that it can create the metadata from either use case.
> Currently it obtains the child descriptor messages from the parent descriptor.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
7 years, 9 months