[jira] [Created] (FLINK-31117) Split flink connector to each module of each version

Jingsong Lee created FLINK-31117: Summary: Split flink connector to each module of each version Key: FLINK-31117 URL: https://issues.apache.org/jira/browse/FLINK-31117 Project: Flink Issue

[jira] [Closed] (FLINK-31103) Public Table Reader API for table store

[ https://issues.apache.org/jira/browse/FLINK-31103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31103. Resolution: Fixed master: 726af803d233e2752cc5532b59ed977eecc8c5aa > Public Table Reader API for

[jira] [Closed] (FLINK-31028) Provide different compression methods for per level

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

[jira] [Assigned] (FLINK-31113) Support AND filter for flink-orc

[ https://issues.apache.org/jira/browse/FLINK-31113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31113: Assignee: Shammon > Support AND filter for flink-orc >

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

Jingsong Lee created FLINK-3: Summary: Introduce CatalogTestBase Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-25537) [JUnit5 Migration] Module: flink-core

[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25537: Assignee: Aiden Gong (was: Shammon) > [JUnit5 Migration] Module: flink-core >

[jira] [Assigned] (FLINK-25537) [JUnit5 Migration] Module: flink-core

[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25537: Assignee: Shammon (was: Aiden Gong) > [JUnit5 Migration] Module: flink-core >

[jira] [Updated] (FLINK-31103) Public Table Reader API for table store

[ https://issues.apache.org/jira/browse/FLINK-31103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31103: - Summary: Public Table Reader API for table store (was: Public Table API for table store) >

[jira] [Created] (FLINK-31103) Public Table API for table store

Jingsong Lee created FLINK-31103: Summary: Public Table API for table store Key: FLINK-31103 URL: https://issues.apache.org/jira/browse/FLINK-31103 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-31009) Add recordCount to snapshot meta

[ https://issues.apache.org/jira/browse/FLINK-31009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31009: Assignee: Nicholas Jiang > Add recordCount to snapshot meta >

[jira] [Closed] (FLINK-31096) Unify versions in pom of table store

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

[jira] [Updated] (FLINK-31094) Add table name to Writer

[ https://issues.apache.org/jira/browse/FLINK-31094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31094: - Fix Version/s: table-store-0.3.1 > Add table name to Writer > - > >

[jira] [Closed] (FLINK-31094) Add table name to Writer

[ https://issues.apache.org/jira/browse/FLINK-31094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31094. Resolution: Fixed master: 9edee3afec998c186726bb7d30d486f34d47c461 release-0.3:

[jira] [Assigned] (FLINK-31094) Add table name to Writer

[ https://issues.apache.org/jira/browse/FLINK-31094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31094: Assignee: DaiXinyu > Add table name to Writer > - > >

[jira] [Closed] (FLINK-31072) Introduce streaming-read-atomic to ensure UB and UA cannot be split

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

[jira] [Closed] (FLINK-31088) Flink free for flink-table-store-docs

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

[jira] [Closed] (FLINK-31078) Flink-table-planner free for flink-table-store-core

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

[jira] [Closed] (FLINK-31050) Add cases for IN and NOT IN predicate in ORC format

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

[jira] [Updated] (FLINK-31050) Add cases for IN and NOT IN predicate in ORC format

[ https://issues.apache.org/jira/browse/FLINK-31050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31050: - Description: (was: Supports IN and NOT IN predicate push down in ORC format of table store.

[jira] [Updated] (FLINK-31050) Add cases for IN and NOT IN predicate in ORC format

[ https://issues.apache.org/jira/browse/FLINK-31050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31050: - Summary: Add cases for IN and NOT IN predicate in ORC format (was: Supports IN and NOT IN

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

[ https://issues.apache.org/jira/browse/FLINK-31074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17688844#comment-17688844 ] Jingsong Lee commented on FLINK-31074: -- Currently we can only perform filter push down on keys

[jira] [Assigned] (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 reassigned FLINK-31076: Assignee: Nicholas Jiang > Supports filter predicate in Parquet format of table store >

[jira] [Closed] (FLINK-30985) [Flink][Table Store] Change the Splits allocation algorithm of ContinuousFileSplitEnumerator in TableStore to a fair algorithm.

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

[jira] [Updated] (FLINK-31072) Introduce streaming-read-atomic to ensure UB and UA cannot be split

[ https://issues.apache.org/jira/browse/FLINK-31072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31072: - Component/s: Table Store > Introduce streaming-read-atomic to ensure UB and UA cannot be split

[jira] [Assigned] (FLINK-31072) Introduce streaming-read-atomic to ensure UB and UA cannot be split

[ https://issues.apache.org/jira/browse/FLINK-31072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31072: Assignee: Jingsong Lee > Introduce streaming-read-atomic to ensure UB and UA cannot be

[jira] [Updated] (FLINK-31072) Introduce streaming-read-atomic to ensure UB and UA cannot be split

[ https://issues.apache.org/jira/browse/FLINK-31072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31072: - Fix Version/s: table-store-0.4.0 > Introduce streaming-read-atomic to ensure UB and UA cannot

[jira] [Created] (FLINK-31072) Introduce streaming-read-atomic to ensure UB and UA cannot be split

Jingsong Lee created FLINK-31072: Summary: Introduce streaming-read-atomic to ensure UB and UA cannot be split Key: FLINK-31072 URL: https://issues.apache.org/jira/browse/FLINK-31072 Project: Flink

[jira] [Closed] (FLINK-31051) Introduce `delete` action to support deleting from table

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

[jira] [Closed] (FLINK-31054) Flink free to common codegen core shade

[ https://issues.apache.org/jira/browse/FLINK-31054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31054. Resolution: Fixed master: 6a5e4084d95563f7094deec62c36aa1e921f9ec6 > Flink free to common

[jira] [Closed] (FLINK-31023) Introduce ConfigOption for table store

[ https://issues.apache.org/jira/browse/FLINK-31023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31023. Resolution: Fixed master: 1796d3fa960169649299bb4bdaffac6d3848718e > Introduce ConfigOption for

[jira] [Created] (FLINK-31054) Flink free to common codegen core shade

Jingsong Lee created FLINK-31054: Summary: Flink free to common codegen core shade Key: FLINK-31054 URL: https://issues.apache.org/jira/browse/FLINK-31054 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-31032) Supports AND predicate in orc format for table store

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

[jira] [Closed] (FLINK-31027) Introduce annotation for table store

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

[jira] [Closed] (FLINK-30997) Refactor tests in connector to extends AbstractTestBase

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

[jira] [Closed] (FLINK-30979) The buckets of the secondary partition should fall on different tasks

[ https://issues.apache.org/jira/browse/FLINK-30979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30979. Resolution: Fixed master: 219c4de518c419eade41e99fc419d7f2ccfed213 > The buckets of the

[jira] [Closed] (FLINK-31038) Avoid accessing non-TableStore tables in HiveCatalog.listTables

[ https://issues.apache.org/jira/browse/FLINK-31038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31038. Resolution: Fixed master: bd6036cc1f9cc853e04f45dac7b65b66ffdb669f > Avoid accessing

[jira] [Closed] (FLINK-31024) Copy code splitter to table store from flink table

[ https://issues.apache.org/jira/browse/FLINK-31024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31024. Resolution: Fixed master: a9b33ad59f08ae8b3ba19291dc166371f529719f > Copy code splitter to table

[jira] [Closed] (FLINK-31008) [Flink][Table Store] The Split allocation of the same bucket in ContinuousFileSplitEnumerator may be out of order

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

[jira] [Created] (FLINK-31038) Avoid accessing non-TableStore tables in HiveCatalog.listTables

Jingsong Lee created FLINK-31038: Summary: Avoid accessing non-TableStore tables in HiveCatalog.listTables Key: FLINK-31038 URL: https://issues.apache.org/jira/browse/FLINK-31038 Project: Flink

[jira] [Created] (FLINK-31037) Table Store supports streaming reading a whole snapshot in one checkpoint

Jingsong Lee created FLINK-31037: Summary: Table Store supports streaming reading a whole snapshot in one checkpoint Key: FLINK-31037 URL: https://issues.apache.org/jira/browse/FLINK-31037 Project:

[jira] [Closed] (FLINK-31022) Using new Serializer for table store

[ https://issues.apache.org/jira/browse/FLINK-31022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31022. Resolution: Fixed master: 5b6ff938922aa067b59a0132c62e6cd675680b63 > Using new Serializer for

[jira] [Updated] (FLINK-31023) Introduce ConfigOption for table store

[ https://issues.apache.org/jira/browse/FLINK-31023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31023: - Parent: FLINK-30276 Issue Type: Sub-task (was: Improvement) > Introduce ConfigOption

[jira] [Updated] (FLINK-31022) Using new Serializer for table store

[ https://issues.apache.org/jira/browse/FLINK-31022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31022: - Parent: FLINK-30276 Issue Type: Sub-task (was: Improvement) > Using new Serializer for

[jira] [Closed] (FLINK-30874) Introduce configuration for table store

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

[jira] [Commented] (FLINK-30874) Introduce configuration for table store

[ https://issues.apache.org/jira/browse/FLINK-30874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687540#comment-17687540 ] Jingsong Lee commented on FLINK-30874: -- Thanks [~zhoupeijie] and [~zjureel], this is duplicated to

[jira] [Updated] (FLINK-30874) Introduce configuration for table store

[ https://issues.apache.org/jira/browse/FLINK-30874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30874: - Parent: (was: FLINK-30276) Issue Type: New Feature (was: Sub-task) > Introduce

[jira] [Closed] (FLINK-30900) Introduce utils for table store

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

[jira] [Created] (FLINK-31024) Copy code splitter to table store from flink table

Jingsong Lee created FLINK-31024: Summary: Copy code splitter to table store from flink table Key: FLINK-31024 URL: https://issues.apache.org/jira/browse/FLINK-31024 Project: Flink Issue

[jira] [Created] (FLINK-31023) Introduce ConfigOption for table store

Jingsong Lee created FLINK-31023: Summary: Introduce ConfigOption for table store Key: FLINK-31023 URL: https://issues.apache.org/jira/browse/FLINK-31023 Project: Flink Issue Type:

[jira] [Created] (FLINK-31022) Using new Serializer for table store

Jingsong Lee created FLINK-31022: Summary: Using new Serializer for table store Key: FLINK-31022 URL: https://issues.apache.org/jira/browse/FLINK-31022 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-31004) Introduce data input and output stream for table store

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

[jira] [Closed] (FLINK-30994) Introduce DoubleSerializer for Table Store

[ https://issues.apache.org/jira/browse/FLINK-30994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30994. Assignee: Feng Wang Resolution: Fixed master: 8363dc6f57ae053f9b34cf7403c734b9e6c66a3b >

[jira] [Closed] (FLINK-30995) Introduce ByteSerializer for Table Store

[ https://issues.apache.org/jira/browse/FLINK-30995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30995. Assignee: Feng Wang Resolution: Fixed master: 677313714323a2f745cfe15497e7de7c8f866069 >

[jira] [Closed] (FLINK-30993) Introduce FloatSerializer for Table Store

[ https://issues.apache.org/jira/browse/FLINK-30993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30993. Assignee: Feng Wang Resolution: Fixed master: c62992cef568274ec777c2d6e264a12f077b0925 >

[jira] [Closed] (FLINK-30992) Introduce ShortSerializer for Table Store

[ https://issues.apache.org/jira/browse/FLINK-30992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30992. Assignee: Feng Wang Resolution: Fixed master: f285db56b8a440ef4ef08d15b5a48d58b7c10e01 >

[jira] [Closed] (FLINK-30991) Introduce LongSerializer for Table Store

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

[jira] [Assigned] (FLINK-30985) [Flink][Table Store] Change the Splits allocation algorithm of ContinuousFileSplitEnumerator in TableStore to a fair algorithm.

[ https://issues.apache.org/jira/browse/FLINK-30985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-30985: Assignee: ming li > [Flink][Table Store] Change the Splits allocation algorithm of >

[jira] [Commented] (FLINK-30985) [Flink][Table Store] Change the Splits allocation algorithm of ContinuousFileSplitEnumerator in TableStore to a fair algorithm.

[ https://issues.apache.org/jira/browse/FLINK-30985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687047#comment-17687047 ] Jingsong Lee commented on FLINK-30985: -- [~Ming Li] Thanks for the explaination. I see, this is a

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

[ https://issues.apache.org/jira/browse/FLINK-31002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687026#comment-17687026 ] Jingsong Lee commented on FLINK-31002: -- [~zhangjun] I think we can implement this by table option.

[jira] [Closed] (FLINK-30999) Introduce flink-table-store-test-utils for table store

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

[jira] [Closed] (FLINK-30608) support rename table

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

[jira] [Closed] (FLINK-31012) Update docs for files table in table store

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

[jira] [Commented] (FLINK-30985) [Flink][Table Store] Change the Splits allocation algorithm of ContinuousFileSplitEnumerator in TableStore to a fair algorithm.

[ https://issues.apache.org/jira/browse/FLINK-30985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687001#comment-17687001 ] Jingsong Lee commented on FLINK-30985: -- [~Ming Li] I can not get it. Can you provide some example?

[jira] [Commented] (FLINK-30985) [Flink][Table Store] Change the Splits allocation algorithm of ContinuousFileSplitEnumerator in TableStore to a fair algorithm.

[ https://issues.apache.org/jira/browse/FLINK-30985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686974#comment-17686974 ] Jingsong Lee commented on FLINK-30985: -- [~Ming Li] Thanks for reporting. This ticket may be related

[jira] [Commented] (FLINK-31008) [Flink][Table Store] The Split allocation of the same bucket in ContinuousFileSplitEnumerator may be out of order

[ https://issues.apache.org/jira/browse/FLINK-31008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686963#comment-17686963 ] Jingsong Lee commented on FLINK-31008: -- [~Ming Li] Assigned to u~ > [Flink][Table Store] The Split

[jira] [Assigned] (FLINK-31008) [Flink][Table Store] The Split allocation of the same bucket in ContinuousFileSplitEnumerator may be out of order

[ https://issues.apache.org/jira/browse/FLINK-31008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31008: Assignee: ming li > [Flink][Table Store] The Split allocation of the same bucket in >

[jira] [Created] (FLINK-31009) Add recordCount to snapshot meta

Jingsong Lee created FLINK-31009: Summary: Add recordCount to snapshot meta Key: FLINK-31009 URL: https://issues.apache.org/jira/browse/FLINK-31009 Project: Flink Issue Type: New Feature

[jira] [Commented] (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:comment-tabpanel=17686919#comment-17686919 ] Jingsong Lee commented on FLINK-30945: -- [~vicky_papavas] Thanks for reporting! I think this needs

[jira] [Commented] (FLINK-31008) [Flink][Table Store] The Split allocation of the same bucket in ContinuousFileSplitEnumerator may be out of order

[ https://issues.apache.org/jira/browse/FLINK-31008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686917#comment-17686917 ] Jingsong Lee commented on FLINK-31008: -- [~Ming Li] Thanks for reporting! Wow, you're right. This

[jira] [Closed] (FLINK-30871) add bloom filter for orc

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

[jira] [Closed] (FLINK-30988) Deprecate TableStoreManagedFactory

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

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

Jingsong Lee created FLINK-31002: Summary: Provide data sampling query Key: FLINK-31002 URL: https://issues.apache.org/jira/browse/FLINK-31002 Project: Flink Issue Type: New Feature

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

Jingsong Lee created FLINK-31001: Summary: Introduce Hive writer Key: FLINK-31001 URL: https://issues.apache.org/jira/browse/FLINK-31001 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-30986) Refactor CreateTableITCase and DropTableITCase to get rid of managed table

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

[jira] [Closed] (FLINK-30980) Support s3.signer-type for S3

[ https://issues.apache.org/jira/browse/FLINK-30980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30980. Resolution: Fixed master: 6202410e995cb0ab8176a544eaa9f6d2db1357be > Support s3.signer-type for

[jira] [Assigned] (FLINK-30979) The buckets of the secondary partition should fall on different tasks

[ https://issues.apache.org/jira/browse/FLINK-30979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-30979: Assignee: Shammon > The buckets of the secondary partition should fall on different

[jira] [Closed] (FLINK-30934) Refactor ComputedColumnAndWatermarkTableITCase and StreamingWarehouseITCase to get rid of managed table

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

[jira] [Updated] (FLINK-30980) Support s3.signer-type for S3

[ https://issues.apache.org/jira/browse/FLINK-30980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30980: - Description: Currently, s3.signer-type should be s3a.signing-algorithm, we can also support

[jira] [Created] (FLINK-30980) Support s3.signer-type for S3

Jingsong Lee created FLINK-30980: Summary: Support s3.signer-type for S3 Key: FLINK-30980 URL: https://issues.apache.org/jira/browse/FLINK-30980 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30979) The buckets of the secondary partition should fall on different tasks

Jingsong Lee created FLINK-30979: Summary: The buckets of the secondary partition should fall on different tasks Key: FLINK-30979 URL: https://issues.apache.org/jira/browse/FLINK-30979 Project: Flink

[jira] [Closed] (FLINK-30918) Refactor CompositePkAndMultiPartitionedTableITCase to get rid of managed table

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

[jira] [Closed] (FLINK-30894) Introduce Serializer to serialize internal data structure

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

[jira] [Closed] (FLINK-30882) Introduce partition.expiration-time to automatically delete expired partitions

[ https://issues.apache.org/jira/browse/FLINK-30882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30882. Resolution: Fixed master: 42bb9a49d48e35a15d07f75c48aac80c4ef5b8fa release-0.3:

[jira] [Closed] (FLINK-30867) Support streaming read changes from overwrite

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

[jira] [Closed] (FLINK-30892) Clean codes for memory and tests

[ https://issues.apache.org/jira/browse/FLINK-30892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30892. Resolution: Fixed master: fa4a69913987416d7fd6b3ebe21d0eb39945fff2 > Clean codes for memory and

[jira] [Closed] (FLINK-27365) [umbrella] Schema evolution on table store

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

[jira] [Closed] (FLINK-27845) Introduce Column Type Schema evolution

[ https://issues.apache.org/jira/browse/FLINK-27845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27845. Assignee: Shammon Resolution: Fixed master: 277b544478c7b922bb9b466a385d86f8eb07c8a0 >

[jira] [Closed] (FLINK-30891) Introduce Preconditions for table store

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

[jira] [Updated] (FLINK-30882) Introduce partition.expiration-time to automatically delete expired partitions

[ https://issues.apache.org/jira/browse/FLINK-30882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30882: - Fix Version/s: table-store-0.3.1 > Introduce partition.expiration-time to automatically delete

[jira] [Closed] (FLINK-29735) Introduce Metadata tables for table store

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

[jira] [Closed] (FLINK-30516) Support files table in table store

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

[jira] [Closed] (FLINK-30866) Introduce FileIO for table store

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

[jira] [Created] (FLINK-30882) Introduce partition.expiration-time to automatically delete expired partitions

Jingsong Lee created FLINK-30882: Summary: Introduce partition.expiration-time to automatically delete expired partitions Key: FLINK-30882 URL: https://issues.apache.org/jira/browse/FLINK-30882

[jira] [Closed] (FLINK-30750) CompactActionITCase.testBatchCompact in table store is unstable

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

[jira] [Created] (FLINK-30866) Introduce FileIO for table store

Jingsong Lee created FLINK-30866: Summary: Introduce FileIO for table store Key: FLINK-30866 URL: https://issues.apache.org/jira/browse/FLINK-30866 Project: Flink Issue Type: Sub-task

[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=17682804#comment-17682804 ] Jingsong Lee commented on FLINK-30419: -- Sorry for late reply. I was on vacation before. [~Ge]

[jira] [Assigned] (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 reassigned FLINK-30419: Assignee: Alex Sorokoumov > Allow tuning of transaction timeout >

[jira] [Closed] (FLINK-30038) HiveE2E test is not stable

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

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

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

[jira] [Closed] (FLINK-30711) Support dropping partition via Flink action

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

<    1   2   3   4   5   6   7   8   9   10   >