marchpure opened a new pull request #3621: [HOTFIX] Support both listfile() and 
listfile(maxCount) in InsertStag…
URL: https://github.com/apache/carbondata/pull/3621
 
 
   …e flow
   
    ### Why is this PR needed?
    Flink writes files to obs with setting the filename in order of time, when 
loading stages files to carbondata, files are list and loaded with the 
parameter "maxcount" which will return "maxcount" files with smaller filename, 
in the other words, "maxcount" files with earliest generation time. but in same 
senario, it is possible that the filename of stage files is not in order of 
time, a switch is used here to judge whether to list files with specify batch 
size, or just list all files in the stage dir.
    
    ### What changes were proposed in this PR?
    A swith "CARBON_STAGE_FILENAME_IS_IN_ORDER_OF_TIME" is added.
       
    ### Does this PR introduce any user interface change?
    - No
   
    ### Is any new testcase added?
    - No
   
       
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to