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
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
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
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
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
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
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
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
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:
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
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:
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
Caizhi Weng created FLINK-29968:
---
Summary: Update streaming query document for Table Store to
include full compaction changelog producer
Key: FLINK-29968
URL: https://issues.apache.org/jira/browse/FLINK-29968
Caizhi Weng created FLINK-29943:
---
Summary: Bump Table Store 0.2 Flink version to 1.15.2
Key: FLINK-29943
URL: https://issues.apache.org/jira/browse/FLINK-29943
Project: Flink
Issue Type: Improv
Caizhi Weng created FLINK-29916:
---
Summary: Levels in Table Store may mistakenly ignore level 0 files
when two files have the same sequence number
Key: FLINK-29916
URL: https://issues.apache.org/jira/browse/FLINK-299
Caizhi Weng created FLINK-29876:
---
Summary: Explicitly throw exception from Table Store sink when
unaligned checkpoint is enabled
Key: FLINK-29876
URL: https://issues.apache.org/jira/browse/FLINK-29876
P
Caizhi Weng created FLINK-29842:
---
Summary: Change commitIdentifier in Table Store snapshot to long
value
Key: FLINK-29842
URL: https://issues.apache.org/jira/browse/FLINK-29842
Project: Flink
Caizhi Weng created FLINK-29840:
---
Summary: Old record may overwrite new record in Table Store when
snapshot committing is slow
Key: FLINK-29840
URL: https://issues.apache.org/jira/browse/FLINK-29840
Pro
Caizhi Weng created FLINK-29805:
---
Summary: Table Store sink continuously fails with "Trying to add
file which is already added" when snapshot committing is slow
Key: FLINK-29805
URL: https://issues.apache.org/jira/b
Caizhi Weng created FLINK-29792:
---
Summary: FileStoreCommitTest is unstable and may stuck
Key: FLINK-29792
URL: https://issues.apache.org/jira/browse/FLINK-29792
Project: Flink
Issue Type: Bug
Caizhi Weng created FLINK-29773:
---
Summary: PreAggregationITCase.LastValueAggregation and
PreAggregationITCase.LastNonNullValueAggregation are unstable
Key: FLINK-29773
URL: https://issues.apache.org/jira/browse/FLIN
Caizhi Weng created FLINK-29752:
---
Summary: Modify Flink Table Store connector to trigger full
compaction constantly when full changelog is needed
Key: FLINK-29752
URL: https://issues.apache.org/jira/browse/FLINK-297
Caizhi Weng created FLINK-29714:
---
Summary: Merge TableWrite and TableCompact into one interface
Key: FLINK-29714
URL: https://issues.apache.org/jira/browse/FLINK-29714
Project: Flink
Issue Type
Caizhi Weng created FLINK-29698:
---
Summary: Job Manager fails with FileAlreadyExistsException if
java.io.tmpdir points to a symbolic link
Key: FLINK-29698
URL: https://issues.apache.org/jira/browse/FLINK-29698
Caizhi Weng created FLINK-29612:
---
Summary: Extract changelog files out of DataFileMeta#extraFiles
Key: FLINK-29612
URL: https://issues.apache.org/jira/browse/FLINK-29612
Project: Flink
Issue Ty
Caizhi Weng created FLINK-29297:
---
Summary: Group Table Store file writers into SingleFileWriter and
RollingFileWriter
Key: FLINK-29297
URL: https://issues.apache.org/jira/browse/FLINK-29297
Project: Fli
Caizhi Weng created FLINK-29294:
---
Summary: Introduce a CompactTask for full compaction
Key: FLINK-29294
URL: https://issues.apache.org/jira/browse/FLINK-29294
Project: Flink
Issue Type: Sub-tas
Caizhi Weng created FLINK-29293:
---
Summary: Introduce a MergeFunction for full compaction
Key: FLINK-29293
URL: https://issues.apache.org/jira/browse/FLINK-29293
Project: Flink
Issue Type: Sub-t
Caizhi Weng created FLINK-29292:
---
Summary: Change MergeFunction to produce not only KeyValues
Key: FLINK-29292
URL: https://issues.apache.org/jira/browse/FLINK-29292
Project: Flink
Issue Type:
Caizhi Weng created FLINK-29291:
---
Summary: Change DataFileWriter into a factory to create writers
Key: FLINK-29291
URL: https://issues.apache.org/jira/browse/FLINK-29291
Project: Flink
Issue Ty
Caizhi Weng created FLINK-29290:
---
Summary: Produce changelog during full compaction in Table Store
Key: FLINK-29290
URL: https://issues.apache.org/jira/browse/FLINK-29290
Project: Flink
Issue T
Caizhi Weng created FLINK-29142:
---
Summary: round(float, int) fails to compile in Flink 1.14
Key: FLINK-29142
URL: https://issues.apache.org/jira/browse/FLINK-29142
Project: Flink
Issue Type: Bu
Caizhi Weng created FLINK-29071:
---
Summary: Fix Table Store Hive CDH support
Key: FLINK-29071
URL: https://issues.apache.org/jira/browse/FLINK-29071
Project: Flink
Issue Type: Bug
Comp
Caizhi Weng created FLINK-28967:
---
Summary: Fix Hive multi-version support for Table Store
Key: FLINK-28967
URL: https://issues.apache.org/jira/browse/FLINK-28967
Project: Flink
Issue Type: Bug
Caizhi Weng created FLINK-28760:
---
Summary: Hive table store support can't be fully enabled by ADD
JAR statement
Key: FLINK-28760
URL: https://issues.apache.org/jira/browse/FLINK-28760
Project: Flink
Caizhi Weng created FLINK-28730:
---
Summary: Add Tez execution engine test for Table Store Hive
connector
Key: FLINK-28730
URL: https://issues.apache.org/jira/browse/FLINK-28730
Project: Flink
I
Caizhi Weng created FLINK-28717:
---
Summary: Table Store Hive connector will throw exception if
primary key fields are not selected
Key: FLINK-28717
URL: https://issues.apache.org/jira/browse/FLINK-28717
Caizhi Weng created FLINK-28700:
---
Summary: Table store sink fails to commit for Flink 1.14 batch job
Key: FLINK-28700
URL: https://issues.apache.org/jira/browse/FLINK-28700
Project: Flink
Issue
Caizhi Weng created FLINK-28662:
---
Summary: Compaction may block job cancelling
Key: FLINK-28662
URL: https://issues.apache.org/jira/browse/FLINK-28662
Project: Flink
Issue Type: Improvement
Caizhi Weng created FLINK-28605:
---
Summary: Throw exception intentionally when new snapshots are
committed during restore
Key: FLINK-28605
URL: https://issues.apache.org/jira/browse/FLINK-28605
Project:
Caizhi Weng created FLINK-28582:
---
Summary: LSM tree structure may be incorrect when multiple jobs
are committing into the same bucket
Key: FLINK-28582
URL: https://issues.apache.org/jira/browse/FLINK-28582
Caizhi Weng created FLINK-28190:
---
Summary: NullPointerException is thrown if the intermediate result
of nesting UDFs is used
Key: FLINK-28190
URL: https://issues.apache.org/jira/browse/FLINK-28190
Proje
Caizhi Weng created FLINK-28079:
---
Summary: Check Hive DDL against table store schema when creating
table
Key: FLINK-28079
URL: https://issues.apache.org/jira/browse/FLINK-28079
Project: Flink
Caizhi Weng created FLINK-28020:
---
Summary: Refactor Flink connector for table store with
FileStoreTable
Key: FLINK-28020
URL: https://issues.apache.org/jira/browse/FLINK-28020
Project: Flink
I
Caizhi Weng created FLINK-28014:
---
Summary: Extract snapshot related methods to SnapshotManager
Key: FLINK-28014
URL: https://issues.apache.org/jira/browse/FLINK-28014
Project: Flink
Issue Type:
Caizhi Weng created FLINK-27973:
---
Summary: Introduce TableWrite and TableCommit as an abstraction
layer above FileStore for writing RowData
Key: FLINK-27973
URL: https://issues.apache.org/jira/browse/FLINK-27973
Caizhi Weng created FLINK-27957:
---
Summary: Extract AppendOnlyFileStore out of KeyValueFileStore
Key: FLINK-27957
URL: https://issues.apache.org/jira/browse/FLINK-27957
Project: Flink
Issue Type
Caizhi Weng created FLINK-27875:
---
Summary: Introduce TableScan and TableRead as an abstraction layer
above FileStore for reading RowData
Key: FLINK-27875
URL: https://issues.apache.org/jira/browse/FLINK-27875
Caizhi Weng created FLINK-27863:
---
Summary: Refactor RecordReader and RecordIterator in table store
into generic types
Key: FLINK-27863
URL: https://issues.apache.org/jira/browse/FLINK-27863
Project: Fli
Caizhi Weng created FLINK-27835:
---
Summary: Introduce LeafPredicate interface and children method in
Predicate
Key: FLINK-27835
URL: https://issues.apache.org/jira/browse/FLINK-27835
Project: Flink
Caizhi Weng created FLINK-27814:
---
Summary: Add an abstraction layer for connectors to read and write
row data instead of key-values
Key: FLINK-27814
URL: https://issues.apache.org/jira/browse/FLINK-27814
Caizhi Weng created FLINK-27739:
---
Summary: Add benchmark module for table store
Key: FLINK-27739
URL: https://issues.apache.org/jira/browse/FLINK-27739
Project: Flink
Issue Type: Improvement
Caizhi Weng created FLINK-27629:
---
Summary: Table Store throws NullPointerException when pushing down
NotEqual predicate to a column consisting of nulls
Key: FLINK-27629
URL: https://issues.apache.org/jira/browse/FLI
Caizhi Weng created FLINK-27628:
---
Summary: Table Store records and fetches incorrect results with NaN
Key: FLINK-27628
URL: https://issues.apache.org/jira/browse/FLINK-27628
Project: Flink
Issu
Caizhi Weng created FLINK-27627:
---
Summary: Incorrect result when order by (string, double) pair with
NaN values
Key: FLINK-27627
URL: https://issues.apache.org/jira/browse/FLINK-27627
Project: Flink
Caizhi Weng created FLINK-27589:
---
Summary: Fix incorrect implementation of
TableStoreDateObjectInspector
Key: FLINK-27589
URL: https://issues.apache.org/jira/browse/FLINK-27589
Project: Flink
Caizhi Weng created FLINK-27580:
---
Summary: Implement filter pushdown for TableStoreHiveStorageHandler
Key: FLINK-27580
URL: https://issues.apache.org/jira/browse/FLINK-27580
Project: Flink
Issu
Caizhi Weng created FLINK-27562:
---
Summary: Creating HDFS table in SQL client throws
UnsupportedFileSystemSchemeException even if hadoop jar is added through --jar
argument
Key: FLINK-27562
URL: https://issues.apach
Caizhi Weng created FLINK-27542:
---
Summary: Add end to end tests for Hive to read external table
store files
Key: FLINK-27542
URL: https://issues.apache.org/jira/browse/FLINK-27542
Project: Flink
Caizhi Weng created FLINK-27439:
---
Summary: Fix ClassNotFoundException when using array type in table
store
Key: FLINK-27439
URL: https://issues.apache.org/jira/browse/FLINK-27439
Project: Flink
Caizhi Weng created FLINK-27408:
---
Summary: Package Flink runtime dependencies into associated table
store modules instead of flink-table-store-dist
Key: FLINK-27408
URL: https://issues.apache.org/jira/browse/FLINK-2
Caizhi Weng created FLINK-27286:
---
Summary: Fix table store connector throws ClassNotFoundException:
org.apache.flink.table.store.shaded.org.apache.flink.connector.file.table.RowDataPartitionComputer
Key: FLINK-27286
Caizhi Weng created FLINK-27283:
---
Summary: Add end to end tests for table store
Key: FLINK-27283
URL: https://issues.apache.org/jira/browse/FLINK-27283
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-27139:
---
Summary: FileStoreCommitImpl#filterCommitted should exit when
faced with expired files
Key: FLINK-27139
URL: https://issues.apache.org/jira/browse/FLINK-27139
Project:
Caizhi Weng created FLINK-27136:
---
Summary: Disable rolling file when writing level 0 sst files
Key: FLINK-27136
URL: https://issues.apache.org/jira/browse/FLINK-27136
Project: Flink
Issue Type:
Caizhi Weng created FLINK-27135:
---
Summary: Rename 'file.path' table option in table store to 'path'
Key: FLINK-27135
URL: https://issues.apache.org/jira/browse/FLINK-27135
Project: Flink
Issue
Caizhi Weng created FLINK-27089:
---
Summary: Calling TRY_CAST with an invalid value throws
IndexOutOfBounds Exception.
Key: FLINK-27089
URL: https://issues.apache.org/jira/browse/FLINK-27089
Project: Flin
Caizhi Weng created FLINK-27085:
---
Summary: Introduce snapshot.num-retained.min option
Key: FLINK-27085
URL: https://issues.apache.org/jira/browse/FLINK-27085
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-27070:
---
Summary: Reuse FileFormat instead of DecodingFormat/EncodingFormat
to ensure thread safety.
Key: FLINK-27070
URL: https://issues.apache.org/jira/browse/FLINK-27070
Proj
Caizhi Weng created FLINK-27004:
---
Summary: Use '.' instead of
'file..' in table properties of managed table
Key: FLINK-27004
URL: https://issues.apache.org/jira/browse/FLINK-27004
Project: Flink
Caizhi Weng created FLINK-26703:
---
Summary: Introduce flink-table-store-dist module for packaging
Key: FLINK-26703
URL: https://issues.apache.org/jira/browse/FLINK-26703
Project: Flink
Issue Typ
Caizhi Weng created FLINK-26648:
---
Summary: Ban dependencies on flink-table-planner and depend on
flink-table-planner-loader instead
Key: FLINK-26648
URL: https://issues.apache.org/jira/browse/FLINK-26648
Caizhi Weng created FLINK-26544:
---
Summary: Apply key & value filter in FileStoreScanImpl
Key: FLINK-26544
URL: https://issues.apache.org/jira/browse/FLINK-26544
Project: Flink
Issue Type: Sub-t
Caizhi Weng created FLINK-26526:
---
Summary: Record hasNull and allNull instead of nullCount in
fieldStats
Key: FLINK-26526
URL: https://issues.apache.org/jira/browse/FLINK-26526
Project: Flink
Caizhi Weng created FLINK-26442:
---
Summary: Allow ManifestFile to write a list of ManifestFileMeta
into multiple files if too many.
Key: FLINK-26442
URL: https://issues.apache.org/jira/browse/FLINK-26442
Caizhi Weng created FLINK-26346:
---
Summary: Add statistics collecting to sst files
Key: FLINK-26346
URL: https://issues.apache.org/jira/browse/FLINK-26346
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-26277:
---
Summary: Java docs & implementation of TimestampColumnReader are
contradicting
Key: FLINK-26277
URL: https://issues.apache.org/jira/browse/FLINK-26277
Project: Flink
Caizhi Weng created FLINK-26066:
---
Summary: Introduce FileStoreRead
Key: FLINK-26066
URL: https://issues.apache.org/jira/browse/FLINK-26066
Project: Flink
Issue Type: Sub-task
Componen
Caizhi Weng created FLINK-26031:
---
Summary: Support projection pushdown on keys and values in sst
file readers
Key: FLINK-26031
URL: https://issues.apache.org/jira/browse/FLINK-26031
Project: Flink
Caizhi Weng created FLINK-26001:
---
Summary: Implement ProjectableDecodingFormat for avro bulk format
Key: FLINK-26001
URL: https://issues.apache.org/jira/browse/FLINK-26001
Project: Flink
Issue
Caizhi Weng created FLINK-25994:
---
Summary: Implement FileStoreExpire
Key: FLINK-25994
URL: https://issues.apache.org/jira/browse/FLINK-25994
Project: Flink
Issue Type: Sub-task
Compon
Caizhi Weng created FLINK-25876:
---
Summary: Implement overwrite in FileStoreScanImpl
Key: FLINK-25876
URL: https://issues.apache.org/jira/browse/FLINK-25876
Project: Flink
Issue Type: Sub-task
1 - 100 of 220 matches
Mail list logo
