[jira] [Created] (FLINK-30816) Fix Sql Client always uses the packaged highests version to connect to gateway

2023-01-29 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-30816: - Summary: Fix Sql Client always uses the packaged highests version to connect to gateway Key: FLINK-30816 URL: https://issues.apache.org/jira/browse/FLINK-30816 Proj

[jira] [Created] (FLINK-30817) ClassCastException in TestValuesTableFactory.TestValuesScanTableSourceWithoutProjectionPushDown

2023-01-29 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-30817: -- Summary: ClassCastException in TestValuesTableFactory.TestValuesScanTableSourceWithoutProjectionPushDown Key: FLINK-30817 URL: https://issues.apache.org/jira/browse/FLINK-3081

[jira] [Created] (FLINK-30818) add metrics to measure the count of window

2023-01-29 Thread chenyuzhi (Jira)
chenyuzhi created FLINK-30818: - Summary: add metrics to measure the count of window Key: FLINK-30818 URL: https://issues.apache.org/jira/browse/FLINK-30818 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store

2023-01-29 Thread Shammon FY
Hi @Vicky Thank you for your suggestions about consistency and they're very nice to me! I have updated the examples and consistency types[1] in FLIP. In general, I regard the Timestamp Barrier processing as a transaction and divide the data consistency supported in FLIP into three types 1. Read

[jira] [Created] (FLINK-30819) Fix history file records incomplete statement sets

2023-01-29 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-30819: - Summary: Fix history file records incomplete statement sets Key: FLINK-30819 URL: https://issues.apache.org/jira/browse/FLINK-30819 Project: Flink Issue Ty

[jira] [Created] (FLINK-30820) Support varchar and char for spark in table store

2023-01-29 Thread Shammon (Jira)
Shammon created FLINK-30820: --- Summary: Support varchar and char for spark in table store Key: FLINK-30820 URL: https://issues.apache.org/jira/browse/FLINK-30820 Project: Flink Issue Type: Improveme

Re: [VOTE] Release 1.16.1, release candidate #1

2023-01-29 Thread ConradJam
+1 (non-binding) - built from sources sucessful - Run StateMachineExample on a local cluster and k8s cluster - check the pr Martijn Visser 于2023年1月20日周五 00:07写道： > Hi everyone, > Please review and vote on the release candidate #1 for the version 1.16.1, > as follows: > [ ] +1, Approve

[jira] [Created] (FLINK-30821) The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected

2023-01-29 Thread Junrui Li (Jira)
Junrui Li created FLINK-30821: - Summary: The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected Key: FLINK-30821 URL: https://iss

Re: [DISCUSS] Release new FRocksDB

2023-01-29 Thread Yanfei Lei
Hi all, Thanks for everyone's advice, FRocksDB 6.20.3-ververica-2.0[1] had been released, compared with FRocksDB 6.20.3-ververica-1.0, there are the following 4 points of improvement: 1. [FLINK-30457] Add periodic_compaction_seconds option to RocksJava[2] 2. [FLINK-30321] Upgrade ZLIB of FRocksDB

Re: [VOTE] Release 1.16.1, release candidate #1

2023-01-29 Thread Jing Zhang
Thanks Martijn for driving this. +1 (non-binding) - verified signatures and checksums - built from source code flink-1.16.1-src.tgz - start a standalone Flink cluster, run the WordCount example, WebUI looks good, no suspicious output/log. - start cluster and run some e2e sql queries using SQL Cli