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 <todd@cloudera.com> | |
| 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 <todd@cloudera.com> | |
| 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; | |
| -@InterfaceAudience.Private | |
| -@InterfaceStability.Evolving |
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); |