This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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; | |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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; |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
class Foo { | |
public void dog() { | |
print("woof"); | |
} | |
public void cat() { | |
print("meow"); | |
} | |
public void both() { |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file has been truncated, but you can view the full file.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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] |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#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); |