Hey guys,

question. How do i enabled tez.runtime.compress programatically ?
When i set this property in the tez-site.xml it is picket up correctly.
But all other options i tried:
- dag.setConf(TezRuntimeConfiguration.TEZ_RUNTIME_COMPRESS, "true");
- mapVertex.setConf(TezRuntimeConfiguration.TEZ_RUNTIME_COMPRESS, "true");
- reduceVertex.setConf(TezRuntimeConfiguration.TEZ_RUNTIME_COMPRESS, "true”);

do not have any effect! (Checking the log output of the Shuffle class)

Johannes

Reply via email to