You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Mao Jiayi (Jira)" <ji...@apache.org> on 2026/07/23 09:10:00 UTC

[jira] [Created] (FLINK-40223) Support additional Flink SQL string functions in YAML Transform

Mao Jiayi created FLINK-40223:
---------------------------------

             Summary: Support additional Flink SQL string functions in YAML Transform
                 Key: FLINK-40223
                 URL: https://issues.apache.org/jira/browse/FLINK-40223
             Project: Flink
          Issue Type: Improvement
          Components: Flink CDC
            Reporter: Mao Jiayi


Flink CDC YAML Transform currently provides only a basic set of string functions, such as CONCAT, CHAR_LENGTH, UPPER, LOWER, TRIM, SUBSTRING, and REGEXP_REPLACE.

Many commonly used Flink SQL string functions are still unavailable. As a result, users may need to implement UDFs or preprocess data for string operations that can be expressed directly in Flink SQL.

The missing functions include:

* OVERLAY, POSITION, INSTR, and LOCATE
* LTRIM, RTRIM, and BTRIM
* CONCAT_WS, LPAD, and RPAD
* REPLACE, REPEAT, LEFT, and RIGHT
* STARTSWITH and ENDSWITH
* TO_BASE64 and FROM_BASE64

YAML Transform should support these functions with argument validation, return types, NULL handling, and edge-case behavior aligned with Flink SQL.

This would improve compatibility between Flink SQL and row-level YAML Transform expressions without changing the behavior of existing functions.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)