Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / apache/paimon issues and pull requests

#4109 - [flink] Support Flink Materialized Table

Pull Request - State: closed - Opened by reswqa 2 months ago

#4108 - [doc] Factor out most recent Flink version to docs config, and bump it

Pull Request - State: closed - Opened by kaygorodov 2 months ago - 2 comments

#4107 - [core] Check consumer-id cannot be blank string

Pull Request - State: closed - Opened by xuzifu666 2 months ago - 2 comments

#4106 - [flink] Check that cannot set non-existed fallback branch

Pull Request - State: closed - Opened by yuzelin 2 months ago

#4105 - [spark] Add string length check for char while writing

Pull Request - State: closed - Opened by Zouxxyy 2 months ago

#4102 - [doc] Complement the version limit of mysql-cdc Bundled jar.

Pull Request - State: closed - Opened by LinMingQiang 2 months ago

#4101 - [flink] add CreateTagFromWatermarkAction

Pull Request - State: closed - Opened by herefree 3 months ago - 1 comment

#4099 - [core] skip clean tag manifest file if exception

Pull Request - State: closed - Opened by wwj6591812 3 months ago - 1 comment

#4098 - [flink] fix the source data fetcher thread leak

Pull Request - State: closed - Opened by Aitozi 3 months ago - 3 comments

#4096 - [Feature] Add block cache for sorted lookup file store

Issue - State: open - Opened by FangYongs 3 months ago
Labels: enhancement

#4094 - [core] Revisit merge schema to fix issues

Pull Request - State: closed - Opened by ulysses-you 3 months ago - 1 comment

#4092 - [Bug] The Source Data Fetcher thread may not exit during job failover

Issue - State: closed - Opened by Aitozi 3 months ago - 2 comments
Labels: bug

#4089 - [WIP][core] cut StoreSinkWriteState when write unaware bucket table

Pull Request - State: closed - Opened by wwj6591812 3 months ago - 3 comments

#4089 - [WIP][core] cut StoreSinkWriteState when write unaware bucket table

Pull Request - State: closed - Opened by wwj6591812 3 months ago - 3 comments

#4087 - [flink][procedure] Support named argument in procedures

Pull Request - State: closed - Opened by yunfengzhou-hub 3 months ago - 5 comments

#4082 - [spark] Support dataframe v2 write with overwrite

Pull Request - State: closed - Opened by ulysses-you 3 months ago - 2 comments

#4081 - [flink] Fix that cannot create table with empty fallback branch

Pull Request - State: closed - Opened by yuzelin 3 months ago

#4074 - [core] Introduce level0FileCount for partitions table

Pull Request - State: open - Opened by MonsterChenzhuo 3 months ago - 4 comments

#4071 - [core] Introduce min/maxCompactionTime metrics

Pull Request - State: closed - Opened by MonsterChenzhuo 3 months ago

#4059 - [spark] Adjust ExpireSnapshotsProcedure param type

Pull Request - State: closed - Opened by askwang 3 months ago - 1 comment

#4052 - [flink] Support lookup join of partial-update and no changelog dim table

Pull Request - State: open - Opened by discivigour 3 months ago - 1 comment

#4045 - [Feature] Support Flink Materialized Table

Issue - State: closed - Opened by reswqa 3 months ago - 1 comment
Labels: enhancement

#4044 - [core] add parallelism argument for remove orphan files

Pull Request - State: closed - Opened by LsomeYeah 3 months ago - 1 comment

#4043 - [core] Fix caching catalog case sensitive

Pull Request - State: closed - Opened by ulysses-you 3 months ago - 4 comments

#4041 - [core] Support custom data file name prefix

Pull Request - State: closed - Opened by askwang 3 months ago - 1 comment

#4028 - [hotfix] Remove useless #withPartitionKeys call

Pull Request - State: open - Opened by yuzelin 3 months ago - 1 comment

#3994 - [Bug] Paimon 0.8 catalog with flink 1.18/1.19 and minio s3 can't create database

