hehuiyuan

[FLINK-28750][Hive]The field comment for hive ddl has logic error

2

## What is the purpose of the change The field comment is lost when using hive parser. There are som logic error for parsering hive sql ```java "set table.sql-dialect=hive;\n" +...

hi,I met a problem that is the streamingsource 's metrics is not reported to influxes

[FLINK-29052][TABLE]Support TO_TIMESTAMP built-in function in Table API

2

## What is the purpose of the change Support TO_TIMESTAMP built-in function in Table API. ## Brief change log Support TO_TIMESTAMP built-in functions in Table API. Support TO_TIMESTAMP built-in functions...

开启checkpoint后异常

2

18/08/22 15:50:41 ERROR Utils: Exception encountered java.io.NotSerializableException: org.apache.hadoop.conf.Configuration at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184) at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1548) 我这是spark streaming任务 stream.foreach{rdd=>rdd.put2hase(....)} 应该是put2hbase方法中：def put2Hbase(tableName: String)(implicit config: HbRddConfig) 调用了config.getHbaseConfig 然后这个方法实现是：def getHbaseConfig = HBaseConfiguration.create(config) create方法中创建了Configuration conf = new Configuration();　　...

[DOC]Update watermark column type

1

## What is the purpose of the change  https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/sql/create/#watermark Add rowtime colunm type `TIMESTAMP_LTZ(3)` ## Brief change log Add rowtime colunm type `TIMESTAMP_LTZ(3)` ## Verifying this change ## Does...

[FLINK-33871][HIVE]Reduce getTable call for hive client and optimize graph generation time

3

## What is the purpose of the change HiveCatalog.getHiveTable method wastes a lot of time when generate graph, because the number of calls is relatively high. I have an sql...

try doing compcation once for batch mode

1

### Change Logs Support to do compcation for batch mode ### Impact ### Risk level (write none, low medium or high below) ### Documentation Update ### Contributor's checklist