[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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [Created] (FLINK-29832) Refactor default database name in flink table store

Shammon created FLINK-29832: --- Summary: Refactor default database name in flink table store Key: FLINK-29832 URL: https://issues.apache.org/jira/browse/FLINK-29832 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29828) Support to read data from table with given snapshot id

Shammon created FLINK-29828: --- Summary: Support to read data from table with given snapshot id Key: FLINK-29828 URL: https://issues.apache.org/jira/browse/FLINK-29828 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-29823) Support create schema for table snapshot

Shammon created FLINK-29823: --- Summary: Support create schema for table snapshot Key: FLINK-29823 URL: https://issues.apache.org/jira/browse/FLINK-29823 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29820) Support to read data from table store with specify snapshot id

Shammon created FLINK-29820: --- Summary: Support to read data from table store with specify snapshot id Key: FLINK-29820 URL: https://issues.apache.org/jira/browse/FLINK-29820 Project: Flink Issue T

[jira] [Created] (FLINK-29746) Add workflow in github for micro benchmarks

Shammon created FLINK-29746: --- Summary: Add workflow in github for micro benchmarks Key: FLINK-29746 URL: https://issues.apache.org/jira/browse/FLINK-29746 Project: Flink Issue Type: Sub-task

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

Shammon created FLINK-29745: --- Summary: Split reader/writer factory for compaction in MergeTreeTest Key: FLINK-29745 URL: https://issues.apache.org/jira/browse/FLINK-29745 Project: Flink Issue Type

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

Shammon created FLINK-29702: --- Summary: Add merge tree reader and writer micro benchmarks Key: FLINK-29702 URL: https://issues.apache.org/jira/browse/FLINK-29702 Project: Flink Issue Type: Sub-task

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

Shammon created FLINK-29701: --- Summary: Refactor flink-table-store-benchmark and create micro benchmarks module Key: FLINK-29701 URL: https://issues.apache.org/jira/browse/FLINK-29701 Project: Flink

[jira] [Created] (FLINK-29637) Improve to reuse threads in TaskManager for different tasks between jobs

Shammon created FLINK-29637: --- Summary: Improve to reuse threads in TaskManager for different tasks between jobs Key: FLINK-29637 URL: https://issues.apache.org/jira/browse/FLINK-29637 Project: Flink

[jira] [Created] (FLINK-29636) Add micro benchmark module in flink table store

Shammon created FLINK-29636: --- Summary: Add micro benchmark module in flink table store Key: FLINK-29636 URL: https://issues.apache.org/jira/browse/FLINK-29636 Project: Flink Issue Type: Improvement

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

Shammon created FLINK-29385: --- Summary: AddColumn in flink table store should check the duplicate field names Key: FLINK-29385 URL: https://issues.apache.org/jira/browse/FLINK-29385 Project: Flink

[jira] [Created] (FLINK-29317) Add WebSocket in Dispatcher to support olap query submission and push results in session cluster

Shammon created FLINK-29317: --- Summary: Add WebSocket in Dispatcher to support olap query submission and push results in session cluster Key: FLINK-29317 URL: https://issues.apache.org/jira/browse/FLINK-29317

[jira] [Created] (FLINK-25794) Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager

Shammon created FLINK-25794: --- Summary: Memory pages in LazyMemorySegmentPool should be clear after they are released to MemoryManager Key: FLINK-25794 URL: https://issues.apache.org/jira/browse/FLINK-25794

[jira] [Created] (FLINK-25586) ExecutionGraphInfoStore in session cluster should split failed and successful jobs

Shammon created FLINK-25586: --- Summary: ExecutionGraphInfoStore in session cluster should split failed and successful jobs Key: FLINK-25586 URL: https://issues.apache.org/jira/browse/FLINK-25586 Project: Fli

[jira] [Created] (FLINK-25445) TaskExecutor always creates local file for task even when local state store is not used

Shammon created FLINK-25445: --- Summary: TaskExecutor always creates local file for task even when local state store is not used Key: FLINK-25445 URL: https://issues.apache.org/jira/browse/FLINK-25445 Project

[jira] [Created] (FLINK-25376) Too many JM logs in flink session cluster for olap queries

Shammon created FLINK-25376: --- Summary: Too many JM logs in flink session cluster for olap queries Key: FLINK-25376 URL: https://issues.apache.org/jira/browse/FLINK-25376 Project: Flink Issue Type:

[jira] [Created] (FLINK-25338) Improvement of connection from TM to JM in session cluster

Shammon created FLINK-25338: --- Summary: Improvement of connection from TM to JM in session cluster Key: FLINK-25338 URL: https://issues.apache.org/jira/browse/FLINK-25338 Project: Flink Issue Type:

[jira] [Created] (FLINK-25334) Manage and share gateways of taskmanagers between jobs in session cluster

Shammon created FLINK-25334: --- Summary: Manage and share gateways of taskmanagers between jobs in session cluster Key: FLINK-25334 URL: https://issues.apache.org/jira/browse/FLINK-25334 Project: Flink

[jira] [Created] (FLINK-25329) Improvement of disk operations in flink session cluster for jobs

Shammon created FLINK-25329: --- Summary: Improvement of disk operations in flink session cluster for jobs Key: FLINK-25329 URL: https://issues.apache.org/jira/browse/FLINK-25329 Project: Flink Issue

[jira] [Created] (FLINK-25328) Improvement of share memory manager between jobs if they use the same slot in TaskManager for flink olap queries

Shammon created FLINK-25328: --- Summary: Improvement of share memory manager between jobs if they use the same slot in TaskManager for flink olap queries Key: FLINK-25328 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Created] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

Shammon created FLINK-25318: --- Summary: Improvement of scheduler and execution for Flink OLAP Key: FLINK-25318 URL: https://issues.apache.org/jira/browse/FLINK-25318 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-25087) Move heartbeats from akka to the dedicated thread pool in JM

Shammon created FLINK-25087: --- Summary: Move heartbeats from akka to the dedicated thread pool in JM Key: FLINK-25087 URL: https://issues.apache.org/jira/browse/FLINK-25087 Project: Flink Issue Typ

[jira] [Created] (FLINK-25086) Move resource timeout checkers in JM from akka executors to the dedicated thread pool

Shammon created FLINK-25086: --- Summary: Move resource timeout checkers in JM from akka executors to the dedicated thread pool Key: FLINK-25086 URL: https://issues.apache.org/jira/browse/FLINK-25086 Project:

[jira] [Created] (FLINK-25085) Add a scheduled thread pool in JM and close it when job terminates

Shammon created FLINK-25085: --- Summary: Add a scheduled thread pool in JM and close it when job terminates Key: FLINK-25085 URL: https://issues.apache.org/jira/browse/FLINK-25085 Project: Flink Iss

[jira] [Created] (FLINK-25055) Support listen and notify mechanism for PartitionRequest

Shammon created FLINK-25055: --- Summary: Support listen and notify mechanism for PartitionRequest Key: FLINK-25055 URL: https://issues.apache.org/jira/browse/FLINK-25055 Project: Flink Issue Type: Im