Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2024-09-26 Thread via GitHub
github-actions[bot] closed pull request #8653: Flink: new sink base on the unified sink API - WIP URL: https://github.com/apache/iceberg/pull/8653 -- 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

Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2024-09-26 Thread via GitHub
github-actions[bot] commented on PR #8653: URL: https://github.com/apache/iceberg/pull/8653#issuecomment-2378157962 This pull request has been closed due to lack of activity. This is not a judgement on the merit of the PR in any way. It is just a way of keeping the PR queue manageable. If y

Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2024-09-19 Thread via GitHub
github-actions[bot] commented on PR #8653: URL: https://github.com/apache/iceberg/pull/8653#issuecomment-2362461718 This pull request has been marked as stale due to 30 days of inactivity. It will be closed in 1 week if no further activity occurs. If you think that’s incorrect or this pull

Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2023-10-04 Thread via GitHub
gyfora commented on code in PR #8653: URL: https://github.com/apache/iceberg/pull/8653#discussion_r1345706466 ## flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java: ## @@ -0,0 +1,276 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under on

Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2023-10-04 Thread via GitHub
gyfora commented on code in PR #8653: URL: https://github.com/apache/iceberg/pull/8653#discussion_r1345702939 ## flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java: ## @@ -0,0 +1,276 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under on

Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2023-10-04 Thread via GitHub
gyfora commented on code in PR #8653: URL: https://github.com/apache/iceberg/pull/8653#discussion_r1345705474 ## flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java: ## @@ -0,0 +1,276 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under on

Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2023-10-04 Thread via GitHub
gyfora commented on code in PR #8653: URL: https://github.com/apache/iceberg/pull/8653#discussion_r1345702939 ## flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java: ## @@ -0,0 +1,276 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under on

Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2023-10-04 Thread via GitHub
gyfora commented on code in PR #8653: URL: https://github.com/apache/iceberg/pull/8653#discussion_r1345697890 ## flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/SinkBase.java: ## @@ -0,0 +1,326 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one +

Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2023-10-04 Thread via GitHub
gyfora commented on code in PR #8653: URL: https://github.com/apache/iceberg/pull/8653#discussion_r1345500193 ## flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java: ## @@ -18,72 +18,39 @@ */ package org.apache.iceberg.flink.sink; -import static org

Re: [PR] Flink: new sink base on the unified sink API - WIP [iceberg]

2023-10-04 Thread via GitHub
gyfora commented on code in PR #8653: URL: https://github.com/apache/iceberg/pull/8653#discussion_r1345500193 ## flink/v1.17/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java: ## @@ -18,72 +18,39 @@ */ package org.apache.iceberg.flink.sink; -import static org