jiefei30 commented on code in PR #25904:
URL: https://github.com/apache/flink/pull/25904#discussion_r1904252739
##########
docs/content.zh/docs/dev/table/materialized-table/statements.md:
##########
@@ -233,8 +233,8 @@ CREATE MATERIALIZED TABLE my_materialized_table_full
'format' = 'json',
'partition.fields.ds.date-formatter' = 'yyyy-MM-dd'
)
- FRESHNESS = INTERVAL '10' MINUTE
- REFRESH_MODE = 'FULL'
+ FRESHNESS = INTERVAL '1' HOUR
+ REFRESH_MODE = FULL
Review Comment:
@davidradl I understand what you mean, `AUTOMATIC` will be the default
refresh_mode when the refresh_mode was not spicified after I checked the code
and found in `MaterializedTableUtils`.
```java
public static CatalogMaterializedTable.LogicalRefreshMode
deriveLogicalRefreshMode(
SqlRefreshMode sqlRefreshMode) {
if (sqlRefreshMode == null) {
return CatalogMaterializedTable.LogicalRefreshMode.AUTOMATIC;
}
switch (sqlRefreshMode) {
case FULL:
return CatalogMaterializedTable.LogicalRefreshMode.FULL;
case CONTINUOUS:
return
CatalogMaterializedTable.LogicalRefreshMode.CONTINUOUS;
default:
throw new ValidationException(
String.format("Unsupported logical refresh mode:
%s.", sqlRefreshMode));
}
}
```
I will add the default value to the documentation later and add more example
sql.
--
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]
