Return-Path: X-Original-To: apmail-accumulo-notifications-archive@minotaur.apache.org Delivered-To: apmail-accumulo-notifications-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id EB16317CE5 for ; Sat, 28 Mar 2015 13:30:55 +0000 (UTC) Received: (qmail 8211 invoked by uid 500); 28 Mar 2015 13:30:55 -0000 Delivered-To: apmail-accumulo-notifications-archive@accumulo.apache.org Received: (qmail 8164 invoked by uid 500); 28 Mar 2015 13:30:55 -0000 Mailing-List: contact notifications-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: jira@apache.org Delivered-To: mailing list notifications@accumulo.apache.org Received: (qmail 8153 invoked by uid 99); 28 Mar 2015 13:30:55 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 28 Mar 2015 13:30:55 +0000 Date: Sat, 28 Mar 2015 13:30:55 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: notifications@accumulo.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (ACCUMULO-3645) Iterators not run at compaction when tablets are empty MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/ACCUMULO-3645?page=3Dcom.atlass= ian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D1= 4385306#comment-14385306 ]=20 ASF GitHub Bot commented on ACCUMULO-3645: ------------------------------------------ Github user keith-turner commented on a diff in the pull request: https://github.com/apache/accumulo/pull/22#discussion_r27345081 =20 --- Diff: core/src/main/java/org/apache/accumulo/core/iterators/user/Ha= rdListIterator.java --- @@ -0,0 +1,111 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed wi= th + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version= 2.0 + * (the "License"); you may not use this file except in compliance wit= h + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or imp= lied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.accumulo.core.iterators.user; + +import org.apache.accumulo.core.data.ByteSequence; +import org.apache.accumulo.core.data.Key; +import org.apache.accumulo.core.data.PartialKey; +import org.apache.accumulo.core.data.Range; +import org.apache.accumulo.core.data.Value; +import org.apache.accumulo.core.iterators.IteratorEnvironment; +import org.apache.accumulo.core.iterators.SortedKeyValueIterator; +import org.apache.accumulo.core.util.PeekingIterator; +import org.apache.hadoop.io.Text; +import org.apache.log4j.Logger; + +import java.io.IOException; +import java.util.Collection; +import java.util.Collections; +import java.util.Map; +import java.util.SortedMap; +import java.util.TreeMap; + +/** + * A wrapper making a list of hardcoded data into a SKVI. For testing. + */ +public class HardListIterator implements SortedKeyValueIterator { + private static final Logger log =3D Logger.getLogger(HardListIterato= r.class); + public final static SortedMap allEntriesToInject; + static { + SortedMap t =3D new TreeMap<>(); + t.put(new Key(new Text("a1"), new Text("colF3"), new Text("colQ3")= , System.currentTimeMillis()), new Value("1".getBytes())); + t.put(new Key(new Text("c1"), new Text("colF3"), new Text("colQ3")= , System.currentTimeMillis()), new Value("1".getBytes())); + t.put(new Key(new Text("m1"), new Text("colF3"), new Text("colQ3")= , System.currentTimeMillis()), new Value("1".getBytes())); + allEntriesToInject =3D Collections.unmodifiableSortedMap(t); // fo= r safety + } + + private PeekingIterator> inner; + private Range seekRng; + + @Override + public void init(SortedKeyValueIterator source, Map options, IteratorEnvironment env) throws IOException { --- End diff -- =20 Your comment made me realize HardListIterator was in core/src/main/java= , should probably be in core/src/test/java. On Mar 27, 2015 7:33 PM, "Dylan Hutchison" w= rote: =20 > In > core/src/main/java/org/apache/accumulo/core/iterators/user/HardListIt= erator.java > : > > > +public class HardListIterator implements SortedKeyValueIterator { > > + private static final Logger log =3D Logger.getLogger(HardListIte= rator.class); > > + public final static SortedMap allEntriesToInject; > > + static { > > + SortedMap t =3D new TreeMap<>(); > > + t.put(new Key(new Text("a1"), new Text("colF3"), new Text("col= Q3"), System.currentTimeMillis()), new Value("1".getBytes())); > > + t.put(new Key(new Text("c1"), new Text("colF3"), new Text("col= Q3"), System.currentTimeMillis()), new Value("1".getBytes())); > > + t.put(new Key(new Text("m1"), new Text("colF3"), new Text("col= Q3"), System.currentTimeMillis()), new Value("1".getBytes())); > > + allEntriesToInject =3D Collections.unmodifiableSortedMap(t); /= / for safety > > + } > > + > > + private PeekingIterator> inner; > > + private Range seekRng; > > + > > + @Override > > + public void init(SortedKeyValueIterator source, Map options, IteratorEnvironment env) throws IOException { > > I confirmed that env.isFullMajorCompaction() is true when the tablet = has > no files on a standalone single-node instance. > > Writing a test for it is possible by writing an iterator, similar to > HardListIterator, that emits an entry with a boolean value-- the resu= lt of > env.isFullMajorCompaction(). It does not seem worth it to include a n= ew > iterator class in the source code for one test like this. > > =E2=80=94 > Reply to this email directly or view it on GitHub > . > > Iterators not run at compaction when tablets are empty > ------------------------------------------------------ > > Key: ACCUMULO-3645 > URL: https://issues.apache.org/jira/browse/ACCUMULO-3645 > Project: Accumulo > Issue Type: Bug > Components: client, mini, tserver > Affects Versions: 1.6.1 > Environment: Ubuntu 14.04, Accumulo 1.6.1, Hadoop 2.6.0, Zookeepe= r 3.4.6 > Reporter: Dylan Hutchison > Assignee: Dylan Hutchison > > When an iterator is configured to run during a one-time manual major comp= action on a tablet that is empty, the iterator never runs. It seems as if A= ccumulo never constructs the SKVI stack at all, because it tries to optimiz= e by eliminating "unnecessary" tablet compactions. Also true of MiniAccumul= o. > This is bad for "generator" iterators that emit keys (in sorted order) no= t present in the tablet's data. They never have a chance to run. > A workaround is for the client to insert "dummy data" into the tablets he= wants to compact, before starting a compaction with "generator" iterators.= Note that *any* data is sufficient, even delete keys, to ensure the SKVI = stack is built and run through. > Test file: [InjectTest|https://github.com/Accla/d4m_api_java/blob/master/= src/test/java/edu/mit/ll/graphulo/InjectTest.java] > * method {{testInjectOnCompact_Empty}} fails because no data is in the ta= blets > * method {{testInjectOnCompact}} passes because data is written into the = tablets before initiating compaction.=20 > Two logs follow. Both have a [DebugIterator|https://accumulo.apache.org/= 1.6/apidocs/org/apache/accumulo/core/iterators/DebugIterator.html] set afte= r an [InjectIterator|https://github.com/Accla/d4m_api_java/blob/master/src/= main/java/edu/mit/ll/graphulo/InjectIterator.java], an SKVI which "generate= s" hard-coded entries. The root user scans the table after flush and compa= ct. > Logs when no data in the tablets: > {code} > 2015-03-05 06:58:04,914 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:04,974 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.01 secs, nbTimes =3D [4 4 4.00 1]=20 > 2015-03-05 06:58:04,992 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:60455 15 entries in 0.01 secs (lookup_time:0.01 secs tablets:1 ranges:= 1)=20 > 2015-03-05 06:58:05,018 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:60455 2 entries in 0.00 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:05,052 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 4 entries in 0.00 secs, nbTimes =3D [2 2 2.00 1]=20 > 2015-03-05 06:58:05,054 [tserver.TabletServer] DEBUG: Got compact message= from user: !SYSTEM > 2015-03-05 06:58:05,135 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:60455 15 entries in 0.01 secs (lookup_time:0.01 secs tablets:1 ranges:= 1)=20 > 2015-03-05 06:58:05,138 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36422 2 entries in 0.00 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:05,384 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36422 2 entries in 0.00 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:05,386 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:60455 15 entries in 0.01 secs (lookup_time:0.01 secs tablets:1 ranges:= 1)=20 > 2015-03-05 06:58:05,504 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:60455 2 entries in 0.00 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:05,509 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36422 15 entries in 0.01 secs (lookup_time:0.01 secs tablets:1 ranges:= 1)=20 > 2015-03-05 06:58:06,069 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.01 secs, nbTimes =3D [3 3 3.00 1]=20 > 2015-03-05 06:58:06,158 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36456;=20 > 2015-03-05 06:58:06,158 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36456;=20 > 2015-03-05 06:58:06,168 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36456 2 entries in 0.01 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:06,174 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36456;=20 > 2015-03-05 06:58:06,174 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36456; action: scan; targetTable: test_InjectTest_test= InjectOnCompact_Empty; authorizations: ; range: {5m;f<=3D[(-inf,f%00; : [] = 9223372036854775807 false)]}; columns: []; iterators: []; iteratorOptions: = {}; > 2015-03-05 06:58:06,174 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36478;=20 > 2015-03-05 06:58:06,174 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36456;=20 > 2015-03-05 06:58:06,174 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36478; action: scan; targetTable: test_InjectTest_test= InjectOnCompact_Empty; authorizations: ; range: {5m<;f=3D[[f%00; : [] 92233= 72036854775807 false,+inf)]}; columns: []; iterators: []; iteratorOptions: = {}; > 2015-03-05 06:58:06,175 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36478;=20 > 2015-03-05 06:58:06,176 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36478 0 entries in 0.00 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:06,176 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36456 0 entries in 0.00 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > {code} > Logs when data is in the tablets: > {code} > 2015-03-05 06:58:31,673 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:31,674 [tserver.NativeMap] DEBUG: Allocated native map 0= x000000000300ac20 > 2015-03-05 06:58:31,674 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:60455 17 entries in 0.01 secs (lookup_time:0.00 secs tablets:1 ranges:= 1)=20 > 2015-03-05 06:58:31,676 [tserver.Tablet] DEBUG: MinC initiate lock 0.00 s= ecs > 2015-03-05 06:58:31,676 [tserver.NativeMap] DEBUG: Allocated native map 0= x000000000300acc0 > 2015-03-05 06:58:31,676 [tserver.Tablet] DEBUG: MinC initiate lock 0.00 s= ecs > 2015-03-05 06:58:31,684 [tserver.MinorCompactor] DEBUG: Begin minor compa= ction hdfs://localhost:9000/accumulo/tables/5n/t-00001h5/F00001h6.rf_tmp 5n= ;f< > 2015-03-05 06:58:31,691 [tserver.MinorCompactor] DEBUG: Begin minor compa= ction hdfs://localhost:9000/accumulo/tables/5n/default_tablet/F00001h7.rf_t= mp 5n<;f > 2015-03-05 06:58:31,725 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [1 1 1.00 1]=20 > 2015-03-05 06:58:31,726 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:31,766 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:60455 2 entries in 0.00 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:31,779 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [1 1 1.00 1]=20 > 2015-03-05 06:58:31,780 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:31,833 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [1 1 1.00 1]=20 > 2015-03-05 06:58:31,834 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:31,886 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [1 1 1.00 1]=20 > 2015-03-05 06:58:31,887 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:31,939 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [1 1 1.00 1]=20 > 2015-03-05 06:58:31,940 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:31,992 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [1 1 1.00 1]=20 > 2015-03-05 06:58:31,993 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:32,046 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [0 0 0.00 1]=20 > 2015-03-05 06:58:32,047 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:32,099 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [1 1 1.00 1]=20 > 2015-03-05 06:58:32,100 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:32,147 [tserver.Compactor] DEBUG: Compaction 5n;f< 1 rea= d | 1 written | 2,147,483,647 entries/sec | 0.000 secs > 2015-03-05 06:58:32,148 [tserver.Compactor] DEBUG: Compaction 5n<;f 2 rea= d | 2 written | 2,147,483,647 entries/sec | 0.000 secs > 2015-03-05 06:58:32,153 [tserver.Tablet] DEBUG: Logs for memory compacted= : 5n;f< localhost:9997/hdfs://localhost:9000/accumulo/wal/localhost+9997/70= 6df902-2745-4c08-86bf-dfd4e9b8c729 > 2015-03-05 06:58:32,153 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [2 2 2.00 1]=20 > 2015-03-05 06:58:32,153 [tserver.Tablet] DEBUG: Logs to be destroyed: 5n;= f< localhost:9997/hdfs://localhost:9000/accumulo/wal/localhost+9997/706df90= 2-2745-4c08-86bf-dfd4e9b8c729 > 2015-03-05 06:58:32,155 [tserver.Tablet] DEBUG: Logs for memory compacted= : 5n<;f localhost:9997/hdfs://localhost:9000/accumulo/wal/localhost+9997/70= 6df902-2745-4c08-86bf-dfd4e9b8c729 > 2015-03-05 06:58:32,155 [tserver.Tablet] DEBUG: Logs to be destroyed: 5n<= ;f localhost:9997/hdfs://localhost:9000/accumulo/wal/localhost+9997/706df90= 2-2745-4c08-86bf-dfd4e9b8c729 > 2015-03-05 06:58:32,155 [tserver.TabletServer] DEBUG: Got flush message f= rom user: !SYSTEM > 2015-03-05 06:58:32,172 [log.TabletServerLogger] DEBUG: wrote MinC finis= h 400: writeTime:10ms=20 > 2015-03-05 06:58:32,173 [tserver.Tablet] TABLET_HIST: 5n;f< MinC [memory]= -> hdfs://localhost:9000/accumulo/tables/5n/t-00001h5/F00001h6.rf > 2015-03-05 06:58:32,173 [tserver.Tablet] DEBUG: MinC finish lock 0.00 sec= s 5n;f< > 2015-03-05 06:58:32,173 [tserver.NativeMap] DEBUG: Deallocating native ma= p 0x00000000037a1720 > 2015-03-05 06:58:32,178 [log.TabletServerLogger] DEBUG: wrote MinC finis= h 401: writeTime:11ms=20 > 2015-03-05 06:58:32,178 [tserver.Tablet] TABLET_HIST: 5n<;f MinC [memory]= -> hdfs://localhost:9000/accumulo/tables/5n/default_tablet/F00001h7.rf > 2015-03-05 06:58:32,178 [tserver.Tablet] DEBUG: MinC finish lock 0.00 sec= s 5n<;f > 2015-03-05 06:58:32,178 [tserver.NativeMap] DEBUG: Deallocating native ma= p 0x000000000300aaa0 > 2015-03-05 06:58:32,208 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [1 1 1.00 1]=20 > 2015-03-05 06:58:32,253 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 4 entries in 0.00 secs, nbTimes =3D [1 1 1.00 1]=20 > 2015-03-05 06:58:32,254 [tserver.TabletServer] DEBUG: Got compact message= from user: !SYSTEM > 2015-03-05 06:58:32,256 [tserver.Tablet] DEBUG: Major compaction plan: nu= ll propogate deletes : false > 2015-03-05 06:58:32,256 [tserver.Tablet] DEBUG: MajC initiate lock 0.00 s= ecs, wait 0.00 secs > 2015-03-05 06:58:32,256 [tserver.Tablet] DEBUG: Major compaction plan: nu= ll propogate deletes : false > 2015-03-05 06:58:32,256 [tserver.Tablet] DEBUG: MajC initiate lock 0.00 s= ecs, wait 0.00 secs > 2015-03-05 06:58:32,257 [tserver.Tablet] DEBUG: Starting MajC 5n<;f (USER= ) [hdfs://localhost:9000/accumulo/tables/5n/default_tablet/F00001h7.rf] -->= hdfs://localhost:9000/accumulo/tables/5n/default_tablet/A00001h8.rf_tmp [= name:InjectIterator, priority:15, class:edu.mit.ll.graphulo.InjectIterator,= properties:{}, name:DebugIterator, priority:16, class:org.apache.accumulo.= core.iterators.DebugIterator, properties:{}] > 2015-03-05 06:58:32,257 [tserver.Tablet] DEBUG: Starting MajC 5n;f< (USER= ) [hdfs://localhost:9000/accumulo/tables/5n/t-00001h5/F00001h6.rf] --> hdfs= ://localhost:9000/accumulo/tables/5n/t-00001h5/A00001h9.rf_tmp [name:Injec= tIterator, priority:15, class:edu.mit.ll.graphulo.InjectIterator, propertie= s:{}, name:DebugIterator, priority:16, class:org.apache.accumulo.core.itera= tors.DebugIterator, properties:{}] > 2015-03-05 06:58:32,270 [graphulo.BranchIterator] INFO : class edu.mit.ll= .graphulo.InjectIterator: init on scope majc fullScan=3Dtrue > 2015-03-05 06:58:32,270 [iterators.DebugIterator] DEBUG: init(edu.mit.ll.= graphulo.InjectIterator@20a11899, {}, org.apache.accumulo.tserver.TabletIte= ratorEnvironment@3055f58b) > 2015-03-05 06:58:32,271 [iterators.DebugIterator] DEBUG: 0x5B6B9177 seek(= [f%00; : [] 9223372036854775807 false,+inf), [], false) > 2015-03-05 06:58:32,272 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> true > 2015-03-05 06:58:32,272 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pKey() --> kTablet2 :cq [] 1425556711614 false > 2015-03-05 06:58:32,272 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> true > 2015-03-05 06:58:32,272 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pKey() --> kTablet2 :cq [] 1425556711614 false > 2015-03-05 06:58:32,272 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> true > 2015-03-05 06:58:32,272 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pKey() --> kTablet2 :cq [] 1425556711614 false > 2015-03-05 06:58:32,272 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pValue() --> 7 > 2015-03-05 06:58:32,272 [iterators.DebugIterator] DEBUG: 0x5B6B9177 next(= ) > 2015-03-05 06:58:32,272 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> true > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pKey() --> m1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> true > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pKey() --> m1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> true > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pKey() --> m1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pValue() --> 1 > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 next(= ) > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> true > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pKey() --> zTablet2 :cq [] 1425556711614 false > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> true > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pKey() --> zTablet2 :cq [] 1425556711614 false > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> true > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pKey() --> zTablet2 :cq [] 1425556711614 false > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 getTo= pValue() --> 7 > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 next(= ) > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> false > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> false > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> false > 2015-03-05 06:58:32,273 [iterators.DebugIterator] DEBUG: 0x5B6B9177 hasTo= p() --> false > 2015-03-05 06:58:32,275 [graphulo.BranchIterator] INFO : class edu.mit.ll= .graphulo.InjectIterator: init on scope majc fullScan=3Dtrue > 2015-03-05 06:58:32,275 [iterators.DebugIterator] DEBUG: init(edu.mit.ll.= graphulo.InjectIterator@6b76817, {}, org.apache.accumulo.tserver.TabletIter= atorEnvironment@7312c172) > 2015-03-05 06:58:32,275 [iterators.DebugIterator] DEBUG: 0x545A5E63 seek(= (-inf,f%00; : [] 9223372036854775807 false), [], false) > 2015-03-05 06:58:32,276 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,276 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> a1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,276 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> a1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pValue() --> 1 > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 next(= ) > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> aTablet1 :cq [] 1425556711614 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> aTablet1 :cq [] 1425556711614 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> aTablet1 :cq [] 1425556711614 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pValue() --> 7 > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 next(= ) > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> c1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> c1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> c1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pValue() --> 1 > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 next(= ) > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> m1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> m1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> true > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pKey() --> m1 colF3:colQ3 [] 1425553534769 false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 getTo= pValue() --> 1 > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 next(= ) > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> false > 2015-03-05 06:58:32,277 [iterators.DebugIterator] DEBUG: 0x545A5E63 hasTo= p() --> false > 2015-03-05 06:58:32,307 [tserver.Compactor] DEBUG: Compaction 5n<;f 2 rea= d | 3 written | 181 entries/sec | 0.011 secs > 2015-03-05 06:58:32,320 [tserver.TabletServer] INFO : Adding 1 logs for e= xtent !0<;~ as alias 3 > 2015-03-05 06:58:32,340 [tserver.Tablet] DEBUG: MajC finish lock 0.00 sec= s > 2015-03-05 06:58:32,340 [tserver.Tablet] TABLET_HIST: 5n<;f MajC [hdfs://= localhost:9000/accumulo/tables/5n/default_tablet/F00001h7.rf] --> hdfs://lo= calhost:9000/accumulo/tables/5n/default_tablet/A00001h8.rf > 2015-03-05 06:58:32,612 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36422 2 entries in 0.00 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:32,612 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:60455 17 entries in 0.01 secs (lookup_time:0.01 secs tablets:1 ranges:= 1)=20 > 2015-03-05 06:58:32,718 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36525;=20 > 2015-03-05 06:58:32,722 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36525;=20 > 2015-03-05 06:58:32,725 [tserver.Compactor] DEBUG: Compaction 5n;f< 1 rea= d | 4 written | 71 entries/sec | 0.014 secs > 2015-03-05 06:58:32,736 [tserver.TabletServer] DEBUG: UpSess 127.0.0.1:36= 525 59 in 0.018s, at=3D[0 0 0.00 1] ft=3D0.013s(pt=3D0.000s lt=3D0.013s ct= =3D0.000s) > 2015-03-05 06:58:32,749 [tserver.Tablet] DEBUG: MajC finish lock 0.00 sec= s > 2015-03-05 06:58:32,749 [tserver.Tablet] TABLET_HIST: 5n;f< MajC [hdfs://= localhost:9000/accumulo/tables/5n/t-00001h5/F00001h6.rf] --> hdfs://localho= st:9000/accumulo/tables/5n/t-00001h5/A00001h9.rf > 2015-03-05 06:58:33,269 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:60455 !0 6 entries in 0.00 secs, nbTimes =3D [4 4 4.00 1]=20 > 2015-03-05 06:58:33,361 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36506;=20 > 2015-03-05 06:58:33,361 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36526;=20 > 2015-03-05 06:58:33,362 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36506; action: scan; targetTable: test_InjectTest_test= InjectOnCompact; authorizations: ; range: {5n;f<=3D[(-inf,f%00; : [] 922337= 2036854775807 false)]}; columns: []; iterators: []; iteratorOptions: {}; > 2015-03-05 06:58:33,362 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36526; action: scan; targetTable: test_InjectTest_test= InjectOnCompact; authorizations: ; range: {5n<;f=3D[[f%00; : [] 92233720368= 54775807 false,+inf)]}; columns: []; iterators: []; iteratorOptions: {}; > 2015-03-05 06:58:33,362 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36506;=20 > 2015-03-05 06:58:33,362 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36526;=20 > 2015-03-05 06:58:33,378 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36526 3 entries in 0.02 secs (lookup_time:0.01 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:33,378 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36506 3 entries in 0.02 secs (lookup_time:0.01 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:33,459 [tserver.TabletServer] DEBUG: ScanSess tid 127.0.= 0.1:36530 !0 0 entries in 0.00 secs, nbTimes =3D [0 0 0.00 1]=20 > 2015-03-05 06:58:33,493 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36525;=20 > 2015-03-05 06:58:33,495 [Audit ] INFO : operation: permitted; user: roo= t; client: 127.0.0.1:36525;=20 > 2015-03-05 06:58:33,505 [tserver.TabletServer] DEBUG: UpSess 127.0.0.1:36= 525 4 in 0.011s, at=3D[1 1 1.00 1] ft=3D0.008s(pt=3D0.000s lt=3D0.008s ct= =3D0.000s) > 2015-03-05 06:58:33,580 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:60455 2 entries in 0.00 secs (lookup_time:0.00 secs tablets:1 ranges:1= )=20 > 2015-03-05 06:58:33,586 [tserver.TabletServer] DEBUG: MultiScanSess 127.0= .0.1:36422 17 entries in 0.01 secs (lookup_time:0.01 secs tablets:1 ranges:= 1)=20 > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)