[ 
https://issues.apache.org/jira/browse/HADOOP-4162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12897084#action_12897084
 ] 

Alex Rovner commented on HADOOP-4162:
-------------------------------------

We are using 0.20 and LZO can be used for map compression. In which case the 
same issue appears:

[2010-08-10 18:19:18,459] INFO  (JvmMetrics.java:71) - Initializing JVM Metrics 
with processName=SHUFFLE, sessionId=
[2010-08-10 18:19:18,729] INFO  (GPLNativeCodeLoader.java:34) - Loaded native 
gpl library
[2010-08-10 18:19:18,739] INFO  (LzoCodec.java:65) - Successfully loaded & 
initialized native-lzo library [hadoop-lzo rev fatal: Not a git repository]
[2010-08-10 18:19:18,793] INFO  (ReduceTask.java:1014) - ShuffleRamManager: 
MemoryLimit=358881696, MaxSingleShuffleLimit=89720424
[2010-08-10 18:19:18,836] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,839] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,841] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,842] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,844] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,845] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,847] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,849] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,851] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,852] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,854] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,855] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,857] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,859] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,863] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,865] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,867] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,881] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,885] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,886] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,888] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,889] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,891] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,892] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,894] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,895] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,897] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,899] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,901] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,902] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,904] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,905] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,907] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,908] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,910] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,912] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,914] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,915] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,917] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,918] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,920] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,921] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,923] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,924] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,926] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,928] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,930] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,931] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,933] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,934] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,936] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,938] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,939] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,941] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,942] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,943] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,945] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,946] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,947] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,948] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,949] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,950] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,951] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,953] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,954] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,955] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,956] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,957] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,958] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,960] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,961] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,962] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,963] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,964] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,964] INFO  (CodecPool.java:121) - Got brand-new 
decompressor
[2010-08-10 18:19:18,970] INFO  (ReduceTask.java:2468) - 
attempt_201008101538_0280_r_000000_0 Thread started: Thread for merging on-disk 
files
[2010-08-10 18:19:18,971] INFO  (ReduceTask.java:2473) - 
attempt_201008101538_0280_r_000000_0 Thread waiting: Thread for merging on-disk 
files


> CodecPool.getDecompressor(LzopCodec) always creates a brand-new decompressor.
> -----------------------------------------------------------------------------
>
>                 Key: HADOOP-4162
>                 URL: https://issues.apache.org/jira/browse/HADOOP-4162
>             Project: Hadoop Common
>          Issue Type: Bug
>    Affects Versions: 0.18.0
>            Reporter: Hong Tang
>            Assignee: Arun C Murthy
>         Attachments: HADOOP-4162_0_20080911.patch
>
>
> CodecPool.getDecompressor(LzopCodec) always creates a brand-new decompressor. 
> I investigated the code, the reason seems to be the following:
> LzopCodec inherits from LzoCodec. The getDecompressorType() method is 
> supposed to return the concrete Decompressor class type the specific Codec 
> class creates. In this case, LzopCodec creates LzopDecompressors and should 
> return LzopDecompressor.class. But instead, it uses the getDecompressorType() 
> method defined in the parent and returns LzoDecompressor.class.
> This leads to CodecPool unable to properly recycle the decompressors.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.

Reply via email to