[ 
https://issues.apache.org/jira/browse/PHOENIX-6721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749593#comment-17749593
 ] 

ASF GitHub Bot commented on PHOENIX-6721:
-----------------------------------------

steveloughran commented on code in PR #1450:
URL: https://github.com/apache/phoenix/pull/1450#discussion_r1280377772


##########
phoenix-core/src/main/java/org/apache/phoenix/mapreduce/MultiHfileOutputFormat.java:
##########
@@ -122,11 +123,11 @@ public RecordWriter<TableRowkeyPair, Cell> 
getRecordWriter(TaskAttemptContext co
      * @return
      * @throws IOException 
      */
-    static <V extends Cell> RecordWriter<TableRowkeyPair, V> 
createRecordWriter(final TaskAttemptContext context)
+    static <V extends Cell> RecordWriter<TableRowkeyPair, V> 
createRecordWriter(
+        final TaskAttemptContext context, final OutputCommitter committer)
             throws IOException {
         // Get the path of the temporary output file
-        final Path outputPath = FileOutputFormat.getOutputPath(context);
-        final Path outputdir = new FileOutputCommitter(outputPath, 
context).getWorkPath();
+        final Path outputdir = ((PathOutputCommitter) 
committer).getOutputPath();

Review Comment:
   this is no longer a h path, it is the final path of the work, the same value 
as  L128 in the original code.
   
   





> CSV bulkload tool fails with FileNotFoundException if --output points to the 
> S3 location
> ----------------------------------------------------------------------------------------
>
>                 Key: PHOENIX-6721
>                 URL: https://issues.apache.org/jira/browse/PHOENIX-6721
>             Project: Phoenix
>          Issue Type: Bug
>          Components: core
>            Reporter: Sergey Soldatov
>            Assignee: Sergey Soldatov
>            Priority: Major
>
> We were trying to use CSV bulkload tool with the HBase/Phoenix running on top 
> of AWS S3 and found that once we use --output params pointing to  S3, the job 
> fails with FNFE



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to