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
#25430 - [FLINK-36310][docs] Remove per-job mode, run-application and scala api related documents
Pull Request -
State: open - Opened by codenohup about 9 hours ago
- 1 comment
Labels: component=<none>
#25429 - [hotfix] Update the violations to avoid archi test failed
Pull Request -
State: open - Opened by xuyangzhong about 9 hours ago
- 1 comment
#25428 - [FLINK-36405][runtime][security] Fix startup issues on kerberos clusters.
Pull Request -
State: open - Opened by zhengchenyu about 12 hours ago
- 1 comment
Labels: component=TableSQL/Runtime
#25427 - [FLINK-36369][table] Replace all class annotations in the legacy package with Internal in table modules (table-common, table-api-java and table-api-java-bridge)
Pull Request -
State: closed - Opened by xuyangzhong about 15 hours ago
Labels: component=TableSQL/API
#25426 - [hotfix][runtime] Fix concurrency issue in callback runner of async state processing
Pull Request -
State: open - Opened by Zakelly about 15 hours ago
- 1 comment
#25425 - [WIP] Run tests.
Pull Request -
State: closed - Opened by JunRuiLee about 16 hours ago
- 2 comments
#25424 - [FLINK-36355][runtime] Remove deprecated CLI options
Pull Request -
State: open - Opened by yunfengzhou-hub about 17 hours ago
- 1 comment
Labels: component=Runtime/Coordination, component=Runtime/WebFrontend, component=API/DataStream, component=Runtime/REST
#25423 - [DRAFT] Test PR failed reason
Pull Request -
State: closed - Opened by codenohup about 21 hours ago
- 2 comments
#25422 - [FLINK-34975][state/forst] Implement Aggregating Async State API for ForStStateBackend
Pull Request -
State: open - Opened by jectpro7 1 day ago
- 2 comments
Labels: component=Runtime/StateBackends
#25421 - [FLINK-36323][StateBackend] Remove deprecated MemoryStateBackend, FsStateBackend and RocksDBStateBackend.
Pull Request -
State: open - Opened by xing1mo 1 day ago
- 3 comments
Labels: component=Runtime/StateBackends
#25420 - [FLINK-36362][table] Remove dependency flink-java in table modules
Pull Request -
State: open - Opened by xuyangzhong 2 days ago
- 1 comment
Labels: component=TableSQL/Planner, component=TableSQL/API
#25419 - [DRAFT][FLINK-36336] Remove deprecated dataset API exclude table module
Pull Request -
State: open - Opened by codenohup 2 days ago
- 1 comment
Labels: component=<none>
#25418 - [FLINK-36399][table] Fix incorrect cast behavior.
Pull Request -
State: open - Opened by liuyongvs 2 days ago
- 1 comment
Labels: component=TableSQL/Planner
#25417 - [FLINK-36355][runtime] Remove deprecated metrics
Pull Request -
State: open - Opened by yunfengzhou-hub 3 days ago
- 2 comments
Labels: component=Runtime/Coordination, component=Runtime/WebFrontend, component=API/DataStream, component=Runtime/REST
#25416 - [FLINK-36395][state/forst] Graceful quit for Forst StateBackend
Pull Request -
State: open - Opened by Zakelly 3 days ago
- 3 comments
Labels: component=<none>
#25415 - [DRAFT][FLINK-36362][table] Remove dependency `flink-java` in table modules
Pull Request -
State: open - Opened by xuyangzhong 3 days ago
- 7 comments
Labels: component=TableSQL/Planner, component=TableSQL/API
#25414 - [FLINK-36066][runtime] Introducing the AdaptiveGraphManager component
Pull Request -
State: open - Opened by noorall 3 days ago
- 2 comments
Labels: component=Runtime/Coordination
#25413 - [FLINK-36181][build] Bump CI Java version to 11
Pull Request -
State: closed - Opened by Sxnan 3 days ago
- 4 comments
Labels: component=BuildSystem, component=BuildSystem/AzurePipelines, component=BuildSystem/CI
#25412 - [FLINK-36389][security] Add check in DelegationTokenReceiverRepository for DT enabled flag
Pull Request -
State: open - Opened by argoyal2212 3 days ago
- 7 comments
Labels: component=Deployment/YARN, component=Deployment/Kubernetes
#25411 - Detect base href dynamically
Pull Request -
State: open - Opened by abhijitWakchaure 3 days ago
- 1 comment
#25410 - [FLINK-33045][format avro-confluent] disable auto-registering schema in registry
Pull Request -
State: open - Opened by parisni 3 days ago
- 1 comment
Labels: component=Formats
#25409 - [FLINK-36323][StateBackend] Remove deprecated MemoryStateBackend, FsStateBackend and RocksDBStateBackend
Pull Request -
State: closed - Opened by xing1mo 3 days ago
- 4 comments
Labels: component=Runtime/StateBackends
#25408 - [FLINK-36373][state/forst] Support dispatch state requests in task thread
Pull Request -
State: closed - Opened by fredia 3 days ago
- 1 comment
Labels: component=<none>
#25407 - [FLINK-36355][runtime] Remove deprecated SetupableStreamOperator
Pull Request -
State: open - Opened by yunfengzhou-hub 4 days ago
- 1 comment
Labels: component=Runtime/Coordination, component=Runtime/WebFrontend, component=API/DataStream, component=Runtime/REST
#25406 - [FLINK-36181][build] Bump target Java version to 11 and drop support for Java 8
Pull Request -
State: open - Opened by Sxnan 4 days ago
- 2 comments
Labels: component=BuildSystem, component=BuildSystem/AzurePipelines, component=BuildSystem/CI
#25405 - [FLINK-36368] Do not prematurely merge CommittableManager
Pull Request -
State: open - Opened by AHeise 4 days ago
- 1 comment
Labels: component=<none>
#25404 - [FLINK-36378][table] Fix type extraction bug between java BigDecimal …
Pull Request -
State: closed - Opened by liuyongvs 4 days ago
- 1 comment
Labels: component=TableSQL/Planner
#25403 - [FLINK-36376] More friendly error or warn message for misconfigured statebackend with async state processing
Pull Request -
State: closed - Opened by Zakelly 4 days ago
- 1 comment
Labels: component=<none>
#25402 - [FLINK-36374][state/forst] Bundle forst statebackend in flink-dist and provide shortcut to enable
Pull Request -
State: open - Opened by Zakelly 4 days ago
- 1 comment
Labels: component=<none>
#25401 - [FLINK-35709][table-planner] Allow reordering source columns in CTAS and RTAS
Pull Request -
State: open - Opened by spena 4 days ago
- 1 comment
Labels: component=<none>
#25400 - [FLINK-36369][table] Move deprecated user-visible classes in table modules to the legacy package
Pull Request -
State: closed - Opened by xuyangzhong 4 days ago
- 5 comments
Labels: component=TableSQL/API
#25399 - [FLINK-36344][runtime/metrics] Introduce lastCheckpointCompletedTimestamp metric
Pull Request -
State: open - Opened by xingsuo-zbz 4 days ago
- 4 comments
Labels: component=Runtime/Metrics, component=Runtime/Checkpointing
#25398 - [FLINK-36307][python] Remove deprecated API in PyFlink module
Pull Request -
State: closed - Opened by dianfu 4 days ago
- 1 comment
Labels: component=API/Python
#25397 - [FLINK-36325][statebackend] Implement basic restore from checkpoint for ForStStateBackend
Pull Request -
State: open - Opened by zoltar9264 5 days ago
- 3 comments
Labels: component=Runtime/StateBackends
#25396 - [FLINK-36366][core] Remove deprecate API in flink-core exclude connector and state part
Pull Request -
State: closed - Opened by reswqa 5 days ago
- 1 comment
Labels: component=API/Core
#25395 - [FLINK-36355][runtime] Remove deprecated xxxStreams#with
Pull Request -
State: closed - Opened by yunfengzhou-hub 5 days ago
- 1 comment
Labels: component=Runtime/Coordination, component=Runtime/WebFrontend, component=API/DataStream, component=Runtime/REST
#25394 - [FLINK-36364][state/forst] Do not reuse serialized key in Forst map state and/or other namespaces
Pull Request -
State: closed - Opened by Zakelly 5 days ago
- 1 comment
Labels: component=Runtime/StateBackends
#25393 - [FLINK-29741][scala] Delete flink-scala and flink-streaming-scala modules
Pull Request -
State: closed - Opened by codenohup 5 days ago
- 5 comments
Labels: component=API/Scala
#25392 - [FLINK-36355][runtime] Remove deprecated iterative stream
Pull Request -
State: open - Opened by yunfengzhou-hub 5 days ago
- 1 comment
Labels: component=Runtime/Coordination, component=Runtime/WebFrontend, component=API/DataStream, component=Runtime/REST
#25391 - [FLINK-36355][runtime] Remove deprecated KeydStream#asQueryableState
Pull Request -
State: closed - Opened by yunfengzhou-hub 5 days ago
- 2 comments
Labels: component=Runtime/Coordination, component=Runtime/WebFrontend, component=API/DataStream, component=Runtime/REST
#25390 - [FLINK-36355][runtime] Remove miscellaneous deprecated interfaces related to DataStream
Pull Request -
State: open - Opened by yunfengzhou-hub 5 days ago
- 1 comment
Labels: component=Runtime/Coordination, component=Runtime/WebFrontend, component=API/DataStream, component=Runtime/REST
#25389 - [FLINK-36355][runtime] Remove deprecated interfaces related to window and time
Pull Request -
State: open - Opened by yunfengzhou-hub 5 days ago
- 1 comment
Labels: component=Runtime/Coordination, component=Runtime/WebFrontend, component=API/DataStream, component=Runtime/REST
#25388 - [FLINK-36361][table] Do not use StringBuilder for EquivalentExprShuttle
Pull Request -
State: closed - Opened by snuyanzin 5 days ago
- 3 comments
Labels: component=TableSQL/Planner
#25387 - [FLINK-36311][format/csv/json/avro] Remove deprecated APIs in Flink Csv/Json/Avro format
Pull Request -
State: closed - Opened by dianfu 5 days ago
- 1 comment
Labels: component=Formats
#25386 - Debug Flink E2E by azure pipeline
Pull Request -
State: closed - Opened by xuyangzhong 5 days ago
- 1 comment
#25385 - [FLINK-36360] Introduce scripts for cutting branch for a preview release
Pull Request -
State: open - Opened by xintongsong 5 days ago
- 1 comment
Labels: component=ReleaseSystem
#25384 - [FLINK-30614][serializer] Remove old method of resolving schema compa…
Pull Request -
State: closed - Opened by AlexYinHan 6 days ago
- 5 comments
Labels: component=API/TypeSerializationSystem
#25383 - [FLINK-36390][core] Remove deprecated open(Configuration) method in RichFunction
Pull Request -
State: closed - Opened by reswqa 6 days ago
- 3 comments
Labels: component=API/Core
#25382 - [FLINK-36358][table] Fix incorrect timestamp to string behavior.
Pull Request -
State: closed - Opened by liuyongvs 6 days ago
- 1 comment
Labels: component=TableSQL/Planner
#25381 - [FLINK-36308][cep] Remove deprecated APIs from CEP module and dropped state compatible support for old versions
Pull Request -
State: closed - Opened by dianfu 6 days ago
- 1 comment
Labels: component=Library/CEP
#25380 - [FLINK-34702][table-planner] Refactor Deduplicate optimization to defer to StreamPhysicalRank for valid StreamExecDeduplicate node conversion to avoid exceptions
Pull Request -
State: closed - Opened by lincoln-lil 6 days ago
- 3 comments
Labels: component=TableSQL/Planner
#25379 - [FLINK-36350][hotfix] Fix IllegalAccessError in JDK 17 due to kryo InstantiatorStrategy changed
Pull Request -
State: open - Opened by codenohup 6 days ago
- 1 comment
Labels: component=Tests
#25378 - [FLINK-36349][tests] Fix ClosureCleanerITCase fail in the AdaptiveScheduler test profile
Pull Request -
State: closed - Opened by codenohup 6 days ago
- 1 comment
Labels: component=API/TypeSerializationSystem
#25377 - [FLINK-36299][runtime] Fixes bug in AdaptiveSchedulerTest that might cause concurrency issues
Pull Request -
State: closed - Opened by XComp 6 days ago
- 2 comments
Labels: component=Runtime/Coordination
#25376 - [FLINK-3992][core] Do not implement deprecated Key interface
Pull Request -
State: closed - Opened by reswqa 7 days ago
- 1 comment
Labels: component=API/DataSet
#25375 - [FLINK-36295] [runtime] Test `testCheckpointStatsPersistedAcrossRescale` waits until the desired parallelism is reached
Pull Request -
State: closed - Opened by ztison 7 days ago
- 1 comment
Labels: component=Runtime/Coordination
#25374 - [FLINK-36346][API] Remove deprecated API in flink-streaming-java module
Pull Request -
State: closed - Opened by reswqa 8 days ago
- 3 comments
Labels: component=API/DataStream
#25373 - [FLINK-36293][state] make sure register is closed before verification in testAsyncCancellation
Pull Request -
State: open - Opened by showuon 8 days ago
- 2 comments
Labels: component=Runtime/StateBackends
#25372 - [FLINK-34702][table] Do not deduplicate GroupAggregate and some joins for rank
Pull Request -
State: closed - Opened by snuyanzin 8 days ago
- 3 comments
Labels: component=TableSQL/Planner
#25371 - [FLINK-36292][Connectors/Common]: remove timeout to avoid timeout exception
Pull Request -
State: closed - Opened by showuon 8 days ago
- 2 comments
Labels: component=Connectors/Common
#25370 - [FLINK-36342][runtime] Rename misleading variable name 'targetTotalBu…
Pull Request -
State: closed - Opened by XuHao41 9 days ago
- 1 comment
Labels: component=Runtime/Checkpointing
#25369 - [1.20][FLINK-36318] Fix deserializing from 1.18 savepoint with RAW<MAP...> types
Pull Request -
State: closed - Opened by dawidwys 9 days ago
- 1 comment
Labels: component=TableSQL/Planner
#25368 - [hotfix] Fix UnifiedSinkMigrationITCase
Pull Request -
State: closed - Opened by AHeise 9 days ago
- 1 comment
#25367 - [FLINK-36338] Properly handle KeyContext when using AsyncKeyedStateBackendAdaptor
Pull Request -
State: closed - Opened by Zakelly 10 days ago
- 1 comment
Labels: component=<none>
#25366 - [FLINK-36335][runtime] Improving Method Reusability in StreamGraphGenerator with JobVertexBuildContext
Pull Request -
State: open - Opened by noorall 10 days ago
- 4 comments
Labels: component=Runtime/Coordination
#25365 - [DRAFT][FLINK-36336] Remove deprecated dataset API dependency exclude table module
Pull Request -
State: open - Opened by codenohup 10 days ago
- 10 comments
Labels: component=<none>
#25364 - [FLINK-36327][table] Remove dependency about flink-scala and flink-streaming-scala in table module
Pull Request -
State: closed - Opened by xuyangzhong 10 days ago
- 5 comments
Labels: component=TableSQL/API
#25363 - [FLINK-34975][state/forst] Support multiget for forstdb
Pull Request -
State: closed - Opened by fredia 10 days ago
- 1 comment
Labels: component=Runtime/StateBackends
#25362 - [FLINK-36330] Session Window TVFs with named parameters don't support column expansion
Pull Request -
State: closed - Opened by jnh5y 10 days ago
- 1 comment
Labels: component=TableSQL/Planner, component=TableSQL/API
#25361 - [FLINK-35411] Optimize buffer triggering of async state requests
Pull Request -
State: closed - Opened by Zakelly 10 days ago
- 1 comment
Labels: component=Runtime/StateBackends, component=Runtime/Task
#25360 - [FLINK-36321][state/forst] Execute read/write state request in different executors
Pull Request -
State: closed - Opened by fredia 11 days ago
- 2 comments
Labels: component=<none>
#25359 - [FLINK-28770][table-planner] CREATE TABLE AS SELECT supports explain
Pull Request -
State: closed - Opened by spena 11 days ago
- 1 comment
Labels: component=TableSQL/Planner
#25358 - [master][FLINK-36318] Fix deserializing from 1.18 savepoint with RAW<MAP...> types
Pull Request -
State: closed - Opened by dawidwys 11 days ago
- 3 comments
Labels: component=TableSQL/Planner
#25357 - [FLINK-36318] Fix deserializing from 1.18 savepoint with RAW<MAP...> types
Pull Request -
State: closed - Opened by dawidwys 11 days ago
- 2 comments
Labels: component=TableSQL/Planner
#25356 - [FLINK-36015] [runtime] Align rescale parameters
Pull Request -
State: closed - Opened by ztison 11 days ago
- 1 comment
Labels: component=Runtime/Configuration
#25355 - [FLINK-33750][config] Remove deprecated runtime config option
Pull Request -
State: closed - Opened by Sxnan 11 days ago
- 3 comments
Labels: component=API/Core
#25354 - [hotfix][docs] Fix typo in Hive connector overview Python example
Pull Request -
State: open - Opened by TomiFG 11 days ago
- 1 comment
#25353 - [FLINK-36287] Disallow UC for inner sink channels
Pull Request -
State: closed - Opened by AHeise 12 days ago
- 3 comments
Labels: component=<none>
#25352 - [FLINK-36251][streaming-java] Remove StateBackend-related configuration getters/setters that return/set complex Java objects.
Pull Request -
State: closed - Opened by JunRuiLee 12 days ago
- 2 comments
Labels: component=API/Core
#25351 - [FLINK-35764][runtime/metrics] Fix TimerGauge producing incorrect results when updating during a measurement
Pull Request -
State: open - Opened by auroflow 12 days ago
- 1 comment
Labels: component=Runtime/Metrics
#25350 - [FLINK-34125][serializer] Remove deprecated TypeInformation#createSerializer(ExecutionConfig) method
Pull Request -
State: closed - Opened by reswqa 12 days ago
- 2 comments
Labels: component=Runtime/Configuration, component=API/TypeSerializationSystem
#25349 - [FLINK-36314][state/forst] Support state V1 interface in forst statebackend
Pull Request -
State: closed - Opened by fredia 12 days ago
- 3 comments
Labels: component=<none>
#25348 - [FLINK-36310] Remove per-job and run-application
Pull Request -
State: closed - Opened by codenohup 12 days ago
- 1 comment
Labels: component=<none>
#25347 - [FLINK-36257][API] Remove easy-to-drop deprecated API
Pull Request -
State: closed - Opened by reswqa 12 days ago
- 2 comments
Labels: component=<none>
#25346 - [FLINK-34511] Remove legacy State&Checkpointing&Recovery options
Pull Request -
State: closed - Opened by Zakelly 12 days ago
- 5 comments
Labels: component=<none>
#25345 - [FLINK-36117] Internal adaptor from State v1 interfaces to v2
Pull Request -
State: closed - Opened by Zakelly 12 days ago
- 4 comments
Labels: component=Runtime/StateBackends
#25344 - [hotfix][doc] Fix the wrong link of materialized table
Pull Request -
State: closed - Opened by 1996fanrui 13 days ago
- 3 comments
#25343 - [hotfix][docs] Fix typo in Hive connector overview Python example
Pull Request -
State: closed - Opened by TomiFG 13 days ago
- 1 comment
#25342 - [docs] Update Java 17 compatibility docs
Pull Request -
State: closed - Opened by mbalassi 13 days ago
- 3 comments
#25341 - [FLINK-36279][runtime] Making desired resources being calculated based on all available slots for the job
Pull Request -
State: closed - Opened by XComp 14 days ago
- 1 comment
Labels: component=Runtime/Coordination
#25340 - [FLINK-36146][connector] Fix SingleThreadFetcherManager race condition
Pull Request -
State: open - Opened by kimgr 14 days ago
- 2 comments
Labels: component=API/Core
#25339 - [FLINK-36240][runtime/metrics] Fix incorrect Ports display in the PrometheusReporter constructor in case of the httpServer creation failure
Pull Request -
State: closed - Opened by eon2208 14 days ago
- 14 comments
Labels: component=Runtime/Metrics
#25338 - Resolve the error in OperatorIDPairTest.jar compilation report: Too many files with unapproved license
Pull Request -
State: closed - Opened by wangjunyou 15 days ago
- 1 comment
#25337 - Resolve the error in OperatorIDPairTest.jar compilation report: Too many files with unapproved license
Pull Request -
State: closed - Opened by wangjunyou 15 days ago
- 2 comments
#25336 - [FLINK-36284][format-avro] Support extracting Avro type with new DataType stack
Pull Request -
State: closed - Opened by xuyangzhong 16 days ago
- 2 comments
Labels: component=Formats, component=TableSQL/API
#25335 - [FLINK-36283][table-planner] Fix an issue where a UDAF incorrectly accessed the implementation of a built-in function with the same name
Pull Request -
State: closed - Opened by dylanhz 16 days ago
- 2 comments
Labels: component=<none>
#25334 - [FLINK-36273][table] Remove deprecated Table/SQL configuration in 2.0
Pull Request -
State: closed - Opened by xuyangzhong 16 days ago
- 4 comments
Labels: component=<none>
#25333 - [FLINK-36281][runtime] resourceSpec replace SlotSharingGroupUtils.extractResourceSpec(slotSharingGroup)
Pull Request -
State: closed - Opened by caicancai 16 days ago
- 4 comments
Labels: component=API/Core
#25332 - [FLINK-36250][streaming-java] Remove CheckpointStorage-related configuration getters/setters that return/set complex Java objects.
Pull Request -
State: closed - Opened by JunRuiLee 16 days ago
- 1 comment
Labels: component=API/Core
#25331 - [Flink 36245] Remove legacy SourceFunction / SinkFunction / Sink V1 API in 2.0
Pull Request -
State: open - Opened by lvyanquan 16 days ago
- 4 comments