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

#23302 - [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/shuffle tests to JUnit5

Pull Request - State: closed - Opened by X-czh about 1 year ago - 4 comments

#23301 - [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/rpc tests to JUnit5

Pull Request - State: closed - Opened by X-czh about 1 year ago - 8 comments

#23300 - [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/registration tests to JUnit5

Pull Request - State: closed - Opened by X-czh about 1 year ago - 5 comments

#23299 - [FLINK-32848][tests][JUnit5 migration] Migrate flink-runtime/query tests to JUnit5

Pull Request - State: closed - Opened by X-czh about 1 year ago - 4 comments

#23280 - [BP-1.17][FLINK-32909][dist]fix the bug of Pass arguments to jobmanager.sh failed

Pull Request - State: closed - Opened by wuqqq about 1 year ago - 1 comment

#23279 - [BP-1.16][FLINK-32909][dist]fix the bug of Pass arguments to jobmanager.sh failed

Pull Request - State: closed - Opened by wuqqq about 1 year ago - 2 comments

#23278 - [BP-1.18][FLINK-32909][dist]fix the bug of Pass arguments to jobmanager.sh failed

Pull Request - State: closed - Opened by wuqqq about 1 year ago - 1 comment

#23271 - [FLINK-32909] [dist] fix the bug of Pass arguments to jobmanager.sh failed

Pull Request - State: closed - Opened by wuqqq about 1 year ago - 6 comments

#23265 - [FLINK-32853][runtime][JUnit5 Migration] The security, taskmanager an…

Pull Request - State: open - Opened by zhangyy91 about 1 year ago - 5 comments

#23263 - [FLINK-32671][docs] Document Externalized Declarative Resource Management

Pull Request - State: closed - Opened by czy006 about 1 year ago - 3 comments

#23259 - [hotfix][docs] Update the parameter type of JobVertex#finalizeOnMaster in JavaDocs

Pull Request - State: closed - Opened by wangzzu about 1 year ago - 2 comments

#23248 - [FLINK-32176][config] create default option for scheduler-mode

Pull Request - State: open - Opened by kination about 1 year ago - 1 comment

#23243 - [FLINK-32846][runtime][JUnit5 Migration] The metrics package of flink-runtime module

Pull Request - State: closed - Opened by wangzzu about 1 year ago - 8 comments

#23242 - [FLINK-32851][runtime][JUnit5 Migration] The rest package of flink-runtime module

Pull Request - State: closed - Opened by wangzzu about 1 year ago - 8 comments

#23240 - Update local_installation.md

Pull Request - State: open - Opened by arthurlee over 1 year ago - 1 comment

#23226 - [FLINK-32877][Filesystem]add HTTP options to gcs-cloud-storage client

Pull Request - State: open - Opened by singhravidutt over 1 year ago - 10 comments

#23223 - [FLINK-32873][table] - Add config to allow disabling QUERY hints

Pull Request - State: open - Opened by bvarghese1 over 1 year ago - 1 comment

#23220 - [FLINK-32871][SQL] Support BuiltInMethod TO_TIMESTAMP with timezone options

Pull Request - State: closed - Opened by xuzifu666 over 1 year ago - 3 comments

#23206 - [hotfix][state] Fix the class referenced by the logger

Pull Request - State: closed - Opened by TBCCC over 1 year ago - 9 comments

#23200 - [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

Pull Request - State: closed - Opened by Jiabao-Sun over 1 year ago - 11 comments

#23194 - [BP-1.17]historgram

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23190 - [BP1.17][FLINK-32720][table] Add built-in GENERATE_SERIES function

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23189 - [BP-1.17][FLINK-32565][table] Support Cast From NUMBER to BYTES

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23188 - [BP-1.17][FLINK-32564][table] Support Cast From BYTES to NUMBER

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23186 - [BP-1.17][FLINK-31664][table]Add ARRAY_INTERSECT function

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23185 - [BP-1.17][FLINK-31663][table] Add-ARRAY_EXCEPT-function.

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23184 - [BP-1.17][FLINK-32815][table] Add HASHCODE function.

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23177 - [BP-1.17][FLINK-32706][table] Add built-in SPLIT_STRING function

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23176 - [BP-1.17][FLINK-32264][table] Add-built-in FIELD-function.

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23175 - [BP-1.17][FLINK-32263][table]Add-ELT-function

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23169 - [FLINK-31238] [WIP] Use IngestDB to speed up Rocksdb rescaling recovery

