twalthr commented on a change in pull request #18858:
URL: https://github.com/apache/flink/pull/18858#discussion_r811704208
##########
File path:
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ContextResolvedTableJsonDeserializer.java
##########
@@ -172,9 +172,10 @@ private boolean isLookupEnabled(CatalogPlanRestore
planRestoreOption) {
static ValidationException missingIdentifier() {
return new ValidationException(
String.format(
- "The table cannot be deserialized, as no identifier is
present within the JSON, "
- + "but lookup is forced by '%s' == '%s'. "
- + "Either allow restoring table from the
catalog with '%s' == '%s' | '%s' or make sure you don't use anonymous tables
when generating the plan.",
+ "The table cannot be deserialized as no identifier is
present in the persisted plan."
Review comment:
I agree. I will put this on my list for polishing the table
serialization.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
