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
#23965 - [FLINK-33907][ci] Makes copying test jars being done later
Pull Request -
State: closed - Opened by XComp 11 months ago
- 1 comment
#23964 - [FLINK-33906][ci] tools/azure-pipelines/debug_files_utils.sh should support GHA output as well
Pull Request -
State: closed - Opened by XComp 11 months ago
- 3 comments
#23963 - [FLINK-33904][test] Installs missing zip package
Pull Request -
State: closed - Opened by XComp 11 months ago
- 2 comments
#23962 - [FLINK-27082][ci] Disables tests that relies on disabling file permissions
Pull Request -
State: closed - Opened by XComp 11 months ago
- 1 comment
#23961 - [FLINK-33902][ci] Adds -legacy to openssl command
Pull Request -
State: closed - Opened by XComp 11 months ago
- 2 comments
#23960 - [FLINK-25537] [JUnit5 Migration] Module: flink-core package api-common
Pull Request -
State: open - Opened by GOODBOY008 11 months ago
- 5 comments
#23959 - [FLINK-31664][table] Add ARRAY_INTERSECT function
Pull Request -
State: closed - Opened by liuyongvs 11 months ago
- 3 comments
#23959 - [FLINK-31664][table] Add ARRAY_INTERSECT function
Pull Request -
State: closed - Opened by liuyongvs 11 months ago
- 3 comments
#23958 - [FLINK-33891] Remove the obsolete SingleJobGraphStore
Pull Request -
State: open - Opened by X-czh 11 months ago
- 1 comment
#23958 - [FLINK-33891] Remove the obsolete SingleJobGraphStore
Pull Request -
State: closed - Opened by X-czh 11 months ago
- 1 comment
#23957 - [FLINK-33879] Avoids the potential hang of Hybrid Shuffle during redistribution
Pull Request -
State: closed - Opened by jiangxin369 11 months ago
- 5 comments
#23956 - [FLINK-33861] Implement restore tests for WindowRank node
Pull Request -
State: closed - Opened by bvarghese1 11 months ago
- 1 comment
#23955 - [FLINK-33877][streaming] Fix unstable test of CollectSinkFunctionTest.testConfiguredPortIsUsed
Pull Request -
State: closed - Opened by Jiabao-Sun 11 months ago
- 1 comment
#23955 - [FLINK-33877][streaming] Fix unstable test of CollectSinkFunctionTest.testConfiguredPortIsUsed
Pull Request -
State: closed - Opened by Jiabao-Sun 11 months ago
- 1 comment
#23954 - [FLINK-33502][network] Refactor DiskIOScheduler to handle exceptions more gracefully and improve error handling logic
Pull Request -
State: closed - Opened by WencongLiu 11 months ago
- 1 comment
#23953 - [BP-1.18][FLINK-33534][runtime] Support configuring PARALLELISM_OVERRIDES during job submission
Pull Request -
State: closed - Opened by yunfengzhou-hub 11 months ago
- 2 comments
#23953 - [BP-1.18][FLINK-33534][runtime] Support configuring PARALLELISM_OVERRIDES during job submission
Pull Request -
State: closed - Opened by yunfengzhou-hub 11 months ago
- 2 comments
#23952 - [FLINK-33876][table-planner][JUnit5 Migration] Introduce methodName method in TableTestBase
Pull Request -
State: closed - Opened by Jiabao-Sun 11 months ago
- 3 comments
#23952 - [FLINK-33876][table-planner][JUnit5 Migration] Introduce methodName method in TableTestBase
Pull Request -
State: closed - Opened by Jiabao-Sun 11 months ago
- 3 comments
#23951 - [FLINK-33872] Retrieve checkpoint history for jobs in completed state
Pull Request -
State: closed - Opened by hlteoh37 11 months ago
- 1 comment
#23951 - [FLINK-33872] Retrieve checkpoint history for jobs in completed state
Pull Request -
State: closed - Opened by hlteoh37 11 months ago
- 1 comment
#23950 - [BP-1.18][FLINK-33531][python] Remove cython upper bounds
Pull Request -
State: closed - Opened by snuyanzin 11 months ago
- 4 comments
#23950 - [BP-1.18][FLINK-33531][python] Remove cython upper bounds
Pull Request -
State: closed - Opened by snuyanzin 11 months ago
- 4 comments
#23949 - [FLINK-33872] Retrieve checkpoint history for jobs in completed state
Pull Request -
State: closed - Opened by hlteoh37 11 months ago
- 3 comments
#23949 - [FLINK-33872] Retrieve checkpoint history for jobs in completed state
Pull Request -
State: closed - Opened by hlteoh37 11 months ago
- 3 comments
#23948 - [FLINK-33823] Make PlannerQueryOperation SQL serializable
Pull Request -
State: closed - Opened by dawidwys 11 months ago
- 1 comment
#23947 - [BP-1.18][FLINK-33588]Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics
Pull Request -
State: closed - Opened by JingGe 11 months ago
- 3 comments
#23947 - [BP-1.18][FLINK-33588]Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics
Pull Request -
State: closed - Opened by JingGe 11 months ago
- 3 comments
#23946 - [FLINK-31472][Connectors/Base] Update AsyncSink Throttling test to use concurrent mailbox
Pull Request -
State: closed - Opened by vahmed-hamdy 11 months ago
- 2 comments
#23945 - [FLINK-33871][HIVE]Reduce getTable call for hive client and optimize graph generation time
Pull Request -
State: open - Opened by hehuiyuan 11 months ago
- 2 comments
#23945 - [FLINK-33871][HIVE]Reduce getTable call for hive client and optimize graph generation time
Pull Request -
State: open - Opened by hehuiyuan 11 months ago
- 2 comments
#23944 - [FLINK-33534][runtime] Support configuring PARALLELISM_OVERRIDES during job submission
Pull Request -
State: closed - Opened by yunfengzhou-hub 11 months ago
- 3 comments
#23944 - [FLINK-33534][runtime] Support configuring PARALLELISM_OVERRIDES during job submission
Pull Request -
State: closed - Opened by yunfengzhou-hub 11 months ago
- 3 comments
#23943 - [FLINK-32721] [planner] Support CharType for the MaxAggFunction
Pull Request -
State: closed - Opened by liuyongvs 11 months ago
- 4 comments
#23943 - [FLINK-32721] [planner] Support CharType for the MaxAggFunction
Pull Request -
State: closed - Opened by liuyongvs 11 months ago
- 4 comments
#23942 - [FLINK-33865][runtime] Adding an ITCase to ensure `exponential-delay.attempts-before-reset-backoff` works well
Pull Request -
State: closed - Opened by 1996fanrui 11 months ago
- 6 comments
#23941 - Update content.zh/docs/dev/table/overview.md
Pull Request -
State: open - Opened by shalk 11 months ago
- 1 comment
#23941 - Update content.zh/docs/dev/table/overview.md
Pull Request -
State: open - Opened by shalk 11 months ago
- 1 comment
#23940 - [Docs]remove no necessary text
Pull Request -
State: closed - Opened by zzzk1 11 months ago
- 1 comment
#23939 - [FLINK-33956] Bump org.apache.zookeeper:zookeeper from 3.7.1 to 3.7.2
Pull Request -
State: open - Opened by dependabot[bot] 11 months ago
- 2 comments
Labels: dependencies, java
#23939 - [FLINK-33956] Bump org.apache.zookeeper:zookeeper from 3.7.1 to 3.7.2
Pull Request -
State: open - Opened by dependabot[bot] 11 months ago
- 2 comments
Labels: dependencies, java
#23938 - [FLINK-33863][checkpoint] Fix restoring compressed operator state
Pull Request -
State: closed - Opened by ruibinx 11 months ago
- 3 comments
#23937 - [FLINK-33611] [flink-protobuf] Support Large Protobuf Schemas
Pull Request -
State: closed - Opened by sharath1709 11 months ago
- 10 comments
#23936 - [FLINK-33860] Implement restore tests for WindowTableFunction node
Pull Request -
State: closed - Opened by bvarghese1 11 months ago
- 2 comments
#23935 - [FLINK-33704][BP 1.18][Filesytems] Update GCS filesystems to latest available versions
Pull Request -
State: closed - Opened by MartijnVisser 11 months ago
- 4 comments
#23934 - [FLINK-33688][client] Reuse connections in RestClient to save connection establish time
Pull Request -
State: open - Opened by xiangyuf 11 months ago
- 1 comment
#23933 - test request
Pull Request -
State: closed - Opened by singhravidutt 11 months ago
- 6 comments
#23932 - [FLINK-33853][runtime][JUnit5 Migration] Migrate Junit5 for DeclarativeSlotPoolBridge test classes of runtime module
Pull Request -
State: closed - Opened by RocMarshal 11 months ago
- 2 comments
#23931 - [FLINK-33588][Flink-Runtime] Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics
Pull Request -
State: closed - Opened by zhutong6688 11 months ago
- 3 comments
#23930 - [FLINK-33268][rest] Skip unknown fields in REST response deserialization
Pull Request -
State: closed - Opened by gaborgsomogyi 11 months ago
- 11 comments
#23929 - [hotfix] Apply spotless
Pull Request -
State: closed - Opened by snuyanzin 11 months ago
- 1 comment
#23928 - [FLINK-20772][State] Make TtlValueState#update follow the description of interface about null values
Pull Request -
State: closed - Opened by Zakelly 11 months ago
- 4 comments
#23927 - [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel
Pull Request -
State: open - Opened by yunfengzhou-hub 11 months ago
- 4 comments
#23926 - [FLINK-32756][ha] Implement reusable ClientHAServices and reuse it when creating RestClusterClient
Pull Request -
State: open - Opened by xiangyuf 11 months ago
- 1 comment
#23925 - [FLINK-33686][client] Reuse ClusterDescriptor in AbstractSessionClusterExecutor
Pull Request -
State: open - Opened by xiangyuf 11 months ago
- 1 comment
#23924 - [FLINK-33809] HiveCatalog load hivemetastore-site.xml
Pull Request -
State: open - Opened by cuibo01 11 months ago
- 3 comments
#23923 - [FLINK-33818] Implement restore tests for WindowDeduplicate node
Pull Request -
State: closed - Opened by bvarghese1 11 months ago
- 1 comment
#23922 - [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited.
Pull Request -
State: open - Opened by liming30 11 months ago
- 2 comments
#23921 - [FLINK-33687][client] Reuse RestClusterClient in StandaloneClusterDescriptor
Pull Request -
State: open - Opened by xiangyuf 11 months ago
- 1 comment
#23920 - [FLINK-33603][1.18][Filesystem] Bundle Guava for GCS connector
Pull Request -
State: closed - Opened by MartijnVisser 11 months ago
- 3 comments
#23919 - [FLINK-33810][Runtime] Propagate RecordAttributes that contains isProcessingBacklog status
Pull Request -
State: closed - Opened by Sxnan 11 months ago
- 1 comment
#23918 - [FLINK-33808] Implement restore tests for WindowJoin node
Pull Request -
State: closed - Opened by bvarghese1 11 months ago
- 1 comment
#23917 - [FLINK-33807] Update JUnit to 5.10.1
Pull Request -
State: closed - Opened by snuyanzin 11 months ago
- 6 comments
#23916 - [FLINK-33767] Implement restore tests for TemporalJoin node
Pull Request -
State: closed - Opened by jnh5y 11 months ago
- 1 comment
#23915 - [FLINK-33588][Flink-Runtime] Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics
Pull Request -
State: closed - Opened by zhutong6688 11 months ago
- 6 comments
#23914 - [FLINK-33641][test] Suppress the DirectoryNotEmptyException in StreamingWithStateTestBase to prevent test failures
Pull Request -
State: closed - Opened by Jiabao-Sun 11 months ago
- 16 comments
#23913 - [FLINK-33685][client] Refactor StandaloneClusterId to distinguish different remote clusters
Pull Request -
State: open - Opened by xiangyuf 11 months ago
- 1 comment
#23912 - [FLINK-33328] Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable - mixin approach
Pull Request -
State: closed - Opened by pvary 11 months ago
- 4 comments
#23911 - [FLINK-33736][Scheduler] Update default value of exponential-delay.max-backoff and exponential-delay.backoff-multiplier
Pull Request -
State: closed - Opened by 1996fanrui 11 months ago
- 2 comments
#23910 - [hotfix] [tests] Per-class the lifecycle of mini-cluster in `ClientHeartbeatTest`.
Pull Request -
State: open - Opened by TestBoost 11 months ago
- 5 comments
#23909 - [hotfix][docs] config key for parquet int64 option
Pull Request -
State: closed - Opened by tweise 11 months ago
- 1 comment
#23908 - [FLINK-33775] Report JobInitialization traces
Pull Request -
State: closed - Opened by pnowojski 11 months ago
- 1 comment
#23907 - [FLINK-33797] Change log level for Application CANCELED/FAILED logs to WARN
Pull Request -
State: open - Opened by ashangit 11 months ago
- 1 comment
#23906 - [FLINK-33714][doc] Update the documentation about the usage of RuntimeContext#getExecutionConfig.
Pull Request -
State: closed - Opened by JunRuiLee 11 months ago
- 1 comment
#23905 - [FLINK-33905][core] Unify the Provision of Diverse Metadata for Context-like APIs
Pull Request -
State: closed - Opened by WencongLiu 11 months ago
- 1 comment
#23904 - [DRAFT][FLINK-32667] Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster
Pull Request -
State: open - Opened by KarmaGYZ 11 months ago
- 1 comment
#23903 - [doc-fix] - changed preference to settings for setting pycharm for pyflink ide setting section
Pull Request -
State: closed - Opened by adipolak 11 months ago
- 1 comment
#23902 - Fix abnormal prompt information: When sorting in non-time attribute f…
Pull Request -
State: open - Opened by Gianzie 11 months ago
- 1 comment
#23901 - [FLINK-33728][k8s] do not rewatch when KubernetesResourceManagerDrive…
Pull Request -
State: open - Opened by zhougit86 11 months ago
- 1 comment
#23900 - [FLINK-25565][Formats][Parquet] timestamp int64 option tidy up
Pull Request -
State: closed - Opened by tweise 12 months ago
- 1 comment
#23899 - [FLINK-33786][Connectors / Hive] Remove Hive connector from master branch
Pull Request -
State: open - Opened by snuyanzin 12 months ago
- 1 comment
#23898 - [FLINK-33719][table] Cleanup the usage of deprecated StreamTableEnvir…
Pull Request -
State: open - Opened by liuyongvs 12 months ago
- 5 comments
#23897 - [FLINK-33781][table] Cleanup usage of deprecated TableConfig#ctor
Pull Request -
State: closed - Opened by liuyongvs 12 months ago
- 4 comments
#23896 - [FLINK-33777] Fix ParquetTimestampITCase>FsStreamingSinkITCaseBase failing
Pull Request -
State: closed - Opened by snuyanzin 12 months ago
- 3 comments
#23895 - [FLINK-33779][table] Cleanup usage of deprecated BaseExpressions#cast
Pull Request -
State: closed - Opened by liuyongvs 12 months ago
- 3 comments
#23894 - [FLINK-33778][table] Cleanup usage of deprecated TableConfig#setIdleS…
Pull Request -
State: closed - Opened by liuyongvs 12 months ago
- 4 comments
#23893 - [FLINK-33782] Fix GroupAggregate restore tests
Pull Request -
State: closed - Opened by bvarghese1 12 months ago
- 2 comments
#23892 - [FLINK-33470] Moving (Join|Expand)TestPrograms and RestoreTests to th…
Pull Request -
State: closed - Opened by jnh5y 12 months ago
- 1 comment
#23891 - [FLINK-33523][BP 1.18][table-planner] Revert [FLINK-31835] Fix the array type that can't be converted from the external primitive array
Pull Request -
State: closed - Opened by MartijnVisser 12 months ago
- 1 comment
#23890 - [FLINK-33523][table-planner] Revert [FLINK-31835] Fix the array type that can't be converted from the external primitive array
Pull Request -
State: closed - Opened by MartijnVisser 12 months ago
- 1 comment
#23889 - [FLINK-33693][checkpoint] Force aligned barrier works with timeoutable aligned checkpoint barrier
Pull Request -
State: closed - Opened by 1996fanrui 12 months ago
- 1 comment
#23888 - [FLINK-33693][checkpoint] Force aligned barrier works with timeoutable aligned checkpoint barrier
Pull Request -
State: closed - Opened by 1996fanrui 12 months ago
- 1 comment
#23887 - [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp
Pull Request -
State: closed - Opened by tweise 12 months ago
- 3 comments
#23886 - [FLINK-33676] Implement RestoreTests for WindowAggregate
Pull Request -
State: open - Opened by jnh5y 12 months ago
- 1 comment
#23885 - [FLINK-33718][table] Cleanup the usage of deprecated StreamTableEnvironment#toAppendStream
Pull Request -
State: closed - Opened by snuyanzin 12 months ago
- 1 comment
#23884 - [FLINK-33754] Serialize QueryOperations into SQL string
Pull Request -
State: closed - Opened by dawidwys 12 months ago
- 1 comment
#23883 - [FLINK-33599] Run restore tests with RocksDB state backend
Pull Request -
State: closed - Opened by dawidwys 12 months ago
- 1 comment
#23882 - [hotfix][test] Migrate JsonRowDeserializationSchemaTest/JsonRowSerializationSchemaTest to Junit5 and Assertj
Pull Request -
State: closed - Opened by swuferhong 12 months ago
- 1 comment
#23881 - [FLINK-33759] flink parquet writer support write nested array or map type
Pull Request -
State: open - Opened by LoveHeat 12 months ago
- 1 comment
#23880 - [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation
Pull Request -
State: open - Opened by zhengzhili333 12 months ago
- 2 comments