[jira] [Created] (FLINK-15994) Support byte array arguments for FROM_BASE64 function

[hailong wang (Jira)]

hailong wang created FLINK-15994:
------------------------------------

             Summary: Support byte array arguments for FROM_BASE64 function
                 Key: FLINK-15994
                 URL: https://issues.apache.org/jira/browse/FLINK-15994
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Planner
    Affects Versions: 1.10.0
            Reporter: hailong wang
             Fix For: 1.11.0


For the following sql,
{code:java}
testSqlApi("FROM_BASE64(cast(x'6147567362473867643239796247513D' as 
varbinary))",
 "hello world"){code}
it will throw:
{code:java}
Caused by: 
org.apache.flink.shaded.guava18.com.google.common.util.concurrent.UncheckedExecutionException:
 org.apache.flink.api.common.InvalidProgramException: Table program cannot be 
compiled. This is a bug. Please file an issue.Caused by: 
org.apache.flink.shaded.guava18.com.google.common.util.concurrent.UncheckedExecutionException:
 org.apache.flink.api.common.InvalidProgramException: Table program cannot be 
compiled. This is a bug. Please file an issue. at 
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2203)
 at 
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937)
 at 
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739)
 at 
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:66)
 ... 27 moreCaused by: org.apache.flink.api.common.InvalidProgramException: 
Table program cannot be compiled. This is a bug. Please file an issue. at 
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:81)
 at 
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:66)
 at 
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4742)
 at 
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527)
 at 
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2319)
 at 
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2282)
 at 
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2197)
 ... 30 moreCaused by: org.codehaus.commons.compiler.CompileException: Line 
114, Column 94: No applicable constructor/method found for actual parameters 
"byte[]"; candidates are: "public static 
org.apache.flink.table.dataformat.BinaryString 
org.apache.flink.table.runtime.functions.SqlFunctionUtils.fromBase64(org.apache.flink.table.dataformat.BinaryString)"
 at org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:12124) at 
org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:9176)
 at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9036) at 
org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:8938)
{code}
For the reason that we did not implement SqlFunctionUtils.fromBase64(byte[] 
bytes) method.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)