diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TemporalTableFunction.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TemporalTableFunction.scala index bbb9911c63f30..bf668480a0ad7 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TemporalTableFunction.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TemporalTableFunction.scala @@ -65,7 +65,7 @@ class TemporalTableFunction private( } object TemporalTableFunction { - def create( + private[flink] def create( table: Table, timeAttribute: Expression, primaryKey: String): TemporalTableFunction = {