[ https://issues.apache.org/jira/browse/FLINK-15994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jark Wu resolved FLINK-15994. ----------------------------- Resolution: Fixed Fixed in master(1.11.0): aedbdc3f6f7275204e6b1733c6d4f56c88297f05 > 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 > Assignee: hailong wang > Priority: Major > Labels: pull-request-available > Fix For: 1.11.0 > > Time Spent: 20m > Remaining Estimate: 0h > > 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)