You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "HuangZhenQiu (via GitHub)" <gi...@apache.org> on 2026/08/14 18:08:57 UTC

[PR] feat(flink): add RFC-107 RocksDB partitioned RLI ejhgcbrbblbntdglvhjvrjbltbggddkvigjgvlhgulc options to Fli… [hudi]

HuangZhenQiu opened a new pull request, #19641:
URL: https://github.com/apache/hudi/pull/19641

   …nkOptions
   
   Exposes the 7 configuration properties defined by RFC-107 (Support data partition aware RocksDB RecordIndexBackend) as ConfigOptions in FlinkOptions
   
   ### Describe the issue this Pull Request addresses
   
   <!-- Either describe the issue inline here with motivation behind the changes 
        (or) link to an issue by including `Closes #<issue-number>` for context. 
        If this PR includes changes to the storage format, public APIs,
        or has breaking changes, use `!` (e.g., feat!: ...) -->
   
   ### Summary and Changelog
   
   <!-- Short, plain-English summary of what users gain or what changed in behavior.
        Followed by a detailed log of all the changes. Highlight if any code was copied. -->
   
   ### Impact
   
   <!-- Describe any public API or user-facing feature change or any performance impact. -->
   
   ### Risk Level
   
   <!-- Accepted values: none, low, medium or high. Other than `none`, explain the risk.
        If medium or high, explain what verification was done to mitigate the risks. -->
   
   ### Documentation Update
   
   <!-- Describe any necessary documentation update if there is any new feature, config, or user-facing change. If not, put "none".
   
   - The config description must be updated if new configs are added or the default value of the configs are changed.
   - Any new feature or user-facing change requires updating the Hudi website. Please follow the 
     [instruction](https://hudi.apache.org/contribute/developer-setup#website) to make changes to the website. -->
   
   ### Contributor's checklist
   
   - [ ] Read through [contributor's guide](https://hudi.apache.org/contribute/how-to-contribute)
   - [ ] Enough context is provided in the sections above
   - [ ] Adequate tests were added if applicable
   


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "danny0405 (via GitHub)" <gi...@apache.org>.
danny0405 merged PR #19641:
URL: https://github.com/apache/hudi/pull/19641


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org>.
HuangZhenQiu commented on code in PR #19641:
URL: https://github.com/apache/hudi/pull/19641#discussion_r3839722948


##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RLI RocksDB Partitioned Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_CACHE_ROCKSDB_ENABLED = ConfigOptions
+      .key("index.rli.cache.rocksdb.enabled")

Review Comment:
   To use the new feature, users need to enable both index.bootstrap.enabled and index.rli.cache.rocksdb.enabled. Otherwise, the full RLI will be bootstrap to rocksDB if only index.bootstrap.enabled = true.



-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org>.
HuangZhenQiu commented on code in PR #19641:
URL: https://github.com/apache/hudi/pull/19641#discussion_r3839735338


##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RLI RocksDB Partitioned Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_CACHE_ROCKSDB_ENABLED = ConfigOptions
+      .key("index.rli.cache.rocksdb.enabled")

Review Comment:
   I feel the existing splitable-map RocksDB fallback is different with the new proactive partitioned cache, the new flag will supersede and probably could replace the hardcoded behavior. 



-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "danny0405 (via GitHub)" <gi...@apache.org>.
danny0405 commented on code in PR #19641:
URL: https://github.com/apache/hudi/pull/19641#discussion_r3834941526


##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RLI RocksDB Partitioned Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_CACHE_ROCKSDB_ENABLED = ConfigOptions
+      .key("index.rli.cache.rocksdb.enabled")

Review Comment:
   do we need this option, currently the rocksDB is by defaule enabled for RLI if native MDT is disabled, do we want to keep that inference?



-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5296715773

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7811c790c17555fdf5bacb400e9db0409786dc4d UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org>.
HuangZhenQiu commented on code in PR #19641:
URL: https://github.com/apache/hudi/pull/19641#discussion_r3852680338


##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RLI RocksDB Partitioned Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_CACHE_ROCKSDB_ENABLED = ConfigOptions
+      .key("index.rli.cache.rocksdb.enabled")

Review Comment:
   Make sense. Thanks for the suggestion.



-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org>.
HuangZhenQiu commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5395985762

   @danny0405 
   Replied to your question. Would you please take a look. Thanks.


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "danny0405 (via GitHub)" <gi...@apache.org>.
danny0405 commented on code in PR #19641:
URL: https://github.com/apache/hudi/pull/19641#discussion_r3849245120


##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RLI RocksDB Partitioned Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_CACHE_ROCKSDB_ENABLED = ConfigOptions
+      .key("index.rli.cache.rocksdb.enabled")

Review Comment:
   Maybe we could introudce a new backend type option: `index.rli.backend.type` and it has two option values:
   
   - rocksdb
   - mdt(default)
   
   so that we can make the backend type more explicit and straight-forward.



-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5302724560

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 4cdd217f13f457c88d1470e9506d46e91469ae2e Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313) 
   * 19481547c45336360e656575cd8cbde000e6a56b Azure: [PENDING](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5302931672

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 19481547c45336360e656575cd8cbde000e6a56b Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317) 
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * d2df0729aa88cf01b61130c9357e0b835d2b9b91 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5389210522

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16493",
       "triggerID" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * 3cf84940d661a17cd71c4e32ebdd2440136c8daf Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16493) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5296814086

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7811c790c17555fdf5bacb400e9db0409786dc4d Azure: [PENDING](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311) 
   * 4cdd217f13f457c88d1470e9506d46e91469ae2e UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5297756957

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 4cdd217f13f457c88d1470e9506d46e91469ae2e Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5388825863

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16493",
       "triggerID" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * d2df0729aa88cf01b61130c9357e0b835d2b9b91 Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319) 
   * 3cf84940d661a17cd71c4e32ebdd2440136c8daf Azure: [PENDING](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16493) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5302850233

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 4cdd217f13f457c88d1470e9506d46e91469ae2e Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313) 
   * 19481547c45336360e656575cd8cbde000e6a56b Azure: [PENDING](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317) 
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * d2df0729aa88cf01b61130c9357e0b835d2b9b91 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5302973280

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 19481547c45336360e656575cd8cbde000e6a56b Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317) 
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * d2df0729aa88cf01b61130c9357e0b835d2b9b91 Azure: [PENDING](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5388802766

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * d2df0729aa88cf01b61130c9357e0b835d2b9b91 Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319) 
   * 3cf84940d661a17cd71c4e32ebdd2440136c8daf UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5296765952

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7811c790c17555fdf5bacb400e9db0409786dc4d Azure: [PENDING](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-agent (via GitHub)" <gi...@apache.org>.
hudi-agent commented on code in PR #19641:
URL: https://github.com/apache/hudi/pull/19641#discussion_r3786277550


##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RocksDB Partitioned RLI Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_ENABLED = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.enabled")
+      .booleanType()
+      .defaultValue(false)
+      .withDescription("Enable RocksDB-based partitioned cache for record level index lookups, default false.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_BASE_PATH = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.base.path")
+      .stringType()
+      .defaultValue("/tmp/hudi-index-cache")
+      .withDescription("Local directory for RocksDB partitioned record level index cache data.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Integer> INDEX_RLI_ROCKSDB_CACHE_BOOTSTRAP_DAYS = ConfigOptions

Review Comment:
   🤖 nit: "bootstrap" is already a well-known term in Hudi (the Bootstrap feature for ingesting external tables). Using `BOOTSTRAP_DAYS` here for a pre-loading / warm-up window might confuse readers — have you considered `PRELOAD_DAYS` or `WARMUP_DAYS`?
   
   <sub><i>⚠️ AI-generated; verify before applying. React 👍/👎 to flag quality.</i></sub>



##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RocksDB Partitioned RLI Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_ENABLED = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.enabled")
+      .booleanType()
+      .defaultValue(false)
+      .withDescription("Enable RocksDB-based partitioned cache for record level index lookups, default false.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_BASE_PATH = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.base.path")
+      .stringType()
+      .defaultValue("/tmp/hudi-index-cache")
+      .withDescription("Local directory for RocksDB partitioned record level index cache data.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Integer> INDEX_RLI_ROCKSDB_CACHE_BOOTSTRAP_DAYS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.bootstrap.days")
+      .intType()
+      .defaultValue(7)
+      .withDescription("Number of days of Partitioned Record Index to load during bootstrap. Only partitions "
+          + "within this window are pre-loaded; older partitions are loaded on demand when updates are observed.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_PARTITION_TTL_HOURS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.partition.ttl.hours")
+      .longType()
+      .defaultValue(168L) // default 7 days
+      .withDescription("TTL for partition column families in the RocksDB partitioned record level index cache, default 168 hours (7 days).");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_BLOCK_CACHE_MB = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.block.cache.mb")
+      .longType()
+      .defaultValue(256L)
+      .withDescription("RocksDB block cache size (off-heap) in MB for the partitioned record level index cache, default 256.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_COMPACTION_STYLE = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.compaction.style")
+      .stringType()
+      .defaultValue("LEVEL")
+      .withDescription("RocksDB compaction style for the partitioned record level index cache, default LEVEL.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_INVALIDATE_ON_REPLACE_COMMIT = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.invalidate.on.replacecommit")

Review Comment:
   🤖 nit: `replacecommit` runs two words together without a separator, which breaks the standard `hoodie.xxx.yyy.zzz` dot-separated convention. Could you use `replace.commit` instead?
   
   <sub><i>⚠️ AI-generated; verify before applying. React 👍/👎 to flag quality.</i></sub>



##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RocksDB Partitioned RLI Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_ENABLED = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.enabled")
+      .booleanType()
+      .defaultValue(false)
+      .withDescription("Enable RocksDB-based partitioned cache for record level index lookups, default false.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_BASE_PATH = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.base.path")
+      .stringType()
+      .defaultValue("/tmp/hudi-index-cache")
+      .withDescription("Local directory for RocksDB partitioned record level index cache data.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Integer> INDEX_RLI_ROCKSDB_CACHE_BOOTSTRAP_DAYS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.bootstrap.days")
+      .intType()
+      .defaultValue(7)
+      .withDescription("Number of days of Partitioned Record Index to load during bootstrap. Only partitions "
+          + "within this window are pre-loaded; older partitions are loaded on demand when updates are observed.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_PARTITION_TTL_HOURS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.partition.ttl.hours")
+      .longType()
+      .defaultValue(168L) // default 7 days

Review Comment:
   🤖 nit: the inline `// default 7 days` comment duplicates what the `withDescription` already says — could you drop it to reduce noise?
   
   <sub><i>⚠️ AI-generated; verify before applying. React 👍/👎 to flag quality.</i></sub>



-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5297256164

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7811c790c17555fdf5bacb400e9db0409786dc4d Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311) 
   * 4cdd217f13f457c88d1470e9506d46e91469ae2e UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "codecov-commenter (via GitHub)" <gi...@apache.org>.
codecov-commenter commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5296906610

   ## [Codecov](https://app.codecov.io/gh/apache/hudi/pull/19641?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) Report
   :white_check_mark: All modified and coverable lines are covered by tests.
   :white_check_mark: Project coverage is 77.71%. Comparing base ([`558007d`](https://app.codecov.io/gh/apache/hudi/commit/558007d76eaf345f759a349bd4bc6d17967708d9?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)) to head ([`4cdd217`](https://app.codecov.io/gh/apache/hudi/commit/4cdd217f13f457c88d1470e9506d46e91469ae2e?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)).
   
   <details><summary>Additional details and impacted files</summary>
   
   
   
   ```diff
   @@            Coverage Diff            @@
   ##             master   #19641   +/-   ##
   =========================================
     Coverage     77.70%   77.71%           
     Complexity    32988    32988           
   =========================================
     Files          2524     2524           
     Lines        139525   139525           
     Branches      16786    16786           
   =========================================
   + Hits         108424   108426    +2     
   + Misses        23475    23474    -1     
   + Partials       7626     7625    -1     
   ```
   
   | [Components](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=components&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Coverage Δ | |
   |---|---|---|
   | [hudi-common](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `83.26% <ø> (ø)` | |
   | [hudi-client](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `82.73% <ø> (+<0.01%)` | :arrow_up: |
   | [hudi-flink](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `85.74% <ø> (ø)` | |
   | [hudi-spark-datasource](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `71.88% <ø> (ø)` | |
   | [hudi-utilities](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `73.69% <ø> (ø)` | |
   | [hudi-cli](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `15.26% <ø> (ø)` | |
   | [hudi-hadoop](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `69.04% <ø> (ø)` | |
   | [hudi-sync](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `75.55% <ø> (ø)` | |
   | [hudi-io](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `79.42% <ø> (ø)` | |
   | [hudi-timeline-service](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `83.44% <ø> (ø)` | |
   | [hudi-cloud](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `64.06% <ø> (ø)` | |
   | [hudi-kafka-connect](https://app.codecov.io/gh/apache/hudi/pull/19641/components?src=pr&el=component&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `53.20% <ø> (ø)` | |
   
   | [Flag](https://app.codecov.io/gh/apache/hudi/pull/19641/flags?src=pr&el=flags&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Coverage Δ | |
   |---|---|---|
   | [hadoop-mr-java-client](https://app.codecov.io/gh/apache/hudi/pull/19641/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `43.87% <ø> (+<0.01%)` | :arrow_up: |
   
   Flags with carried forward coverage won't be shown. [Click here](https://docs.codecov.io/docs/carryforward-flags?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#carryforward-flags-in-the-pull-request-comment) to find out more.
   
   | [Files with missing lines](https://app.codecov.io/gh/apache/hudi/pull/19641?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Coverage Δ | |
   |---|---|---|
   | [...va/org/apache/hudi/configuration/FlinkOptions.java](https://app.codecov.io/gh/apache/hudi/pull/19641?src=pr&el=tree&filepath=hudi-flink-datasource%2Fhudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Fconfiguration%2FFlinkOptions.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay1kYXRhc291cmNlL2h1ZGktZmxpbmsvc3JjL21haW4vamF2YS9vcmcvYXBhY2hlL2h1ZGkvY29uZmlndXJhdGlvbi9GbGlua09wdGlvbnMuamF2YQ==) | `99.78% <ø> (ø)` | |
   
   ... and [1 file with indirect coverage changes](https://app.codecov.io/gh/apache/hudi/pull/19641/indirect-changes?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
   </details>
   <details><summary> :rocket: New features to boost your workflow: </summary>
   
   - :snowflake: [Test Analytics](https://docs.codecov.com/docs/test-analytics): Detect flaky tests, report on failures, and find test suite problems.
   - :package: [JS Bundle Analysis](https://docs.codecov.com/docs/javascript-bundle-analysis): Save yourself from yourself by tracking and limiting bundle sizes in JS merges.
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5302830300

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 4cdd217f13f457c88d1470e9506d46e91469ae2e Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313) 
   * 19481547c45336360e656575cd8cbde000e6a56b Azure: [PENDING](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317) 
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5410163570

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16493",
       "triggerID" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4ee2c740e9eb7e75e2389c67372104e1191e5a00",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "4ee2c740e9eb7e75e2389c67372104e1191e5a00",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * 3cf84940d661a17cd71c4e32ebdd2440136c8daf Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16493) 
   * 4ee2c740e9eb7e75e2389c67372104e1191e5a00 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5410763836

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16493",
       "triggerID" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4ee2c740e9eb7e75e2389c67372104e1191e5a00",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16527",
       "triggerID" : "4ee2c740e9eb7e75e2389c67372104e1191e5a00",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * 3cf84940d661a17cd71c4e32ebdd2440136c8daf Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16493) 
   * 4ee2c740e9eb7e75e2389c67372104e1191e5a00 Azure: [PENDING](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16527) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-agent (via GitHub)" <gi...@apache.org>.
hudi-agent commented on code in PR #19641:
URL: https://github.com/apache/hudi/pull/19641#discussion_r3789558559


##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RocksDB Partitioned RLI Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_ENABLED = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.enabled")
+      .booleanType()
+      .defaultValue(false)
+      .withDescription("Enable RocksDB-based partitioned cache for record level index lookups, default false.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_BASE_PATH = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.base.path")
+      .stringType()
+      .defaultValue("/tmp/hudi-index-cache")
+      .withDescription("Local directory for RocksDB partitioned record level index cache data.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Integer> INDEX_RLI_ROCKSDB_CACHE_BOOTSTRAP_DAYS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.bootstrap.days")
+      .intType()
+      .defaultValue(7)
+      .withDescription("Number of days of Partitioned Record Index to load during bootstrap. Only partitions "
+          + "within this window are pre-loaded; older partitions are loaded on demand when updates are observed.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_PARTITION_TTL_HOURS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.partition.ttl.hours")
+      .longType()
+      .defaultValue(168L) // default 7 days
+      .withDescription("TTL for partition column families in the RocksDB partitioned record level index cache, default 168 hours (7 days).");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_BLOCK_CACHE_MB = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.block.cache.mb")
+      .longType()
+      .defaultValue(256L)
+      .withDescription("RocksDB block cache size (off-heap) in MB for the partitioned record level index cache, default 256.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_COMPACTION_STYLE = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.compaction.style")
+      .stringType()
+      .defaultValue("LEVEL")
+      .withDescription("RocksDB compaction style for the partitioned record level index cache, default LEVEL.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_INVALIDATE_ON_REPLACE_COMMIT = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.invalidate.on.replacecommit")

Review Comment:
   🤖 nit: `replacecommit` is missing a dot separator — could you rename this to `hoodie.record.index.cache.rocksdb.invalidate.on.replace.commit` to stay consistent with the dot-separated key convention used everywhere else?
   
   <sub><i>⚠️ AI-generated; verify before applying. React 👍/👎 to flag quality.</i></sub>



##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RocksDB Partitioned RLI Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_ENABLED = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.enabled")
+      .booleanType()
+      .defaultValue(false)
+      .withDescription("Enable RocksDB-based partitioned cache for record level index lookups, default false.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_BASE_PATH = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.base.path")
+      .stringType()
+      .defaultValue("/tmp/hudi-index-cache")
+      .withDescription("Local directory for RocksDB partitioned record level index cache data.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Integer> INDEX_RLI_ROCKSDB_CACHE_BOOTSTRAP_DAYS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.bootstrap.days")
+      .intType()
+      .defaultValue(7)
+      .withDescription("Number of days of Partitioned Record Index to load during bootstrap. Only partitions "
+          + "within this window are pre-loaded; older partitions are loaded on demand when updates are observed.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_PARTITION_TTL_HOURS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.partition.ttl.hours")
+      .longType()
+      .defaultValue(168L) // default 7 days

Review Comment:
   🤖 nit: the `// default 7 days` inline comment is already covered by the description string — could you drop it to avoid duplication that can drift if the default changes?
   
   <sub><i>⚠️ AI-generated; verify before applying. React 👍/👎 to flag quality.</i></sub>



##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RocksDB Partitioned RLI Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_ENABLED = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.enabled")
+      .booleanType()
+      .defaultValue(false)
+      .withDescription("Enable RocksDB-based partitioned cache for record level index lookups, default false.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_BASE_PATH = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.base.path")
+      .stringType()
+      .defaultValue("/tmp/hudi-index-cache")
+      .withDescription("Local directory for RocksDB partitioned record level index cache data.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Integer> INDEX_RLI_ROCKSDB_CACHE_BOOTSTRAP_DAYS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.bootstrap.days")
+      .intType()
+      .defaultValue(7)
+      .withDescription("Number of days of Partitioned Record Index to load during bootstrap. Only partitions "
+          + "within this window are pre-loaded; older partitions are loaded on demand when updates are observed.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_PARTITION_TTL_HOURS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.partition.ttl.hours")
+      .longType()
+      .defaultValue(168L) // default 7 days
+      .withDescription("TTL for partition column families in the RocksDB partitioned record level index cache, default 168 hours (7 days).");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_BLOCK_CACHE_MB = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.block.cache.mb")
+      .longType()
+      .defaultValue(256L)
+      .withDescription("RocksDB block cache size (off-heap) in MB for the partitioned record level index cache, default 256.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_COMPACTION_STYLE = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.compaction.style")
+      .stringType()
+      .defaultValue("LEVEL")
+      .withDescription("RocksDB compaction style for the partitioned record level index cache, default LEVEL.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_INVALIDATE_ON_REPLACE_COMMIT = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.invalidate.on.replacecommit")

Review Comment:
   🤖 Worth noting that `replacecommit` isn't an arbitrary run-together — it mirrors Hudi's own action name, `HoodieTimeline.REPLACE_COMMIT_ACTION = "replacecommit"` (hudi-common .../HoodieTimeline.java). Since this config keys off that action, keeping it as one token stays consistent with how the action is spelled everywhere else in the timeline; `replace.commit` would actually diverge from it.



-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5302703793

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 4cdd217f13f457c88d1470e9506d46e91469ae2e Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313) 
   * 19481547c45336360e656575cd8cbde000e6a56b UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-agent (via GitHub)" <gi...@apache.org>.
hudi-agent commented on code in PR #19641:
URL: https://github.com/apache/hudi/pull/19641#discussion_r3790006598


##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RocksDB Partitioned RLI Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_ENABLED = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.enabled")
+      .booleanType()
+      .defaultValue(false)
+      .withDescription("Enable RocksDB-based partitioned cache for record level index lookups, default false.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_BASE_PATH = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.base.path")
+      .stringType()
+      .defaultValue("/tmp/hudi-index-cache")
+      .withDescription("Local directory for RocksDB partitioned record level index cache data.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Integer> INDEX_RLI_ROCKSDB_CACHE_BOOTSTRAP_DAYS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.bootstrap.days")
+      .intType()
+      .defaultValue(7)
+      .withDescription("Number of days of Partitioned Record Index to load during bootstrap. Only partitions "
+          + "within this window are pre-loaded; older partitions are loaded on demand when updates are observed.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_PARTITION_TTL_HOURS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.partition.ttl.hours")
+      .longType()
+      .defaultValue(168L) // default 7 days
+      .withDescription("TTL for partition column families in the RocksDB partitioned record level index cache, default 168 hours (7 days).");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_BLOCK_CACHE_MB = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.block.cache.mb")
+      .longType()
+      .defaultValue(256L)
+      .withDescription("RocksDB block cache size (off-heap) in MB for the partitioned record level index cache, default 256.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_COMPACTION_STYLE = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.compaction.style")
+      .stringType()
+      .defaultValue("LEVEL")
+      .withDescription("RocksDB compaction style for the partitioned record level index cache, default LEVEL.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_INVALIDATE_ON_REPLACE_COMMIT = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.invalidate.on.replacecommit")

Review Comment:
   🤖 Before renaming to `...invalidate.on.replace.commit`, note that this token mirrors the timeline action name, which is a single word: `HoodieTimeline.REPLACE_COMMIT_ACTION = "replacecommit"` (hudi-common/.../HoodieTimeline.java:64). Dotting it would diverge from the action spelling used across the timeline, so `replacecommit` is arguably the consistent form here.



##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RocksDB Partitioned RLI Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_ENABLED = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.enabled")
+      .booleanType()
+      .defaultValue(false)
+      .withDescription("Enable RocksDB-based partitioned cache for record level index lookups, default false.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_BASE_PATH = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.base.path")
+      .stringType()
+      .defaultValue("/tmp/hudi-index-cache")
+      .withDescription("Local directory for RocksDB partitioned record level index cache data.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Integer> INDEX_RLI_ROCKSDB_CACHE_BOOTSTRAP_DAYS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.bootstrap.days")
+      .intType()
+      .defaultValue(7)
+      .withDescription("Number of days of Partitioned Record Index to load during bootstrap. Only partitions "
+          + "within this window are pre-loaded; older partitions are loaded on demand when updates are observed.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_PARTITION_TTL_HOURS = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.partition.ttl.hours")
+      .longType()
+      .defaultValue(168L) // default 7 days
+      .withDescription("TTL for partition column families in the RocksDB partitioned record level index cache, default 168 hours (7 days).");
+
+  @AdvancedConfig
+  public static final ConfigOption<Long> INDEX_RLI_ROCKSDB_CACHE_BLOCK_CACHE_MB = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.block.cache.mb")
+      .longType()
+      .defaultValue(256L)
+      .withDescription("RocksDB block cache size (off-heap) in MB for the partitioned record level index cache, default 256.");
+
+  @AdvancedConfig
+  public static final ConfigOption<String> INDEX_RLI_ROCKSDB_CACHE_COMPACTION_STYLE = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.compaction.style")
+      .stringType()
+      .defaultValue("LEVEL")
+      .withDescription("RocksDB compaction style for the partitioned record level index cache, default LEVEL.");
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_ROCKSDB_CACHE_INVALIDATE_ON_REPLACE_COMMIT = ConfigOptions
+      .key("hoodie.record.index.cache.rocksdb.invalidate.on.replacecommit")

Review Comment:
   🤖 One thing worth factoring in here: this key derives from the timeline action name, which is spelled as a single token — `HoodieTimeline.REPLACE_COMMIT_ACTION = "replacecommit"` (hudi-common/.../HoodieTimeline.java:64). Splitting it into `replace.commit` would actually diverge from how the action is written everywhere in the timeline, so `replacecommit` may be the more consistent choice despite looking run-together.



-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5303212190

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * d2df0729aa88cf01b61130c9357e0b835d2b9b91 Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org>.
HuangZhenQiu commented on code in PR #19641:
URL: https://github.com/apache/hudi/pull/19641#discussion_r3839722948


##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java:
##########
@@ -349,6 +349,61 @@ public class FlinkOptions extends HoodieConfig {
       .noDefaultValue()
       .withDescription("Parallelism of tasks that do the index writing, default is the parallelism of the execution environment");
 
+  // ------------------------------------------------------------------------
+  //  RLI RocksDB Partitioned Cache Options
+  // ------------------------------------------------------------------------
+
+  @AdvancedConfig
+  public static final ConfigOption<Boolean> INDEX_RLI_CACHE_ROCKSDB_ENABLED = ConfigOptions
+      .key("index.rli.cache.rocksdb.enabled")

Review Comment:
   It is a good question. In my mind, to use the new feature, users need to enable both index.bootstrap.enabled and index.rli.cache.rocksdb.enabled. Otherwise, the full RLI will be bootstrap to rocksDB if only index.bootstrap.enabled = true. How do you think?



-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5411937451

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     }, {
       "hash" : "19481547c45336360e656575cd8cbde000e6a56b",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16317",
       "triggerID" : "19481547c45336360e656575cd8cbde000e6a56b",
       "triggerType" : "PUSH"
     }, {
       "hash" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "b32df4f295b13c59dca2f8068f9423a058848ec0",
       "triggerType" : "PUSH"
     }, {
       "hash" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16319",
       "triggerID" : "d2df0729aa88cf01b61130c9357e0b835d2b9b91",
       "triggerType" : "PUSH"
     }, {
       "hash" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16493",
       "triggerID" : "3cf84940d661a17cd71c4e32ebdd2440136c8daf",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4ee2c740e9eb7e75e2389c67372104e1191e5a00",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16527",
       "triggerID" : "4ee2c740e9eb7e75e2389c67372104e1191e5a00",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * b32df4f295b13c59dca2f8068f9423a058848ec0 UNKNOWN
   * 4ee2c740e9eb7e75e2389c67372104e1191e5a00 Azure: [SUCCESS](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16527) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] feat(flink): add RocksDB partitioned RLI Cache Flink Options [hudi]

Posted by "hudi-bot (via GitHub)" <gi...@apache.org>.
hudi-bot commented on PR #19641:
URL: https://github.com/apache/hudi/pull/19641#issuecomment-5297308046

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311",
       "triggerID" : "7811c790c17555fdf5bacb400e9db0409786dc4d",
       "triggerType" : "PUSH"
     }, {
       "hash" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313",
       "triggerID" : "4cdd217f13f457c88d1470e9506d46e91469ae2e",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 7811c790c17555fdf5bacb400e9db0409786dc4d Azure: [FAILURE](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16311) 
   * 4cdd217f13f457c88d1470e9506d46e91469ae2e Azure: [PENDING](https://dev.azure.com/apachehudi/a1a51da7-8592-47d4-88dc-fd67bed336bb/_build/results?buildId=16313) 
   
   <details>
   <summary>Bot commands</summary>
     @hudi-bot supports the following commands:
   
    - `@hudi-bot run azure` re-run the last Azure build
   </details>


-- 
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: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org