[teiid-commits] teiid SVN: r3078 - in trunk/engine/src/main/java/org/teiid: query/tempdata and 1 other directory.
teiid-commits at lists.jboss.org
teiid-commits at lists.jboss.org
Fri Apr 8 14:29:53 EDT 2011
Author: shawkins
Date: 2011-04-08 14:29:53 -0400 (Fri, 08 Apr 2011)
New Revision: 3078
Modified:
trunk/engine/src/main/java/org/teiid/dqp/internal/process/DataTierManagerImpl.java
trunk/engine/src/main/java/org/teiid/query/tempdata/TempTableDataManager.java
Log:
TEIID-1473 fixing the limit compensation
Modified: trunk/engine/src/main/java/org/teiid/dqp/internal/process/DataTierManagerImpl.java
===================================================================
--- trunk/engine/src/main/java/org/teiid/dqp/internal/process/DataTierManagerImpl.java 2011-04-07 20:21:17 UTC (rev 3077)
+++ trunk/engine/src/main/java/org/teiid/dqp/internal/process/DataTierManagerImpl.java 2011-04-08 18:29:53 UTC (rev 3078)
@@ -126,7 +126,6 @@
AtomicRequestMessage aqr = createRequest(context.getProcessorID(), command, modelName, connectorBindingId, nodeID);
if (limit > 0) {
aqr.setFetchSize(Math.min(limit, aqr.getFetchSize()));
- throw new AssertionError();
}
ConnectorManagerRepository cmr = workItem.getDqpWorkContext().getVDB().getAttachment(ConnectorManagerRepository.class);
ConnectorWork work = cmr.getConnectorManager(aqr.getConnectorName()).registerRequest(aqr);
Modified: trunk/engine/src/main/java/org/teiid/query/tempdata/TempTableDataManager.java
===================================================================
--- trunk/engine/src/main/java/org/teiid/query/tempdata/TempTableDataManager.java 2011-04-07 20:21:17 UTC (rev 3077)
+++ trunk/engine/src/main/java/org/teiid/query/tempdata/TempTableDataManager.java 2011-04-08 18:29:53 UTC (rev 3078)
@@ -172,7 +172,7 @@
return result;
}
}
- return this.processorDataManager.registerRequest(context, command, modelName, connectorBindingId, nodeID, -1);
+ return this.processorDataManager.registerRequest(context, command, modelName, connectorBindingId, nodeID, limit);
}
TupleSource registerRequest(CommandContext context, String modelName, Command command) throws TeiidComponentException, TeiidProcessingException {
More information about the teiid-commits
mailing list