[hotfix] Fix doc and improve error message (#2489)

apache · Dec 12, 2023 · 223cccc · 223cccc
1 parent 2c401ac
commit 223cccc
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/docs/content/api/flink-api.md b/docs/content/api/flink-api.md
@@ -73,6 +73,8 @@ public class WriteToTable {
     public static void writeTo() {
         // create environments of both APIs
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
+        // for CONTINUOUS_UNBOUNDED source, set checkpoint interval
+        // env.enableCheckpointing(60_000);
         StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
 
         // create a changelog DataStream
@@ -173,6 +175,8 @@ public class WriteCdcToTable {
 
     public static void writeTo() throws Exception {
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
+        // for CONTINUOUS_UNBOUNDED source, set checkpoint interval
+        // env.enableCheckpointing(60_000);
 
         DataStream<RichCdcRecord> dataStream =
                 env.fromElements(

diff --git a/docs/layouts/shortcodes/generated/compute_column.html b/docs/layouts/shortcodes/generated/compute_column.html
@@ -42,8 +42,10 @@
         <td>Extract hour from a DATE, DATETIME or TIMESTAMP (or its corresponding string format). Output is an INT value represent the hour.</td>
     </tr>
     <tr>
-        <td><h5>date_format(date-column)</h5></td>
-        <td>Convert date format from a DATE, DATETIME or TIMESTAMP (or its corresponding string format). Output is a string value in converted date format.</td>
+        <td><h5>date_format(date-column,format)</h5></td>
+        <td>Convert date format from a DATE, DATETIME or TIMESTAMP (or its corresponding string format).
+            'format' is compatible with Java's DateTimeFormatter String (for example, 'yyyy-MM-dd'). Output is a string value in converted date format.
+        </td>
     </tr>
     <tr>
         <td><h5>substring(column,beginInclusive)</h5></td>

diff --git a/...n-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/MessageQueueSchemaUtils.java b/...n-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/MessageQueueSchemaUtils.java
@@ -66,7 +66,10 @@ public static Schema getSchema(
             if (retry >= MAX_RETRY) {
                 throw new SchemaRetrievalException(
                         String.format(
-                                "Could not get metadata from server, topic: %s", consumer.topic()));
+                                "Could not get metadata from server, topic: %s. If this topic is not empty, "
+                                        + "please check the configuration of synchronization job. "
+                                        + "Otherwise, you should create the Paimon table first.",
+                                consumer.topic()));
             }
 
             sleepSafely(retryInterval);