Jinho Kim created TAJO-1829:
-------------------------------

             Summary: Fix DelimitedTextFileAppender NPE in negative tests
                 Key: TAJO-1829
                 URL: https://issues.apache.org/jira/browse/TAJO-1829
             Project: Tajo
          Issue Type: Improvement
          Components: Storage
    Affects Versions: 0.11.0, 0.12.0
            Reporter: Jinho Kim
            Assignee: Jinho Kim
            Priority: Minor


If initialization is failed, DelimitedTextFileAppender should check null 
condition
{noformat}
org.apache.tajo.storage.exception.AlreadyExistsStorageException: Error: 
hdfs://localhost:46021/tmp/tajo-travis/staging/q_1441719763556_0020/RESULT/part-01-000000-000
 alreay exists
        at 
org.apache.tajo.storage.text.DelimitedTextFile$DelimitedTextFileAppender.init(DelimitedTextFile.java:160)
        at 
org.apache.tajo.engine.planner.physical.StoreTableExec.openNewFile(StoreTableExec.java:119)
        at 
org.apache.tajo.engine.planner.physical.StoreTableExec.init(StoreTableExec.java:79)
        at org.apache.tajo.worker.TaskImpl.run(TaskImpl.java:401)
        at org.apache.tajo.worker.TaskContainer.run(TaskContainer.java:65)
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
        at java.util.concurrent.FutureTask.run(FutureTask.java:262)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        at java.lang.Thread.run(Thread.java:745)
2015-09-08 13:43:27,432 ERROR: org.apache.tajo.worker.TaskContainer (run(70)) - 
java.lang.NullPointerException
        at 
org.apache.tajo.storage.text.DelimitedTextFile$DelimitedTextFileAppender.flushBuffer(DelimitedTextFile.java:208)
        at 
org.apache.tajo.storage.text.DelimitedTextFile$DelimitedTextFileAppender.flush(DelimitedTextFile.java:222)
        at 
org.apache.tajo.engine.planner.physical.StoreTableExec.close(StoreTableExec.java:152)
        at org.apache.tajo.worker.TaskImpl.run(TaskImpl.java:414)
        at org.apache.tajo.worker.TaskContainer.run(TaskContainer.java:65)
        at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
        at java.util.concurrent.FutureTask.run(FutureTask.java:262)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        at java.lang.Thread.run(Thread.java:745)
2015-09-08 13:43:27,433 ERROR: org.apache.tajo.querymaster.TaskAttempt 
(transition(438)) - ta_1441719763556_0020_000001_000000_02 FROM localhost >> No 
error message
{noformat}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to