You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by jc...@apache.org on 2023/12/18 13:18:12 UTC
(flink) 01/02: [hotfix] Fix DataGen connector `fields.#.var-len` option type
This is an automated email from the ASF dual-hosted git repository.
jchan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit c3c31dbe16f36d5a1661e579ff4c46bdc88ae418
Author: Yubin Li <li...@163.com>
AuthorDate: Mon Dec 11 11:22:33 2023 +0800
[hotfix] Fix DataGen connector `fields.#.var-len` option type
This closes #23678
---
.../flink/connector/datagen/table/DataGenConnectorOptions.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenConnectorOptions.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenConnectorOptions.java
index 379e0456856..aa900754111 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenConnectorOptions.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenConnectorOptions.java
@@ -118,10 +118,10 @@ public class DataGenConnectorOptions {
.withDescription("The proportion of null values.");
/** Placeholder {@link ConfigOption}. Not used for retrieving values. */
- public static final ConfigOption<Float> FIELD_VAR_LEN =
+ public static final ConfigOption<Boolean> FIELD_VAR_LEN =
ConfigOptions.key(String.format("%s.#.%s", FIELDS, VAR_LEN))
- .floatType()
- .defaultValue(0f)
+ .booleanType()
+ .defaultValue(false)
.withDescription(
"Whether to generate a variable-length data, please notice that it should only be used for variable-length types (varchar, string, varbinary, bytes).");