You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2014/09/26 19:18:33 UTC
[1/3] git commit: ACCUMULO-3175 Include scaling factor in sleep
statement
Repository: accumulo
Updated Branches:
refs/heads/1.6.2-SNAPSHOT b43abcb5a -> b9a0b27ef
refs/heads/master ed3377626 -> 15ca1007a
ACCUMULO-3175 Include scaling factor in sleep statement
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b9a0b27e
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b9a0b27e
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b9a0b27e
Branch: refs/heads/1.6.2-SNAPSHOT
Commit: b9a0b27eff5bf522ab150a2e83d39f78da32496b
Parents: b43abcb
Author: Josh Elser <el...@apache.org>
Authored: Fri Sep 26 13:17:41 2014 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Fri Sep 26 13:17:41 2014 -0400
----------------------------------------------------------------------
.../org/apache/accumulo/test/Accumulo3047IT.java | 16 +++++++++++++++-
1 file changed, 15 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/b9a0b27e/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java b/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java
index a333901..6066bf3 100644
--- a/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java
+++ b/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java
@@ -34,6 +34,7 @@ import org.apache.accumulo.test.functional.ConfigurableMacIT;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.Text;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
public class Accumulo3047IT extends ConfigurableMacIT {
@@ -50,6 +51,19 @@ public class Accumulo3047IT extends ConfigurableMacIT {
cfg.setProperty(Property.GC_CYCLE_START, "0s");
}
+ private int timeoutFactor = 1;
+
+ @Before
+ public void setup() {
+ try {
+ timeoutFactor = Integer.parseInt(System.getProperty("timeout.factor"));
+ } catch (NumberFormatException e) {
+ log.warn("Could not parse integer from timeout.factor");
+ }
+
+ Assert.assertTrue("timeout.factor must be greater than or equal to 1", timeoutFactor >= 1);
+ }
+
@Test
public void test() throws Exception {
// make a table
@@ -67,7 +81,7 @@ public class Accumulo3047IT extends ConfigurableMacIT {
// get rid of the table
c.tableOperations().delete(tableName);
// let gc run
- UtilWaitThread.sleep(5 * 1000);
+ UtilWaitThread.sleep(timeoutFactor * 5 * 1000);
// look for delete markers
Scanner scanner = c.createScanner(MetadataTable.NAME, Authorizations.EMPTY);
scanner.setRange(MetadataSchema.DeletesSection.getRange());
[3/3] git commit: Merge branch '1.6.2-SNAPSHOT'
Posted by el...@apache.org.
Merge branch '1.6.2-SNAPSHOT'
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/15ca1007
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/15ca1007
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/15ca1007
Branch: refs/heads/master
Commit: 15ca1007adea80b6f4beb9018c5011597da0906a
Parents: ed33776 b9a0b27
Author: Josh Elser <el...@apache.org>
Authored: Fri Sep 26 13:18:18 2014 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Fri Sep 26 13:18:18 2014 -0400
----------------------------------------------------------------------
.../accumulo/test/BadDeleteMarkersCreatedIT.java | 16 +++++++++++++++-
1 file changed, 15 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/15ca1007/test/src/test/java/org/apache/accumulo/test/BadDeleteMarkersCreatedIT.java
----------------------------------------------------------------------
diff --cc test/src/test/java/org/apache/accumulo/test/BadDeleteMarkersCreatedIT.java
index 7d032c1,0000000..6b5fb70
mode 100644,000000..100644
--- a/test/src/test/java/org/apache/accumulo/test/BadDeleteMarkersCreatedIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/BadDeleteMarkersCreatedIT.java
@@@ -1,80 -1,0 +1,94 @@@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * 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 with
+ * 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 implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.accumulo.test;
+
+import java.util.Map.Entry;
+import java.util.SortedSet;
+import java.util.TreeSet;
+
+import org.apache.accumulo.core.client.Connector;
+import org.apache.accumulo.core.client.Scanner;
+import org.apache.accumulo.core.conf.Property;
+import org.apache.accumulo.core.data.Key;
+import org.apache.accumulo.core.data.Value;
+import org.apache.accumulo.core.metadata.MetadataTable;
+import org.apache.accumulo.core.metadata.schema.MetadataSchema;
+import org.apache.accumulo.core.security.Authorizations;
+import org.apache.accumulo.core.util.UtilWaitThread;
+import org.apache.accumulo.minicluster.impl.MiniAccumuloConfigImpl;
+import org.apache.accumulo.test.functional.ConfigurableMacIT;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.io.Text;
+import org.junit.Assert;
++import org.junit.Before;
+import org.junit.Test;
+
+// Accumulo3047
+public class BadDeleteMarkersCreatedIT extends ConfigurableMacIT {
+
+ @Override
+ public int defaultTimeoutSeconds() {
+ return 60;
+ }
+
+ @Override
+ public void configure(MiniAccumuloConfigImpl cfg, Configuration hadoopCoreSite) {
+ cfg.setNumTservers(1);
+ cfg.setProperty(Property.GC_CYCLE_DELAY, "1s");
+ cfg.setProperty(Property.GC_CYCLE_START, "0s");
+ }
+
++ private int timeoutFactor = 1;
++
++ @Before
++ public void setup() {
++ try {
++ timeoutFactor = Integer.parseInt(System.getProperty("timeout.factor"));
++ } catch (NumberFormatException e) {
++ log.warn("Could not parse integer from timeout.factor");
++ }
++
++ Assert.assertTrue("timeout.factor must be greater than or equal to 1", timeoutFactor >= 1);
++ }
++
+ @Test
+ public void test() throws Exception {
+ // make a table
+ String tableName = getUniqueNames(1)[0];
+ Connector c = getConnector();
+ c.tableOperations().create(tableName);
+ // add some splits
+ SortedSet<Text> splits = new TreeSet<Text>();
+ for (int i = 0; i < 10; i++) {
+ splits.add(new Text("" + i));
+ }
+ c.tableOperations().addSplits(tableName, splits);
+ // get rid of all the splits
+ c.tableOperations().deleteRows(tableName, null, null);
+ // get rid of the table
+ c.tableOperations().delete(tableName);
+ // let gc run
- UtilWaitThread.sleep(5 * 1000);
++ UtilWaitThread.sleep(timeoutFactor * 5 * 1000);
+ // look for delete markers
+ Scanner scanner = c.createScanner(MetadataTable.NAME, Authorizations.EMPTY);
+ scanner.setRange(MetadataSchema.DeletesSection.getRange());
+ for (Entry<Key,Value> entry : scanner) {
+ Assert.fail(entry.getKey().getRow().toString());
+ }
+ }
+
+}
[2/3] git commit: ACCUMULO-3175 Include scaling factor in sleep
statement
Posted by el...@apache.org.
ACCUMULO-3175 Include scaling factor in sleep statement
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b9a0b27e
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b9a0b27e
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b9a0b27e
Branch: refs/heads/master
Commit: b9a0b27eff5bf522ab150a2e83d39f78da32496b
Parents: b43abcb
Author: Josh Elser <el...@apache.org>
Authored: Fri Sep 26 13:17:41 2014 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Fri Sep 26 13:17:41 2014 -0400
----------------------------------------------------------------------
.../org/apache/accumulo/test/Accumulo3047IT.java | 16 +++++++++++++++-
1 file changed, 15 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/b9a0b27e/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java b/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java
index a333901..6066bf3 100644
--- a/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java
+++ b/test/src/test/java/org/apache/accumulo/test/Accumulo3047IT.java
@@ -34,6 +34,7 @@ import org.apache.accumulo.test.functional.ConfigurableMacIT;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.Text;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
public class Accumulo3047IT extends ConfigurableMacIT {
@@ -50,6 +51,19 @@ public class Accumulo3047IT extends ConfigurableMacIT {
cfg.setProperty(Property.GC_CYCLE_START, "0s");
}
+ private int timeoutFactor = 1;
+
+ @Before
+ public void setup() {
+ try {
+ timeoutFactor = Integer.parseInt(System.getProperty("timeout.factor"));
+ } catch (NumberFormatException e) {
+ log.warn("Could not parse integer from timeout.factor");
+ }
+
+ Assert.assertTrue("timeout.factor must be greater than or equal to 1", timeoutFactor >= 1);
+ }
+
@Test
public void test() throws Exception {
// make a table
@@ -67,7 +81,7 @@ public class Accumulo3047IT extends ConfigurableMacIT {
// get rid of the table
c.tableOperations().delete(tableName);
// let gc run
- UtilWaitThread.sleep(5 * 1000);
+ UtilWaitThread.sleep(timeoutFactor * 5 * 1000);
// look for delete markers
Scanner scanner = c.createScanner(MetadataTable.NAME, Authorizations.EMPTY);
scanner.setRange(MetadataSchema.DeletesSection.getRange());