hbase-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hudson (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (HBASE-12487) Explicitly flush the file name in sweep job
Date Wed, 22 Jul 2015 22:49:26 GMT

    [ https://issues.apache.org/jira/browse/HBASE-12487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14637836#comment-14637836

Hudson commented on HBASE-12487:

FAILURE: Integrated in HBase-TRUNK #6672 (See [https://builds.apache.org/job/HBase-TRUNK/6672/])
HBASE-12487 Explicitly flush the file name in sweep job (Jingcheng Du) (ramkrishna: rev 170eb1e88d51776b093f7b546e4b9b0dc6e2cf52)
* hbase-server/src/main/java/org/apache/hadoop/hbase/mob/mapreduce/SweepJob.java
* hbase-server/src/main/java/org/apache/hadoop/hbase/mob/mapreduce/SweepReducer.java

> Explicitly flush the file name in sweep job
> -------------------------------------------
>                 Key: HBASE-12487
>                 URL: https://issues.apache.org/jira/browse/HBASE-12487
>             Project: HBase
>          Issue Type: Sub-task
>          Components: regionserver, Scanners
>    Affects Versions: hbase-11339
>            Reporter: Jingcheng Du
>            Assignee: Jingcheng Du
>             Fix For: hbase-11339
>         Attachments: HBASE-12487.diff
> Currently in the implementation of sweeper, we need to remove the mob files that are
not referenced by hbase any more.
> # List the names of all the existing files and write them to a seq file.
> # In each reducer, write the visited mob file names to a seq file.
> # After the mapreduce is done, remove the files that are existent in step1 but not in
step2 (those are the unused/unreferenced files).
> Currently the flush of the writer depends on the IOUtils.closeStream(writer), if this
close operation fails silently, the file names won't be written to seq files, some files that
are still referenced by hbase will be archived after the mapreduce is finished.
> We should explicitly invoke write.hflush() to flush out the user buffer.

This message was sent by Atlassian JIRA

View raw message