Fix Bug TDI-25323 : Parallel job with partitioner / departitioner never stop in some cases like more than 2 tPartitioner components in the same job

https://jira.talendforge.org/browse/TDI-25323

git-svn-id: http://talendforge.org/svn/tos/trunk@101008 f6f1c999-d317-4740-80b0-e6d1abc6f99e
This commit is contained in:
wliu
2013-04-10 12:48:06 +00:00
parent b2e347f4f4
commit 51c671efd5

View File

@@ -237,7 +237,7 @@
%>
<%if(firstIn){%> finally{ <% firstIn = false;}%>
//free memory for "<%=node.getUniqueName() %>"
globalMap.put("<%=origin %>", null);
globalMap.remove("<%=origin %>");
<%
}
}else{
@@ -251,7 +251,7 @@
%>
<%if(firstIn){%> finally{ <% firstIn = false;}%>
//free memory for "<%=node.getUniqueName() %>"
globalMap.put("tHash_Lookup_<%=connection.getName() %>", null);
globalMap.remove("tHash_Lookup_<%=connection.getName() %>");
<%
}
}else{
@@ -259,7 +259,7 @@
%>
<%if(firstIn){%> finally{ <% firstIn = false;}%>
//free memory for "<%=node.getUniqueName() %>"
globalMap.put("tHash_<%=connection.getName() %>", null);
globalMap.remove("tHash_<%=connection.getName() %>");
<%
}
}