[incubator-paimon] branch master updated: [flink] Display the specific table name in the error message when the table doesn't support lookup join (#795)

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new d527ca76e [flink] Display the specific table name in the error message 
when the table doesn't support lookup join (#795)
d527ca76e is described below

commit d527ca76e471aba931b6307dce70d5c19ac6962e
Author: Xianxun Ye <yxx_c...@163.com>
AuthorDate: Mon Apr 3 14:29:16 2023 +0800

    [flink] Display the specific table name in the error message when the table 
doesn't support lookup join (#795)
---
 .../apache/paimon/flink/lookup/FileStoreLookupFunction.java   | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java
index 629f6effd..2beddf707 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java
@@ -86,8 +86,15 @@ public class FileStoreLookupFunction implements 
Serializable, Closeable {
     public FileStoreLookupFunction(
             Table table, int[] projection, int[] joinKeyIndex, @Nullable 
Predicate predicate) {
         checkArgument(
-                table.partitionKeys().isEmpty(), "Currently only support 
non-partitioned table.");
-        checkArgument(table.primaryKeys().size() > 0, "Currently only support 
primary key table.");
+                table.partitionKeys().isEmpty(),
+                String.format(
+                        "Currently only support non-partitioned table, the 
lookup table is [%s].",
+                        table.name()));
+        checkArgument(
+                table.primaryKeys().size() > 0,
+                String.format(
+                        "Currently only support primary key table, the lookup 
table is [%s].",
+                        table.name()));
         TableScanUtils.streamingReadingValidate(table);
 
         this.table = table;