Issue - State: open - Opened by jalousiex 3 months ago - 3 comments
Labels: bug

#3976 - [spark] Support cross partition write

Pull Request - State: closed - Opened by Zouxxyy 3 months ago

#3941 - [Feature] [Spark] Remove support for Spark 3.1

Issue - State: closed - Opened by YannByron 3 months ago - 1 comment
Labels: enhancement

#3940 - [Feature] [Spark] Support Spark 4.0 (preview)

Issue - State: open - Opened by YannByron 3 months ago - 7 comments
Labels: enhancement

#3931 - [common] [flink] Add support for complex types in kafka debezium avro cdc action.

Pull Request - State: closed - Opened by umeshdangat 3 months ago - 2 comments

#3866 - [core]IcebergConversions addType for Timestamp and Time

Pull Request - State: open - Opened by dbac 3 months ago - 11 comments

#3791 - [feature][flink] introduce RecordAttributesProcessor for write operators

Pull Request - State: closed - Opened by yunfengzhou-hub 4 months ago - 1 comment

#3769 - [cdc] Adjust-CdcJsonDeserializationSchema

Pull Request - State: closed - Opened by MOBIN-F 4 months ago - 1 comment

#3755 - [core] fix the collect of overlapped snapshots

Pull Request - State: open - Opened by askwang 4 months ago - 3 comments

#3655 - [cdc] optimize database sync table filter logic

Pull Request - State: closed - Opened by MOBIN-F 4 months ago - 1 comment

#3599 - [Feature] Upgrade Flink CDC to 3.1.X Version

Issue - State: closed - Opened by czy006 5 months ago - 1 comment
Labels: enhancement

#3597 - [Feature] Kafka debezium json supports automatic discovery of primary keys

Pull Request - State: closed - Opened by sunxiaojian 5 months ago - 1 comment

#3558 - [Bug] mysqlcdc2paimon does not support field comment synchronization

Issue - State: closed - Opened by Pandas886 5 months ago - 3 comments
Labels: bug

#3531 - [Feature] Improve the compatibility test between the new and old versions of paimon

Issue - State: open - Opened by FangYongs 5 months ago - 1 comment
Labels: enhancement, good first issue, tests

#3432 - [doc] update totalRecordCount and deltaRecordCount in understand-files.md

Issue - State: open - Opened by wpj980205 6 months ago - 1 comment
Labels: documentation, enhancement, good first issue

#3362 - [cdc] fix paimon cdc job restart failed when schema changed

Pull Request - State: open - Opened by MOBIN-F 6 months ago - 4 comments

#3308 - [Bug] Primary key issues with MySQL

Issue - State: open - Opened by CodyPin 6 months ago - 6 comments
Labels: bug

#3236 - [Feature] Support Hive 4.0.0

Issue - State: open - Opened by BsoBird 7 months ago - 1 comment
Labels: enhancement

#3116 - [POC][Feature] Support common jdbc catalog lock for filesystem catalog

Pull Request - State: closed - Opened by sunxiaojian 8 months ago - 4 comments

#2701 - [cdc] support debezium-json format with schema for kafka sync action

Issue - State: open - Opened by zhangjun0x01 10 months ago - 13 comments
Labels: enhancement

#915 - Who is using Apache Paimon?

Issue - State: open - Opened by SteNicholas over 1 year ago - 19 comments

#100 - [FLINK-27361] Introduce retry mechanism for SnapshotFinder

Pull Request - State: closed - Opened by LadyForest over 2 years ago - 1 comment

#99 - [FLINK-27307] Flink table store support append-only ingestion without primary keys.

Pull Request - State: closed - Opened by openinx over 2 years ago - 5 comments

#98 - [FLINK-26457] Introduce PartialUpdateMergeFunction

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#97 - [FLINK-27335] Optimize async compaction in MergeTreeWriter

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#96 - [FLINK-27316] Prevent users from changing bucket number

Pull Request - State: closed - Opened by LadyForest over 2 years ago

