Hi houyin, Jark,
Sorry I missed Jark's response before.
> We should support lookup HBase on multiple fields (by Get#setFilter).
Feel free to open issues.
I agree with Jark. It's better to support multiple keys for HBase.
> How can I solve this problem ?
Before Hbase supports multiple keys, we could
Hi houyin,
> It maybe because the conditions in where clause, being pushed down as a
> predicate
into join clause ?
Yes, after pushdown, hbase lookupkeys are `rowKey` and `city_code`, which
trigger above exception.
> How can I solve this problem ?
Because only constant value and field input ref o
Yes. Currently, the HBase lookup source only supports lookup on rowkey.
If there is more than one join on condition, it may fail.
We should support lookup HBase on multiple fields (by Get#setFilter).
Feel free to open issues.
Best,
Jark
On Mon, 28 Jun 2021 at 12:48, 纳兰清风 wrote:
> Hi,
>
> Whe
Hi,
When I was using hbase table as my lookup table, I got this error:
Caused by: java.lang.IllegalArgumentException: Currently, HBase table can
only be lookup by single row key.
at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138)
My SQL is
insert into si