Pull Request - State: open - Opened by mayuehappy over 1 year ago - 11 comments

#23164 - [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

Pull Request - State: closed - Opened by architgyl over 1 year ago - 9 comments

#23162 - [FLINK-32650][protobuf]Added the ability to split flink-protobuf code…

Pull Request - State: closed - Opened by ljw-hit over 1 year ago - 12 comments

#23158 - [BP-1.17] [FLINK-26948][table] Add-ARRAY_SORT-function.

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23153 - [FLINK-32769][hotfix][state-changelog] Fix the invalid placeholder {}…

Pull Request - State: closed - Opened by zoltar9264 over 1 year ago - 1 comment

#23152 - [FLINK-32767][doc] Fix en-doc SHOW CREATE TABLE usage

Pull Request - State: closed - Opened by GOODBOY008 over 1 year ago - 6 comments

#23151 - [BP-1.17][FLINK-32256][table] Add built-in ARRAY_ MIN function.

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 4 comments

#23150 - fix(sec): upgrade com.google.guava:guava to 32.0.0-jre

Pull Request - State: open - Opened by ChengDaqi2023 over 1 year ago - 2 comments

#23149 - [BP-1.17][FLINK-32257][table] Add built-in ARRAY_MAX function.

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 4 comments

#23145 - [BP-1.17][FLINK-31665] [table] Add ARRAY_CONCAT function

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23144 - [BP-1.17][FLINK-32261][table] Add built-in MAP_UNION function.

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 2 comments

#23141 - [FLINK-32758][python] Remove PyFlink dependencies' upper bounds

Pull Request - State: closed - Opened by deepyaman over 1 year ago - 9 comments

#23127 - [FLINK-32223][runtime][security] Add Hive delegation token support

Pull Request - State: closed - Opened by jiaoqingbo over 1 year ago - 10 comments

#23121 - [FLINK-32721] [planner] Support CharType for the MaxAggFunction and M…

Pull Request - State: closed - Opened by liuyongvs over 1 year ago - 3 comments

#23121 - [FLINK-32721] [planner] Support CharType for the MaxAggFunction and M…

Pull Request - State: open - Opened by liuyongvs over 1 year ago - 3 comments

#23114 - [REVERT][FLINK-32223][runtime][security] Add Hive delegation token support

Pull Request - State: closed - Opened by XComp over 1 year ago - 2 comments

#23111 - [FLINK-32681][rocksdb][tests] Add TaskFailureCleaner to RocksDBStateD…

Pull Request - State: closed - Opened by zoltar9264 over 1 year ago - 2 comments

#23102 - [FLINK-32712][format/json] enhance flink ogg-json format

Pull Request - State: closed - Opened by yuanoOo over 1 year ago - 2 comments

#23052 - Bump org.apache.calcite:calcite-core from 1.16.0 to 1.32.0 in /flink-connectors/flink-sql-connector-hive-3.1.3

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago - 3 comments
Labels: dependencies, java

#23043 - [python][docs] Fix broken syntax in Flink Table API query example

Pull Request - State: closed - Opened by deepyaman over 1 year ago - 1 comment

#23040 - try fix e2e_1

Pull Request - State: closed - Opened by wanglijie95 over 1 year ago - 4 comments

#23035 - [FLINK-32608][table-planner] Support scan reusing with projection pushdown

Pull Request - State: closed - Opened by lsyldliu over 1 year ago - 4 comments

#23024 - Bump word-wrap from 1.2.3 to 1.2.4 in /flink-runtime-web/web-dashboard

Pull Request - State: open - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies, javascript

#22999 - [FLINK-32573][docs-content.zh] Translate "Custom Serialization for Ma…

Pull Request - State: open - Opened by ping-cai over 1 year ago - 1 comment

#22985 - [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler

Pull Request - State: closed - Opened by echauchot over 1 year ago - 18 comments

#22973 - [FLINK-32440][checkpoint] Introduce file merging configurations

Pull Request - State: open - Opened by fredia over 1 year ago - 1 comment

#22971 - Bump stylelint from 14.8.5 to 15.10.1 in /flink-runtime-web/web-dashboard

Pull Request - State: open - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies, javascript

#22931 - [FLINK-32514] Support configuring checkpointing interval during process backlog

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 7 comments

#22931 - [FLINK-32514] Support configuring checkpointing interval during process backlog

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 7 comments

