[jira] [Assigned] (FLINK-29965) Support Spark/Hive with S3

[ https://issues.apache.org/jira/browse/FLINK-29965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29965: Assignee: Jane Chan > Support Spark/Hive with S3 > -- > >

[jira] [Closed] (FLINK-30013) Add data type compatibility check in SchemaChange.updateColumnType

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

[jira] [Commented] (FLINK-29962) Exclude Jamon 2.3.1

[ https://issues.apache.org/jira/browse/FLINK-29962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632353#comment-17632353 ] Jingsong Lee commented on FLINK-29962: -- Merged in Flink Table Store master:

[jira] [Closed] (FLINK-29994) Update official document about Lookup Join.

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

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

Jingsong Lee created FLINK-3: Summary: Introduce FileSystemFactory to create FileSystem from custom configuration Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project:

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

Jingsong Lee created FLINK-29988: Summary: Improve upper case fields for hive metastore Key: FLINK-29988 URL: https://issues.apache.org/jira/browse/FLINK-29988 Project: Flink Issue Type:

[jira] [Created] (FLINK-29987) PartialUpdateITCase.testForeignKeyJo is unstable

Jingsong Lee created FLINK-29987: Summary: PartialUpdateITCase.testForeignKeyJo is unstable Key: FLINK-29987 URL: https://issues.apache.org/jira/browse/FLINK-29987 Project: Flink Issue Type:

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

Jingsong Lee created FLINK-29953: Summary: Get rid of flink-connector-hive dependency in flink-table-store-hive Key: FLINK-29953 URL: https://issues.apache.org/jira/browse/FLINK-29953 Project: Flink

[jira] [Commented] (FLINK-27846) Schema evolution for data file reading

[ https://issues.apache.org/jira/browse/FLINK-27846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630703#comment-17630703 ] Jingsong Lee commented on FLINK-27846: -- [~zjureel] (y) Assigned to u. > Schema evolution for data

[jira] [Assigned] (FLINK-27846) Schema evolution for data file reading

[ https://issues.apache.org/jira/browse/FLINK-27846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-27846: Assignee: Shammon > Schema evolution for data file reading >

[jira] [Commented] (FLINK-27846) Schema evolution for data file reading

[ https://issues.apache.org/jira/browse/FLINK-27846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630388#comment-17630388 ] Jingsong Lee commented on FLINK-27846: -- Hi [~zjureel], there is schemaId in DataFileMeta, even if

[jira] [Closed] (FLINK-29930) ParquetFileStatsExtractorTest is unstable

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

[jira] [Closed] (FLINK-29933) Bump Flink version to 1.16.0

[ https://issues.apache.org/jira/browse/FLINK-29933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29933. Resolution: Fixed master: 668e857f0b088737a19bfb0ed489a00e0df7fe5d > Bump Flink version to

[jira] [Created] (FLINK-29933) Bump Flink version to 1.16.0

Jingsong Lee created FLINK-29933: Summary: Bump Flink version to 1.16.0 Key: FLINK-29933 URL: https://issues.apache.org/jira/browse/FLINK-29933 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-29790) Implement Catalog#getDatabase

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

[jira] [Closed] (FLINK-29294) Introduce a CompactRewriter for full compaction

[ https://issues.apache.org/jira/browse/FLINK-29294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29294. Resolution: Fixed master: 08211f0e190ca8dcce288d93b72350a2b1185ff6 > Introduce a CompactRewriter

[jira] [Closed] (FLINK-29774) Introduce options metadata table

[ https://issues.apache.org/jira/browse/FLINK-29774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29774. Resolution: Fixed master: 3959440576f6d8e8e3dc88eb4130a04cdce4c3b1 > Introduce options metadata

[jira] [Closed] (FLINK-29760) Introduce snapshots metadata table

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

[jira] [Closed] (FLINK-29075) RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite is not stable

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

[jira] [Created] (FLINK-29774) Introduce options metadata table

Jingsong Lee created FLINK-29774: Summary: Introduce options metadata table Key: FLINK-29774 URL: https://issues.apache.org/jira/browse/FLINK-29774 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-28157) Table Store Hive Reader supports Hive3

[ https://issues.apache.org/jira/browse/FLINK-28157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28157. Resolution: Fixed master: f80659ba2219a4b70b83007f83fef71c304affa0 > Table Store Hive Reader

[jira] [Closed] (FLINK-29702) Add merge tree reader and writer micro benchmarks

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

[jira] [Closed] (FLINK-29252) Support create table-store table with 'connector'='table-store'

[ https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29252. Fix Version/s: table-store-0.3.0 Assignee: Jingsong Lee (was: MOBIN) Resolution:

[jira] [Created] (FLINK-29760) Introduce snapshots metadata table

Jingsong Lee created FLINK-29760: Summary: Introduce snapshots metadata table Key: FLINK-29760 URL: https://issues.apache.org/jira/browse/FLINK-29760 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-29736) Abstract a table interface for both data and metadata tables

[ https://issues.apache.org/jira/browse/FLINK-29736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29736. Resolution: Fixed master: b9527abac18a7c1f4eba13dadfb07227ba23f4b8 > Abstract a table interface

[jira] [Closed] (FLINK-29714) Merge TableWrite and TableCompact into one interface

[ https://issues.apache.org/jira/browse/FLINK-29714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29714. Resolution: Fixed master: 9c9f5f823ce52a20eb417444b59baac3e96d6a75 > Merge TableWrite and

[jira] [Updated] (FLINK-29745) Split reader/writer factory for compaction in MergeTreeTest

[ https://issues.apache.org/jira/browse/FLINK-29745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29745: - Fix Version/s: table-store-0.3.0 (was: shammon) > Split reader/writer

[jira] [Assigned] (FLINK-29745) Split reader/writer factory for compaction in MergeTreeTest

[ https://issues.apache.org/jira/browse/FLINK-29745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29745: Assignee: Shammon > Split reader/writer factory for compaction in MergeTreeTest >

[jira] [Closed] (FLINK-29745) Split reader/writer factory for compaction in MergeTreeTest

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

[jira] [Updated] (FLINK-29736) Abstract a table interface for both data and metadata tables

[ https://issues.apache.org/jira/browse/FLINK-29736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29736: - Description: Currently, FileStoreTable is only for data tables, we can create a new interface

[jira] [Created] (FLINK-29736) Abstract a table interface for both data and metadata tables

Jingsong Lee created FLINK-29736: Summary: Abstract a table interface for both data and metadata tables Key: FLINK-29736 URL: https://issues.apache.org/jira/browse/FLINK-29736 Project: Flink

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

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

[jira] [Closed] (FLINK-28256) Move the write and prepareCommit logic of AbstractTableWrite to FileStoreWrite

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

[jira] [Assigned] (FLINK-28157) Table Store Hive Reader supports Hive3

[ https://issues.apache.org/jira/browse/FLINK-28157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28157: Assignee: Jingsong Lee > Table Store Hive Reader supports Hive3 >

[jira] [Closed] (FLINK-29700) Serializer to BinaryInMemorySortBuffer is wrong

[ https://issues.apache.org/jira/browse/FLINK-29700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29700. Resolution: Fixed release-0.2: aa6846089afc61e6715a7d50ae40e6bb9d8efc0f > Serializer to

[jira] [Updated] (FLINK-29700) Serializer to BinaryInMemorySortBuffer is wrong

[ https://issues.apache.org/jira/browse/FLINK-29700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29700: - Fix Version/s: (was: table-store-0.3.0) > Serializer to BinaryInMemorySortBuffer is wrong >

[jira] [Closed] (FLINK-29687) Do not throw exception when Lookup table is empty

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

[jira] [Closed] (FLINK-29701) Refactor flink-table-store-benchmark and create micro benchmarks module

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

[jira] [Created] (FLINK-29700) Serializer to BinaryInMemorySortBuffer is wrong

Jingsong Lee created FLINK-29700: Summary: Serializer to BinaryInMemorySortBuffer is wrong Key: FLINK-29700 URL: https://issues.apache.org/jira/browse/FLINK-29700 Project: Flink Issue Type:

[jira] [Closed] (FLINK-29690) listTables in HiveCatalog should only return table store tables

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

[jira] [Created] (FLINK-29690) listTables in HiveCatalog should only return table store tables

Jingsong Lee created FLINK-29690: Summary: listTables in HiveCatalog should only return table store tables Key: FLINK-29690 URL: https://issues.apache.org/jira/browse/FLINK-29690 Project: Flink

[jira] [Updated] (FLINK-29679) DESCRIBE statement shows column comment

[ https://issues.apache.org/jira/browse/FLINK-29679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29679: - Summary: DESCRIBE statement shows column comment (was: DESCRIBE statement shows comment) >

[jira] [Assigned] (FLINK-28985) support create table like view

[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28985: Assignee: waywtdcc > support create table like view > -- > >

[jira] [Closed] (FLINK-29621) Append-only with eventual log.consistency can not work

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

[jira] [Updated] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join

[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29554: - Fix Version/s: (was: table-store-0.2.2) > Add partial-update.ignore-delete option to avoid

[jira] [Closed] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join

[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29554. Resolution: Fixed master: 8e63f1f67fcfe83773a7264068687c7340bc01cb > Add

[jira] [Closed] (FLINK-29616) Polish Table Store Pom file to avoid warning.

[ https://issues.apache.org/jira/browse/FLINK-29616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29616. Assignee: Aiden Gong Resolution: Fixed master: 97bb1b1aba2eeca2db6a4c6181d86c39cc45 >

[jira] [Updated] (FLINK-29621) Append-only with eventual log.consistency can not work

[ https://issues.apache.org/jira/browse/FLINK-29621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29621: - Description: {code:java} "CREATE TABLE T (i INT, j INT) WITH ("

[jira] [Created] (FLINK-29621) Append-only with eventual log.consistency can not work

Jingsong Lee created FLINK-29621: Summary: Append-only with eventual log.consistency can not work Key: FLINK-29621 URL: https://issues.apache.org/jira/browse/FLINK-29621 Project: Flink Issue

[jira] [Created] (FLINK-29614) Introduce Spark writer for table store

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

[jira] [Updated] (FLINK-25205) Optimize SinkUpsertMaterializer

[ https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25205: - Fix Version/s: 1.17.0 > Optimize SinkUpsertMaterializer > --- > >

[jira] [Assigned] (FLINK-25205) Optimize SinkUpsertMaterializer

[ https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25205: Assignee: lincoln lee > Optimize SinkUpsertMaterializer >

[jira] [Closed] (FLINK-28128) Create e2e test for spark reader

[ https://issues.apache.org/jira/browse/FLINK-28128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28128. Assignee: Shammon Resolution: Fixed > Create e2e test for spark reader >

[jira] [Updated] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join

[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29554: - Fix Version/s: table-store-0.2.2 > Add partial-update.ignore-delete option to avoid exception

[jira] [Updated] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join

[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29554: - Fix Version/s: (was: table-store-0.2.1) > Add partial-update.ignore-delete option to avoid

[jira] [Created] (FLINK-29586) Let write buffer spillable

Jingsong Lee created FLINK-29586: Summary: Let write buffer spillable Key: FLINK-29586 URL: https://issues.apache.org/jira/browse/FLINK-29586 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-29579) Flink parquet reader cannot read fully optional elements in a repeated list

[ https://issues.apache.org/jira/browse/FLINK-29579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615722#comment-17615722 ] Jingsong Lee commented on FLINK-29579: -- Old ParquetInputFormat has been dropped in 1.14, it is

[jira] [Assigned] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join

[ https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29554: Assignee: Jingsong Lee > Add partial-update.ignore-delete option to avoid exception

[jira] [Created] (FLINK-29554) Add partial-update.ignore-delete option to avoid exception after join

Jingsong Lee created FLINK-29554: Summary: Add partial-update.ignore-delete option to avoid exception after join Key: FLINK-29554 URL: https://issues.apache.org/jira/browse/FLINK-29554 Project: Flink

[jira] [Closed] (FLINK-29491) Primary key without partition field can be supported from full changelog

[ https://issues.apache.org/jira/browse/FLINK-29491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29491. Resolution: Invalid > Primary key without partition field can be supported from full changelog >

[jira] [Closed] (FLINK-29292) Change MergeFunction to produce not only KeyValues

[ https://issues.apache.org/jira/browse/FLINK-29292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29292. Resolution: Fixed master: e4c19b66a8af319dd9f412aed250683d54969b34 > Change MergeFunction to

[jira] [Reopened] (FLINK-29345) Too many open files in table store orc writer

[ https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-29345: -- > Too many open files in table store orc writer > - >

[jira] [Closed] (FLINK-29345) Too many open files in table store orc writer

[ https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29345. Fix Version/s: (was: table-store-0.2.1) Resolution: Fixed Re-merged in: master:

[jira] [Closed] (FLINK-29291) Change DataFileWriter into a factory to create writers

[ https://issues.apache.org/jira/browse/FLINK-29291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29291. Resolution: Fixed master: a881f41368ef48148d5cef795822ac51625811b6 > Change DataFileWriter into

[jira] [Closed] (FLINK-29149) Migrate E2E tests to catalog-based and enable E2E tests for Flink1.14

[ https://issues.apache.org/jira/browse/FLINK-29149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29149. Resolution: Fixed master: 7e2f5850c4ae2315a729b3b1ba007162414ccd89 > Migrate E2E tests to

[jira] [Closed] (FLINK-29406) Expose Finish Method For TableFunction

[ https://issues.apache.org/jira/browse/FLINK-29406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29406. Resolution: Fixed master: 1f2001cfd28dbf6fdecdb2645052cdd61c84 > Expose Finish Method For

[jira] [Closed] (FLINK-29506) ParquetInputFormatFactory fails to create format on Flink 1.14

[ https://issues.apache.org/jira/browse/FLINK-29506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29506. Assignee: Jane Chan Resolution: Fixed master: 09827774e2f435de3133ced33c61dcf1e6ceae0a >

[jira] [Created] (FLINK-29491) Primary key without partition field can be supported from full changelog

Jingsong Lee created FLINK-29491: Summary: Primary key without partition field can be supported from full changelog Key: FLINK-29491 URL: https://issues.apache.org/jira/browse/FLINK-29491 Project:

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

Jingsong Lee created FLINK-29490: Summary: Timestamp LTZ is unsupported in table store Key: FLINK-29490 URL: https://issues.apache.org/jira/browse/FLINK-29490 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-29345) Too many open files in table store orc writer

[ https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29345. Resolution: Invalid revert in: master: 696d65c387b708228c99bef6914a8859c301d6e8 release-0.2:

[jira] [Reopened] (FLINK-29345) Too many open files in table store orc writer

[ https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-29345: -- > Too many open files in table store orc writer > - >

[jira] [Commented] (FLINK-29345) Too many open files in table store orc writer

[ https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610476#comment-17610476 ] Jingsong Lee commented on FLINK-29345: -- The orc writer has memory management and needs to be

[jira] [Assigned] (FLINK-28256) Move the write and prepareCommit logic of AbstractTableWrite to FileStoreWrite

[ https://issues.apache.org/jira/browse/FLINK-28256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28256: Assignee: Shammon > Move the write and prepareCommit logic of AbstractTableWrite to

[jira] [Updated] (FLINK-29181) log.system can be congiured by dynamic options

[ https://issues.apache.org/jira/browse/FLINK-29181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29181: - Issue Type: Improvement (was: New Feature) > log.system can be congiured by dynamic options >

[jira] [Updated] (FLINK-29154) Support LookupTableSource for table store

[ https://issues.apache.org/jira/browse/FLINK-29154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29154: - Issue Type: Improvement (was: New Feature) > Support LookupTableSource for table store >

[jira] [Updated] (FLINK-29154) Support LookupTableSource for table store

[ https://issues.apache.org/jira/browse/FLINK-29154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29154: - Fix Version/s: table-store-0.2.1 > Support LookupTableSource for table store >

[jira] [Comment Edited] (FLINK-29154) Support LookupTableSource for table store

[ https://issues.apache.org/jira/browse/FLINK-29154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17600665#comment-17600665 ] Jingsong Lee edited comment on FLINK-29154 at 9/27/22 2:09 AM: --- master:

[jira] [Closed] (FLINK-29412) Connection leak in orc reader

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

[jira] [Closed] (FLINK-27346) [umbrella] Introduce Hive reader for table store

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

[jira] [Closed] (FLINK-29349) Use state ttl instead of timer to clean up state in proctime unbounded over aggregate

[ https://issues.apache.org/jira/browse/FLINK-29349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29349. Resolution: Fixed master: 0f8909cfb5179cb9e87de2615404bb6dd12e359f > Use state ttl instead of

[jira] [Assigned] (FLINK-29349) Use state ttl instead of timer to clean up state in proctime unbounded over aggregate

[ https://issues.apache.org/jira/browse/FLINK-29349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29349: Assignee: lincoln lee > Use state ttl instead of timer to clean up state in proctime

[jira] [Closed] (FLINK-29342) Do not query writer.length() per record in RollingFileWriter

[ https://issues.apache.org/jira/browse/FLINK-29342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29342. Resolution: Fixed master: 557594ed42f075383f0a35c1320ba98f00171e88 > Do not query

[jira] [Updated] (FLINK-29412) Connection leak in orc reader

[ https://issues.apache.org/jira/browse/FLINK-29412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29412: - Description: 1. OrcFileStatsExtractor forget closing reader. 2. HadoopReadOnlyFileSystem forget

[jira] [Created] (FLINK-29412) Connection leak in orc reader

Jingsong Lee created FLINK-29412: Summary: Connection leak in orc reader Key: FLINK-29412 URL: https://issues.apache.org/jira/browse/FLINK-29412 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-29369) Commit delete file failure due to Checkpoint aborted

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

[jira] [Assigned] (FLINK-29342) Do not query writer.length() per record in RollingFileWriter

[ https://issues.apache.org/jira/browse/FLINK-29342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29342: Assignee: Jane Chan > Do not query writer.length() per record in RollingFileWriter >

[jira] [Updated] (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 updated FLINK-29272: - Fix Version/s: (was: table-store-0.2.1) > Document DataStream API (DataStream to Table) for

[jira] [Assigned] (FLINK-29373) DataStream to table not support BigDecimalTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-29373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29373: Assignee: hk__lrzy > DataStream to table not support BigDecimalTypeInfo >

[jira] [Commented] (FLINK-29373) DataStream to table not support BigDecimalTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-29373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17609270#comment-17609270 ] Jingsong Lee commented on FLINK-29373: -- [~hk__lrzy] Thanks, assigned to u. CC [~jark] to review~ >

[jira] [Updated] (FLINK-29098) StoreWriteOperator#prepareCommit should let logSinkFunction flush first before fetching offset

[ https://issues.apache.org/jira/browse/FLINK-29098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29098: - Fix Version/s: table-store-0.2.1 > StoreWriteOperator#prepareCommit should let logSinkFunction

[jira] [Comment Edited] (FLINK-29098) StoreWriteOperator#prepareCommit should let logSinkFunction flush first before fetching offset

[ https://issues.apache.org/jira/browse/FLINK-29098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17596979#comment-17596979 ] Jingsong Lee edited comment on FLINK-29098 at 9/24/22 2:38 AM: --- master:

[jira] [Closed] (FLINK-29276) Flush all memory in SortBufferMemTable.clear

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

[jira] [Commented] (FLINK-29373) DataStream to table not support BigDecimalTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-29373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608478#comment-17608478 ] Jingsong Lee commented on FLINK-29373: -- {code:java} /** * Converter from {@link TypeInformation}

[jira] [Commented] (FLINK-29349) Use state ttl instead of timer to clean up state in proctime unbounded over aggregate

[ https://issues.apache.org/jira/browse/FLINK-29349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608479#comment-17608479 ] Jingsong Lee commented on FLINK-29349: -- [~lincoln.86xy] yes, you can > Use state ttl instead of

[jira] [Commented] (FLINK-18346) Support partition pruning for lookup table source

[ https://issues.apache.org/jira/browse/FLINK-18346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608466#comment-17608466 ] Jingsong Lee commented on FLINK-18346: -- cc: [~godfreyhe] > Support partition pruning for lookup

[jira] [Closed] (FLINK-29367) Avoid manifest corruption for incorrect checkpoint recovery

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

[jira] [Closed] (FLINK-29385) AddColumn in flink table store should check the duplicate field names

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

[jira] [Assigned] (FLINK-29385) AddColumn in flink table store should check the duplicate field names

[ https://issues.apache.org/jira/browse/FLINK-29385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29385: Assignee: Shammon > AddColumn in flink table store should check the duplicate field

[jira] [Closed] (FLINK-29278) BINARY type is not supported in table store

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

[jira] [Comment Edited] (FLINK-29345) Too many open files in table store orc writer

[ https://issues.apache.org/jira/browse/FLINK-29345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17607479#comment-17607479 ] Jingsong Lee edited comment on FLINK-29345 at 9/21/22 11:25 AM: master:

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