根据网上修改未成功TEZ-3703【https://community.hortonworks.co ... alangillegalst.html】
自己修改【只校验大小,不校验时间戳】,目前已经可执行,是否存在其他问题待验证
[mw_shl_code=shell,true]vi tez-api/src/main/java/org/apache/tez/dag/api/DAG.java[/mw_shl_code]
[mw_shl_code=java,true]// 源代码
if (commonTaskLocalFiles.containsKey(resourceName)
&& !commonTaskLocalFiles.get(resourceName).equals(resource)) {
throw new IllegalStateException("There is conflicting local resource (" + resourceName
+ ") between dag local resource and vertex " + v.getName() + " local resource. "
+ "\nResource of dag : " + commonTaskLocalFiles.get(resourceName)
+ "\nResource of vertex: " + resource);
}[/mw_shl_code]
[mw_shl_code=java,true]// 修改后的代码
if (commonTaskLocalFiles.containsKey(resourceName)) {
LocalResource commonResource = commonTaskLocalFiles.get(resourceName);
if (!commonResource.equals(resource)) {
String msg = "There is conflicting local resource (" + resourceName
+ ") between dag local resource and vertex " + v.getName() + " local resource. "
+ "\nResource of dag : " + commonResource + "\nResource of vertex: " + resource;
if (resource.getSize() != commonResource.getSize()) {
throw new IllegalStateException(msg);
} else {
LOG.error("[Default execution before same size. wangjw6] " + msg);
}
}
}[/mw_shl_code] |