[jira] [Commented] (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 commented on FLINK-31461: -- I think this is good > Supports schema historical version

[jira] [Closed] (FLINK-31438) Improved exception assertion for ContinuousFileStoreITCase

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

[jira] [Closed] (FLINK-31353) Merge SnapshotEnumerator into TableScan

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

[jira] [Assigned] (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 reassigned FLINK-31451: Assignee: Zaihu Shi > Flink Table Store Ecosystem: Introduce Presto Reader for table

[jira] [Closed] (FLINK-31397) Introduce write-once hash lookup store

[ https://issues.apache.org/jira/browse/FLINK-31397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31397. Resolution: Fixed master: 0f5744a92bc52f52bc0f6644dc063dcb60fe326c > Introduce write-once hash

[jira] [Closed] (FLINK-31415) Support target alias and using ddls to create source

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

[jira] [Closed] (FLINK-31412) HiveCatalog rollback schema if alter table failed in table store

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

[jira] [Closed] (FLINK-31392) Refactor classes code of full-compaction

[ https://issues.apache.org/jira/browse/FLINK-31392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31392. Resolution: Fixed master: c3e24fa4b0fd052a227296b03f9dfb0521ad833e > Refactor classes code of

[jira] [Closed] (FLINK-31292) User HadoopUtils to get Configuration in CatalogContext

[ https://issues.apache.org/jira/browse/FLINK-31292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31292. Resolution: Fixed master: d2d4dd0bf8d206307eb2c93aa97e7c1cb750f187 > User HadoopUtils to get

[jira] [Created] (FLINK-31397) Introduce write-once hash lookup store

Jingsong Lee created FLINK-31397: Summary: Introduce write-once hash lookup store Key: FLINK-31397 URL: https://issues.apache.org/jira/browse/FLINK-31397 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-31394) Fix spark jar name in the create release script for table store

[ https://issues.apache.org/jira/browse/FLINK-31394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31394: - Fix Version/s: table-store-0.4.0 > Fix spark jar name in the create release script for table

[jira] [Closed] (FLINK-31394) Fix spark jar name in the create release script for table store

[ https://issues.apache.org/jira/browse/FLINK-31394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31394. Assignee: zhuangchong Resolution: Fixed master: 54bfd291563e907e26ab8aa2c1584b88688703ed >

[jira] [Closed] (FLINK-31389) Fix spark jar name in docs for table store

[ https://issues.apache.org/jira/browse/FLINK-31389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31389. Assignee: zhuangchong Resolution: Fixed master: 0ffa6654b2d64fc65c430e453e656fa68ce74632 >

[jira] [Updated] (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 updated FLINK-31391: - Description: Currently, only full-compaction can produce changelog, some merge-engine must

[jira] [Created] (FLINK-31392) Refactor classes code of full-compaction

Jingsong Lee created FLINK-31392: Summary: Refactor classes code of full-compaction Key: FLINK-31392 URL: https://issues.apache.org/jira/browse/FLINK-31392 Project: Flink Issue Type:

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

Jingsong Lee created FLINK-31391: Summary: Introduce lookup changelog producer Key: FLINK-31391 URL: https://issues.apache.org/jira/browse/FLINK-31391 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-31292) User HadoopUtils to get Configuration in CatalogContext

[ https://issues.apache.org/jira/browse/FLINK-31292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31292: - Priority: Blocker (was: Major) > User HadoopUtils to get Configuration in CatalogContext >

[jira] [Closed] (FLINK-31365) Simplify FlinkActionsE2ETest#testMergeInto

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

[jira] [Closed] (FLINK-31311) Supports Bounded Watermark streaming read

[ https://issues.apache.org/jira/browse/FLINK-31311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31311. Resolution: Fixed master: e715ac81a906e8f1b285d3847cc75879bb54d062 > Supports Bounded Watermark

[jira] [Closed] (FLINK-31343) Remove JMH dependency in flink-table-store-micro-benchmark

[ https://issues.apache.org/jira/browse/FLINK-31343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31343. Resolution: Fixed master: d1c224890dad80c1d7664dc3011534b3ae1679f9 > Remove JMH dependency in

[jira] [Closed] (FLINK-31287) Default value of 'changelog-producer.compaction-interval' can be zero

[ https://issues.apache.org/jira/browse/FLINK-31287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31287. Resolution: Fixed master: 77b4a085424e446863b6d2e4464b4689898d51d5 > Default value of

[jira] [Closed] (FLINK-31323) Fix unstable E2E test for flink actions

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

[jira] [Created] (FLINK-31343) Remove JMH dependency in flink-table-store-micro-benchmark

Jingsong Lee created FLINK-31343: Summary: Remove JMH dependency in flink-table-store-micro-benchmark Key: FLINK-31343 URL: https://issues.apache.org/jira/browse/FLINK-31343 Project: Flink

[jira] [Closed] (FLINK-31331) Flink 1.16 should implement new LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-31331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31331. Resolution: Fixed master: dfc0d558d2c0d5d299e2da2ffa0819d0c4720919 > Flink 1.16 should implement

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

[ https://issues.apache.org/jira/browse/FLINK-31224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696818#comment-17696818 ] Jingsong Lee commented on FLINK-31224: -- Hi [~zhangjun] , thanks for your contribution. My main

[jira] [Commented] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696809#comment-17696809 ] Jingsong Lee commented on FLINK-31310: -- [~nicholasjiang] You are right, it is good to keep the

[jira] [Closed] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31310. Resolution: Invalid > Force clear directory no matter what situation in HiveCatalog.dropTable >

[jira] [Closed] (FLINK-31309) Rollback DFS schema if hive sync fail in HiveCatalog.createTable

[ https://issues.apache.org/jira/browse/FLINK-31309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31309. Resolution: Fixed master: fa51956e4fd1df18c7cfa87ae0f0042bab2a209b > Rollback DFS schema if hive

[jira] [Closed] (FLINK-31329) Fix Parquet stats extractor

[ https://issues.apache.org/jira/browse/FLINK-31329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31329. Resolution: Fixed master: 97ca28c4f97ed705b0ae27cd0b30954db1dd6a18 > Fix Parquet stats extractor

[jira] [Closed] (FLINK-31290) Remove features in documentation

[ https://issues.apache.org/jira/browse/FLINK-31290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31290. Resolution: Fixed master: c139b4baa508d8a8ef35d2013b684e206cffb1b4 > Remove features in

[jira] [Created] (FLINK-31331) Flink 1.16 should implement new LookupFunction

Jingsong Lee created FLINK-31331: Summary: Flink 1.16 should implement new LookupFunction Key: FLINK-31331 URL: https://issues.apache.org/jira/browse/FLINK-31331 Project: Flink Issue Type:

[jira] [Created] (FLINK-31329) Fix Parquet stats extractor

Jingsong Lee created FLINK-31329: Summary: Fix Parquet stats extractor Key: FLINK-31329 URL: https://issues.apache.org/jira/browse/FLINK-31329 Project: Flink Issue Type: Bug

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

Jingsong Lee created FLINK-31315: Summary: FlinkActionsE2eTest.testMergeInto is unstable Key: FLINK-31315 URL: https://issues.apache.org/jira/browse/FLINK-31315 Project: Flink Issue Type:

[jira] [Updated] (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 updated FLINK-31315: - Issue Type: Bug (was: Improvement) > FlinkActionsE2eTest.testMergeInto is unstable >

[jira] [Closed] (FLINK-31294) CommitterOperator forgot to close Committer when closing.

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

[jira] [Commented] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696077#comment-17696077 ] Jingsong Lee commented on FLINK-31310: -- [~nicholasjiang] Thanks! > Force clear directory no matter

[jira] [Assigned] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31310: Assignee: Nicholas Jiang (was: Jingsong Lee) > Force clear directory no matter what

[jira] [Assigned] (FLINK-31309) Rollback DFS schema if hive sync fail in HiveCatalog.createTable

[ https://issues.apache.org/jira/browse/FLINK-31309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31309: Assignee: Shammon > Rollback DFS schema if hive sync fail in HiveCatalog.createTable >

[jira] [Assigned] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31310: Assignee: Jingsong Lee > Force clear directory no matter what situation in

[jira] [Closed] (FLINK-31302) Split spark modules according to version

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

[jira] [Closed] (FLINK-31252) Improve StaticFileStoreSplitEnumerator to assign batch splits

[ https://issues.apache.org/jira/browse/FLINK-31252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31252. Resolution: Fixed master: 4296d7c1cca7ff8fb5525401b1ef1659aae5879a > Improve

[jira] [Closed] (FLINK-31087) Introduce MergeIntoAction.

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

[jira] [Closed] (FLINK-31291) Document table.exec.sink.upsert-materialize to none

[ https://issues.apache.org/jira/browse/FLINK-31291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31291. Resolution: Fixed master: 2d1da3d8780b46740a1962e118a2dbd780791480 > Document

[jira] [Created] (FLINK-31311) Supports Bounded Watermark streaming read

Jingsong Lee created FLINK-31311: Summary: Supports Bounded Watermark streaming read Key: FLINK-31311 URL: https://issues.apache.org/jira/browse/FLINK-31311 Project: Flink Issue Type:

[jira] [Created] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

Jingsong Lee created FLINK-31310: Summary: Force clear directory no matter what situation in HiveCatalog.dropTable Key: FLINK-31310 URL: https://issues.apache.org/jira/browse/FLINK-31310 Project:

[jira] [Created] (FLINK-31309) Rollback DFS schema if hive sync fail in HiveCatalog.createTable

Jingsong Lee created FLINK-31309: Summary: Rollback DFS schema if hive sync fail in HiveCatalog.createTable Key: FLINK-31309 URL: https://issues.apache.org/jira/browse/FLINK-31309 Project: Flink

[jira] [Assigned] (FLINK-31294) CommitterOperator forgot to close Committer when closing.

[ https://issues.apache.org/jira/browse/FLINK-31294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31294: Assignee: Ming Li > CommitterOperator forgot to close Committer when closing. >

[jira] [Assigned] (FLINK-31287) Default value of 'changelog-producer.compaction-interval' can be zero

[ https://issues.apache.org/jira/browse/FLINK-31287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31287: Assignee: xzw0223 > Default value of 'changelog-producer.compaction-interval' can be

[jira] [Commented] (FLINK-31287) Default value of 'changelog-producer.compaction-interval' can be zero

[ https://issues.apache.org/jira/browse/FLINK-31287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695980#comment-17695980 ] Jingsong Lee commented on FLINK-31287: -- [~xzw0223] Thanks! > Default value of

[jira] [Commented] (FLINK-31292) User HadoopUtils to get Configuration in CatalogContext

[ https://issues.apache.org/jira/browse/FLINK-31292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695979#comment-17695979 ] Jingsong Lee commented on FLINK-31292: -- [~liyubin117]  Thanks! > User HadoopUtils to get

[jira] [Assigned] (FLINK-31292) User HadoopUtils to get Configuration in CatalogContext

[ https://issues.apache.org/jira/browse/FLINK-31292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31292: Assignee: Yubin Li > User HadoopUtils to get Configuration in CatalogContext >

[jira] [Commented] (FLINK-31294) CommitterOperator forgot to close Committer when closing.

[ https://issues.apache.org/jira/browse/FLINK-31294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695978#comment-17695978 ] Jingsong Lee commented on FLINK-31294: -- [~Ming Li] Thanks! > CommitterOperator forgot to close

[jira] [Assigned] (FLINK-31290) Remove features in documentation

[ https://issues.apache.org/jira/browse/FLINK-31290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31290: Assignee: Guojun Li > Remove features in documentation >

[jira] [Assigned] (FLINK-31291) Document table.exec.sink.upsert-materialize to none

[ https://issues.apache.org/jira/browse/FLINK-31291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31291: Assignee: Guojun Li > Document table.exec.sink.upsert-materialize to none >

[jira] [Closed] (FLINK-31289) Default aggregate-function for field can be last_non_null_value

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

[jira] [Created] (FLINK-31292) User HadoopUtils to get Configuration in CatalogContext

Jingsong Lee created FLINK-31292: Summary: User HadoopUtils to get Configuration in CatalogContext Key: FLINK-31292 URL: https://issues.apache.org/jira/browse/FLINK-31292 Project: Flink

[jira] [Created] (FLINK-31291) Document table.exec.sink.upsert-materialize to none

Jingsong Lee created FLINK-31291: Summary: Document table.exec.sink.upsert-materialize to none Key: FLINK-31291 URL: https://issues.apache.org/jira/browse/FLINK-31291 Project: Flink Issue

[jira] [Created] (FLINK-31290) Remove features in documentation

Jingsong Lee created FLINK-31290: Summary: Remove features in documentation Key: FLINK-31290 URL: https://issues.apache.org/jira/browse/FLINK-31290 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31289) Default aggregate-function for field can be last_non_null_value

Jingsong Lee created FLINK-31289: Summary: Default aggregate-function for field can be last_non_null_value Key: FLINK-31289 URL: https://issues.apache.org/jira/browse/FLINK-31289 Project: Flink

[jira] [Created] (FLINK-31287) Default value of 'changelog-producer.compaction-interval' can be zero

Jingsong Lee created FLINK-31287: Summary: Default value of 'changelog-producer.compaction-interval' can be zero Key: FLINK-31287 URL: https://issues.apache.org/jira/browse/FLINK-31287 Project: Flink

[jira] [Closed] (FLINK-31128) Add Create Table As for flink table store

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

[jira] [Closed] (FLINK-31270) Fix flink jar name in docs for table store

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

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

[ https://issues.apache.org/jira/browse/FLINK-27548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694826#comment-17694826 ] Jingsong Lee commented on FLINK-27548: -- [~monster#12] Thanks assgined > Improve quick-start of

[jira] [Assigned] (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 reassigned FLINK-27548: Assignee: ZhuoYu Chen > Improve quick-start of table store >

[jira] [Assigned] (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 reassigned FLINK-31253: Assignee: Chao Tian (was: Chao Tian) > Port itcases to Flink 1.15 and 1.14 >

[jira] [Commented] (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:comment-tabpanel=17694827#comment-17694827 ] Jingsong Lee commented on FLINK-31253: -- [~tyrantlucifer] Assigned thanks! > Port itcases to Flink

[jira] [Assigned] (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 reassigned FLINK-31253: Assignee: Chao Tian > Port itcases to Flink 1.15 and 1.14 >

[jira] [Comment Edited] (FLINK-31213) Aggregation merge engine supports retract inputs

[ https://issues.apache.org/jira/browse/FLINK-31213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693969#comment-17693969 ] Jingsong Lee edited comment on FLINK-31213 at 3/1/23 2:39 AM: -- master:

[jira] [Updated] (FLINK-31213) Aggregation merge engine supports retract inputs

[ https://issues.apache.org/jira/browse/FLINK-31213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31213: - Fix Version/s: table-store-0.3.1 > Aggregation merge engine supports retract inputs >

[jira] [Closed] (FLINK-31254) Improve the read performance for files table

[ https://issues.apache.org/jira/browse/FLINK-31254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31254. Resolution: Fixed master: 0a8c3a1c426454258b663ffd52de5bcdc1e8ed20 > Improve the read

[jira] [Closed] (FLINK-31226) Bump the FRocksDB version in table-store's lookup module

[ https://issues.apache.org/jira/browse/FLINK-31226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31226. Resolution: Fixed master: 3f56f3b8cf5bd4075be84690bb8e8c677506e8ef > Bump the FRocksDB version

[jira] [Closed] (FLINK-31250) Parquet format supports MULTISET type

[ https://issues.apache.org/jira/browse/FLINK-31250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31250. Assignee: Nicholas Jiang Resolution: Fixed master: 161014149e803bfd1d3653badb230b2ed36ce3cb

[jira] [Created] (FLINK-31254) Improve the read performance for files table

Jingsong Lee created FLINK-31254: Summary: Improve the read performance for files table Key: FLINK-31254 URL: https://issues.apache.org/jira/browse/FLINK-31254 Project: Flink Issue Type:

[jira] [Updated] (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 updated FLINK-31253: - Labels: starter (was: ) > Port itcases to Flink 1.15 and 1.14 >

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

Jingsong Lee created FLINK-31253: Summary: Port itcases to Flink 1.15 and 1.14 Key: FLINK-31253 URL: https://issues.apache.org/jira/browse/FLINK-31253 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-31252) Improve StaticFileStoreSplitEnumerator to assign batch splits

[ https://issues.apache.org/jira/browse/FLINK-31252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31252: - Description: The following batch assignment operation is for two things: 1. It can be evenly

[jira] [Created] (FLINK-31252) Improve StaticFileStoreSplitEnumerator to assign batch splits

Jingsong Lee created FLINK-31252: Summary: Improve StaticFileStoreSplitEnumerator to assign batch splits Key: FLINK-31252 URL: https://issues.apache.org/jira/browse/FLINK-31252 Project: Flink

[jira] [Created] (FLINK-31248) Improve documentation for append-only table

Jingsong Lee created FLINK-31248: Summary: Improve documentation for append-only table Key: FLINK-31248 URL: https://issues.apache.org/jira/browse/FLINK-31248 Project: Flink Issue Type:

[jira] [Closed] (FLINK-31213) Aggregation merge engine supports retract inputs

[ https://issues.apache.org/jira/browse/FLINK-31213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31213. Resolution: Fixed master: a441f56e49ffb2fc70cef60f43bbf2c45ad83e60 > Aggregation merge engine

[jira] [Closed] (FLINK-31236) Limit pushdown should not open useless RecordReader

[ https://issues.apache.org/jira/browse/FLINK-31236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31236. Resolution: Fixed master: ed454b8f909a85cdd43fac70c4280b24d0c0e34f > Limit pushdown should not

[jira] [Closed] (FLINK-31209) Introduce creation time to files table

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

[jira] [Closed] (FLINK-31201) Provides option to sort partition for full stage in streaming read

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

[jira] [Closed] (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 closed FLINK-31009. Fix Version/s: table-store-0.4.0 Resolution: Fixed master:

[jira] [Updated] (FLINK-31236) Limit pushdown should not open useless RecordReader

[ https://issues.apache.org/jira/browse/FLINK-31236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31236: - Summary: Limit pushdown should not open useless RecordReader (was: Limit pushdown will open

[jira] [Created] (FLINK-31236) Limit pushdown will open useless RecordReader

Jingsong Lee created FLINK-31236: Summary: Limit pushdown will open useless RecordReader Key: FLINK-31236 URL: https://issues.apache.org/jira/browse/FLINK-31236 Project: Flink Issue Type:

[jira] [Closed] (FLINK-31232) Parquet format supports MULTISET type for Table Store

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

[jira] [Created] (FLINK-31213) Aggregation merge engine supports retract inputs

Jingsong Lee created FLINK-31213: Summary: Aggregation merge engine supports retract inputs Key: FLINK-31213 URL: https://issues.apache.org/jira/browse/FLINK-31213 Project: Flink Issue Type:

[jira] [Created] (FLINK-31209) Introduce creation time to files table

Jingsong Lee created FLINK-31209: Summary: Introduce creation time to files table Key: FLINK-31209 URL: https://issues.apache.org/jira/browse/FLINK-31209 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-31204) HiveCatalogITCase fails due to avro conflict in table store

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

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

[ https://issues.apache.org/jira/browse/FLINK-31117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31117. Resolution: Fixed master: 37f75a85091697b75c6968293edfb060595adae3 > Split flink connector to

[jira] [Assigned] (FLINK-31201) Provides option to sort partition for full stage in streaming read

[ https://issues.apache.org/jira/browse/FLINK-31201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31201: Assignee: Jingsong Lee > Provides option to sort partition for full stage in streaming

[jira] [Updated] (FLINK-31201) Provides option to sort partition for full stage in streaming read

[ https://issues.apache.org/jira/browse/FLINK-31201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31201: - Priority: Blocker (was: Major) > Provides option to sort partition for full stage in streaming

[jira] [Updated] (FLINK-31201) Provides option to sort partition for full stage in streaming read

[ https://issues.apache.org/jira/browse/FLINK-31201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31201: - Description: The overall order may be out of order due to the writing of the old partition. We

[jira] [Created] (FLINK-31201) Provides option to sort partition for full stage in streaming read

Jingsong Lee created FLINK-31201: Summary: Provides option to sort partition for full stage in streaming read Key: FLINK-31201 URL: https://issues.apache.org/jira/browse/FLINK-31201 Project: Flink

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

Jingsong Lee created FLINK-31195: Summary: FullChangelogStoreSinkWrite bucket writer conflicts with rescale Key: FLINK-31195 URL: https://issues.apache.org/jira/browse/FLINK-31195 Project: Flink

[jira] [Assigned] (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 reassigned FLINK-28086: Assignee: (was: Nicholas Jiang) > Table Store Catalog supports partition methods >

[jira] [Assigned] (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 reassigned FLINK-31190: Assignee: Nicholas Jiang > Supports Spark call procedure command on Table Store >

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

Jingsong Lee created FLINK-31179: Summary: Make data structures serializable Key: FLINK-31179 URL: https://issues.apache.org/jira/browse/FLINK-31179 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31178) Public Writer API

Jingsong Lee created FLINK-31178: Summary: Public Writer API Key: FLINK-31178 URL: https://issues.apache.org/jira/browse/FLINK-31178 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-31075) Upgrade test units in table store to junit5

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

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