You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/03/10 14:45:18 UTC

[flink] 01/02: [hotfix][table-planner] Raw to Binary can fail if the user type ser/de fails

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

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

commit cbfca3afae5d33f9137ae97eb4f4c27ea0d82919
Author: slinkydeveloper <fr...@gmail.com>
AuthorDate: Thu Feb 17 13:33:49 2022 +0100

    [hotfix][table-planner] Raw to Binary can fail if the user type ser/de fails
---
 .../flink/table/planner/functions/casting/RawToBinaryCastRule.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RawToBinaryCastRule.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RawToBinaryCastRule.java
index 8dc2111..06a60ec 100644
--- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RawToBinaryCastRule.java
+++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RawToBinaryCastRule.java
@@ -43,6 +43,11 @@ class RawToBinaryCastRule extends AbstractNullAwareCodeGeneratorCastRule<Object,
                         .build());
     }
 
+    @Override
+    public boolean canFail() {
+        return true;
+    }
+
     /* Example generated code for BINARY(3):
 
     // legacy behavior