tsreaper
tsreaper
Run the following SQL in SQL client: ```sql create temporary table faker ( a string ) with ( 'connector' = 'faker', 'number-of-rows' = '10', 'fields.a.expression' = '#{address.city}' ); select *...
Run the following SQL in SQL client: ```sql create temporary table faker ( a string, b string, c string, d string ) with ( 'connector' = 'faker', 'number-of-rows' = '3',...
[This pull request](https://github.com/ververica/flink-sql-gateway/pull/28) changes the REST API of Flink SQL gateway and breaks current Flink JDBC driver. This PR adapts to the REST API changes.
This PR adds detailed documentation for the gateway, including the REST API documentation and an API usage example.
### Purpose To directly consume changes from Flink CDC connectors, we need a special CDC sink for Paimon. ### Tests * FlinkCdcSinkITCase ### API and Format N/A ### Documentation N/A
As mentioned in `Perceptron.ipynb`, the gradient descent algorithm comes with a learning rate. However there is no learning rate in the `train` function.
### Purpose This PR adds a `numWriters` metrics to monitor the number of active writers in each parallelism. This metric can help us determine if the memory shortage is caused...
### Purpose This PR introduces an identity-based privilege system for catalogs. Catalogs can now be updated into a privileged catalogs, where privileged users can be created and granted privileges to...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation In #3731 we've introduced `IcebergCommitCallback` to create Iceberg metadata after commit. We convert...
### Purpose In #3731 we introduce `IcebergCommitCallback` to create Iceberg metadata. In this PR we improve this class so that it can reuse Iceberg manifest files created before to create...