Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-15 Thread via GitHub
HonahX merged PR #701: URL: https://github.com/apache/iceberg-python/pull/701 -- 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 catalog: Add retry logic for hive locking [iceberg-python]

2024-05-15 Thread via GitHub
HonahX commented on PR #701: URL: https://github.com/apache/iceberg-python/pull/701#issuecomment-2111753317 Looks like all the review comments are addressed. I'll merge this. Thanks everyone! -- This is an automated message from the Apache Git Service. To respond to the message, please lo

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-08 Thread via GitHub
frankliee commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1594885592 ## pyiceberg/catalog/hive.py: ## @@ -111,6 +122,15 @@ HIVE2_COMPATIBLE = "hive.hive2-compatible" HIVE2_COMPATIBLE_DEFAULT = False +LOCK_CHECK_MIN_WAIT_TIME =

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-08 Thread via GitHub
Fokko commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1594699293 ## pyiceberg/catalog/hive.py: ## @@ -111,6 +122,15 @@ HIVE2_COMPATIBLE = "hive.hive2-compatible" HIVE2_COMPATIBLE_DEFAULT = False +LOCK_CHECK_MIN_WAIT_TIME = "lo

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-07 Thread via GitHub
frankliee commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1592047115 ## pyiceberg/catalog/hive.py: ## @@ -356,11 +371,46 @@ def _create_lock_request(self, database_name: str, table_name: str) -> LockReque return lock_r

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-07 Thread via GitHub
frankliee commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1592047115 ## pyiceberg/catalog/hive.py: ## @@ -356,11 +371,46 @@ def _create_lock_request(self, database_name: str, table_name: str) -> LockReque return lock_r

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-07 Thread via GitHub
frankliee commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1591985541 ## tests/integration/test_reads.py: ## @@ -506,3 +508,40 @@ def test_hive_locking(session_catalog_hive: HiveCatalog) -> None: table.transactio

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-07 Thread via GitHub
frankliee commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1591970151 ## pyiceberg/catalog/hive.py: ## @@ -356,6 +378,28 @@ def _create_lock_request(self, database_name: str, table_name: str) -> LockReque return lock_re

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-06 Thread via GitHub
frankliee commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1591903957 ## pyiceberg/catalog/hive.py: ## @@ -111,6 +122,13 @@ HIVE2_COMPATIBLE = "hive.hive2-compatible" HIVE2_COMPATIBLE_DEFAULT = False +DEFAULT_LOCK_CHECK_MIN_WAI

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-06 Thread via GitHub
HonahX commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1591782640 ## pyiceberg/catalog/hive.py: ## @@ -111,6 +122,13 @@ HIVE2_COMPATIBLE = "hive.hive2-compatible" HIVE2_COMPATIBLE_DEFAULT = False +DEFAULT_LOCK_CHECK_MIN_WAIT_T

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-06 Thread via GitHub
HonahX commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1591768312 ## pyiceberg/catalog/hive.py: ## @@ -356,11 +371,46 @@ def _create_lock_request(self, database_name: str, table_name: str) -> LockReque return lock_requ

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-06 Thread via GitHub
frankliee commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1591771902 ## pyiceberg/catalog/hive.py: ## @@ -111,6 +122,13 @@ HIVE2_COMPATIBLE = "hive.hive2-compatible" HIVE2_COMPATIBLE_DEFAULT = False +DEFAULT_LOCK_CHECK_MIN_WAI

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-06 Thread via GitHub
HonahX commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1591764194 ## pyiceberg/catalog/hive.py: ## @@ -111,6 +122,13 @@ HIVE2_COMPATIBLE = "hive.hive2-compatible" HIVE2_COMPATIBLE_DEFAULT = False +DEFAULT_LOCK_CHECK_MIN_WAIT_T

Re: [PR] Hive catalog: Add retry logic for hive locking [iceberg-python]

2024-05-05 Thread via GitHub
kevinjqliu commented on code in PR #701: URL: https://github.com/apache/iceberg-python/pull/701#discussion_r1590382950 ## pyiceberg/catalog/hive.py: ## @@ -111,6 +122,13 @@ HIVE2_COMPATIBLE = "hive.hive2-compatible" HIVE2_COMPATIBLE_DEFAULT = False +DEFAULT_LOCK_CHECK_MIN_WA