[jira] [Created] (FLINK-31461) Supports schema historical version expiring

Shammon created FLINK-31461: --- Summary: Supports schema historical version expiring Key: FLINK-31461 URL: https://issues.apache.org/jira/browse/FLINK-31461 Project: Flink Issue Type: Improvement

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

Shammon created FLINK-31412: --- Summary: HiveCatalog rollback schema if alter table failed in table store Key: FLINK-31412 URL: https://issues.apache.org/jira/browse/FLINK-31412 Project: Flink Issue

[jira] [Commented] (FLINK-31368) Move operation execution logic out from TableEnvironmentImpl

[ https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697814#comment-17697814 ] Shammon commented on FLINK-31368: - Hi [~jark] +1 for this proposal. In fact, there are s

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

[ https://issues.apache.org/jira/browse/FLINK-31309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696007#comment-17696007 ] Shammon commented on FLINK-31309: - [~lzljs3620320] Please help to assign to me, thanks

[jira] [Commented] (FLINK-28691) Improve cache hit rate of generated class

[ https://issues.apache.org/jira/browse/FLINK-28691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695973#comment-17695973 ] Shammon commented on FLINK-28691: - Hi [~jark] We found the metaspace fullgc problem in c

[jira] [Commented] (FLINK-31308) JobManager's metaspace out-of-memory when submit a flinksessionjobs

[ https://issues.apache.org/jira/browse/FLINK-31308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695968#comment-17695968 ] Shammon commented on FLINK-31308: - I think it's a same kind of issue in https://issues.

[jira] [Updated] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-31275: Summary: Flink supports reporting and storage of source/sink tables relationship (was: Flink supports rep

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695938#comment-17695938 ] Shammon commented on FLINK-31275: - [~jark] Get. In order to describe what I want more ac

[jira] [Updated] (FLINK-31275) Flink supports reporting and storage of source/sink tables

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-31275: Description: Currently flink generates job id in `JobGraph` which can identify a job. On the other hand, f

[jira] [Updated] (FLINK-31275) Flink supports reporting and storage of source/sink tables

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-31275: Summary: Flink supports reporting and storage of source/sink tables (was: Generate planner id in planner)

[jira] [Commented] (FLINK-31275) Generate planner id in planner

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695671#comment-17695671 ] Shammon commented on FLINK-31275: - Thanks [~jark], please assign this issue to me and I

[jira] [Commented] (FLINK-31275) Generate planner id in planner

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695598#comment-17695598 ] Shammon commented on FLINK-31275: - [~jark] As described in FLIP-276, we'd like to store

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695539#comment-17695539 ] Shammon commented on FLINK-31259: - Thanks [~jark], I get it. If there is demand, I think

[jira] [Updated] (FLINK-31275) Generate planner id in planner

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-31275: Description: Currently flink generates job id in `JobGraph` which can identify a job. On the other hand, f

[jira] [Updated] (FLINK-31275) Generate planner id in planner

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-31275: Summary: Generate planner id in planner (was: Generate job id in planner) > Generate planner id in planne

[jira] [Commented] (FLINK-31275) Generate job id in planner

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694913#comment-17694913 ] Shammon commented on FLINK-31275: - Hi [~jark] [~lzljs3620320] What do you think of this

[jira] [Created] (FLINK-31275) Generate job id in planner

Shammon created FLINK-31275: --- Summary: Generate job id in planner Key: FLINK-31275 URL: https://issues.apache.org/jira/browse/FLINK-31275 Project: Flink Issue Type: Improvement Components

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694894#comment-17694894 ] Shammon commented on FLINK-31259: - [~jark] I'm not sure whether my understanding of `glo

[jira] [Created] (FLINK-31271) Introduce system database for catalog in table store

Shammon created FLINK-31271: --- Summary: Introduce system database for catalog in table store Key: FLINK-31271 URL: https://issues.apache.org/jira/browse/FLINK-31271 Project: Flink Issue Type: Improv

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

Shammon created FLINK-31270: --- Summary: Fix flink jar name in docs for table store Key: FLINK-31270 URL: https://issues.apache.org/jira/browse/FLINK-31270 Project: Flink Issue Type: Bug Co

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

Shammon created FLINK-31269: --- Summary: Split hive connector to each module of each version Key: FLINK-31269 URL: https://issues.apache.org/jira/browse/FLINK-31269 Project: Flink Issue Type: Improve

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694821#comment-17694821 ] Shammon commented on FLINK-31259: - Hi [~jark] We'd like to initialize catalogs in sessio

[jira] [Created] (FLINK-31259) Gateway supports initialization of catalog at startup

Shammon created FLINK-31259: --- Summary: Gateway supports initialization of catalog at startup Key: FLINK-31259 URL: https://issues.apache.org/jira/browse/FLINK-31259 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-31251) Deprecate deserialize method in DeserializationSchema

Shammon created FLINK-31251: --- Summary: Deprecate deserialize method in DeserializationSchema Key: FLINK-31251 URL: https://issues.apache.org/jira/browse/FLINK-31251 Project: Flink Issue Type: Impro

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

Shammon created FLINK-31204: --- Summary: HiveCatalogITCase fails due to avro conflict in table store Key: FLINK-31204 URL: https://issues.apache.org/jira/browse/FLINK-31204 Project: Flink Issue Type

[jira] [Created] (FLINK-31129) Introduce FlinkEmbeddedHiveRunner for junit5 in table store

Shammon created FLINK-31129: --- Summary: Introduce FlinkEmbeddedHiveRunner for junit5 in table store Key: FLINK-31129 URL: https://issues.apache.org/jira/browse/FLINK-31129 Project: Flink Issue Type

[jira] [Commented] (FLINK-30810) Rework the CliClientITCase to extend AbstractSqlGatewayStatementITCase

[ https://issues.apache.org/jira/browse/FLINK-30810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691003#comment-17691003 ] Shammon commented on FLINK-30810: - Hi [~fsk119] I'd like to fix this issue, can you assi

[jira] [Commented] (FLINK-31121) KafkaSink should be able to catch and ignore exp via config on/off

[ https://issues.apache.org/jira/browse/FLINK-31121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690349#comment-17690349 ] Shammon commented on FLINK-31121: - I'd like to fix it, can you assign to me? THX [~jingg

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

Shammon created FLINK-31113: --- Summary: Support AND filter for flink-orc Key: FLINK-31113 URL: https://issues.apache.org/jira/browse/FLINK-31113 Project: Flink Issue Type: Improvement Com

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

[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689709#comment-17689709 ] Shammon edited comment on FLINK-25537 at 2/16/23 11:48 AM: --- Hi

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

[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689709#comment-17689709 ] Shammon edited comment on FLINK-25537 at 2/16/23 11:48 AM: --- Hi

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

[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689709#comment-17689709 ] Shammon commented on FLINK-25537: - Hi, what's the status of this issue? I found that it

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

Shammon created FLINK-31096: --- Summary: Unify versions in pom of table store Key: FLINK-31096 URL: https://issues.apache.org/jira/browse/FLINK-31096 Project: Flink Issue Type: Improvement

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

Shammon created FLINK-31088: --- Summary: Flink free for flink-table-store-docs Key: FLINK-31088 URL: https://issues.apache.org/jira/browse/FLINK-31088 Project: Flink Issue Type: Sub-task Co

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

Shammon created FLINK-31078: --- Summary: Flink-table-planner free for flink-table-store-core Key: FLINK-31078 URL: https://issues.apache.org/jira/browse/FLINK-31078 Project: Flink Issue Type: Sub-tas

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

Shammon created FLINK-31075: --- Summary: Upgrade test units in table store to junit5 Key: FLINK-31075 URL: https://issues.apache.org/jira/browse/FLINK-31075 Project: Flink Issue Type: Sub-task

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

Shammon created FLINK-31074: --- Summary: Introduce value filter for table store Key: FLINK-31074 URL: https://issues.apache.org/jira/browse/FLINK-31074 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31039) ChangelogWithKeyFileStoreTableITCase in table store is not stable

Shammon created FLINK-31039: --- Summary: ChangelogWithKeyFileStoreTableITCase in table store is not stable Key: FLINK-31039 URL: https://issues.apache.org/jira/browse/FLINK-31039 Project: Flink Issu

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

Shammon created FLINK-31032: --- Summary: Supports AND predicate in orc format for table store Key: FLINK-31032 URL: https://issues.apache.org/jira/browse/FLINK-31032 Project: Flink Issue Type: Improv

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

Shammon created FLINK-31027: --- Summary: Introduce annotation for table store Key: FLINK-31027 URL: https://issues.apache.org/jira/browse/FLINK-31027 Project: Flink Issue Type: Sub-task Com

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

Shammon created FLINK-31012: --- Summary: Update docs for files table in table store Key: FLINK-31012 URL: https://issues.apache.org/jira/browse/FLINK-31012 Project: Flink Issue Type: Bug Co

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

Shammon created FLINK-31004: --- Summary: Introduce data input and output stream for table store Key: FLINK-31004 URL: https://issues.apache.org/jira/browse/FLINK-31004 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-31000) Upgrade test units in flink-table-store-common to junit5

Shammon created FLINK-31000: --- Summary: Upgrade test units in flink-table-store-common to junit5 Key: FLINK-31000 URL: https://issues.apache.org/jira/browse/FLINK-31000 Project: Flink Issue Type: Su

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

Shammon created FLINK-30999: --- Summary: Introduce flink-table-store-test-utils for table store Key: FLINK-30999 URL: https://issues.apache.org/jira/browse/FLINK-30999 Project: Flink Issue Type: Sub-

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

Shammon created FLINK-30997: --- Summary: Refactor tests in connector to extends AbstractTestBase Key: FLINK-30997 URL: https://issues.apache.org/jira/browse/FLINK-30997 Project: Flink Issue Type: Sub

[jira] [Updated] (FLINK-30968) Sql-client supports dynamic config to open session

[ https://issues.apache.org/jira/browse/FLINK-30968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30968: Description: Currently sql client will open session with configuration in flink-conf.yaml when it creates

[jira] [Created] (FLINK-30968) Sql-client supports dynamic config to open session

Shammon created FLINK-30968: --- Summary: Sql-client supports dynamic config to open session Key: FLINK-30968 URL: https://issues.apache.org/jira/browse/FLINK-30968 Project: Flink Issue Type: Improvem

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

Shammon created FLINK-30900: --- Summary: Introduce utils for table store Key: FLINK-30900 URL: https://issues.apache.org/jira/browse/FLINK-30900 Project: Flink Issue Type: Sub-task Componen

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

[ https://issues.apache.org/jira/browse/FLINK-30874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683660#comment-17683660 ] Shammon commented on FLINK-30874: - [~zhoupeijie] Sure! Hi [~lzljs3620320] can you help t

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

Shammon created FLINK-30891: --- Summary: Introduce Preconditions for table store Key: FLINK-30891 URL: https://issues.apache.org/jira/browse/FLINK-30891 Project: Flink Issue Type: Sub-task

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

Shammon created FLINK-30874: --- Summary: Introduce configuration for table store Key: FLINK-30874 URL: https://issues.apache.org/jira/browse/FLINK-30874 Project: Flink Issue Type: Sub-task

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

Shammon created FLINK-30820: --- Summary: Support varchar and char for spark in table store Key: FLINK-30820 URL: https://issues.apache.org/jira/browse/FLINK-30820 Project: Flink Issue Type: Improveme

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

[ https://issues.apache.org/jira/browse/FLINK-30750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30750: Description: https://github.com/apache/flink-table-store/actions/runs/3954989166/jobs/6772877033 2023-01

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

[ https://issues.apache.org/jira/browse/FLINK-30750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30750: Description: https://github.com/apache/flink-table-store/actions/runs/3954989166/jobs/6772877033 2023-01

[jira] [Commented] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678496#comment-17678496 ] Shammon commented on FLINK-30680: - Thanks [~gyfora] to create this issue. In fact out te

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

[ https://issues.apache.org/jira/browse/FLINK-30750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30750: Description: https://github.com/apache/flink-table-store/actions/runs/3954989166/jobs/6772877033 2023-01

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

Shammon created FLINK-30750: --- Summary: CompactActionITCase.testBatchCompact in table store is unstable Key: FLINK-30750 URL: https://issues.apache.org/jira/browse/FLINK-30750 Project: Flink Issue

[jira] [Created] (FLINK-30723) Introduce filter pushdown for parquet format

Shammon created FLINK-30723: --- Summary: Introduce filter pushdown for parquet format Key: FLINK-30723 URL: https://issues.apache.org/jira/browse/FLINK-30723 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30710) Fix invalid field id for nested type in spark catalog

Shammon created FLINK-30710: --- Summary: Fix invalid field id for nested type in spark catalog Key: FLINK-30710 URL: https://issues.apache.org/jira/browse/FLINK-30710 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30701) Remove SimpleTableTestHelper and use sql in SparkITCase

Shammon created FLINK-30701: --- Summary: Remove SimpleTableTestHelper and use sql in SparkITCase Key: FLINK-30701 URL: https://issues.apache.org/jira/browse/FLINK-30701 Project: Flink Issue Type: Sub

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

[ https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677208#comment-17677208 ] Shammon edited comment on FLINK-30603 at 1/16/23 7:45 AM: -- This

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

[ https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677208#comment-17677208 ] Shammon edited comment on FLINK-30603 at 1/16/23 7:45 AM: -- This

[jira] [Updated] (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 ] Shammon updated FLINK-30603: Description: https://github.com/apache/flink-table-store/actions/runs/3927960511/jobs/6715071149 Error:

[jira] [Reopened] (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 ] Shammon reopened FLINK-30603: - This test case is still unstable > CompactActionITCase in table store is unstable > ---

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

Shammon created FLINK-30603: --- Summary: CompactActionITCase in table store is unstable Key: FLINK-30603 URL: https://issues.apache.org/jira/browse/FLINK-30603 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30602) Remove FileStoreTableITCase in table store

Shammon created FLINK-30602: --- Summary: Remove FileStoreTableITCase in table store Key: FLINK-30602 URL: https://issues.apache.org/jira/browse/FLINK-30602 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-30590) Remove set default value manually for table options

[ https://issues.apache.org/jira/browse/FLINK-30590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655787#comment-17655787 ] Shammon commented on FLINK-30590: - [~nicholasjiang] Currently `CoreOptions.startupMode`

[jira] [Updated] (FLINK-30590) Remove set default value manually for table options

[ https://issues.apache.org/jira/browse/FLINK-30590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30590: Summary: Remove set default value manually for table options (was: Remove set default value manual for ta

[jira] [Created] (FLINK-30590) Remove set default value manual for table options

Shammon created FLINK-30590: --- Summary: Remove set default value manual for table options Key: FLINK-30590 URL: https://issues.apache.org/jira/browse/FLINK-30590 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-30587) Validate primary key in an append-only table in ddl

Shammon created FLINK-30587: --- Summary: Validate primary key in an append-only table in ddl Key: FLINK-30587 URL: https://issues.apache.org/jira/browse/FLINK-30587 Project: Flink Issue Type: Improve

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

[ https://issues.apache.org/jira/browse/FLINK-30516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30516: Description: Add files table in Table Store and user can query row count from `mytable$files` (was: Add f

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

[ https://issues.apache.org/jira/browse/FLINK-30516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30516: Summary: Support files table in table store (was: Add file count and row count in snapshots table) > Sup

[jira] [Commented] (FLINK-30516) Add file count and row count in snapshots table

[ https://issues.apache.org/jira/browse/FLINK-30516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654813#comment-17654813 ] Shammon commented on FLINK-30516: - For this issue, I think maybe we should add statistic

[jira] [Created] (FLINK-30516) Add file count and row count in snapshots table

Shammon created FLINK-30516: --- Summary: Add file count and row count in snapshots table Key: FLINK-30516 URL: https://issues.apache.org/jira/browse/FLINK-30516 Project: Flink Issue Type: Sub-task

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

Shammon created FLINK-30428: --- Summary: SparkReadITCase.testSnapshotsTable is unstable Key: FLINK-30428 URL: https://issues.apache.org/jira/browse/FLINK-30428 Project: Flink Issue Type: Bug

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

Shammon created FLINK-30423: --- Summary: Introduce cast executor codegen for column type evolution Key: FLINK-30423 URL: https://issues.apache.org/jira/browse/FLINK-30423 Project: Flink Issue Type: S

[jira] [Created] (FLINK-30324) Support column/partition statistics in table store

Shammon created FLINK-30324: --- Summary: Support column/partition statistics in table store Key: FLINK-30324 URL: https://issues.apache.org/jira/browse/FLINK-30324 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30323) Add statistics and support table statistics in table store

Shammon created FLINK-30323: --- Summary: Add statistics and support table statistics in table store Key: FLINK-30323 URL: https://issues.apache.org/jira/browse/FLINK-30323 Project: Flink Issue Type:

[jira] [Created] (FLINK-30322) Support table/column/partition statistics in table store

Shammon created FLINK-30322: --- Summary: Support table/column/partition statistics in table store Key: FLINK-30322 URL: https://issues.apache.org/jira/browse/FLINK-30322 Project: Flink Issue Type: Im

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

Shammon created FLINK-30319: --- Summary: Validate illegal column name in table store Key: FLINK-30319 URL: https://issues.apache.org/jira/browse/FLINK-30319 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-30303) Support max column width in sql client

Shammon created FLINK-30303: --- Summary: Support max column width in sql client Key: FLINK-30303 URL: https://issues.apache.org/jira/browse/FLINK-30303 Project: Flink Issue Type: Improvement

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

Shammon created FLINK-30288: --- Summary: Use visitor to convert predicate for orc Key: FLINK-30288 URL: https://issues.apache.org/jira/browse/FLINK-30288 Project: Flink Issue Type: Improvement

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

Shammon created FLINK-30269: --- Summary: Validate table name for metadata table Key: FLINK-30269 URL: https://issues.apache.org/jira/browse/FLINK-30269 Project: Flink Issue Type: Sub-task C

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

[ https://issues.apache.org/jira/browse/FLINK-30263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30263: Summary: Introduce schemas meta table (was: Introduce schemas table to table store) > Introduce schemas

[jira] [Updated] (FLINK-30263) Introduce schemas table to table store

[ https://issues.apache.org/jira/browse/FLINK-30263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30263: Parent: FLINK-29735 Issue Type: Sub-task (was: New Feature) > Introduce schemas table to table st

[jira] [Created] (FLINK-30263) Introduce schemas table to table store

Shammon created FLINK-30263: --- Summary: Introduce schemas table to table store Key: FLINK-30263 URL: https://issues.apache.org/jira/browse/FLINK-30263 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-30255) Throw exception for upper case fields are used in hive metastore

[ https://issues.apache.org/jira/browse/FLINK-30255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30255: Summary: Throw exception for upper case fields are used in hive metastore (was: Throw exception for upper

[jira] [Created] (FLINK-30255) Throw exception for upper case fields is used in hive metastore

Shammon created FLINK-30255: --- Summary: Throw exception for upper case fields is used in hive metastore Key: FLINK-30255 URL: https://issues.apache.org/jira/browse/FLINK-30255 Project: Flink Issue

[jira] [Created] (FLINK-30227) Add LeafEmptyFunction for predicate without fields

Shammon created FLINK-30227: --- Summary: Add LeafEmptyFunction for predicate without fields Key: FLINK-30227 URL: https://issues.apache.org/jira/browse/FLINK-30227 Project: Flink Issue Type: Improvem

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

Shammon created FLINK-30161: --- Summary: Add TableSchema validation before it is commited Key: FLINK-30161 URL: https://issues.apache.org/jira/browse/FLINK-30161 Project: Flink Issue Type: Improvemen

[jira] [Updated] (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 ] Shammon updated FLINK-29988: Component/s: Table Store > Improve upper case fields for hive metastore >

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

Shammon created FLINK-30038: --- Summary: HiveE2E test is not stable Key: FLINK-30038 URL: https://issues.apache.org/jira/browse/FLINK-30038 Project: Flink Issue Type: Bug Components: Table

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

Shammon created FLINK-30033: --- Summary: Add primary key data type validation Key: FLINK-30033 URL: https://issues.apache.org/jira/browse/FLINK-30033 Project: Flink Issue Type: Improvement

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

Shammon created FLINK-30027: --- Summary: Fields min and max in BinaryTableStats support lazy deserialization Key: FLINK-30027 URL: https://issues.apache.org/jira/browse/FLINK-30027 Project: Flink Is

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

Shammon created FLINK-30013: --- Summary: Add data type compatibility check in SchemaChange.updateColumnType Key: FLINK-30013 URL: https://issues.apache.org/jira/browse/FLINK-30013 Project: Flink Iss

[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&focusedCommentId=17630689#comment-17630689 ] Shammon commented on FLINK-27846: - Thanks [~lzljs3620320] , then we can transform differ

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

Shammon created FLINK-29930: --- Summary: ParquetFileStatsExtractorTest is unstable Key: FLINK-29930 URL: https://issues.apache.org/jira/browse/FLINK-29930 Project: Flink Issue Type: Bug Com

[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&focusedCommentId=17630272#comment-17630272 ] Shammon edited comment on FLINK-27846 at 11/8/22 10:49 AM: --- Hi

[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&focusedCommentId=17630272#comment-17630272 ] Shammon commented on FLINK-27846: - Hi [~lzljs3620320] [~TsReaper] Currently flink table

[jira] [Updated] (FLINK-29832) Improve switch to default database in docs

[ https://issues.apache.org/jira/browse/FLINK-29832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-29832: Summary: Improve switch to default database in docs (was: Refactor default database name in flink table s

  1   2   >