Return-Path: X-Original-To: apmail-incubator-chukwa-dev-archive@www.apache.org Delivered-To: apmail-incubator-chukwa-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 1B4A89DF8 for ; Mon, 16 Apr 2012 22:52:38 +0000 (UTC) Received: (qmail 90330 invoked by uid 500); 16 Apr 2012 22:52:38 -0000 Delivered-To: apmail-incubator-chukwa-dev-archive@incubator.apache.org Received: (qmail 90236 invoked by uid 500); 16 Apr 2012 22:52:38 -0000 Mailing-List: contact chukwa-dev-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: chukwa-dev@incubator.apache.org Delivered-To: mailing list chukwa-dev@incubator.apache.org Received: (qmail 90228 invoked by uid 99); 16 Apr 2012 22:52:38 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Apr 2012 22:52:37 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Apr 2012 22:52:37 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id F074739A7CD for ; Mon, 16 Apr 2012 22:52:16 +0000 (UTC) Date: Mon, 16 Apr 2012 22:52:16 +0000 (UTC) From: "Abhijit Dhar (Updated) (JIRA)" To: chukwa-dev@incubator.apache.org Message-ID: <1550623105.30777.1334616736997.JavaMail.tomcat@hel.zones.apache.org> In-Reply-To: <1146066018.5211.1328221377799.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Updated] (CHUKWA-632) Logs getting lost in hbase using TsProcessor MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/CHUKWA-632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhijit Dhar updated CHUKWA-632: -------------------------------- Status: Patch Available (was: Open) > Logs getting lost in hbase using TsProcessor > -------------------------------------------- > > Key: CHUKWA-632 > URL: https://issues.apache.org/jira/browse/CHUKWA-632 > Project: Chukwa > Issue Type: Bug > Affects Versions: 0.5.0 > Reporter: Abhijit Dhar > Attachments: patch.txt > > > When collector writes to hbase using TsProcessor, it is using timestamp as the key. If there are multiple log statements with the same timestamp, which is the key, it looses them in hbase. > As a fix, I extended AbstractProcessor and built my key using timestamp and the AbstractProcessor.startOffset. But, for that, it has to be protected or a getter on it in AbstractProcessor class to be able to use it. > Also, the way OutputCollector.collect method works, it might need to redo the way rowKey is created. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira