Skip to content

Instantly share code, notes, and snippets.

View toddlipcon's full-sized avatar

Todd Lipcon toddlipcon

View GitHub Profile
diff --git a/src/java/org/apache/hadoop/hdfs/BlockReader.java b/src/java/org/apache/hadoop/hdfs/BlockReader.java
index 9adedef..ff85af5 100644
--- a/src/java/org/apache/hadoop/hdfs/BlockReader.java
+++ b/src/java/org/apache/hadoop/hdfs/BlockReader.java
@@ -95,6 +95,7 @@ public class BlockReader extends FSInputChecker {
private final long bytesNeededToFinish;
private boolean eos = false;
+ private boolean sentStatusCode = false;
import org.apache.hadoop.fs.*;
import org.apache.hadoop.conf.Configuration;
import java.util.Random;
import java.io.IOException;
public class RandomIO {
private static class Reader extends Thread {
Path path;
FileSystem fs;
commit 207d7caf5dba7f2fe8df905d1d25971b7be700e3
Author: Todd Lipcon <[email protected]>
Date: Tue Jul 26 14:45:46 2011 -0700
refactor edits log buffering to new class
diff --git a/hdfs/src/java/org/apache/hadoop/hdfs/server/namenode/EditLogBackupOutputStream.java b/hdfs/src/java/org/apache/hadoop/hdfs/server/namenode/EditLogBackupOutputStream.java
index 2685e69..5e9d539 100644
--- a/hdfs/src/java/org/apache/hadoop/hdfs/server/namenode/EditLogBackupOutputStream.java
+++ b/hdfs/src/java/org/apache/hadoop/hdfs/server/namenode/EditLogBackupOutputStream.java
class Foo {
public void dog() {
print("woof");
}
public void cat() {
print("meow");
}
public void both() {
commit 6718fc5bf16eae47e291b12313b112a0bfd03d16
Author: Todd Lipcon <[email protected]>
Date: Sun Jun 12 20:58:10 2011 -0700
Make pom use CDH
diff --git a/pom.xml b/pom.xml
index 059dc0e..87dad99 100644
--- a/pom.xml
+++ b/pom.xml
hbase(main):022:0> scan 't1', { FILTER => "SingleColumnValueFilter('f1', 'word', >, 'binary:c')" }
ROW COLUMN+CELL
r1 column=f1:word, timestamp=1315608975212, value=hello
r1 column=f2:word, timestamp=1315608975238, value=bonjour
r2 column=f1:word, timestamp=1315608975258, value=goodbye
r2 column=f2:word, timestamp=1315608975286, value=au revoir
2 row(s) in 0.0300 seconds
@toddlipcon
toddlipcon / er
Created September 21, 2011 07:21
This file has been truncated, but you can view the full file.
it was a bright cold day in April , and the clocks were striking thirteen . Winston Smith , his chin nuzzled into his breast in an effort to escape the vile wind , slipped quickly through the glass doors of Victory Mansions , though not quickly enough to prevent a swirl of gritty dust from entering along with him . intr - o zi senina si friguroasa de aprilie , pe cind ceasurile bateau ora treisprezece , Winston Smith , cu barbia infundata in piept pentru a scapa de vintul care - l lua pe sus , se strecura iute prin usile de sticla ale Blocului Victoria , desi nu destul de repede pentru a impiedica un virtej de praf si nisip sa patrunda o data cu el .
the hallway smelt of boiled cabbage and old rag mats . holul blocului mirosea a varza calita si a presuri vechi .
at one end of it a coloured poster , too large for indoor display , had been tacked to the wall . It depicted simply an enormous face , more than a metre wide : the face of a man of about forty - five , with a heavy black moustache and ruggedly ha
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/protocol/HeartbeatResponse.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/protocol/HeartbeatResponse.java
index 2d6aa53..372589a 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/protocol/HeartbeatResponse.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/protocol/HeartbeatResponse.java
@@ -26,15 +26,18 @@ import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.io.ObjectWritable;
import org.apache.hadoop.io.Writable;
[email protected]
[email protected]
Exception in thread "ThreadedStreamConsumer" java.lang.OutOfMemoryError: Java heap space
at java.util.Arrays.copyOf(Arrays.java:2882)
at java.lang.AbstractStringBuilder.expandCapacity(AbstractStringBuilder.java:100)
at java.lang.AbstractStringBuilder.append(AbstractStringBuilder.java:390)
at java.lang.StringBuffer.append(StringBuffer.java:224)
at org.apache.maven.surefire.report.ConsoleOutputFileReporter.writeMessage(ConsoleOutputFileReporter.java:115)
at org.apache.maven.surefire.report.MulticastingReporter.writeMessage(MulticastingReporter.java:101)
at org.apache.maven.surefire.report.TestSetRunListener.writeTestOutput(TestSetRunListener.java:99)
at org.apache.maven.plugin.surefire.booterclient.output.ForkClient.consumeLine(ForkClient.java:132)
at org.apache.maven.plugin.surefire.booterclient.output.ThreadedStreamConsumer$Pumper.run(ThreadedStreamConsumer.java:67)
#include <xmmintrin.h>
#include <stdio.h>
#include <stdint.h>
#include <string.h>
#include <assert.h>
__m64 zero ;
inline long atol_chunk(char *str) {
uint32_t chunk = *((uint32_t *)str);