#22930 - [FLINK-32511][FileSystems] Upgrade GCS connector to 2.2.15

Pull Request - State: closed - Opened by jayadeep-jayaraman over 1 year ago - 5 comments

#22922 - [FLINK-32256][table] Add built-in ARRAY_ MIN function.

Pull Request - State: closed - Opened by hanyuzheng7 over 1 year ago - 4 comments

#22897 - [FLINK-32476][runtime] Support configuring object-reuse for internal operators

Pull Request - State: open - Opened by Sxnan over 1 year ago - 2 comments

#22883 - [FLINK-31476] AdaptiveScheduler respects minimum parallelism

Pull Request - State: closed - Opened by zentol over 1 year ago - 4 comments

#22843 - [FLINK-30141][s3][filesystem] Increase retries on MinIO container startup

Pull Request - State: closed - Opened by RyanSkraba over 1 year ago - 3 comments

#22833 - [FLINK-32283][network] Implement the SortBufferAccumulator for the tiered storage

Pull Request - State: closed - Opened by TanYuxin-tyx over 1 year ago - 2 comments

#22804 - [FLINK-31644][network] Implement the disk tier producer for the tiered storage

Pull Request - State: closed - Opened by TanYuxin-tyx over 1 year ago - 3 comments

#22800 - [FLINK-23411][checkpoint] Expose Checkpoint metrics in task level

Pull Request - State: closed - Opened by masteryhx over 1 year ago - 4 comments

#22797 - [FLINK-30859] Remove all Kafka connector code from main repo

Pull Request - State: closed - Opened by mas-chen over 1 year ago - 6 comments

#22789 - [FLINK-27146] [Filesystem] Migrate to Junit5 and Assertj

Pull Request - State: open - Opened by kottmann over 1 year ago - 1 comment

#22772 - [FLINK-19010][metric] Introduce subtask level restore metric

Pull Request - State: closed - Opened by fredia over 1 year ago - 2 comments
Labels: component=Runtime/Metrics, component=Runtime/Checkpointing

#22768 - [FLINK-32309][sql-gateway] Use independent resource manager for table environment

Pull Request - State: closed - Opened by FangYongs over 1 year ago - 6 comments

#22750 - [FLINK-31757][runtime][scheduler] Support balanced tasks scheduling.

Pull Request - State: closed - Opened by RocMarshal over 1 year ago - 1 comment

#22745 - [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

Pull Request - State: open - Opened by liuyongvs over 1 year ago - 9 comments

#22744 - [FLINK-29802][state] Changelog supports native savepoint

Pull Request - State: open - Opened by masteryhx over 1 year ago - 3 comments

#22744 - [FLINK-29802][state] Changelog supports native savepoint

Pull Request - State: open - Opened by masteryhx over 1 year ago - 3 comments

#22728 - [FLINK-31641][network] Implement the memory tier producer for the tiered storage

Pull Request - State: closed - Opened by TanYuxin-tyx over 1 year ago - 2 comments

#22663 - [FLINK-32198][runtime] Enforce single maxExceptions query parameter

Pull Request - State: open - Opened by pgaref over 1 year ago - 4 comments

#22662 - KafkaSource: disable setting client id prefix if client.id is set

Pull Request - State: open - Opened by hmedhat over 1 year ago - 1 comment

#22660 - [FLINK-3154][runtime] Upgrade from Kryo v2 + Chill 0.7.6 to Kryo v5 w…

Pull Request - State: open - Opened by kurtostfeld over 1 year ago - 5 comments

#22659 - [FLINK-32186][runtime-web] Support subtask stack auto-search when red…

Pull Request - State: open - Opened by yuchen-ecnu over 1 year ago - 1 comment

#22658 - disable setting client id prefix if client.id is set

Pull Request - State: closed - Opened by hmedhat over 1 year ago

#22653 - [FLINK-32179][tests] Harden FileUtils#findFlinkDist against custom repo names

Pull Request - State: open - Opened by zentol over 1 year ago - 1 comment

#22652 - [FLINK-31640][network] Introduce the segment id tracker for the tiered storage

Pull Request - State: open - Opened by TanYuxin-tyx over 1 year ago - 1 comment

#22651 - [BP-1.17][FLINK-30257] fix SqlClientITCase#testMatchRecognize

Pull Request - State: closed - Opened by dmvk over 1 year ago - 2 comments