[jira] [Closed] (FLINK-25177) Support "DESCRIBE TABLE EXTENDED" with managed table

[ https://issues.apache.org/jira/browse/FLINK-25177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25177. Fix Version/s: (was: 1.20.0) Resolution: Invalid > Support "DESCRIBE TABLE EXTENDED"

[jira] [Commented] (FLINK-33621) Table Store with PyFlink

[ https://issues.apache.org/jira/browse/FLINK-33621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17788950#comment-17788950 ] Jingsong Lee commented on FLINK-33621: -- Hi [~mfatihaktas] First, I think you can take a look to

[jira] [Commented] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773075#comment-17773075 ] Jingsong Lee commented on FLINK-33200: -- CC [~lincoln.86xy]  > ItemAt Expression validation fail in

[jira] [Commented] (FLINK-22128) Window aggregation should have unique keys

[ https://issues.apache.org/jira/browse/FLINK-22128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766177#comment-17766177 ] Jingsong Lee commented on FLINK-22128: -- [~337361...@qq.com] I think yes, this still should be done.

[jira] [Commented] (FLINK-32001) SupportsRowLevelUpdate does not support returning only a part of the columns.

[ https://issues.apache.org/jira/browse/FLINK-32001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719601#comment-17719601 ] Jingsong Lee commented on FLINK-32001: -- CC [~yuxia]  > SupportsRowLevelUpdate does not support

[jira] [Assigned] (FLINK-31335) using sql-gateway to submit job to yarn cluster, sql-gateway don't support kerberos

[ https://issues.apache.org/jira/browse/FLINK-31335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31335: Assignee: felixzh > using sql-gateway to submit job to yarn cluster, sql-gateway don't

[jira] [Closed] (FLINK-31429) Support CTAS(create table as) streaming job with schema changes in table store

[ https://issues.apache.org/jira/browse/FLINK-31429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31429. Resolution: Fixed > Support CTAS(create table as) streaming job with schema changes in table

[jira] [Closed] (FLINK-31435) Introduce event parser for MySql Debezium JSON format in Table Store

[ https://issues.apache.org/jira/browse/FLINK-31435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31435. Resolution: Fixed > Introduce event parser for MySql Debezium JSON format in Table Store >

[jira] [Closed] (FLINK-30419) Allow tuning of transaction timeout

[ https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30419. Resolution: Fixed > Allow tuning of transaction timeout > --- > >

[jira] [Commented] (FLINK-30419) Allow tuning of transaction timeout

[ https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706198#comment-17706198 ] Jingsong Lee commented on FLINK-30419: -- https://github.com/apache/incubator-paimon/issues/754 >

[jira] [Closed] (FLINK-27958) Compare batch maxKey to reduce comparisons in SortMergeReader

[ https://issues.apache.org/jira/browse/FLINK-27958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27958. Resolution: Fixed > Compare batch maxKey to reduce comparisons in SortMergeReader >

[jira] [Closed] (FLINK-31111) Introduce CatalogTestBase

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-3. Resolution: Fixed > Introduce CatalogTestBase > - > >

[jira] [Closed] (FLINK-31001) Introduce Hive writer

[ https://issues.apache.org/jira/browse/FLINK-31001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31001. Resolution: Fixed > Introduce Hive writer > - > > Key:

[jira] [Closed] (FLINK-27103) Don't store redundant primary key fields

[ https://issues.apache.org/jira/browse/FLINK-27103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27103. Resolution: Fixed > Don't store redundant primary key fields >

[jira] [Closed] (FLINK-27002) Optimize batch multiple partitions inserting

[ https://issues.apache.org/jira/browse/FLINK-27002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27002. Resolution: Fixed > Optimize batch multiple partitions inserting >

[jira] [Closed] (FLINK-31190) Supports Spark call procedure command on Table Store

[ https://issues.apache.org/jira/browse/FLINK-31190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31190. Resolution: Fixed > Supports Spark call procedure command on Table Store >

[jira] [Closed] (FLINK-28086) Table Store Catalog supports partition methods

[ https://issues.apache.org/jira/browse/FLINK-28086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28086. Resolution: Fixed > Table Store Catalog supports partition methods >

[jira] [Closed] (FLINK-31194) Introduces savepoint mechanism of Table Store

[ https://issues.apache.org/jira/browse/FLINK-31194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31194. Resolution: Fixed > Introduces savepoint mechanism of Table Store >

[jira] [Closed] (FLINK-31195) FullChangelogStoreSinkWrite bucket writer conflicts with rescale

[ https://issues.apache.org/jira/browse/FLINK-31195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31195. Resolution: Fixed > FullChangelogStoreSinkWrite bucket writer conflicts with rescale >

[jira] [Closed] (FLINK-30945) FTS does not support multiple writers into the same table and topic

[ https://issues.apache.org/jira/browse/FLINK-30945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30945. Resolution: Fixed https://github.com/apache/incubator-paimon/issues/745 > FTS does not support

[jira] [Closed] (FLINK-31076) Supports filter predicate in Parquet format of table store

[ https://issues.apache.org/jira/browse/FLINK-31076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31076. Resolution: Fixed > Supports filter predicate in Parquet format of table store >

[jira] [Closed] (FLINK-30723) Introduce filter pushdown for parquet format

[ https://issues.apache.org/jira/browse/FLINK-30723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30723. Resolution: Fixed > Introduce filter pushdown for parquet format >

[jira] [Closed] (FLINK-30572) Make parquet as default data file format

[ https://issues.apache.org/jira/browse/FLINK-30572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30572. Resolution: Fixed > Make parquet as default data file format >

[jira] [Closed] (FLINK-31224) Add metrics for flink table store

[ https://issues.apache.org/jira/browse/FLINK-31224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31224. Resolution: Fixed > Add metrics for flink table store > - > >

[jira] [Closed] (FLINK-26465) Optimize SortMergeReader: use loser tree to reduce comparisons

[ https://issues.apache.org/jira/browse/FLINK-26465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26465. Resolution: Fixed > Optimize SortMergeReader: use loser tree to reduce comparisons >

[jira] [Closed] (FLINK-30857) Create table does not create topic with multiple partitions

[ https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30857. Resolution: Fixed > Create table does not create topic with multiple partitions >

[jira] [Commented] (FLINK-30857) Create table does not create topic with multiple partitions

[ https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706179#comment-17706179 ] Jingsong Lee commented on FLINK-30857: -- Kafka topic should be created by users.. > Create table

[jira] [Closed] (FLINK-31039) ChangelogWithKeyFileStoreTableITCase in table store is not stable

[ https://issues.apache.org/jira/browse/FLINK-31039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31039. Resolution: Fixed > ChangelogWithKeyFileStoreTableITCase in table store is not stable >

[jira] [Closed] (FLINK-31011) upgrade hiverunner version

[ https://issues.apache.org/jira/browse/FLINK-31011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31011. Resolution: Fixed > upgrade hiverunner version > -- > >

[jira] [Closed] (FLINK-31074) Introduce value filter for table store

[ https://issues.apache.org/jira/browse/FLINK-31074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31074. Resolution: Fixed > Introduce value filter for table store >

[jira] [Closed] (FLINK-31013) Session window aggregation cannot trigger window using event time

[ https://issues.apache.org/jira/browse/FLINK-31013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31013. Resolution: Fixed > Session window aggregation cannot trigger window using event time >

[jira] [Closed] (FLINK-30580) [umbrella] Refactor tests for table store

[ https://issues.apache.org/jira/browse/FLINK-30580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30580. Resolution: Fixed > [umbrella] Refactor tests for table store >

[jira] [Closed] (FLINK-31129) Introduce FlinkEmbeddedHiveRunner for junit5 in table store

[ https://issues.apache.org/jira/browse/FLINK-31129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31129. Resolution: Fixed > Introduce FlinkEmbeddedHiveRunner for junit5 in table store >

[jira] [Closed] (FLINK-30603) CompactActionITCase in table store is unstable

[ https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30603. Resolution: Fixed > CompactActionITCase in table store is unstable >

[jira] [Closed] (FLINK-30740) INSERT to Kafka does not work when Kafka config auto.create.topics.enabled is set to false

[ https://issues.apache.org/jira/browse/FLINK-30740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30740. Resolution: Fixed https://github.com/apache/incubator-paimon/issues/740 > INSERT to Kafka does

[jira] [Closed] (FLINK-28661) Introduce generic mode for table store catalog

[ https://issues.apache.org/jira/browse/FLINK-28661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28661. Resolution: Fixed > Introduce generic mode for table store catalog >

[jira] [Closed] (FLINK-30248) Spark writer supports insert overwrite

[ https://issues.apache.org/jira/browse/FLINK-30248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30248. Resolution: Fixed > Spark writer supports insert overwrite >

[jira] [Closed] (FLINK-27628) Table Store records and fetches incorrect results with NaN

[ https://issues.apache.org/jira/browse/FLINK-27628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27628. Resolution: Fixed > Table Store records and fetches incorrect results with NaN >

[jira] [Closed] (FLINK-29953) Get rid of flink-connector-hive dependency in flink-table-store-hive

[ https://issues.apache.org/jira/browse/FLINK-29953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29953. Resolution: Fixed > Get rid of flink-connector-hive dependency in flink-table-store-hive >

[jira] [Closed] (FLINK-29756) Support materialized column to improve query performance for complex types

[ https://issues.apache.org/jira/browse/FLINK-29756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29756. Resolution: Fixed https://github.com/apache/incubator-paimon/issues/735 > Support materialized

[jira] [Closed] (FLINK-29490) Timestamp LTZ is unsupported in table store

[ https://issues.apache.org/jira/browse/FLINK-29490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29490. Resolution: Fixed > Timestamp LTZ is unsupported in table store >

[jira] [Closed] (FLINK-30326) SQL Client should not create table directory structure

[ https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30326. Resolution: Fixed I close this, I think it is difficult to implement in paimon, if necessary,

[jira] [Closed] (FLINK-30590) Remove set default value manually for table options

[ https://issues.apache.org/jira/browse/FLINK-30590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30590. Resolution: Fixed > Remove set default value manually for table options >

[jira] [Closed] (FLINK-30317) Create table in FTS catalog with s3 warehouse throws DatabaseNotExistException

[ https://issues.apache.org/jira/browse/FLINK-30317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30317. Resolution: Fixed > Create table in FTS catalog with s3 warehouse throws

[jira] [Commented] (FLINK-30317) Create table in FTS catalog with s3 warehouse throws DatabaseNotExistException

[ https://issues.apache.org/jira/browse/FLINK-30317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706174#comment-17706174 ] Jingsong Lee commented on FLINK-30317: -- https://github.com/apache/incubator-paimon/issues/733 >

[jira] [Closed] (FLINK-30390) Ensure that no compaction is in progress before closing the writer

[ https://issues.apache.org/jira/browse/FLINK-30390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30390. Resolution: Fixed > Ensure that no compaction is in progress before closing the writer >

[jira] [Closed] (FLINK-30564) Select from a new table with Kafka LogStore crashes with UnknownTopicOrPartitionException

[ https://issues.apache.org/jira/browse/FLINK-30564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30564. Resolution: Fixed > Select from a new table with Kafka LogStore crashes with >

[jira] [Closed] (FLINK-30394) [umbrella] Refactor filesystem support in table store

[ https://issues.apache.org/jira/browse/FLINK-30394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30394. Resolution: Fixed > [umbrella] Refactor filesystem support in table store >

[jira] [Commented] (FLINK-30564) Select from a new table with Kafka LogStore crashes with UnknownTopicOrPartitionException

[ https://issues.apache.org/jira/browse/FLINK-30564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706173#comment-17706173 ] Jingsong Lee commented on FLINK-30564: -- https://github.com/apache/incubator-paimon/issues/732 >

[jira] [Closed] (FLINK-30000) Introduce FileSystemFactory to create FileSystem from custom configuration

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-3. Resolution: Fixed > Introduce FileSystemFactory to create FileSystem from custom configuration >

[jira] [Closed] (FLINK-30039) Insert overwrite show excetion that query and insert schema do not match

[ https://issues.apache.org/jira/browse/FLINK-30039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30039. Resolution: Fixed > Insert overwrite show excetion that query and insert schema do not match >

[jira] [Closed] (FLINK-30031) flink table store run abnormally when shade flink

[ https://issues.apache.org/jira/browse/FLINK-30031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30031. Resolution: Fixed > flink table store run abnormally when shade flink >

[jira] [Closed] (FLINK-29630) Junit 5.8.1 run unit test with temporary directory will occur Failed to delete temp directory.

[ https://issues.apache.org/jira/browse/FLINK-29630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29630. Resolution: Fixed > Junit 5.8.1 run unit test with temporary directory will occur Failed to >

[jira] [Closed] (FLINK-26937) Introduce Leveled compression for LSM

[ https://issues.apache.org/jira/browse/FLINK-26937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26937. Resolution: Fixed > Introduce Leveled compression for LSM > -

[jira] [Closed] (FLINK-29988) Improve upper case fields for hive metastore

[ https://issues.apache.org/jira/browse/FLINK-29988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29988. Resolution: Fixed > Improve upper case fields for hive metastore >

[jira] [Closed] (FLINK-27814) Add an abstraction layer for connectors to read and write row data instead of key-values

[ https://issues.apache.org/jira/browse/FLINK-27814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27814. Resolution: Fixed > Add an abstraction layer for connectors to read and write row data instead of

[jira] [Closed] (FLINK-27548) Improve quick-start of table store

[ https://issues.apache.org/jira/browse/FLINK-27548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27548. Resolution: Fixed > Improve quick-start of table store > -- > >

[jira] [Closed] (FLINK-29636) Add micro benchmark module in flink table store

[ https://issues.apache.org/jira/browse/FLINK-29636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29636. Resolution: Fixed > Add micro benchmark module in flink table store >

[jira] [Closed] (FLINK-29290) Produce changelog during full compaction in Table Store

[ https://issues.apache.org/jira/browse/FLINK-29290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29290. Resolution: Fixed > Produce changelog during full compaction in Table Store >

[jira] [Closed] (FLINK-29746) Add workflow in github for micro benchmarks

[ https://issues.apache.org/jira/browse/FLINK-29746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29746. Resolution: Fixed > Add workflow in github for micro benchmarks >

[jira] [Closed] (FLINK-28009) Optimize data split

[ https://issues.apache.org/jira/browse/FLINK-28009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28009. Resolution: Fixed > Optimize data split > --- > > Key:

[jira] [Closed] (FLINK-29331) pre-aggregated merge supports changelog inputs

[ https://issues.apache.org/jira/browse/FLINK-29331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29331. Resolution: Fixed > pre-aggregated merge supports changelog inputs >

[jira] [Closed] (FLINK-28718) SinkSavepointITCase.testRecoverFromSavepoint is unstable

[ https://issues.apache.org/jira/browse/FLINK-28718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28718. Resolution: Fixed > SinkSavepointITCase.testRecoverFromSavepoint is unstable >

[jira] [Closed] (FLINK-28690) UpdateSchema#fromCatalogTable lost column comment

[ https://issues.apache.org/jira/browse/FLINK-28690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28690. Resolution: Fixed > UpdateSchema#fromCatalogTable lost column comment >

[jira] [Closed] (FLINK-29080) Migrate all tests from managed table to catalog-based tests

[ https://issues.apache.org/jira/browse/FLINK-29080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29080. Resolution: Fixed > Migrate all tests from managed table to catalog-based tests >

[jira] [Closed] (FLINK-29243) Introduce a COW mode for table store

[ https://issues.apache.org/jira/browse/FLINK-29243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29243. Resolution: Fixed changelog producer = full-compaction is the cow mode. > Introduce a COW mode

[jira] [Closed] (FLINK-29272) Document DataStream API (DataStream to Table) for table store

[ https://issues.apache.org/jira/browse/FLINK-29272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29272. Resolution: Fixed > Document DataStream API (DataStream to Table) for table store >

[jira] [Commented] (FLINK-29820) Support to read data from table store with specify snapshot id

[ https://issues.apache.org/jira/browse/FLINK-29820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702211#comment-17702211 ] Jingsong Lee commented on FLINK-29820: -- We have already supported this. > Support to read data

[jira] [Closed] (FLINK-29820) Support to read data from table store with specify snapshot id

[ https://issues.apache.org/jira/browse/FLINK-29820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29820. Resolution: Fixed > Support to read data from table store with specify snapshot id >

[jira] [Closed] (FLINK-29823) Support get schema for table snapshot

[ https://issues.apache.org/jira/browse/FLINK-29823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29823. Resolution: Fixed > Support get schema for table snapshot > -

[jira] [Closed] (FLINK-29828) Support to read data from table with given snapshot id

[ https://issues.apache.org/jira/browse/FLINK-29828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29828. Resolution: Fixed > Support to read data from table with given snapshot id >

[jira] [Closed] (FLINK-29882) LargeDataITCase is not stable

[ https://issues.apache.org/jira/browse/FLINK-29882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29882. Resolution: Fixed > LargeDataITCase is not stable > - > >

[jira] [Closed] (FLINK-29832) Improve switch to default database in docs

[ https://issues.apache.org/jira/browse/FLINK-29832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29832. Resolution: Fixed > Improve switch to default database in docs >

[jira] [Closed] (FLINK-30227) Add LeafEmptyFunction for predicate without fields

[ https://issues.apache.org/jira/browse/FLINK-30227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30227. Resolution: Fixed > Add LeafEmptyFunction for predicate without fields >

[jira] [Closed] (FLINK-30080) Introduce public programming api and dependency jar for table store

[ https://issues.apache.org/jira/browse/FLINK-30080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30080. Resolution: Fixed > Introduce public programming api and dependency jar for table store >

[jira] [Closed] (FLINK-30276) [umbrella] Flink free for table store core

[ https://issues.apache.org/jira/browse/FLINK-30276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30276. Resolution: Fixed > [umbrella] Flink free for table store core >

[jira] [Closed] (FLINK-31002) Provide data sampling query

[ https://issues.apache.org/jira/browse/FLINK-31002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31002. Resolution: Fixed this should be implemented by flink sql > Provide data sampling query >

[jira] [Closed] (FLINK-30628) Kerberos in HiveCatalog is not work

[ https://issues.apache.org/jira/browse/FLINK-30628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30628. Resolution: Fixed > Kerberos in HiveCatalog is not work > --- > >

[jira] [Closed] (FLINK-31179) Make data structures serializable

[ https://issues.apache.org/jira/browse/FLINK-31179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31179. Resolution: Fixed > Make data structures serializable > - > >

[jira] [Closed] (FLINK-31322) Improve merge-into action

[ https://issues.apache.org/jira/browse/FLINK-31322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31322. Resolution: Fixed > Improve merge-into action > - > >

[jira] [Closed] (FLINK-31315) FlinkActionsE2eTest.testMergeInto is unstable

[ https://issues.apache.org/jira/browse/FLINK-31315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31315. Resolution: Fixed > FlinkActionsE2eTest.testMergeInto is unstable >

[jira] [Closed] (FLINK-31338) support infer parallelism for flink table store

[ https://issues.apache.org/jira/browse/FLINK-31338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31338. Resolution: Fixed Just use github pr/issues. > support infer parallelism for flink table store

[jira] [Closed] (FLINK-31417) Hadoop version unknown when TrinoPageSourceBase.getNextPage

[ https://issues.apache.org/jira/browse/FLINK-31417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31417. Resolution: Fixed > Hadoop version unknown when TrinoPageSourceBase.getNextPage >

[jira] [Closed] (FLINK-31391) Introduce lookup changelog producer

[ https://issues.apache.org/jira/browse/FLINK-31391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31391. Resolution: Fixed > Introduce lookup changelog producer > --- > >

[jira] [Commented] (FLINK-31417) Hadoop version unknown when TrinoPageSourceBase.getNextPage

[ https://issues.apache.org/jira/browse/FLINK-31417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702207#comment-17702207 ] Jingsong Lee commented on FLINK-31417: -- Thanks [~nonggia] , this has been fixed in 0.3, will cp to

[jira] [Closed] (FLINK-31461) Supports schema historical version expiring

[ https://issues.apache.org/jira/browse/FLINK-31461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31461. Resolution: Fixed Use github pr/issues. > Supports schema historical version expiring >

[jira] [Closed] (FLINK-31462) [Flink] Supports full calculation from specified snapshots in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-31462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31462. Resolution: Fixed Use github pr/issues. > [Flink] Supports full calculation from specified

[jira] [Commented] (FLINK-31429) Support CTAS(create table as) streaming job with schema changes in table store

[ https://issues.apache.org/jira/browse/FLINK-31429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702206#comment-17702206 ] Jingsong Lee commented on FLINK-31429: -- Please use github pr/issues. > Support CTAS(create table

[jira] [Closed] (FLINK-31451) Flink Table Store Ecosystem: Introduce Presto Reader for table store

[ https://issues.apache.org/jira/browse/FLINK-31451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31451. Resolution: Fixed Use github pr/issues. > Flink Table Store Ecosystem: Introduce Presto Reader

[jira] [Closed] (FLINK-31479) Close blocking iterators in tests

[ https://issues.apache.org/jira/browse/FLINK-31479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31479. Resolution: Fixed Use github issues. > Close blocking iterators in tests >

[jira] [Closed] (FLINK-31467) Support time travel for Spark 3.3

[ https://issues.apache.org/jira/browse/FLINK-31467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31467. Resolution: Fixed Use github issues. > Support time travel for Spark 3.3 >

[jira] [Commented] (FLINK-31462) [Flink] Supports full calculation from specified snapshots in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-31462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701571#comment-17701571 ] Jingsong Lee commented on FLINK-31462: -- Watermark will always move forward. What I don't understand

[jira] [Commented] (FLINK-26465) Optimize SortMergeReader: use loser tree to reduce comparisons

[ https://issues.apache.org/jira/browse/FLINK-26465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701565#comment-17701565 ] Jingsong Lee commented on FLINK-26465: -- [~Ming Li]  Yes, you can, but I think this is a very

[jira] [Closed] (FLINK-31430) Support migrating states between different instances of TableWriteImpl and AbstractFileStoreWrite

[ https://issues.apache.org/jira/browse/FLINK-31430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31430. Resolution: Fixed master: 1af16a5a1cb27b6b72bbcef9e5862fda84d8c996 > Support migrating states

[jira] [Closed] (FLINK-31459) add UPDATE COLUMN POSITION for flink table store

[ https://issues.apache.org/jira/browse/FLINK-31459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31459. Assignee: Jun Zhang Resolution: Fixed master: 14d87e4a85e716771c59a5e2fbb840fd1852a0f6 >

[jira] [Closed] (FLINK-31465) [Flink] Fix shortcode errors in docs

[ https://issues.apache.org/jira/browse/FLINK-31465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31465. Fix Version/s: table-store-0.4.0 Assignee: Ming Li Resolution: Fixed master:

[jira] [Closed] (FLINK-31253) Port itcases to Flink 1.15 and 1.14

[ https://issues.apache.org/jira/browse/FLINK-31253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31253. Resolution: Fixed master: 7663615366a16d3481c67aa093a5f95973ae552e > Port itcases to Flink 1.15

[jira] [Closed] (FLINK-31460) Fix hive catalog and connector jar name in the create release script for table store

[ https://issues.apache.org/jira/browse/FLINK-31460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31460. Fix Version/s: table-store-0.4.0 Assignee: zhuangchong Resolution: Fixed master:

[jira] [Commented] (FLINK-31462) [Flink] Supports full calculation from specified snapshots in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-31462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700620#comment-17700620 ] Jingsong Lee commented on FLINK-31462: -- Thanks [~Ming Li] for your reporting, can you explain what

[jira] [Comment Edited] (FLINK-31461) Supports schema historical version expiring

[ https://issues.apache.org/jira/browse/FLINK-31461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700494#comment-17700494 ] Jingsong Lee edited comment on FLINK-31461 at 3/15/23 3:48 AM: --- I think

  1   2   3   4   5   6   7   8   9   10   >