This is an automated email from the ASF dual-hosted git repository.
kenhuuu pushed a commit to branch TINKERPOP-2978-3
in repository https://gitbox.apache.org/repos/asf/tinkerpop.git
The following commit(s) were added to refs/heads/TINKERPOP-2978-3 by this push:
new 3ab08bc9bb Modify tests
3ab08bc9bb is described below
commit 3ab08bc9bbc6287b2312ff56d1322b2ee6c3a7dd
Author: Ken Hu <[email protected]>
AuthorDate: Wed Oct 18 18:26:41 2023 -0700
Modify tests
---
.../gremlin/hadoop/structure/io/RecordReaderWriterTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/hadoop-gremlin/src/test/java/org/apache/tinkerpop/gremlin/hadoop/structure/io/RecordReaderWriterTest.java
b/hadoop-gremlin/src/test/java/org/apache/tinkerpop/gremlin/hadoop/structure/io/RecordReaderWriterTest.java
index b73f62f43d..43f26f801f 100644
---
a/hadoop-gremlin/src/test/java/org/apache/tinkerpop/gremlin/hadoop/structure/io/RecordReaderWriterTest.java
+++
b/hadoop-gremlin/src/test/java/org/apache/tinkerpop/gremlin/hadoop/structure/io/RecordReaderWriterTest.java
@@ -78,7 +78,7 @@ public abstract class RecordReaderWriterTest {
public void shouldSplitFileAndWriteProperSplits() throws Exception {
for (int numberOfSplits = 1; numberOfSplits < 10; numberOfSplits++) {
final File testFile = new
File(TestFiles.PATHS.get(getInputFilename()));
- logger.info("Testing: {}", testFile + " (splits {}",
numberOfSplits + ")");
+ System.out.println("Testing: " + testFile + " (splits " +
numberOfSplits + ")");
final List<FileSplit> splits = generateFileSplits(testFile,
numberOfSplits);
final Class<? extends InputFormat<NullWritable, VertexWritable>>
inputFormatClass = getInputFormat();
final Class<? extends OutputFormat<NullWritable, VertexWritable>>
outputFormatClass = getOutputFormat();
@@ -140,12 +140,12 @@ public abstract class RecordReaderWriterTest {
boolean foundKeyValue = false;
for (final FileSplit split : fileSplits) {
- logger.info("\treading file split {}", split.getPath().getName() +
" ({}", split.getStart() + "..." + (split.getStart() + split.getLength()), "{}
{} bytes)");
+ System.out.println("\treading file split " +
split.getPath().getName() + " (" + split.getStart() + "..." + (split.getStart()
+ split.getLength()) + " bytes)");
final RecordReader reader = inputFormat.createRecordReader(split,
job);
float lastProgress = -1f;
while (reader.nextKeyValue()) {
- //System.out.println("" + reader.getProgress() + "> " +
reader.getCurrentKey() + ": " + reader.getCurrentValue());
+ System.out.println("" + reader.getProgress() + "> " +
reader.getCurrentKey() + ": " + reader.getCurrentValue());
final float progress = reader.getProgress();
assertTrue(progress >= lastProgress);
assertEquals(NullWritable.class,
reader.getCurrentKey().getClass());