rbalamohan commented on code in PR #98:
URL: https://github.com/apache/tez/pull/98#discussion_r1003213501
##########
tez-tests/src/test/java/org/apache/tez/test/TestTezJobs.java:
##########
@@ -164,10 +164,35 @@ public static void tearDown() {
public void testHashJoinExample() throws Exception {
HashJoinExample hashJoinExample = new HashJoinExample();
hashJoinExample.setConf(new Configuration(mrrTezCluster.getConfig()));
- Path stagingDirPath = new Path("/tmp/tez-staging-dir");
- Path inPath1 = new Path("/tmp/hashJoin/inPath1");
- Path inPath2 = new Path("/tmp/hashJoin/inPath2");
- Path outPath = new Path("/tmp/hashJoin/outPath");
+ runHashJoinExample(hashJoinExample);
+ }
+
+ @Test(timeout = 60000)
+ public void testHashJoinExampleWithLogPattern() throws Exception {
+ HashJoinExample hashJoinExample = new HashJoinExample();
+
+ Configuration patternConfig = new Configuration(mrrTezCluster.getConfig());
+
+ patternConfig.set(TezConfiguration.TEZ_AM_LOG_LEVEL, "debug");
+ patternConfig.set(TezConfiguration.TEZ_TASK_LOG_LEVEL, "debug");
+ patternConfig.set(TezConfiguration.TEZ_LOG_PATTERN_LAYOUT_AM,
+ "%d{ISO8601} [%p] [%t (queryId=%X{queryId} dag=%X{dagId})] |%c{2}|:
%m%n");
+ patternConfig.set(TezConfiguration.TEZ_LOG_PATTERN_LAYOUT_TASK,
Review Comment:
Can you check for the case when the value can be reset back to original
value? Plz refer to my comment earlier in TezConfiguration.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@tez.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
