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());

Reply via email to