Leonard Xu created FLINK-20484: ---------------------------------- Summary: Improve hive temporal table exception Key: FLINK-20484 URL: https://issues.apache.org/jira/browse/FLINK-20484 Project: Flink Issue Type: Bug Components: Connectors / Hive Affects Versions: 1.12.0 Reporter: Leonard Xu Attachments: image-2020-12-04-16-42-28-399.png
user need to set options when use the latest hive partition asĀ temporal table: {code:java} 'streaming-source.enable'='true', 'streaming-source.partition.include' = 'latest', {code} if user missed the option `streaming-source.partition.include`, the hive table becomes a unbounded table, currently a unbounded table can only be used as versioned table in temporal join, so the framework require PK and watermark, but it's hard to understand to users. !image-2020-12-04-16-42-28-399.png! -- This message was sent by Atlassian Jira (v8.3.4#803005)