Ecosyste.ms: Issues
An open API service for providing issue and pull request metadata for open source projects.
GitHub / apache/flink issues and pull requests
#24121 - [FLINK-33182][table] Allow metadata columns in Ndu-analyze with ChangelogNormalize
Pull Request -
State: open - Opened by lincoln-lil 10 months ago
- 2 comments
#24120 - [FLINK-34117][bugfix][table] Fix CompactCoordinator data loss upon termination
Pull Request -
State: closed - Opened by afedulov 10 months ago
- 5 comments
#24119 - [FLINK-34134] Add tracing for restored state size and locations
Pull Request -
State: closed - Opened by StefanRRichter 10 months ago
- 1 comment
#24118 - [FLINK-34132][runtime] Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE.
Pull Request -
State: closed - Opened by JunRuiLee 10 months ago
- 3 comments
#24118 - [FLINK-34132][runtime] Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE.
Pull Request -
State: open - Opened by JunRuiLee 10 months ago
- 3 comments
#24117 - [FLINK-34133][table-planner] fix incorrect inference of minibatch interval traits
Pull Request -
State: open - Opened by zhoulii 10 months ago
- 1 comment
#24117 - [FLINK-34133][table-planner] fix incorrect inference of minibatch interval traits
Pull Request -
State: open - Opened by zhoulii 10 months ago
- 1 comment
#24116 - [FLINK-34081][configuration] Refactor all callers of deprecated `getXxx(ConfigOption<Xxx>)`, `getXxx(ConfigOption<Xxx>, Xxx)` and `setXxx(ConfigOption<Integer>, Xxx)` methods of Configuration
Pull Request -
State: closed - Opened by 1996fanrui 10 months ago
- 2 comments
#24115 - [Draft][bugfix] Move the deserialization of shuffleDescriptor to a separate …
Pull Request -
State: open - Opened by caodizhou 10 months ago
- 3 comments
#24115 - [Draft][bugfix] Move the deserialization of shuffleDescriptor to a separate …
Pull Request -
State: open - Opened by caodizhou 10 months ago
- 1 comment
#24114 - [FLINK-33517] Implement restore tests for Values node
Pull Request -
State: open - Opened by bvarghese1 10 months ago
- 1 comment
#24113 - [FLINK-34109][connectors] FileSystem sink connector restore job from historical checkpoint bugfix
Pull Request -
State: open - Opened by ParyshevSergey 10 months ago
- 2 comments
#24112 - [FLINK-34126][configuration] Correct the description of jobmanager.scheduler
Pull Request -
State: closed - Opened by JunRuiLee 10 months ago
- 2 comments
#24112 - [FLINK-34126][configuration] Correct the description of jobmanager.scheduler
Pull Request -
State: open - Opened by JunRuiLee 10 months ago
- 2 comments
#24111 - [FLINK-34119][doc] Improve description about changelog in document
Pull Request -
State: closed - Opened by masteryhx 10 months ago
- 3 comments
#24110 - [FLINK-33441] Move Union restore tests
Pull Request -
State: closed - Opened by bvarghese1 10 months ago
- 1 comment
#24109 - [FLINK-34118] Implement restore tests for Sort node
Pull Request -
State: open - Opened by bvarghese1 10 months ago
- 1 comment
#24107 - [FLINK-33850][doc] Update minor version for 1.18.1 release
Pull Request -
State: closed - Opened by JingGe 10 months ago
- 1 comment
#24106 - [FLINK-34055][table] Introduce a new annotation for named parameters
Pull Request -
State: closed - Opened by hackergin 10 months ago
- 3 comments
#24104 - [FLINK-23687][table-planner] Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys
Pull Request -
State: open - Opened by yunfan123 10 months ago
- 4 comments
#24103 - [FLINK-33974] Implement the Sink transformation depending on the new SinkV2 interfaces
Pull Request -
State: closed - Opened by pvary 10 months ago
- 2 comments
#24102 - [FLINK-31449][resourcemanager] Remove DeclarativeSlotManager related logic
Pull Request -
State: closed - Opened by huwh 10 months ago
- 2 comments
#24102 - [FLINK-31449][resourcemanager] Remove DeclarativeSlotManager related logic
Pull Request -
State: closed - Opened by huwh 10 months ago
- 2 comments
#24101 - [FLINK-33679] Fix the misleading description about RestoreMode#LEGACY
Pull Request -
State: open - Opened by Zakelly 10 months ago
- 1 comment
#24101 - [FLINK-33679] Fix the misleading description about RestoreMode#LEGACY
Pull Request -
State: closed - Opened by Zakelly 10 months ago
- 2 comments
#24100 - [FLINK-34110] Bump janino from 3.1.10 to 3.1.11
Pull Request -
State: open - Opened by snuyanzin 10 months ago
- 1 comment
Labels: component=TableSQL/Planner
#24099 - [FLINK-25054][table-planner] Extend the exception message for SHA2 function
Pull Request -
State: open - Opened by xishuaidelin 10 months ago
- 1 comment
#24099 - [FLINK-25054][table-planner] Extend the exception message for SHA2 function
Pull Request -
State: open - Opened by xishuaidelin 10 months ago
- 1 comment
#24098 - [FLINK-33221][core][config] Add config options for administrator JVM options
Pull Request -
State: closed - Opened by X-czh 10 months ago
- 4 comments
#24098 - [FLINK-33221][core][config] Add config options for administrator JVM options
Pull Request -
State: open - Opened by X-czh 10 months ago
- 4 comments
#24097 - [FLINK-34097] Remove JobMasterGateway#requestJobDetails
Pull Request -
State: open - Opened by zentol 10 months ago
- 1 comment
#24097 - [FLINK-34097] Remove JobMasterGateway#requestJobDetails
Pull Request -
State: open - Opened by zentol 10 months ago
- 1 comment
#24096 - [FLINK-33928][table-planner] Should not throw exception while creating view with specify field names
Pull Request -
State: closed - Opened by swuferhong 10 months ago
- 5 comments
#24096 - [FLINK-33928][table-planner] Should not throw exception while creating view with specify field names
Pull Request -
State: closed - Opened by swuferhong 10 months ago
- 5 comments
#24095 - [FLINK-33907][ci] Moves tests in flink-clients relying on jars into the integration-test phase
Pull Request -
State: closed - Opened by XComp 10 months ago
- 2 comments
#24094 - [BP-1.18][FLINK-33907][ci] Moves tests in flink-clients relying on jars into the integration-test phase
Pull Request -
State: closed - Opened by XComp 10 months ago
- 1 comment
#24093 - [FLINK-34078][state]Move InternalKeyContext classes from o.a.f.runtim…
Pull Request -
State: closed - Opened by ljz2051 10 months ago
- 2 comments
#24093 - [FLINK-34078][state]Move InternalKeyContext classes from o.a.f.runtim…
Pull Request -
State: closed - Opened by ljz2051 10 months ago
- 2 comments
#24092 - [FLINK-34087][tests][JUnit5 Migration] Migarate to junit5 of flink-dist module
Pull Request -
State: open - Opened by Jiabao-Sun 10 months ago
- 3 comments
#24092 - [FLINK-34087][tests][JUnit5 Migration] Migarate to junit5 of flink-dist module
Pull Request -
State: closed - Opened by Jiabao-Sun 10 months ago
- 3 comments
#24091 - [FLINK-33721][core] Extend BashJavaUtils to support reading and writing standard yaml file.
Pull Request -
State: closed - Opened by JunRuiLee 10 months ago
- 2 comments
#24090 - [FLINK-34084][config] Deprecate unused configuration in BinaryInput/OutputFormat and FileInput/OutputFormat
Pull Request -
State: open - Opened by Sxnan 10 months ago
- 1 comment
#24090 - [FLINK-34084][config] Deprecate unused configuration in BinaryInput/OutputFormat and FileInput/OutputFormat
Pull Request -
State: open - Opened by Sxnan 10 months ago
- 1 comment
#24089 - [FLINK-34083][config] Deprecate string configuration keys and unused constants in ConfigConstants
Pull Request -
State: closed - Opened by Sxnan 10 months ago
- 5 comments
#24089 - [FLINK-34083][config] Deprecate string configuration keys and unused constants in ConfigConstants
Pull Request -
State: closed - Opened by Sxnan 10 months ago
- 5 comments
#24088 - [FLINK-34080][configuration] Simplify the Configuration
Pull Request -
State: closed - Opened by 1996fanrui 10 months ago
- 4 comments
#24088 - [FLINK-34080][configuration] Simplify the Configuration
Pull Request -
State: closed - Opened by 1996fanrui 10 months ago
- 4 comments
#24087 - [FLINK-33768] Support dynamic source parallelism inference for batch jobs
Pull Request -
State: closed - Opened by SinBex 10 months ago
- 5 comments
#24087 - [FLINK-33768] Support dynamic source parallelism inference for batch jobs
Pull Request -
State: open - Opened by SinBex 10 months ago
- 5 comments
#24086 - [FLINK-34077][python] Limits some sphinxcontrib packages upper bounds
Pull Request -
State: closed - Opened by HuangXingBo 10 months ago
- 2 comments
#24085 - [FLINK-34072][scripts] Replace java command to JAVA_RUN in config.sh
Pull Request -
State: closed - Opened by yuchen-ecnu 10 months ago
- 1 comment
#24085 - [FLINK-34072][scripts] Replace java command to JAVA_RUN in config.sh
Pull Request -
State: closed - Opened by yuchen-ecnu 10 months ago
- 1 comment
#24084 - [Flink 32701] [cep] Fix CEP Operator Memory Leak Issue
Pull Request -
State: open - Opened by pdream17 10 months ago
- 5 comments
#24083 - [BP-1.18][FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot.
Pull Request -
State: closed - Opened by dmvk 10 months ago
- 1 comment
#24083 - [BP-1.18][FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot.
Pull Request -
State: closed - Opened by dmvk 10 months ago
- 1 comment
#24082 - [FLINK-34070][test] Adds dedicated tests in MiniClusterITCase for scenarios where there are not enough slots available.
Pull Request -
State: closed - Opened by XComp 10 months ago
- 2 comments
#24082 - [FLINK-34070][test] Adds dedicated tests in MiniClusterITCase for scenarios where there are not enough slots available.
Pull Request -
State: closed - Opened by XComp 10 months ago
- 2 comments
#24081 - [hotfix] Add flink-connector-hive in README
Pull Request -
State: closed - Opened by caicancai 10 months ago
- 4 comments
#24081 - [hotfix] Add flink-connector-hive in README
Pull Request -
State: closed - Opened by caicancai 10 months ago
- 4 comments
#24080 - [FLINK-33973] Add new interfaces for SinkV2 to synchronize the API with the SourceV2 API
Pull Request -
State: closed - Opened by pvary 10 months ago
- 2 comments
#24079 - [FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot.
Pull Request -
State: closed - Opened by dmvk 10 months ago
- 21 comments
#24079 - [FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot.
Pull Request -
State: closed - Opened by dmvk 10 months ago
- 20 comments
#24078 - [FLINK-33768] Support dynamic source parallelism inference for batch jobs
Pull Request -
State: closed - Opened by SinBex 10 months ago
- 3 comments
#24078 - [FLINK-33768] Support dynamic source parallelism inference for batch jobs
Pull Request -
State: closed - Opened by SinBex 10 months ago
- 3 comments
#24077 - [FLINK-34034][docs] Update the query hint docs to clarify the resolution of conflicts in kv hint and list hint
Pull Request -
State: open - Opened by swuferhong 10 months ago
- 1 comment
#24077 - [FLINK-34034][docs] Update the query hint docs to clarify the resolution of conflicts in kv hint and list hint
Pull Request -
State: closed - Opened by swuferhong 10 months ago
- 2 comments
#24076 - [FLINK-34067] Fix javacc warnings in flink-sql-parser
Pull Request -
State: closed - Opened by jnh5y 10 months ago
- 2 comments
#24075 - [FLINK-34066][table-planner] Fix LagFunction throw NPE when input argument are not null
Pull Request -
State: closed - Opened by swuferhong 10 months ago
- 4 comments
#24074 - [FLINK-31788][table] TableAggregateFunction supports emitUpdateWithRetract
Pull Request -
State: closed - Opened by LadyForest 10 months ago
- 1 comment
#24074 - [FLINK-31788][table] TableAggregateFunction supports emitUpdateWithRetract
Pull Request -
State: closed - Opened by LadyForest 10 months ago
- 1 comment
#24073 - [DRAFT] FLIP-376 DISTRIBUTED BY
Pull Request -
State: closed - Opened by jnh5y 10 months ago
- 2 comments
#24073 - [DRAFT] FLIP-376 DISTRIBUTED BY
Pull Request -
State: open - Opened by jnh5y 10 months ago
- 1 comment
#24072 - [FLINK-33819] support set CompressionType for RocksDBStateBackend
Pull Request -
State: closed - Opened by mayuehappy 10 months ago
- 3 comments
#24072 - [FLINK-33819] support set CompressionType for RocksDBStateBackend
Pull Request -
State: open - Opened by mayuehappy 10 months ago
- 2 comments
#24071 - [FLINK-32256][table] Add built-in ARRAY_ MIN function.
Pull Request -
State: closed - Opened by dawidwys 10 months ago
- 1 comment
#24071 - [FLINK-32256][table] Add built-in ARRAY_ MIN function.
Pull Request -
State: closed - Opened by dawidwys 10 months ago
- 1 comment
#24070 - [FLINK-32815] Implement internal HASHCODE function
Pull Request -
State: closed - Opened by dawidwys 10 months ago
- 2 comments
#24069 - [FLINK-33946] [rocksdb] set AvoidFlushDuringShutdown to true for avoiding Flush when Cancel Task
Pull Request -
State: closed - Opened by mayuehappy 10 months ago
- 1 comment
#24069 - [FLINK-33946] [rocksdb] set AvoidFlushDuringShutdown to true for avoiding Flush when Cancel Task
Pull Request -
State: closed - Opened by mayuehappy 10 months ago
- 1 comment
#24068 - [FLINK-34049][table]Refactor classes related to window TVF aggregation to prepare for non-aligned windows
Pull Request -
State: closed - Opened by xuyangzhong 10 months ago
- 5 comments
#24068 - [FLINK-34049][table]Refactor classes related to window TVF aggregation to prepare for non-aligned windows
Pull Request -
State: open - Opened by xuyangzhong 10 months ago
- 5 comments
#24067 - [hotfix] Revert the breaking change to the public implementations of RichFunction
Pull Request -
State: closed - Opened by WencongLiu 10 months ago
- 1 comment
#24066 - [FLINK-34051][checkpoint] Fix equals/hashCode/toString for SavepointRestoreSettings
Pull Request -
State: closed - Opened by masteryhx 10 months ago
- 1 comment
#24065 - [FLINK-28915] Support fetching artifacts in native K8s and standalone application mode
Pull Request -
State: closed - Opened by ferenc-csaky 10 months ago
- 5 comments
#24064 - [FLINK-27455][tests] Migrate SnapshotMigrationTestBase to JUnit5
Pull Request -
State: open - Opened by Jiabao-Sun 10 months ago
- 2 comments
#24063 - [BP-1.18][FLINK-34047][ci] Makes uploading_watchdog.sh support Azure Pipelines and GitHub Actions
Pull Request -
State: closed - Opened by XComp 10 months ago
- 1 comment
#24062 - [FLINK-32852][JUnit5 migration] Migrate ExceptionHistoryEntryTest and RootExceptionHistoryEntryTest to Junit5 and Assertj
Pull Request -
State: closed - Opened by 1996fanrui 10 months ago
- 2 comments
#24061 - [FLINK-34047][ci] Make CI scripts agnostic to CI environment
Pull Request -
State: closed - Opened by XComp 10 months ago
- 3 comments
#24060 - [BP-1.18][FLINK-33906][ci] Makes debug files available for both, AzureCI and GitHub Actions
Pull Request -
State: closed - Opened by XComp 10 months ago
- 1 comment
#24059 - [BP-1.18][FLINK-33907][ci] Makes copying test jars being done in the package phase
Pull Request -
State: closed - Opened by XComp 10 months ago
- 1 comment
#24058 - [FLINK-34015][checkpoint] fix that passing ignore-unclaimed-state through dynamic props does not take effect
Pull Request -
State: open - Opened by xiangforever2014 10 months ago
- 5 comments
#24057 - [FLINK-33881]Avoid copy and update value in TtlListState#getUnexpiredOrNull
Pull Request -
State: closed - Opened by ljz2051 10 months ago
- 2 comments
#24056 - [FLINK-34046] Added metrics for AsyncWaitOperator Retry flow
Pull Request -
State: closed - Opened by sdineshkumar1985 10 months ago
- 1 comment
#24055 - [FLINK-33402] 2 CONTINUED
Pull Request -
State: open - Opened by varun1729DD 10 months ago
- 2 comments
#24054 - Bump follow-redirects from 1.15.1 to 1.15.4 in /flink-runtime-web/web-dashboard
Pull Request -
State: open - Opened by dependabot[bot] 10 months ago
- 1 comment
Labels: dependencies, javascript
#24053 - [hotfix][docs][table formats] Add protobuf format info to overview page
Pull Request -
State: closed - Opened by sharath1709 10 months ago
- 2 comments
#24052 - [FLINK-33997] [docs] Typo in the doc 'classloader.parent-first-patter…
Pull Request -
State: closed - Opened by rodmeneses 10 months ago
- 1 comment
#24051 - [FLINK-31788][table] TableAggregateFunction supports emitUpdateWithRetract
Pull Request -
State: closed - Opened by LadyForest 10 months ago
- 1 comment
#24050 - [FLINK-33741]Expose Rocksdb Histogram statistics in Flink metrics
Pull Request -
State: open - Opened by zhougit86 10 months ago
- 1 comment
#24049 - [FLINK-34041] [docs] Fix typo in docs/content/docs/deployment/ha/overview.md
Pull Request -
State: closed - Opened by Eeap 10 months ago
- 2 comments