You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by tw...@apache.org on 2021/12/15 08:24:40 UTC

[flink] branch master updated (ad066f5 -> 3ab9802)

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from ad066f5  [FLINK-24580][Connectors/Kinesis] Make ConnectTimeoutException recoverable (#17785)
     add 419eb1e  [FLINK-25051][table-planner] Port raw <-> binary logic to CastRule
     add 3ab9802  [FLINK-24419][table-planner] Trim to length when casting to BINARY/VARBINARY

No new revisions were added by this update.

Summary of changes:
 ...ngCastRule.java => BinaryToBinaryCastRule.java} |  53 ++++++----
 .../functions/casting/CastRuleProvider.java        |   3 +
 .../planner/functions/casting/CastRuleUtils.java   |   4 +
 .../functions/casting/RawToBinaryCastRule.java     | 113 +++++++++++++++++++++
 .../functions/casting/StringToBinaryCastRule.java  |  64 +++++++++++-
 .../planner/codegen/calls/ScalarOperatorGens.scala |   7 --
 .../planner/functions/CastFunctionITCase.java      |  21 ++--
 .../planner/functions/CastFunctionMiscITCase.java  |  18 +++-
 .../planner/functions/casting/CastRulesTest.java   |  32 ++++--
 9 files changed, 259 insertions(+), 56 deletions(-)
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/{TimestampToStringCastRule.java => BinaryToBinaryCastRule.java} (50%)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RawToBinaryCastRule.java