Re: [I] org.apache.thrift.transport.TSaslTransport: SASL negotiation failure [iceberg]

2025-02-23 Thread via GitHub
github-actions[bot] commented on issue #11019: URL: https://github.com/apache/iceberg/issues/11019#issuecomment-2677206765 This issue has been automatically marked as stale because it has been open for 180 days with no activity. It will be closed in next 14 days if no further activity occur

Re: [I] Contribution Proposal: Kafka to Iceberg Tutorial Repo [iceberg]

2025-02-23 Thread via GitHub
github-actions[bot] closed issue #10933: Contribution Proposal: Kafka to Iceberg Tutorial Repo URL: https://github.com/apache/iceberg/issues/10933 -- 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] Backport #11702 to FLink1.19 and 1.18 [iceberg]

2025-02-23 Thread via GitHub
github-actions[bot] commented on PR #12080: URL: https://github.com/apache/iceberg/pull/12080#issuecomment-2677206929 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 pul

Re: [PR] Flink: Fix the comment error in SketchDataStatistics [iceberg]

2025-02-23 Thread via GitHub
stevenzwu merged PR #12375: URL: https://github.com/apache/iceberg/pull/12375 -- 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

Re: [PR] HIVE: release expired hive lock [iceberg]

2025-02-23 Thread via GitHub
xicm commented on code in PR #12392: URL: https://github.com/apache/iceberg/pull/12392#discussion_r1967008682 ## hive-metastore/src/main/java/org/apache/iceberg/hive/MetastoreLock.java: ## @@ -74,7 +77,10 @@ class MetastoreLock implements HiveLock { private static final long

Re: [PR] HIVE: release expired hive lock [iceberg]

2025-02-23 Thread via GitHub
xicm commented on code in PR #12392: URL: https://github.com/apache/iceberg/pull/12392#discussion_r1967009129 ## hive-metastore/src/main/java/org/apache/iceberg/hive/MetastoreLock.java: ## @@ -372,15 +393,30 @@ private LockInfo findLock() throws LockException, InterruptedExcept

[PR] HIVE: release expired hive lock [iceberg]

2025-02-23 Thread via GitHub
xicm opened a new pull request, #12392: URL: https://github.com/apache/iceberg/pull/12392 ``` org.apache.iceberg.exceptions.CommitFailedException: Timed out after 181159 ms waiting for lock on table at org.apache.iceberg.hive.HiveTableOperations.acquireLock(HiveTableOperation

Re: [I] Enable "Always suggest updating pull request branches" and "merge queue" [iceberg-rust]

2025-02-23 Thread via GitHub
Xuanwo closed issue #671: Enable "Always suggest updating pull request branches" and "merge queue" URL: https://github.com/apache/iceberg-rust/issues/671 -- 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

Re: [PR] Handling no coordinator and data loss in current design in icr mode [iceberg]

2025-02-23 Thread via GitHub
kumarpritam863 commented on code in PR #12372: URL: https://github.com/apache/iceberg/pull/12372#discussion_r1966996671 ## kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/IcebergSinkTask.java: ## @@ -46,26 +45,31 @@ public String version() { @Override

Re: [PR] Handling no coordinator and data loss in current design in icr mode [iceberg]

2025-02-23 Thread via GitHub
kumarpritam863 commented on code in PR #12372: URL: https://github.com/apache/iceberg/pull/12372#discussion_r1966996881 ## kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/ResourceType.java: ## @@ -0,0 +1,27 @@ +/* + * + * * Licensed to the Apache Software F

Re: [PR] Handling no coordinator and data loss in current design in icr mode [iceberg]

2025-02-23 Thread via GitHub
kumarpritam863 commented on code in PR #12372: URL: https://github.com/apache/iceberg/pull/12372#discussion_r1966996956 ## kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/CommitterImpl.java: ## @@ -57,49 +83,67 @@ public int compare(TopicPartition o1

Re: [PR] Flink: Fix the comment error in SketchDataStatistics [iceberg]

2025-02-23 Thread via GitHub
stevenzwu commented on PR #12375: URL: https://github.com/apache/iceberg/pull/12375#issuecomment-2677346357 @Guosmilesmile thx for the fix -- 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 spec

Re: [PR] Flink: Fix the comment error in SketchDataStatistics [iceberg]

2025-02-23 Thread via GitHub
Guosmilesmile commented on PR #12375: URL: https://github.com/apache/iceberg/pull/12375#issuecomment-2677348578 @stevenzwu thx for the review! -- 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] feat: Introduce C FFI for iceberg rust [iceberg-rust]

2025-02-23 Thread via GitHub
lidavidm commented on code in PR #966: URL: https://github.com/apache/iceberg-rust/pull/966#discussion_r1967028458 ## bindings/c/CMakeLists.txt: ## @@ -0,0 +1,61 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the

Re: [PR] feat: Introduce C FFI for iceberg rust [iceberg-rust]

2025-02-23 Thread via GitHub
lidavidm commented on code in PR #966: URL: https://github.com/apache/iceberg-rust/pull/966#discussion_r1967029673 ## bindings/c/CMakeLists.txt: ## @@ -0,0 +1,61 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the

Re: [PR] feat: Introduce C FFI for iceberg rust [iceberg-rust]

2025-02-23 Thread via GitHub
lidavidm commented on PR #966: URL: https://github.com/apache/iceberg-rust/pull/966#issuecomment-2677421602 Ah, and the bindings are fairly minimal I see? I was going to try to experiment with them + cuDF but it seems more work is necessary. In any case it's neat that we can get a C/potenti

<    1   2