[
https://issues.apache.org/jira/browse/FLINK-30974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xi chaomin updated FLINK-30974:
-------------------------------
Description:
I use flink sql to join hbase table, when I set lookup.asycn = true, I get an
error.
{code:java}
Suppressed: java.lang.Exception: java.lang.NoClassDefFoundError:
rg/apache/flink/hbase/shaded/rg/apache/commons/io/I0Utilsat
org.apache.flink.streaming.runtime.tasks.StreamTask.runAndsuppressThrowable(StreamTask.java:1024)at
org.apache.flink.streaming.runtime.tasks.StreamaskcleanUp(StreamTask.java:928)at
org.apache.flink,runtime.taskmanager,Task,lambdarestoreAndInvoke$0(Task.java:940)at
org.apacheflink.runtime
.taskmanagerk.runwithsystemExitMonitoring(Task.java:958)at
org.apache.flink.runtime .task.restoreAndInvoke(Task.java:948.3 moreCaused by:
java,langNoClassDefFoundError:
org/apache/flink/hbase/shaded/org/apache/commons/io/IOUtilsat
org.apache.hadoop.hbase.client.AsyncCnectionImpl.close(AsyncConnectionImpliava:193)at
org.apache.flink.connector .hbase2 .
source..HBaseRowDataAsyncLookupFunction.close(HBaseRowDataAsyncLookupFunction.java:251)
at LookupFunction$281.close(unknowr
at
org.apache.flinkapi.common,functions,util.Functionutils.closeFunction(Functionutils.java:41)at
org.apache.flink.table.runtime.operators.join.lookup.AsyncLookupJoinRunner.close(AsyncLookupJoinRunner,java:137)at
org.apache.flink.api.common.functions.util,Functionutils.closeFunction(Functionutils.java:41)at
org.apache.flink,streaming.api.operators.AbstractUdfStreamoperatorclose(Abstractudfstreamoperator.java:114)at
org.apache.flink.streaming.runtime.tasks.Stream0peratorwrapper.close(Streamoperatorwrapper.java:141)
{code}
was:
I use flink sql to join hbase table, when I set
| |
> NoClassDefFoundError
> org/apache/flink/hbase/shaded/org/apache/commons/io/IOUtils
> --------------------------------------------------------------------------------
>
> Key: FLINK-30974
> URL: https://issues.apache.org/jira/browse/FLINK-30974
> Project: Flink
> Issue Type: Bug
> Reporter: xi chaomin
> Priority: Major
>
> I use flink sql to join hbase table, when I set lookup.asycn = true, I get an
> error.
> {code:java}
> Suppressed: java.lang.Exception: java.lang.NoClassDefFoundError:
> rg/apache/flink/hbase/shaded/rg/apache/commons/io/I0Utilsat
> org.apache.flink.streaming.runtime.tasks.StreamTask.runAndsuppressThrowable(StreamTask.java:1024)at
>
> org.apache.flink.streaming.runtime.tasks.StreamaskcleanUp(StreamTask.java:928)at
>
> org.apache.flink,runtime.taskmanager,Task,lambdarestoreAndInvoke$0(Task.java:940)at
> org.apacheflink.runtime
> .taskmanagerk.runwithsystemExitMonitoring(Task.java:958)at
> org.apache.flink.runtime .task.restoreAndInvoke(Task.java:948.3 moreCaused
> by: java,langNoClassDefFoundError:
> org/apache/flink/hbase/shaded/org/apache/commons/io/IOUtilsat
> org.apache.hadoop.hbase.client.AsyncCnectionImpl.close(AsyncConnectionImpliava:193)at
> org.apache.flink.connector .hbase2 .
> source..HBaseRowDataAsyncLookupFunction.close(HBaseRowDataAsyncLookupFunction.java:251)
> at LookupFunction$281.close(unknowr
> at
> org.apache.flinkapi.common,functions,util.Functionutils.closeFunction(Functionutils.java:41)at
>
> org.apache.flink.table.runtime.operators.join.lookup.AsyncLookupJoinRunner.close(AsyncLookupJoinRunner,java:137)at
>
> org.apache.flink.api.common.functions.util,Functionutils.closeFunction(Functionutils.java:41)at
>
> org.apache.flink,streaming.api.operators.AbstractUdfStreamoperatorclose(Abstractudfstreamoperator.java:114)at
>
> org.apache.flink.streaming.runtime.tasks.Stream0peratorwrapper.close(Streamoperatorwrapper.java:141)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
