[jira] [Assigned] (FLINK-30389) Add retry to read hints

[ https://issues.apache.org/jira/browse/FLINK-30389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-30389: Assignee: Wencong Liu > Add retry to read hints > --- > >

[jira] [Commented] (FLINK-30389) Add retry to read hints

[ https://issues.apache.org/jira/browse/FLINK-30389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653815#comment-17653815 ] Jingsong Lee commented on FLINK-30389: -- [~Wencong Liu] Assigned > Add retry to read hints >

[jira] [Commented] (FLINK-30389) Add retry to read hints

[ https://issues.apache.org/jira/browse/FLINK-30389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653768#comment-17653768 ] Jingsong Lee commented on FLINK-30389: -- [~Wencong Liu] SnapshotManager.readHints. Feel free to open

[jira] [Closed] (FLINK-30423) Introduce cast executor codegen for column type evolution

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

[jira] [Closed] (FLINK-30428) SparkReadITCase.testSnapshotsTable is unstable

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

[jira] [Closed] (FLINK-29679) Migrate to new schema framework & show column comment

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

[jira] [Created] (FLINK-30398) Introduce S3 support for table store

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

[jira] [Updated] (FLINK-30395) Refactor module name and documentation for filesystems

[ https://issues.apache.org/jira/browse/FLINK-30395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30395: - Description: * flink-table-store-filesystem => flink-table-store-filesystems *

[jira] [Created] (FLINK-30395) Refactor module name and documentation for filesystems

Jingsong Lee created FLINK-30395: Summary: Refactor module name and documentation for filesystems Key: FLINK-30395 URL: https://issues.apache.org/jira/browse/FLINK-30395 Project: Flink Issue

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

Jingsong Lee created FLINK-30394: Summary: [umbrella] Refactor filesystem support in table store Key: FLINK-30394 URL: https://issues.apache.org/jira/browse/FLINK-30394 Project: Flink Issue

[jira] [Closed] (FLINK-30373) Flink-table-runtime free for flink-table-store-codegen

[ https://issues.apache.org/jira/browse/FLINK-30373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30373. Resolution: Fixed master: 3e47657054e75d714cd941f502a899e5059cffac > Flink-table-runtime free

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

Jingsong Lee created FLINK-30390: Summary: Ensure that no compaction is in progress before closing the writer Key: FLINK-30390 URL: https://issues.apache.org/jira/browse/FLINK-30390 Project: Flink

[jira] [Updated] (FLINK-30389) Add retry to read hints

[ https://issues.apache.org/jira/browse/FLINK-30389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30389: - Description: For the oss (object store) filesystem. When writing hint file, delete it first

[jira] [Created] (FLINK-30389) Add retry to read hints

Jingsong Lee created FLINK-30389: Summary: Add retry to read hints Key: FLINK-30389 URL: https://issues.apache.org/jira/browse/FLINK-30389 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-30341) Introduce audit_log system table

[ https://issues.apache.org/jira/browse/FLINK-30341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645961#comment-17645961 ] Jingsong Lee edited comment on FLINK-30341 at 12/12/22 9:55 AM: master:

[jira] [Updated] (FLINK-30373) Flink-table-runtime free for flink-table-store-codegen

[ https://issues.apache.org/jira/browse/FLINK-30373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30373: - Description: To remove the dependence of flink-table-store-core on flink-table-runtime,

[jira] [Created] (FLINK-30373) Flink-table-runtime free for flink-table-store-codegen

Jingsong Lee created FLINK-30373: Summary: Flink-table-runtime free for flink-table-store-codegen Key: FLINK-30373 URL: https://issues.apache.org/jira/browse/FLINK-30373 Project: Flink Issue

[jira] [Closed] (FLINK-30341) Introduce audit_log system table

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

[jira] [Updated] (FLINK-30333) Supports lookup a partial-update table

[ https://issues.apache.org/jira/browse/FLINK-30333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30333: - Description: The lookup uses streaming read for reading table. (In TableStreamingReader) - We

[jira] [Assigned] (FLINK-30333) Supports lookup a partial-update table

[ https://issues.apache.org/jira/browse/FLINK-30333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-30333: Assignee: Jingsong Lee > Supports lookup a partial-update table >

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

[ https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645056#comment-17645056 ] Jingsong Lee commented on FLINK-30326: -- Thanks [~Ge]for reporting. I think it is the

[jira] [Updated] (FLINK-30341) Introduce audit_log system table

[ https://issues.apache.org/jira/browse/FLINK-30341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30341: - Description: In some scenarios, users need to get the changelog to do some auditing work, such

[jira] [Created] (FLINK-30341) Introduce audit_log system table

Jingsong Lee created FLINK-30341: Summary: Introduce audit_log system table Key: FLINK-30341 URL: https://issues.apache.org/jira/browse/FLINK-30341 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-30293) Create an enumerator for static (batch)

[ https://issues.apache.org/jira/browse/FLINK-30293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30293. Assignee: Caizhi Weng Resolution: Fixed master: e7690d7c40c9a4371feafc170a147c5b03f70358 >

[jira] [Updated] (FLINK-30333) Supports lookup a partial-update table

[ https://issues.apache.org/jira/browse/FLINK-30333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30333: - Summary: Supports lookup a partial-update table (was: Supports lookup a partial-update table

[jira] [Updated] (FLINK-30333) Supports lookup a partial-update table with full compaction

[ https://issues.apache.org/jira/browse/FLINK-30333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30333: - Description: The lookup uses streaming read for reading table. (In TableStreamingReader) - We

[jira] [Closed] (FLINK-30319) Validate illegal column name in table store

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

[jira] [Created] (FLINK-30333) Supports lookup a partial-update table with full compaction

Jingsong Lee created FLINK-30333: Summary: Supports lookup a partial-update table with full compaction Key: FLINK-30333 URL: https://issues.apache.org/jira/browse/FLINK-30333 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-30317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644628#comment-17644628 ] Jingsong Lee commented on FLINK-30317: -- Thanks [~Ge] for reporting. We should check and create

[jira] [Closed] (FLINK-30288) Use visitor to convert predicate for orc

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

[jira] [Closed] (FLINK-30263) Introduce schemas meta table

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

[jira] [Closed] (FLINK-30273) Introduce RecordReaderUtils.transform to transform RecordReader

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

[jira] [Closed] (FLINK-30271) Introduce Table.copy from dynamic options

[ https://issues.apache.org/jira/browse/FLINK-30271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30271. Resolution: Fixed master: 925186e0904b1eec8d571168ab96706344201211 > Introduce Table.copy from

[jira] [Closed] (FLINK-30207) Move split initialization and discovery logic fully into SnapshotEnumerator in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30207. Resolution: Fixed master: 23dad789879735249651992ab9fe23b986ef1564 > Move split initialization

[jira] [Created] (FLINK-30293) Create an enumerator for static (batch)

Jingsong Lee created FLINK-30293: Summary: Create an enumerator for static (batch) Key: FLINK-30293 URL: https://issues.apache.org/jira/browse/FLINK-30293 Project: Flink Issue Type:

[jira] [Closed] (FLINK-30272) Introduce a Predicate Visitor

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

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

Jingsong Lee created FLINK-30276: Summary: [umbrella] Flink free for table store core Key: FLINK-30276 URL: https://issues.apache.org/jira/browse/FLINK-30276 Project: Flink Issue Type:

[jira] [Closed] (FLINK-30269) Validate table name for metadata table

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

[jira] [Closed] (FLINK-29968) Update streaming query document for Table Store to include full compaction changelog producer

[ https://issues.apache.org/jira/browse/FLINK-29968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29968. Resolution: Fixed master: d03a9b6cc5f503ce846cbeed3a1b2c679bcf42f4 > Update streaming query

[jira] [Created] (FLINK-30273) Introduce RecordReaderUtils.transform to transform RecordReader

Jingsong Lee created FLINK-30273: Summary: Introduce RecordReaderUtils.transform to transform RecordReader Key: FLINK-30273 URL: https://issues.apache.org/jira/browse/FLINK-30273 Project: Flink

[jira] [Created] (FLINK-30272) Introduce a Predicate Visitor

Jingsong Lee created FLINK-30272: Summary: Introduce a Predicate Visitor Key: FLINK-30272 URL: https://issues.apache.org/jira/browse/FLINK-30272 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30271) Introduce Table.copy from dynamic options

Jingsong Lee created FLINK-30271: Summary: Introduce Table.copy from dynamic options Key: FLINK-30271 URL: https://issues.apache.org/jira/browse/FLINK-30271 Project: Flink Issue Type:

[jira] [Updated] (FLINK-27844) Partition Evolution: Schema evolution for ManifestFileMeta

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

[jira] [Updated] (FLINK-27844) Partition Evolution: Schema evolution for ManifestFileMeta

[ https://issues.apache.org/jira/browse/FLINK-27844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-27844: - Fix Version/s: (was: table-store-0.3.0) > Partition Evolution: Schema evolution for

[jira] [Updated] (FLINK-27844) Partition Evolution: Schema evolution for ManifestFileMeta

[ https://issues.apache.org/jira/browse/FLINK-27844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-27844: - Summary: Partition Evolution: Schema evolution for ManifestFileMeta (was: Schema evolution for

[jira] [Closed] (FLINK-27847) SchemaManager supports schema evolution

[ https://issues.apache.org/jira/browse/FLINK-27847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27847. Resolution: Fixed master: 36ed2c37201cabea3779dcb95b9a425f03a80d8e > SchemaManager supports

[jira] [Closed] (FLINK-30110) Enable from-timestamp log scan when timestamp-millis is configured

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

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

Jingsong Lee created FLINK-30248: Summary: Spark writer supports insert overwrite Key: FLINK-30248 URL: https://issues.apache.org/jira/browse/FLINK-30248 Project: Flink Issue Type: New

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

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

[jira] [Created] (FLINK-30247) Introduce Time Travel reading for table store

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

[jira] [Comment Edited] (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=17640003#comment-17640003 ] Jingsong Lee edited comment on FLINK-27846 at 11/29/22 6:12 AM: master:

[jira] [Closed] (FLINK-29964) Support Spark/Hive with OSS

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

[jira] [Closed] (FLINK-29983) Table Store with Hive3 profile lacks hive-standalone-metastore dependency

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

[jira] [Closed] (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 closed FLINK-27846. Resolution: Fixed master: 615473f0645c547aeb7b2922cbc7ad985946315d > Schema evolution for data

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

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

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

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

[jira] [Closed] (FLINK-30205) Modify compact interface for TableWrite and FileStoreWrite to support normal compaction in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30205. Resolution: Fixed master: e6e62699ef42a90d9eb2ca73b10460eb2764a586 > Modify compact interface

[jira] [Created] (FLINK-30223) Refactor Lock to provide Lock.Factory

Jingsong Lee created FLINK-30223: Summary: Refactor Lock to provide Lock.Factory Key: FLINK-30223 URL: https://issues.apache.org/jira/browse/FLINK-30223 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-29987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29987: Assignee: Alex Sorokoumov > PartialUpdateITCase.testForeignKeyJo is unstable >

[jira] [Closed] (FLINK-30125) Projection pushdown is not work for partial update

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

[jira] [Comment Edited] (FLINK-28812) Add read.compacted to read compacted snapshot only

[ https://issues.apache.org/jira/browse/FLINK-28812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638073#comment-17638073 ] Jingsong Lee edited comment on FLINK-28812 at 11/24/22 6:55 AM: master:

[jira] [Closed] (FLINK-28812) Add read.compacted to read compacted snapshot only

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

[jira] [Assigned] (FLINK-28812) Add read.compacted to read compacted snapshot only

[ https://issues.apache.org/jira/browse/FLINK-28812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28812: Assignee: Shammon > Add read.compacted to read compacted snapshot only >

[jira] [Commented] (FLINK-28812) Add read.compacted to read compacted snapshot only

[ https://issues.apache.org/jira/browse/FLINK-28812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638073#comment-17638073 ] Jingsong Lee commented on FLINK-28812: -- master: 638c34b39ab0b57b14cef9b050c749de7b1bf7d3 > Add

[jira] [Closed] (FLINK-30161) Add TableSchema validation before it is commited

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

[jira] [Created] (FLINK-30164) Expose BucketComputer from SupportsWrite

Jingsong Lee created FLINK-30164: Summary: Expose BucketComputer from SupportsWrite Key: FLINK-30164 URL: https://issues.apache.org/jira/browse/FLINK-30164 Project: Flink Issue Type:

[jira] [Closed] (FLINK-30139) CodeGenLoader fails when temporary directory is a symlink

[ https://issues.apache.org/jira/browse/FLINK-30139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30139. Resolution: Fixed master: ae96b335e470a068a7e87f3d1a22c58bf2d82256 > CodeGenLoader fails when

[jira] [Created] (FLINK-30139) CodeGenLoader fails when temporary directory is a symlink

Jingsong Lee created FLINK-30139: Summary: CodeGenLoader fails when temporary directory is a symlink Key: FLINK-30139 URL: https://issues.apache.org/jira/browse/FLINK-30139 Project: Flink

[jira] [Updated] (FLINK-30125) Projection pushdown is not work for partial update

[ https://issues.apache.org/jira/browse/FLINK-30125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30125: - Fix Version/s: table-store-0.2.2 > Projection pushdown is not work for partial update >

[jira] [Created] (FLINK-30125) Projection pushdown is not work for partial update

Jingsong Lee created FLINK-30125: Summary: Projection pushdown is not work for partial update Key: FLINK-30125 URL: https://issues.apache.org/jira/browse/FLINK-30125 Project: Flink Issue

[jira] [Closed] (FLINK-30082) Enable write-buffer-spillable by default only for object storage

[ https://issues.apache.org/jira/browse/FLINK-30082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30082. Resolution: Fixed master: 039f2ff5d2e25154b5ab4b04f4c36086ce51d9c3 > Enable

[jira] [Closed] (FLINK-29232) File store continuous reading support from_timestamp scan mode

[ https://issues.apache.org/jira/browse/FLINK-29232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29232. Resolution: Fixed master: 0d2440984f6ca9c4e26caca7034280e9c3726337 > File store continuous

[jira] [Closed] (FLINK-30071) Throw exception at compile time when sequence field does not exist

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

[jira] [Created] (FLINK-30114) Introduce PyFlink example for table store

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

[jira] [Closed] (FLINK-30091) mvn package verify fails with "Error creating shaded jar: duplicate entry"

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

[jira] [Created] (FLINK-30110) Enable from-timestamp log scan when timestamp-millis is configured

Jingsong Lee created FLINK-30110: Summary: Enable from-timestamp log scan when timestamp-millis is configured Key: FLINK-30110 URL: https://issues.apache.org/jira/browse/FLINK-30110 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-29614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29614: - Fix Version/s: table-store-0.3.0 > Introduce Spark writer for table store >

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

[ https://issues.apache.org/jira/browse/FLINK-29614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29614: Assignee: Jingsong Lee > Introduce Spark writer for table store >

[jira] [Closed] (FLINK-30094) Flink Table Sotre's Lookup Join document may needs left table DDL example.

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

[jira] [Created] (FLINK-30082) Enable write-buffer-spillable by default only for object storage

Jingsong Lee created FLINK-30082: Summary: Enable write-buffer-spillable by default only for object storage Key: FLINK-30082 URL: https://issues.apache.org/jira/browse/FLINK-30082 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-30031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635681#comment-17635681 ] Jingsong Lee commented on FLINK-30031: -- I created FLINK-30080 for this. > flink table store run

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

Jingsong Lee created FLINK-30080: Summary: Introduce public programming api and dependency jar for table store Key: FLINK-30080 URL: https://issues.apache.org/jira/browse/FLINK-30080 Project: Flink

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-29987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635679#comment-17635679 ] Jingsong Lee commented on FLINK-29987: -- [~Ge] Sounds nice~ >

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

[ https://issues.apache.org/jira/browse/FLINK-30039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635677#comment-17635677 ] Jingsong Lee commented on FLINK-30039: -- Hi [~StarBoy1005], if you are using static partition

[jira] [Closed] (FLINK-30028) A little fix with document about period in log.changelog-mode description.

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

[jira] [Assigned] (FLINK-27847) SchemaManager supports schema evolution

[ https://issues.apache.org/jira/browse/FLINK-27847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-27847: Assignee: Shammon > SchemaManager supports schema evolution >

[jira] [Closed] (FLINK-30033) Add primary key data type validation

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

[jira] [Closed] (FLINK-27843) Schema evolution for data file meta

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

[jira] [Assigned] (FLINK-29232) File store continuous reading support from_timestamp scan mode

[ https://issues.apache.org/jira/browse/FLINK-29232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29232: Assignee: Jingsong Lee > File store continuous reading support from_timestamp scan mode

[jira] [Assigned] (FLINK-30043) Some example sqls in flink table store rescale-bucket doucument are incorrect.

[ https://issues.apache.org/jira/browse/FLINK-30043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-30043: Assignee: Hang HOU > Some example sqls in flink table store rescale-bucket doucument are

[jira] [Closed] (FLINK-30043) Some example sqls in flink table store rescale-bucket doucument are incorrect.

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

[jira] [Updated] (FLINK-30049) CsvBulkWriter is unsupported for S3 FileSystem in streaming sink

[ https://issues.apache.org/jira/browse/FLINK-30049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30049: - Description: {code:java} Caused by: org.apache.flink.util.SerializedThrowable: Cannot sync

[jira] [Created] (FLINK-30049) CsvBulkWriter is unsupported for S3 FileSystem

Jingsong Lee created FLINK-30049: Summary: CsvBulkWriter is unsupported for S3 FileSystem Key: FLINK-30049 URL: https://issues.apache.org/jira/browse/FLINK-30049 Project: Flink Issue Type:

[jira] [Updated] (FLINK-30049) CsvBulkWriter is unsupported for S3 FileSystem in streaming sink

[ https://issues.apache.org/jira/browse/FLINK-30049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30049: - Summary: CsvBulkWriter is unsupported for S3 FileSystem in streaming sink (was: CsvBulkWriter

[jira] [Closed] (FLINK-30027) Fields min and max in BinaryTableStats support lazy deserialization

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

[jira] [Closed] (FLINK-28671) Update Spark3 to create/drop table in Compatibility Matrix

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

[jira] [Closed] (FLINK-28552) GenerateUtils#generateCompare supports MULTISET and MAP

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

[jira] [Comment Edited] (FLINK-29922) Table store hive catalog support create external table

[ https://issues.apache.org/jira/browse/FLINK-29922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634181#comment-17634181 ] Jingsong Lee edited comment on FLINK-29922 at 11/15/22 6:41 AM: master:

[jira] [Closed] (FLINK-29922) Table store hive catalog support create external table

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

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