flink
flink copied to clipboard
Apache Flink
## What is the purpose of the change This pr is aims to add document for "ANALYZE TABLE" syntax to introduce it's syntax and usage. ## Brief change log -...
I translate a Chinese comment in the sample code into English for more people to understand it.
The MIN value should be -128 and max value is 127 ## What is the purpose of the change Change the Byte min and max values in the description ##...
…ancelOperation ## What is the purpose of the change *Fix unstable `SqlGatewayServiceITCase.testCancelOperation`. The main cause is the main thread tries to get the OperationStatus after canceling the execution. But the...
## What is the purpose of the change To fix 'Table.INDEX_TABLE' not found in the Hive3 error (It's because hive3 removed this table type). ## Brief change log - fix...
## What is the purpose of the change FLINK-28848 introduces a new LOOKUP hint to support retry both on sync and async lookup, but the async path doesn't works because...
## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring...
Bump up apache-flink-libraries version.
## What is the purpose of the change This PR deprecates the ambiguous StateTTLConfig#cleanFullSnapshot API with the newly introduced `#cleanupOnFullScanSnapshot` API. ## Brief change log 1. Deprecate the StateTTLConfig#cleanFullSnapshot API...
## What is the purpose of the change This PR fixes the semantic of latestLoadTime in caching lookup function ## Brief change log - Fix semantic of latestLoadTime in caching...