forLp811 opened a new issue, #12479:
URL: https://github.com/apache/gravitino/issues/12479

   ### What would you like to be improved?
   
   iceberg version:1.4.3
   gravitino version:1.3.0
   
   I created a template task for merging small files using iceberg. The small 
files were successfully merged, but when gravitino attempted to obtain the 
results, it reported an error. Eventually, the task on the web interface also 
showed as "failed".
   
   <img width="1783" height="748" alt="Image" 
src="https://github.com/user-attachments/assets/865fd757-862f-4244-ae5f-f7fa4140e322";
 />
   
   <img width="1274" height="831" alt="Image" 
src="https://github.com/user-attachments/assets/a803a420-e8b2-4f09-a7e0-aa41a6aa1f30";
 />
   
   <img width="1680" height="440" alt="Image" 
src="https://github.com/user-attachments/assets/5437890b-1fdd-43c5-b083-14e8be2aec49";
 />
   
   The iceberg Low  version is recommended for adaptation.
   
   
   
   ### How should we improve?
   
   example:
   # IcebergRewriteDataFilesJob.java  L176-201
   
         if (results.length > 0) {
           Row result = results[0];
           int size = result.size();
           // Iceberg rewrite_data_files return schema varies by version:
           //   1.4.x -> 3 columns (rewritten, added, rewritten_bytes)
           //   1.5+/1.6+ -> 4 columns (adds failed_data_files)
           //   newer -> 5 columns (adds removed_delete_files)
           // Print only the columns actually present to stay compatible with 
all versions.
           StringBuilder sb = new StringBuilder("Rewrite Data Files 
Results:\n");
           if (size > 0) {
             sb.append("  Rewritten data files: 
").append(result.getInt(0)).append("\n");
           }
           if (size > 1) {
             sb.append("  Added data files: 
").append(result.getInt(1)).append("\n");
           }
           if (size > 2) {
             sb.append("  Rewritten bytes: 
").append(result.getLong(2)).append("\n");
           }
           if (size > 3) {
             sb.append("  Failed data files: 
").append(result.getInt(3)).append("\n");
           }
           if (size > 4) {
             sb.append("  Removed delete files: 
").append(result.getInt(4)).append("\n");
           }
           System.out.print(sb);
         }
   


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to