Jingsong Lee created FLINK-31397:
Summary: Introduce write-once hash lookup store
Key: FLINK-31397
URL: https://issues.apache.org/jira/browse/FLINK-31397
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-31392:
Summary: Refactor classes code of full-compaction
Key: FLINK-31392
URL: https://issues.apache.org/jira/browse/FLINK-31392
Project: Flink
Issue Type:
Jingsong Lee created FLINK-31391:
Summary: Introduce lookup changelog producer
Key: FLINK-31391
URL: https://issues.apache.org/jira/browse/FLINK-31391
Project: Flink
Issue Type: New Feature
Jingsong Lee created FLINK-31343:
Summary: Remove JMH dependency in flink-table-store-micro-benchmark
Key: FLINK-31343
URL: https://issues.apache.org/jira/browse/FLINK-31343
Project: Flink
Jingsong Lee created FLINK-31331:
Summary: Flink 1.16 should implement new LookupFunction
Key: FLINK-31331
URL: https://issues.apache.org/jira/browse/FLINK-31331
Project: Flink
Issue Type:
Jingsong Lee created FLINK-31329:
Summary: Fix Parquet stats extractor
Key: FLINK-31329
URL: https://issues.apache.org/jira/browse/FLINK-31329
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-31315:
Summary: FlinkActionsE2eTest.testMergeInto is unstable
Key: FLINK-31315
URL: https://issues.apache.org/jira/browse/FLINK-31315
Project: Flink
Issue Type:
Jingsong Lee created FLINK-31311:
Summary: Supports Bounded Watermark streaming read
Key: FLINK-31311
URL: https://issues.apache.org/jira/browse/FLINK-31311
Project: Flink
Issue Type:
Jingsong Lee created FLINK-31310:
Summary: Force clear directory no matter what situation in
HiveCatalog.dropTable
Key: FLINK-31310
URL: https://issues.apache.org/jira/browse/FLINK-31310
Project:
Jingsong Lee created FLINK-31309:
Summary: Rollback DFS schema if hive sync fail in
HiveCatalog.createTable
Key: FLINK-31309
URL: https://issues.apache.org/jira/browse/FLINK-31309
Project: Flink
Jingsong Lee created FLINK-31292:
Summary: User HadoopUtils to get Configuration in CatalogContext
Key: FLINK-31292
URL: https://issues.apache.org/jira/browse/FLINK-31292
Project: Flink
Jingsong Lee created FLINK-31291:
Summary: Document table.exec.sink.upsert-materialize to none
Key: FLINK-31291
URL: https://issues.apache.org/jira/browse/FLINK-31291
Project: Flink
Issue
Jingsong Lee created FLINK-31290:
Summary: Remove features in documentation
Key: FLINK-31290
URL: https://issues.apache.org/jira/browse/FLINK-31290
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-31289:
Summary: Default aggregate-function for field can be
last_non_null_value
Key: FLINK-31289
URL: https://issues.apache.org/jira/browse/FLINK-31289
Project: Flink
Jingsong Lee created FLINK-31287:
Summary: Default value of 'changelog-producer.compaction-interval'
can be zero
Key: FLINK-31287
URL: https://issues.apache.org/jira/browse/FLINK-31287
Project: Flink
Jingsong Lee created FLINK-31254:
Summary: Improve the read performance for files table
Key: FLINK-31254
URL: https://issues.apache.org/jira/browse/FLINK-31254
Project: Flink
Issue Type:
Jingsong Lee created FLINK-31253:
Summary: Port itcases to Flink 1.15 and 1.14
Key: FLINK-31253
URL: https://issues.apache.org/jira/browse/FLINK-31253
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-31252:
Summary: Improve StaticFileStoreSplitEnumerator to assign batch
splits
Key: FLINK-31252
URL: https://issues.apache.org/jira/browse/FLINK-31252
Project: Flink
Jingsong Lee created FLINK-31248:
Summary: Improve documentation for append-only table
Key: FLINK-31248
URL: https://issues.apache.org/jira/browse/FLINK-31248
Project: Flink
Issue Type:
Jingsong Lee created FLINK-31236:
Summary: Limit pushdown will open useless RecordReader
Key: FLINK-31236
URL: https://issues.apache.org/jira/browse/FLINK-31236
Project: Flink
Issue Type:
Jingsong Lee created FLINK-31213:
Summary: Aggregation merge engine supports retract inputs
Key: FLINK-31213
URL: https://issues.apache.org/jira/browse/FLINK-31213
Project: Flink
Issue Type:
Jingsong Lee created FLINK-31209:
Summary: Introduce creation time to files table
Key: FLINK-31209
URL: https://issues.apache.org/jira/browse/FLINK-31209
Project: Flink
Issue Type: New
Jingsong Lee created FLINK-31201:
Summary: Provides option to sort partition for full stage in
streaming read
Key: FLINK-31201
URL: https://issues.apache.org/jira/browse/FLINK-31201
Project: Flink
Jingsong Lee created FLINK-31195:
Summary: FullChangelogStoreSinkWrite bucket writer conflicts with
rescale
Key: FLINK-31195
URL: https://issues.apache.org/jira/browse/FLINK-31195
Project: Flink
Jingsong Lee created FLINK-31179:
Summary: Make data structures serializable
Key: FLINK-31179
URL: https://issues.apache.org/jira/browse/FLINK-31179
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-31178:
Summary: Public Writer API
Key: FLINK-31178
URL: https://issues.apache.org/jira/browse/FLINK-31178
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-31117:
Summary: Split flink connector to each module of each version
Key: FLINK-31117
URL: https://issues.apache.org/jira/browse/FLINK-31117
Project: Flink
Issue
Jingsong Lee created FLINK-3:
Summary: Introduce CatalogTestBase
Key: FLINK-3
URL: https://issues.apache.org/jira/browse/FLINK-3
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-31103:
Summary: Public Table API for table store
Key: FLINK-31103
URL: https://issues.apache.org/jira/browse/FLINK-31103
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-31072:
Summary: Introduce streaming-read-atomic to ensure UB and UA
cannot be split
Key: FLINK-31072
URL: https://issues.apache.org/jira/browse/FLINK-31072
Project: Flink
Jingsong Lee created FLINK-31054:
Summary: Flink free to common codegen core shade
Key: FLINK-31054
URL: https://issues.apache.org/jira/browse/FLINK-31054
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-31038:
Summary: Avoid accessing non-TableStore tables in
HiveCatalog.listTables
Key: FLINK-31038
URL: https://issues.apache.org/jira/browse/FLINK-31038
Project: Flink
Jingsong Lee created FLINK-31037:
Summary: Table Store supports streaming reading a whole snapshot
in one checkpoint
Key: FLINK-31037
URL: https://issues.apache.org/jira/browse/FLINK-31037
Project:
Jingsong Lee created FLINK-31024:
Summary: Copy code splitter to table store from flink table
Key: FLINK-31024
URL: https://issues.apache.org/jira/browse/FLINK-31024
Project: Flink
Issue
Jingsong Lee created FLINK-31023:
Summary: Introduce ConfigOption for table store
Key: FLINK-31023
URL: https://issues.apache.org/jira/browse/FLINK-31023
Project: Flink
Issue Type:
Jingsong Lee created FLINK-31022:
Summary: Using new Serializer for table store
Key: FLINK-31022
URL: https://issues.apache.org/jira/browse/FLINK-31022
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-31009:
Summary: Add recordCount to snapshot meta
Key: FLINK-31009
URL: https://issues.apache.org/jira/browse/FLINK-31009
Project: Flink
Issue Type: New Feature
Jingsong Lee created FLINK-31002:
Summary: Provide data sampling query
Key: FLINK-31002
URL: https://issues.apache.org/jira/browse/FLINK-31002
Project: Flink
Issue Type: New Feature
Jingsong Lee created FLINK-31001:
Summary: Introduce Hive writer
Key: FLINK-31001
URL: https://issues.apache.org/jira/browse/FLINK-31001
Project: Flink
Issue Type: New Feature
Jingsong Lee created FLINK-30980:
Summary: Support s3.signer-type for S3
Key: FLINK-30980
URL: https://issues.apache.org/jira/browse/FLINK-30980
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-30979:
Summary: The buckets of the secondary partition should fall on
different tasks
Key: FLINK-30979
URL: https://issues.apache.org/jira/browse/FLINK-30979
Project: Flink
Jingsong Lee created FLINK-30882:
Summary: Introduce partition.expiration-time to automatically
delete expired partitions
Key: FLINK-30882
URL: https://issues.apache.org/jira/browse/FLINK-30882
Jingsong Lee created FLINK-30866:
Summary: Introduce FileIO for table store
Key: FLINK-30866
URL: https://issues.apache.org/jira/browse/FLINK-30866
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-30706:
Summary: Remove flink-table-common dependency for table store core
Key: FLINK-30706
URL: https://issues.apache.org/jira/browse/FLINK-30706
Project: Flink
Jingsong Lee created FLINK-30676:
Summary: Introduce Data Structures for table store
Key: FLINK-30676
URL: https://issues.apache.org/jira/browse/FLINK-30676
Project: Flink
Issue Type:
Jingsong Lee created FLINK-30632:
Summary: Introduce DataType for table store
Key: FLINK-30632
URL: https://issues.apache.org/jira/browse/FLINK-30632
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-30628:
Summary: Kerberos in HiveCatalog is not work
Key: FLINK-30628
URL: https://issues.apache.org/jira/browse/FLINK-30628
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-30611:
Summary: Expire snapshot should be reentrant
Key: FLINK-30611
URL: https://issues.apache.org/jira/browse/FLINK-30611
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-30610:
Summary: Flink-table-runtime free for disk io in flink-core
Key: FLINK-30610
URL: https://issues.apache.org/jira/browse/FLINK-30610
Project: Flink
Issue
Jingsong Lee created FLINK-30600:
Summary: Merge flink-table-store-kafka to
flink-table-store-connector
Key: FLINK-30600
URL: https://issues.apache.org/jira/browse/FLINK-30600
Project: Flink
Jingsong Lee created FLINK-30582:
Summary: Flink-avro Flink-orc free for flink-table-store-format
Key: FLINK-30582
URL: https://issues.apache.org/jira/browse/FLINK-30582
Project: Flink
Issue
Jingsong Lee created FLINK-30581:
Summary: Deprecate FileStoreTableITCase and use CatalogITCaseBase
Key: FLINK-30581
URL: https://issues.apache.org/jira/browse/FLINK-30581
Project: Flink
Jingsong Lee created FLINK-30580:
Summary: [umbrella] Refactor tests for table store
Key: FLINK-30580
URL: https://issues.apache.org/jira/browse/FLINK-30580
Project: Flink
Issue Type:
Jingsong Lee created FLINK-30572:
Summary: Make parquet as default data file format
Key: FLINK-30572
URL: https://issues.apache.org/jira/browse/FLINK-30572
Project: Flink
Issue Type:
Jingsong Lee created FLINK-30569:
Summary: File Format can not change with data file exists
Key: FLINK-30569
URL: https://issues.apache.org/jira/browse/FLINK-30569
Project: Flink
Issue Type:
Jingsong Lee created FLINK-30565:
Summary: Flink-parquet free for flink-table-store-format
Key: FLINK-30565
URL: https://issues.apache.org/jira/browse/FLINK-30565
Project: Flink
Issue Type:
Jingsong Lee created FLINK-30555:
Summary: Hive cluster can not read oss/s3 tables
Key: FLINK-30555
URL: https://issues.apache.org/jira/browse/FLINK-30555
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-30547:
Summary: Flink-table-runtime free for flink-table-store-common
Key: FLINK-30547
URL: https://issues.apache.org/jira/browse/FLINK-30547
Project: Flink
Issue
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
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
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
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
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
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
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
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
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:
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:
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
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
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:
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
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:
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:
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:
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
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
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
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
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
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
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:
Jingsong Lee created FLINK-3:
Summary: Introduce FileSystemFactory to create FileSystem from
custom configuration
Key: FLINK-3
URL: https://issues.apache.org/jira/browse/FLINK-3
Project:
Jingsong Lee created FLINK-29988:
Summary: Improve upper case fields for hive metastore
Key: FLINK-29988
URL: https://issues.apache.org/jira/browse/FLINK-29988
Project: Flink
Issue Type:
Jingsong Lee created FLINK-29987:
Summary: PartialUpdateITCase.testForeignKeyJo is unstable
Key: FLINK-29987
URL: https://issues.apache.org/jira/browse/FLINK-29987
Project: Flink
Issue Type:
Jingsong Lee created FLINK-29953:
Summary: Get rid of flink-connector-hive dependency in
flink-table-store-hive
Key: FLINK-29953
URL: https://issues.apache.org/jira/browse/FLINK-29953
Project: Flink
Jingsong Lee created FLINK-29933:
Summary: Bump Flink version to 1.16.0
Key: FLINK-29933
URL: https://issues.apache.org/jira/browse/FLINK-29933
Project: Flink
Issue Type: New Feature
Jingsong Lee created FLINK-29774:
Summary: Introduce options metadata table
Key: FLINK-29774
URL: https://issues.apache.org/jira/browse/FLINK-29774
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-29760:
Summary: Introduce snapshots metadata table
Key: FLINK-29760
URL: https://issues.apache.org/jira/browse/FLINK-29760
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-29736:
Summary: Abstract a table interface for both data and metadata
tables
Key: FLINK-29736
URL: https://issues.apache.org/jira/browse/FLINK-29736
Project: Flink
Jingsong Lee created FLINK-29735:
Summary: Introduce Metadata tables for table store
Key: FLINK-29735
URL: https://issues.apache.org/jira/browse/FLINK-29735
Project: Flink
Issue Type: New
Jingsong Lee created FLINK-29700:
Summary: Serializer to BinaryInMemorySortBuffer is wrong
Key: FLINK-29700
URL: https://issues.apache.org/jira/browse/FLINK-29700
Project: Flink
Issue Type:
Jingsong Lee created FLINK-29690:
Summary: listTables in HiveCatalog should only return table store
tables
Key: FLINK-29690
URL: https://issues.apache.org/jira/browse/FLINK-29690
Project: Flink
Jingsong Lee created FLINK-29621:
Summary: Append-only with eventual log.consistency can not work
Key: FLINK-29621
URL: https://issues.apache.org/jira/browse/FLINK-29621
Project: Flink
Issue
Jingsong Lee created FLINK-29614:
Summary: Introduce Spark writer for table store
Key: FLINK-29614
URL: https://issues.apache.org/jira/browse/FLINK-29614
Project: Flink
Issue Type: New
Jingsong Lee created FLINK-29586:
Summary: Let write buffer spillable
Key: FLINK-29586
URL: https://issues.apache.org/jira/browse/FLINK-29586
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-29554:
Summary: Add partial-update.ignore-delete option to avoid
exception after join
Key: FLINK-29554
URL: https://issues.apache.org/jira/browse/FLINK-29554
Project: Flink
Jingsong Lee created FLINK-29491:
Summary: Primary key without partition field can be supported from
full changelog
Key: FLINK-29491
URL: https://issues.apache.org/jira/browse/FLINK-29491
Project:
Jingsong Lee created FLINK-29490:
Summary: Timestamp LTZ is unsupported in table store
Key: FLINK-29490
URL: https://issues.apache.org/jira/browse/FLINK-29490
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-29412:
Summary: Connection leak in orc reader
Key: FLINK-29412
URL: https://issues.apache.org/jira/browse/FLINK-29412
Project: Flink
Issue Type: Bug
1 - 100 of 647 matches
Mail list logo