Re: [PR] Spark Streaming: Fix clobbering of files across streaming epochs [iceberg]

2024-01-02 Thread via GitHub
rdblue merged PR #9255: URL: https://github.com/apache/iceberg/pull/9255 -- 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: issues-unsubscr...@iceberg.apac

Re: [PR] Spark Streaming: Fix clobbering of files across streaming epochs [iceberg]

2023-12-27 Thread via GitHub
amogh-jahagirdar commented on code in PR #9255: URL: https://github.com/apache/iceberg/pull/9255#discussion_r1437173563 ## spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java: ## @@ -673,11 +673,11 @@ public DataWriter createWriter(int partitionId, lo

Re: [PR] Spark Streaming: Fix clobbering of files across streaming epochs [iceberg]

2023-12-26 Thread via GitHub
VeeraswamyGatta commented on code in PR #9255: URL: https://github.com/apache/iceberg/pull/9255#discussion_r1436455766 ## spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java: ## @@ -673,11 +673,11 @@ public DataWriter createWriter(int partitionId, lon

Re: [PR] Spark Streaming: Fix clobbering of files across streaming epochs [iceberg]

2023-12-18 Thread via GitHub
veeraswamy87 commented on code in PR #9255: URL: https://github.com/apache/iceberg/pull/9255#discussion_r1430557416 ## spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java: ## @@ -673,11 +673,11 @@ public DataWriter createWriter(int partitionId, long t

Re: [PR] Spark Streaming: Fix clobbering of files across streaming epochs [iceberg]

2023-12-16 Thread via GitHub
amogh-jahagirdar commented on code in PR #9255: URL: https://github.com/apache/iceberg/pull/9255#discussion_r1428890835 ## spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java: ## @@ -673,11 +673,11 @@ public DataWriter createWriter(int partitionId, lo

Re: [PR] Spark Streaming: Fix clobbering of files across streaming epochs [iceberg]

2023-12-16 Thread via GitHub
amogh-jahagirdar commented on code in PR #9255: URL: https://github.com/apache/iceberg/pull/9255#discussion_r1428890835 ## spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java: ## @@ -673,11 +673,11 @@ public DataWriter createWriter(int partitionId, lo

Re: [PR] Spark Streaming: Fix clobbering of files across streaming epochs [iceberg]

2023-12-14 Thread via GitHub
veeraswamy87 commented on code in PR #9255: URL: https://github.com/apache/iceberg/pull/9255#discussion_r1426924289 ## spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java: ## @@ -673,11 +673,11 @@ public DataWriter createWriter(int partitionId, long t

Re: [PR] Spark Streaming: Fix clobbering of files across streaming epochs [iceberg]

2023-12-08 Thread via GitHub
amogh-jahagirdar commented on code in PR #9255: URL: https://github.com/apache/iceberg/pull/9255#discussion_r1421271945 ## spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java: ## @@ -673,11 +673,11 @@ public DataWriter createWriter(int partitionId, lo