#95 - [FLINK-27283] Add end to end tests for table store

Pull Request - State: closed - Opened by tsreaper over 2 years ago

#94 - [hotfix] Add Documentation & Getting Started

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#93 - [FLINK-27283] Add end to end tests for table store

Pull Request - State: closed - Opened by tsreaper over 2 years ago

#90 - [hotfix] Adjust the default value of write-buffer-size to 128 MB

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#89 - [FLINK-27172] Support bulk based format provided by Flink

Pull Request - State: closed - Opened by liyubin117 over 2 years ago

#88 - [hotfix] Add logs to file store compact for better tunning

Pull Request - State: closed - Opened by tsreaper over 2 years ago

#87 - [FLINK-27123] Introduce filter predicate for 'LIKE'

Pull Request - State: closed - Opened by LadyForest over 2 years ago

#86 - [FLINK-27158] Adjust default value of compaction and compress

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#85 - [FLINK-27157] Add version field to manifest entries

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#83 - [FLINK-27136] Disable rolling file when writing level 0 sst files

Pull Request - State: closed - Opened by tsreaper over 2 years ago

#82 - [FLINK-27135] Rename 'file.path' table option in table store to 'path'

Pull Request - State: closed - Opened by tsreaper over 2 years ago

#81 - [hotfix] Shade kafka dependencies

Pull Request - State: closed - Opened by tsreaper over 2 years ago

#80 - Bump checkstyle from 8.14 to 8.29

Pull Request - State: closed - Opened by dependabot[bot] over 2 years ago - 1 comment
Labels: dependencies

#79 - [hotfix] Value field should be named in value count mode

Pull Request - State: closed - Opened by LadyForest over 2 years ago

#78 - [hotfix] Fix junit4 dependency version

Pull Request - State: closed - Opened by tsreaper over 2 years ago

#77 - [hotfix] Add random group id to kafka consumer

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#76 - [FLINK-26913] Add IT case for computed column and watermark

Pull Request - State: closed - Opened by LadyForest over 2 years ago - 1 comment

#75 - [FLINK-27085] Introduce snapshot.num-retained.min option

Pull Request - State: closed - Opened by tsreaper over 2 years ago

#73 - [FLINK-26856] Add ITCase for compound primary key and multi-partition

Pull Request - State: closed - Opened by LadyForest over 2 years ago

#72 - [FLINK-26899] Introduce write/query table document for table store

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#69 - [FLINK-26857] Add ITCase for projection and filter predicate

Pull Request - State: closed - Opened by LadyForest over 2 years ago

#68 - [FLINK-26918] Add documentation build to Github Actions

Pull Request - State: closed - Opened by JingsongLi over 2 years ago - 1 comment

#67 - [FLINK-26911] Introduce parallelism setter for table store

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#66 - [FLINK-26898] Introduce creating table document for table store

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#64 - [FLINK-26877] Introduce auto type inference for filter push down

Pull Request - State: closed - Opened by LadyForest over 2 years ago

#63 - [FLINK-26867] Hybrid reading wrong because of disordered commits

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#62 - [FLINK-26863] Fix that filter predicate does not work

Pull Request - State: closed - Opened by LadyForest over 2 years ago - 1 comment

#61 - [FLINK-26860] FileStore continuous bug for delete row kind records

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#60 - [FLINK-26834] Introduce BlockingIterator to help testing

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#59 - [hotfix] Fix unstable test FileStoreReadTest#testKeyProjection

Pull Request - State: closed - Opened by tsreaper over 2 years ago

#58 - [FLINK-26669] Refactor ReadWriteTableITCase

Pull Request - State: closed - Opened by LadyForest over 2 years ago - 2 comments

#57 - [FLINK-26791] Finish projection push down for table store

Pull Request - State: closed - Opened by JingsongLi over 2 years ago

#56 - [FLINK-26778] Introduce snapshot latest and earliest hint files

Pull Request - State: closed - Opened by JingsongLi over 2 years ago - 1 comment