[jira] [Updated] (FLINK-31695) Calling bin/flink stop when flink-shaded-hadoop-2-uber-2.8.3-10.0.jar is in lib directory throws NoSuchMethodError

[ https://issues.apache.org/jira/browse/FLINK-31695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-31695: Summary: Calling bin/flink stop when flink-shaded-hadoop-2-uber-2.8.3-10.0.jar is in lib directory

[jira] [Updated] (FLINK-31695) Calling bin/flink stop when flink-shaded-hadoop-2-uber-2.8.3-10.0.jar is in lib directory thwos NoSuchMethodError

[ https://issues.apache.org/jira/browse/FLINK-31695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-31695: Summary: Calling bin/flink stop when flink-shaded-hadoop-2-uber-2.8.3-10.0.jar is in lib directory

[jira] [Created] (FLINK-31695) Calling `bin/flink stop` when flink-shaded-hadoop-2-uber-2.8.3-10.0.jar is in lib directory thwos NoSuchMethodError

Caizhi Weng created FLINK-31695: --- Summary: Calling `bin/flink stop` when flink-shaded-hadoop-2-uber-2.8.3-10.0.jar is in lib directory thwos NoSuchMethodError Key: FLINK-31695 URL: https://issues.apache.org/jira/br

[jira] [Updated] (FLINK-31659) java.lang.ClassNotFoundException: org.apache.flink.table.planner.delegation.DialectFactory when bundled Hive connector jar is in classpath

[ https://issues.apache.org/jira/browse/FLINK-31659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-31659: Description: Steps to reproduce this bug: 1. Download a fresh 1.16.1 Flink distribution. 2. Add bo

[jira] [Created] (FLINK-31659) java.lang.ClassNotFoundException: org.apache.flink.table.planner.delegation.DialectFactory when bundled Hive connector jar is in classpath

Caizhi Weng created FLINK-31659: --- Summary: java.lang.ClassNotFoundException: org.apache.flink.table.planner.delegation.DialectFactory when bundled Hive connector jar is in classpath Key: FLINK-31659 URL: https://is

[jira] [Closed] (FLINK-31558) Support updating schema type with restrictions in CDC sink of Table Store

[ https://issues.apache.org/jira/browse/FLINK-31558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31558. --- Resolution: Fixed master: 4322595dfc1809199e3a815c7fa82ccb0750165a > Support updating schema type w

[jira] [Created] (FLINK-31558) Support updating schema type with restrictions in CDC sink of Table Store

Caizhi Weng created FLINK-31558: --- Summary: Support updating schema type with restrictions in CDC sink of Table Store Key: FLINK-31558 URL: https://issues.apache.org/jira/browse/FLINK-31558 Project: Flin

[jira] [Closed] (FLINK-31434) Introduce CDC sink for Table Store

[ https://issues.apache.org/jira/browse/FLINK-31434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31434. --- Resolution: Fixed master: ecce2cc876c1bd9095abef4fdf24400bf179fefa > Introduce CDC sink for Table S

[jira] [Closed] (FLINK-31433) Make SchemaChange serializable

[ https://issues.apache.org/jira/browse/FLINK-31433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31433. --- Resolution: Fixed master: 3179e184da24a09fa67e3bab6bbbcd9a338634e5 > Make SchemaChange serializable

[jira] [Closed] (FLINK-31432) Introduce a special StoreWriteOperator to deal with schema changes

[ https://issues.apache.org/jira/browse/FLINK-31432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31432. --- Resolution: Fixed master: 556443f098252a98610a03450ed8ad2a661f27dd > Introduce a special StoreWrite

[jira] [Closed] (FLINK-31431) Support copying a FileStoreTable with latest schema

[ https://issues.apache.org/jira/browse/FLINK-31431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31431. --- Resolution: Fixed master: c155b9d7c0a6ef40327116cac88659c6be975919 > Support copying a FileStoreTab

[jira] [Closed] (FLINK-31436) Remove schemaId from constructor of FileStoreCommitImpl and ManifestFile in Table Store

[ https://issues.apache.org/jira/browse/FLINK-31436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31436. --- Resolution: Fixed master: a651431f6c9e3e742e2b505920c43e2c18d76502 > Remove schemaId from construct

[jira] [Updated] (FLINK-31436) Remove schemaId from constructor of FileStoreCommitImpl and ManifestFile in Table Store

[ https://issues.apache.org/jira/browse/FLINK-31436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-31436: Summary: Remove schemaId from constructor of FileStoreCommitImpl and ManifestFile in Table Store

[jira] [Created] (FLINK-31436) Remove schemaId from constructor of Snapshot and ManifestFile in Table Store

Caizhi Weng created FLINK-31436: --- Summary: Remove schemaId from constructor of Snapshot and ManifestFile in Table Store Key: FLINK-31436 URL: https://issues.apache.org/jira/browse/FLINK-31436 Project: F

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

Caizhi Weng created FLINK-31435: --- Summary: Introduce event parser for MySql Debezium JSON format in Table Store Key: FLINK-31435 URL: https://issues.apache.org/jira/browse/FLINK-31435 Project: Flink

[jira] [Created] (FLINK-31434) Introduce CDC sink for Table Store

Caizhi Weng created FLINK-31434: --- Summary: Introduce CDC sink for Table Store Key: FLINK-31434 URL: https://issues.apache.org/jira/browse/FLINK-31434 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31433) Make SchemaChange serializable

Caizhi Weng created FLINK-31433: --- Summary: Make SchemaChange serializable Key: FLINK-31433 URL: https://issues.apache.org/jira/browse/FLINK-31433 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-31432) Introduce a special StoreWriteOperator to deal with schema changes

Caizhi Weng created FLINK-31432: --- Summary: Introduce a special StoreWriteOperator to deal with schema changes Key: FLINK-31432 URL: https://issues.apache.org/jira/browse/FLINK-31432 Project: Flink

[jira] [Created] (FLINK-31431) Support copying a FileStoreTable with latest schema

Caizhi Weng created FLINK-31431: --- Summary: Support copying a FileStoreTable with latest schema Key: FLINK-31431 URL: https://issues.apache.org/jira/browse/FLINK-31431 Project: Flink Issue Type:

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

Caizhi Weng created FLINK-31430: --- Summary: Support migrating states between different instances of TableWriteImpl and AbstractFileStoreWrite Key: FLINK-31430 URL: https://issues.apache.org/jira/browse/FLINK-31430

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

Caizhi Weng created FLINK-31429: --- Summary: Support CTAS(create table as) streaming job with schema changes in table store Key: FLINK-31429 URL: https://issues.apache.org/jira/browse/FLINK-31429 Project:

[jira] [Closed] (FLINK-31269) Split hive connector to each module of each version

[ https://issues.apache.org/jira/browse/FLINK-31269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31269. --- Assignee: Shammon Resolution: Fixed master: dd2d600f6743ca074a023fdbb1a7a2cbcfbf8ff0 > Split

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

[ https://issues.apache.org/jira/browse/FLINK-31178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31178. --- Resolution: Fixed master: 9b8dc4e2f3cf8bc28a95d5381c8544868bd5b688 > Public Writer API > --

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

[ https://issues.apache.org/jira/browse/FLINK-31248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31248. --- Resolution: Fixed master: b8a700082a6032dfed7cee4273f3f76ce0483b5a > Improve documentation for appe

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:21 AM:

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:17 AM:

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:17 AM:

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:14 AM:

[jira] [Comment Edited] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692463#comment-17692463 ] Caizhi Weng edited comment on FLINK-31143 at 2/23/23 3:13 AM:

[jira] [Commented] (FLINK-31143) Invalid request: offset doesn't match when restarting from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692463#comment-17692463 ] Caizhi Weng commented on FLINK-31143: - Hi [~mapohl] [~Weijie Guo]. When implementin

[jira] [Updated] (FLINK-31120) ConcurrentModificationException occurred in StringFunctionsITCase.test

[ https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-31120: Release Note: (was: master: fa6a2aed6136ae59ed14cd01819e8f94867840b7 release-1.17: 7201d0aa1c69ae

[jira] [Commented] (FLINK-31120) ConcurrentModificationException occurred in StringFunctionsITCase.test

[ https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692453#comment-17692453 ] Caizhi Weng commented on FLINK-31120: - master: fa6a2aed6136ae59ed14cd01819e8f9486784

[jira] [Updated] (FLINK-31120) ConcurrentModificationException occurred in StringFunctionsITCase.test

[ https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-31120: Fix Version/s: 1.17.0 1.16.2 1.18.0 > ConcurrentModification

[jira] [Closed] (FLINK-31120) ConcurrentModificationException occurred in StringFunctionsITCase.test

[ https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-31120. --- Release Note: master: fa6a2aed6136ae59ed14cd01819e8f94867840b7 release-1.17: 7201d0aa1c69ae0a52f07ce

[jira] [Commented] (FLINK-31120) ConcurrentModificationException occurred in StringFunctionsITCase.test

[ https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691900#comment-17691900 ] Caizhi Weng commented on FLINK-31120: - I've left my review in the github PR. My main

[jira] [Updated] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-25813: Fix Version/s: 1.17.0 1.16.2 > TableITCase.testCollectWithClose failed on azure

[jira] [Closed] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-25813. --- Resolution: Fixed master: 3a647d6bec7d0413bcbc71668ed45be57bb4bfe6 release-1.17: bb66b989188c661d9d7

[jira] [Closed] (FLINK-29237) RexSimplify can not be removed after update to calcite 1.27

[ https://issues.apache.org/jira/browse/FLINK-29237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-29237. --- Fix Version/s: 1.18.0 Assignee: Sergey Nuyanzin Resolution: Fixed master: d9102ddd75

[jira] [Closed] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30927. --- Fix Version/s: (was: 1.16.2) Resolution: Fixed master: 96a296db723575d64857482a1278744e4c

[jira] [Updated] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-30927: Affects Version/s: (was: 1.16.2) > Several tests started generate output with two non-abstract

[jira] [Closed] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-27246. --- Resolution: Fixed master: af9a1128f728c691b896bc9c591e9be1327601c4 release-1.16: f8bf7cc0c26773eecc9

[jira] [Commented] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685066#comment-17685066 ] Caizhi Weng commented on FLINK-25813: - Hi [~mapohl]. Sorry for this late reply as I'

[jira] [Closed] (FLINK-30861) Table Store Hive Catalog throws java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList under certain environment

[ https://issues.apache.org/jira/browse/FLINK-30861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30861. --- Resolution: Fixed master: 5e09dfec910c2aa2dfcf3eca4adcb8191524bf04 release-0.3: 78fdd09077431a7284cd

[jira] [Created] (FLINK-30861) Table Store Hive Catalog throws java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList under certain environment

Caizhi Weng created FLINK-30861: --- Summary: Table Store Hive Catalog throws java.lang.ClassNotFoundException: org.apache.hadoop.hive.common.ValidWriteIdList under certain environment Key: FLINK-30861 URL: https://is

[jira] [Closed] (FLINK-30620) Table Store Hive catalog supports specifying custom Hive metastore client

[ https://issues.apache.org/jira/browse/FLINK-30620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30620. --- Resolution: Fixed master: 6144fa3a65356322b800d0b392099f0ac92043f3 release-0.3: 7a03fcc2b63aa8ca502c

[jira] [Closed] (FLINK-30646) Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented

[ https://issues.apache.org/jira/browse/FLINK-30646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30646. --- Resolution: Fixed master: 072640a72fe18bf3c0439cd4f0ec7602e0b0ff80 release-0.3: fcea22e114888af239e3

[jira] [Updated] (FLINK-30646) Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented

[ https://issues.apache.org/jira/browse/FLINK-30646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-30646: Description: For Hive 2.3.9, if a custom {{hive-site.xml}} is presented in {{$HIVE_HOME/conf}}, w

[jira] [Created] (FLINK-30646) Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented

Caizhi Weng created FLINK-30646: --- Summary: Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented Key: FLINK-30646 URL: https://issues.apache.org/jira/browse/FLINK-30646

[jira] [Created] (FLINK-30620) Table Store Hive catalog supports specifying custom Hive metastore client

Caizhi Weng created FLINK-30620: --- Summary: Table Store Hive catalog supports specifying custom Hive metastore client Key: FLINK-30620 URL: https://issues.apache.org/jira/browse/FLINK-30620 Project: Flin

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

[ https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30603. --- Resolution: Fixed master: b7188bcc46989c66e44f1fb04cd45972e1a6fe50 release-0.3: ad164c32fca33c365192

[jira] [Closed] (FLINK-30611) Expire snapshot should be reentrant

[ https://issues.apache.org/jira/browse/FLINK-30611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30611. --- Resolution: Fixed master: 929a411f29f4fc76dfead6e716daae56c165724c release-0.3: 1f0f28c3cf9c680ba929

[jira] [Assigned] (FLINK-30611) Expire snapshot should be reentrant

[ https://issues.apache.org/jira/browse/FLINK-30611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-30611: --- Assignee: Caizhi Weng > Expire snapshot should be reentrant > -

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

[ https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-30603: --- Assignee: Caizhi Weng > CompactActionITCase in table store is unstable > --

[jira] [Created] (FLINK-30589) Snapshot expiration should be skipped in Table Store dedicated writer jobs

Caizhi Weng created FLINK-30589: --- Summary: Snapshot expiration should be skipped in Table Store dedicated writer jobs Key: FLINK-30589 URL: https://issues.apache.org/jira/browse/FLINK-30589 Project: Fli

[jira] [Closed] (FLINK-30573) Table Store dedicated compact job may skip some records when checkpoint interval is long

[ https://issues.apache.org/jira/browse/FLINK-30573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30573. --- Resolution: Fixed master: 8fdbbd4e8c22a82d79509cab0add4a6aa7331672 release-0.3: 1ba8f372a05d64e7370f

[jira] [Created] (FLINK-30573) Table Store dedicated compact job may skip some records when checkpoint interval is long

Caizhi Weng created FLINK-30573: --- Summary: Table Store dedicated compact job may skip some records when checkpoint interval is long Key: FLINK-30573 URL: https://issues.apache.org/jira/browse/FLINK-30573

[jira] [Closed] (FLINK-30521) Improve `Altering Tables` of Doc

[ https://issues.apache.org/jira/browse/FLINK-30521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30521. --- Resolution: Fixed master: 659a5ce4b1b7a45c506391476b3b67396346403f release-0.3: cfd132362b14ba66b41d

[jira] [Updated] (FLINK-30521) Improve `Altering Tables` of Doc

[ https://issues.apache.org/jira/browse/FLINK-30521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-30521: Fix Version/s: table-store-0.3.0 table-store-0.4.0 > Improve `Altering Tables`

[jira] [Assigned] (FLINK-30521) Improve `Altering Tables` of Doc

[ https://issues.apache.org/jira/browse/FLINK-30521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-30521: --- Assignee: yuzelin > Improve `Altering Tables` of Doc > > >

[jira] [Updated] (FLINK-30521) Improve `Altering Tables` of Doc

[ https://issues.apache.org/jira/browse/FLINK-30521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-30521: Affects Version/s: table-store-0.3.0 > Improve `Altering Tables` of Doc >

[jira] [Closed] (FLINK-30506) Add documentation for writing Table Store with Spark3

[ https://issues.apache.org/jira/browse/FLINK-30506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30506. --- Resolution: Fixed master: 33c30f2e79e85ee15130320d6e712601c1b44d6c release-0.3: d02276de2fdcf90b50b3

[jira] [Created] (FLINK-30506) Add documentation for writing Table Store with Spark3

Caizhi Weng created FLINK-30506: --- Summary: Add documentation for writing Table Store with Spark3 Key: FLINK-30506 URL: https://issues.apache.org/jira/browse/FLINK-30506 Project: Flink Issue Typ

[jira] [Closed] (FLINK-30504) Fix UnsupportedFileSystemSchemeException when writing Table Store on OSS with other engines

[ https://issues.apache.org/jira/browse/FLINK-30504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30504. --- Assignee: Caizhi Weng Resolution: Fixed master: 929c1110bdbf521ad0a9eb09a65d33f76a2b5990 relea

[jira] [Created] (FLINK-30504) Fix UnsupportedFileSystemSchemeException when writing Table Store on OSS with other engines

Caizhi Weng created FLINK-30504: --- Summary: Fix UnsupportedFileSystemSchemeException when writing Table Store on OSS with other engines Key: FLINK-30504 URL: https://issues.apache.org/jira/browse/FLINK-30504

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

[ https://issues.apache.org/jira/browse/FLINK-30247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30247. --- Resolution: Fixed master: 7e9cf0dd907c84b67850503ff61e27944363d06b release-0.3: b7d7518e07cfdd0e5705

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

[ https://issues.apache.org/jira/browse/FLINK-30247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-30247: --- Assignee: Shammon > Introduce Time Travel reading for table store > ---

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651905#comment-17651905 ] Caizhi Weng commented on FLINK-27246: - Hi [~KristoffSC]! Sorry for the long delay a

[jira] [Closed] (FLINK-30458) Refactor Table Store Documentation

[ https://issues.apache.org/jira/browse/FLINK-30458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30458. --- Resolution: Fixed master: 4c607a7356a5fd43364f93d70264d1ede98113ab > Refactor Table Store Documenta

[jira] [Assigned] (FLINK-30453) Fix 'can't find CatalogFactory' error when using FLINK sql-client to add table store bundle jar

[ https://issues.apache.org/jira/browse/FLINK-30453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-30453: --- Assignee: yuzelin > Fix 'can't find CatalogFactory' error when using FLINK sql-client to ad

[jira] [Closed] (FLINK-30453) Fix 'can't find CatalogFactory' error when using FLINK sql-client to add table store bundle jar

[ https://issues.apache.org/jira/browse/FLINK-30453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30453. --- Resolution: Fixed master: 7e0d55ff3dc9fd48455b17d9a439647b0554d020 > Fix 'can't find CatalogFactory

[jira] [Created] (FLINK-30458) Refactor Table Store Documentation

Caizhi Weng created FLINK-30458: --- Summary: Refactor Table Store Documentation Key: FLINK-30458 URL: https://issues.apache.org/jira/browse/FLINK-30458 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-30212) Introduce a TableStoreCompactJob class for users to submit compact jobs in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30212. --- Resolution: Fixed master: 15af711a1bf50b2d612b439a27225c8ad42acb1d > Introduce a TableStoreCompactJ

[jira] [Closed] (FLINK-30204) Table Store support separated compact jobs

[ https://issues.apache.org/jira/browse/FLINK-30204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30204. --- Resolution: Fixed > Table Store support separated compact jobs > ---

[jira] [Closed] (FLINK-30410) Rename 'full' to 'latest-full' and 'compacted' to 'compacted-full' for scan.mode in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30410. --- Resolution: Fixed master: e6156e2f2998a5c7227f0a40512f03312f041e0a > Rename 'full' to 'latest-full'

[jira] [Created] (FLINK-30410) Rename 'full' to 'latest-full' and 'compacted' to 'compacted-full' for scan.mode in Table Store

Caizhi Weng created FLINK-30410: --- Summary: Rename 'full' to 'latest-full' and 'compacted' to 'compacted-full' for scan.mode in Table Store Key: FLINK-30410 URL: https://issues.apache.org/jira/browse/FLINK-30410

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

[ https://issues.apache.org/jira/browse/FLINK-30398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30398. --- Resolution: Fixed master: 54fd3ab2d16999d628faf4ff62c701b12ca20725 > Introduce S3 support for table

[jira] [Closed] (FLINK-30211) Introduce CompactStoreSink for compact jobs in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30211. --- Resolution: Fixed master: 422c409b36efcd0e75fdde61b0601f405b18e3ef > Introduce CompactStoreSink for

[jira] [Closed] (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 ] Caizhi Weng closed FLINK-30395. --- Resolution: Fixed master: 0620350d292600b11ba97779bfdb8869b87597db > Refactor module name and docum

[jira] [Closed] (FLINK-30210) Refactor StoreCompactOperator to accept records containing partitions and buckets in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30210. --- Resolution: Fixed master: 2073bd66a4e41ac47a98b0c0370b0ccdeb516c62, 333bb8dad697d65e70a4d672748bc1e

[jira] [Closed] (FLINK-30209) Introduce CompactFileStoreSource for compact jobs of Table Store

[ https://issues.apache.org/jira/browse/FLINK-30209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30209. --- Resolution: Fixed master: 20dd568f3c2a9b2afd4cb5eb512cd24976602e27 > Introduce CompactFileStoreSour

[jira] [Closed] (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 ] Caizhi Weng closed FLINK-30333. --- Resolution: Fixed master: e33f36ff07d13e55d26da81ebbc916d1fe0c2e15 > Supports lookup a partial-upda

[jira] [Closed] (FLINK-30294) Change table property key 'log.scan' to 'startup.mode' and add a default startup mode in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30294. --- Resolution: Fixed master: dadd735d362d355d60b737bf2c9669cb2fc880f6 > Change table property key 'log

[jira] [Created] (FLINK-30294) Change table property key 'log.scan' to 'startup.mode' and add a default startup mode in Table Store

Caizhi Weng created FLINK-30294: --- Summary: Change table property key 'log.scan' to 'startup.mode' and add a default startup mode in Table Store Key: FLINK-30294 URL: https://issues.apache.org/jira/browse/FLINK-30294

[jira] [Closed] (FLINK-30206) Allow FileStoreScan to read incremental changes from OVERWRITE snapshot in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30206. --- Resolution: Fixed master: c7bc1fb9d1d656dd93fafe66dbef185b560a33c2 > Allow FileStoreScan to read in

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

[ https://issues.apache.org/jira/browse/FLINK-30223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30223. --- Resolution: Fixed master: 6886303b2f482f2f31c7b98221691a650c1e67d3 > Refactor Lock to provide Lock.

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

[ https://issues.apache.org/jira/browse/FLINK-30164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17639748#comment-17639748 ] Caizhi Weng commented on FLINK-30164: - master: d8eb796f035f35e1ac85ff3f657452dd2a41e

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

[ https://issues.apache.org/jira/browse/FLINK-30164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-30164: Release Note: (was: master: d8eb796f035f35e1ac85ff3f657452dd2a41e644) > Expose BucketComputer fr

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

[ https://issues.apache.org/jira/browse/FLINK-30164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30164. --- Release Note: master: d8eb796f035f35e1ac85ff3f657452dd2a41e644 Resolution: Fixed > Expose Buck

[jira] [Created] (FLINK-30212) Introduce a TableStoreCompactJob class for users to submit compact jobs in Table Store

Caizhi Weng created FLINK-30212: --- Summary: Introduce a TableStoreCompactJob class for users to submit compact jobs in Table Store Key: FLINK-30212 URL: https://issues.apache.org/jira/browse/FLINK-30212

[jira] [Created] (FLINK-30211) Introduce CompactStoreSink for compact jobs in Table Store

Caizhi Weng created FLINK-30211: --- Summary: Introduce CompactStoreSink for compact jobs in Table Store Key: FLINK-30211 URL: https://issues.apache.org/jira/browse/FLINK-30211 Project: Flink Issu

[jira] [Created] (FLINK-30210) Refactor StoreCompactOperator to accept records containing partitions and buckets in Table Store

Caizhi Weng created FLINK-30210: --- Summary: Refactor StoreCompactOperator to accept records containing partitions and buckets in Table Store Key: FLINK-30210 URL: https://issues.apache.org/jira/browse/FLINK-30210

[jira] [Created] (FLINK-30209) Introduce CompactFileStoreSource for compact jobs of Table Store

Caizhi Weng created FLINK-30209: --- Summary: Introduce CompactFileStoreSource for compact jobs of Table Store Key: FLINK-30209 URL: https://issues.apache.org/jira/browse/FLINK-30209 Project: Flink

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

Caizhi Weng created FLINK-30207: --- Summary: Move split initialization and discovery logic fully into SnapshotEnumerator in Table Store Key: FLINK-30207 URL: https://issues.apache.org/jira/browse/FLINK-30207

[jira] [Created] (FLINK-30206) Allow FileStoreScan to read incremental changes from OVERWRITE snapshot in Table Store

Caizhi Weng created FLINK-30206: --- Summary: Allow FileStoreScan to read incremental changes from OVERWRITE snapshot in Table Store Key: FLINK-30206 URL: https://issues.apache.org/jira/browse/FLINK-30206

[jira] [Updated] (FLINK-30204) Table Store support separated compact jobs

[ https://issues.apache.org/jira/browse/FLINK-30204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-30204: Description: Currently table store sinks will write and compact data files from the same job. Whi

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

Caizhi Weng created FLINK-30205: --- Summary: Modify compact interface for TableWrite and FileStoreWrite to support normal compaction in Table Store Key: FLINK-30205 URL: https://issues.apache.org/jira/browse/FLINK-302

[jira] [Created] (FLINK-30204) Table Store support separated compact jobs

Caizhi Weng created FLINK-30204: --- Summary: Table Store support separated compact jobs Key: FLINK-30204 URL: https://issues.apache.org/jira/browse/FLINK-30204 Project: Flink Issue Type: New Feat

[jira] [Closed] (FLINK-30143) Table Store fails when temporary directory is a symlink

[ https://issues.apache.org/jira/browse/FLINK-30143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30143. --- Resolution: Duplicate > Table Store fails when temporary directory is a symlink > --

[jira] [Created] (FLINK-30143) Table Store fails when temporary directory is a symlink

Caizhi Weng created FLINK-30143: --- Summary: Table Store fails when temporary directory is a symlink Key: FLINK-30143 URL: https://issues.apache.org/jira/browse/FLINK-30143 Project: Flink Issue T

[jira] [Assigned] (FLINK-30012) A typo in official Table Store document.

[ https://issues.apache.org/jira/browse/FLINK-30012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-30012: --- Assignee: Caizhi Weng > A typo in official Table Store document. >

  1   2   3   4   5   6   7   8   >