swuferhong commented on code in PR #1452:
URL: https://github.com/apache/fluss/pull/1452#discussion_r2664831316
##########
fluss-common/src/main/java/org/apache/fluss/config/ConfigOptions.java:
##########
@@ -1473,6 +1473,14 @@ public class ConfigOptions {
+ "This mode reduces storage and
transmission costs but loses the ability to track previous values. "
+ "This option only affects primary key
tables.");
+ public static final ConfigOption<Boolean>
TABLE_GENERATE_UNBALANCE_TABLE_ASSIGNMENT =
Review Comment:
I will remove this config, and change the test way.
##########
fluss-common/src/main/java/org/apache/fluss/config/TableConfig.java:
##########
@@ -140,4 +140,9 @@ public ArrowCompressionInfo getArrowCompressionInfo() {
public AutoPartitionStrategy getAutoPartitionStrategy() {
return AutoPartitionStrategy.from(config);
}
+
+ /** Whether to generate unbalance assignment fot this table. */
+ public boolean generateUnbalanceAssignment() {
+ return
config.get(ConfigOptions.TABLE_GENERATE_UNBALANCE_TABLE_ASSIGNMENT);
Review Comment:
I will remove this config, and change the test way.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
