From 5709d165170d416d9303601c806d29379be355da Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BB=9F=E5=BC=8B?= Date: Tue, 13 Jan 2026 14:04:46 +0800 Subject: [PATCH] [api] Set blob-as-descriptor default to true --- docs/layouts/shortcodes/generated/core_configuration.html | 2 +- paimon-api/src/main/java/org/apache/paimon/CoreOptions.java | 2 +- .../test/java/org/apache/paimon/flink/BlobTableITCase.java | 2 +- .../test/scala/org/apache/paimon/spark/sql/BlobTestBase.scala | 4 ++-- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/docs/layouts/shortcodes/generated/core_configuration.html b/docs/layouts/shortcodes/generated/core_configuration.html index 8f352e39b31c..89aa6b50b568 100644 --- a/docs/layouts/shortcodes/generated/core_configuration.html +++ b/docs/layouts/shortcodes/generated/core_configuration.html @@ -52,7 +52,7 @@
blob-as-descriptor
- false + true Boolean Write blob field using blob descriptor rather than blob bytes. diff --git a/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java b/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java index de8a9fc20643..5f625c9a4558 100644 --- a/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java +++ b/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java @@ -2065,7 +2065,7 @@ public InlineElement getDescription() { public static final ConfigOption BLOB_AS_DESCRIPTOR = key("blob-as-descriptor") .booleanType() - .defaultValue(false) + .defaultValue(true) .withDescription( "Write blob field using blob descriptor rather than blob bytes."); diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BlobTableITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BlobTableITCase.java index f879b9c67a75..e55301b65bb4 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BlobTableITCase.java +++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/BlobTableITCase.java @@ -48,7 +48,7 @@ public class BlobTableITCase extends CatalogITCaseBase { @Override protected List ddl() { return Arrays.asList( - "CREATE TABLE IF NOT EXISTS blob_table (id INT, data STRING, picture BYTES) WITH ('row-tracking.enabled'='true', 'data-evolution.enabled'='true', 'blob-field'='picture')", + "CREATE TABLE IF NOT EXISTS blob_table (id INT, data STRING, picture BYTES) WITH ('row-tracking.enabled'='true', 'data-evolution.enabled'='true', 'blob-field'='picture', 'blob-as-descriptor'='false')", "CREATE TABLE IF NOT EXISTS blob_table_descriptor (id INT, data STRING, picture BYTES) WITH ('row-tracking.enabled'='true', 'data-evolution.enabled'='true', 'blob-field'='picture', 'blob-as-descriptor'='true')"); } diff --git a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/BlobTestBase.scala b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/BlobTestBase.scala index e05c9ce644c1..818183680820 100644 --- a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/BlobTestBase.scala +++ b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/BlobTestBase.scala @@ -39,7 +39,7 @@ class BlobTestBase extends PaimonSparkTestBase { test("Blob: test basic") { withTable("t") { sql( - "CREATE TABLE t (id INT, data STRING, picture BINARY) TBLPROPERTIES ('row-tracking.enabled'='true', 'data-evolution.enabled'='true', 'blob-field'='picture')") + "CREATE TABLE t (id INT, data STRING, picture BINARY) TBLPROPERTIES ('row-tracking.enabled'='true', 'data-evolution.enabled'='true', 'blob-field'='picture', 'blob-as-descriptor'='false')") sql("INSERT INTO t VALUES (1, 'paimon', X'48656C6C6F')") checkAnswer( @@ -167,7 +167,7 @@ class BlobTestBase extends PaimonSparkTestBase { test("Blob: test compaction") { withTable("t") { sql( - "CREATE TABLE t (id INT, data STRING, picture BINARY) TBLPROPERTIES ('row-tracking.enabled'='true', 'data-evolution.enabled'='true', 'blob-field'='picture')") + "CREATE TABLE t (id INT, data STRING, picture BINARY) TBLPROPERTIES ('row-tracking.enabled'='true', 'data-evolution.enabled'='true', 'blob-field'='picture', 'blob-as-descriptor'='false')") for (i <- 1 to 10) { sql("INSERT INTO t VALUES (" + i + ", 'paimon', X'48656C6C6F')") }