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

#22582 - [FLINK-24696][docs-zh]Translate how to configure unaligned checkpoints into Chinese

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

#22582 - [FLINK-24696][docs-zh]Translate how to configure unaligned checkpoints into Chinese

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

#22582 - [FLINK-24696][docs-zh]Translate how to configure unaligned checkpoints into Chinese

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

#22582 - [FLINK-24696][docs-zh]Translate how to configure unaligned checkpoints into Chinese

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

#22580 - [FLINK-31967][table-runner] Solving the Initial Value Problem of LagA…

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

#22580 - [FLINK-31967][table-runner] Solving the Initial Value Problem of LagA…

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

#22580 - [FLINK-31967][table-runner] Solving the Initial Value Problem of LagA…

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

#22580 - [FLINK-31967][table-runner] Solving the Initial Value Problem of LagA…

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

#22577 - [FLINK-31882][sql-client] Fix sql client can't show result for DELETE…

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

#22576 - Remove savepoint and checkpoint mount instructions from flink playground.

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

#22576 - Remove savepoint and checkpoint mount instructions from flink playground.

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

#22575 - Updating docs on how to upgrade kafka connectors

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

#22575 - Updating docs on how to upgrade kafka connectors

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

#22572 - [FLINK-29618] Remove Timeout annotation in YARNSessionFIFOSecuredITCase

Pull Request - State: open - Opened by WencongLiu over 1 year ago - 7 comments

#22572 - [FLINK-29618] Remove Timeout annotation in YARNSessionFIFOSecuredITCase

Pull Request - State: open - Opened by WencongLiu over 1 year ago - 7 comments

#22571 - [FLINK-32056][Python][Connector/Pulsar] Upgrade flink-connector-pulsar in flink-python to v4.0.0

Pull Request - State: closed - Opened by MartijnVisser over 1 year ago - 4 comments
Labels: component=API/Python, component=Connectors/Pulsar

#22571 - [FLINK-32056][Python][Connector/Pulsar] Upgrade flink-connector-pulsar in flink-python to v4.0.0

Pull Request - State: closed - Opened by MartijnVisser over 1 year ago - 4 comments
Labels: component=API/Python, component=Connectors/Pulsar

#22570 - [FLINK-32064][table-planner] Add subdirectory of test output file for JsonPlanTest to indicate the plan's version

Pull Request - State: closed - Opened by LadyForest over 1 year ago - 4 comments
Labels: component=TableSQL/Planner

#22570 - [FLINK-32064][table-planner] Add subdirectory of test output file for JsonPlanTest to indicate the plan's version

Pull Request - State: closed - Opened by LadyForest over 1 year ago - 4 comments
Labels: component=TableSQL/Planner

#22569 - [FLINK-32014][doc][hotfix] Add Cassandra source documentation to website

Pull Request - State: closed - Opened by echauchot over 1 year ago - 3 comments
Labels: component=Documentation, component=Connectors/Cassandra

#22568 - [FLINK-32048][tests] Migrate DecimalITCase to JUnit5 to resolve the unstable test issues

Pull Request - State: closed - Opened by TanYuxin-tyx over 1 year ago - 2 comments
Labels: component=Runtime/Network, component=Tests, component=TableSQL/Planner

#22568 - [FLINK-32048][tests] Migrate DecimalITCase to JUnit5 to resolve the unstable test issues

Pull Request - State: closed - Opened by TanYuxin-tyx over 1 year ago - 2 comments
Labels: component=Runtime/Network, component=Tests, component=TableSQL/Planner

#22567 - [FLINK-27518][Check only] Check the migration test data generation works

Pull Request - State: closed - Opened by gaoyunhaii over 1 year ago - 1 comment
Labels: component=TestInfrastructure

#22567 - [FLINK-27518][Check only] Check the migration test data generation works

Pull Request - State: closed - Opened by gaoyunhaii over 1 year ago - 1 comment
Labels: component=TestInfrastructure

#22566 - [FLINK-32052][table-runtime] Introduce left and right state retention time to StreamingJoinOperator

Pull Request - State: open - Opened by LadyForest over 1 year ago - 3 comments
Labels: component=TableSQL/Runtime

#22566 - [FLINK-32052][table-runtime] Introduce left and right state retention time to StreamingJoinOperator

Pull Request - State: closed - Opened by LadyForest over 1 year ago - 3 comments
Labels: component=TableSQL/Runtime

#22565 - [FLINK-32059] Update Jackson-BOM to 2.14.3

Pull Request - State: closed - Opened by snuyanzin over 1 year ago - 1 comment
Labels: component=Tests

#22565 - [FLINK-32059] Update Jackson-BOM to 2.14.3

Pull Request - State: closed - Opened by snuyanzin over 1 year ago - 1 comment
Labels: component=Tests

#22564 - [FLINK-31891][runtime] Introduce AdaptiveScheduler per-task failure enrichment/labeling

Pull Request - State: closed - Opened by pgaref over 1 year ago - 3 comments
Labels: component=<none>

#22564 - [FLINK-31891][runtime] Introduce AdaptiveScheduler per-task failure enrichment/labeling

Pull Request - State: open - Opened by pgaref over 1 year ago - 1 comment
Labels: component=<none>

#22563 - [FLINK-32044][table-api] Validate catalog name when listFunctions in FunctionCatalog

Pull Request - State: open - Opened by chucheng92 over 1 year ago - 1 comment
Labels: component=TableSQL/API

#22563 - [FLINK-32044][table-api] Validate catalog name when listFunctions in FunctionCatalog

Pull Request - State: open - Opened by chucheng92 over 1 year ago - 1 comment
Labels: component=TableSQL/API

#22562 - [BP-1.16][FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException.

Pull Request - State: closed - Opened by XComp over 1 year ago - 2 comments
Labels: component=Runtime/Coordination

#22562 - [BP-1.16][FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException.

Pull Request - State: closed - Opened by XComp over 1 year ago - 2 comments
Labels: component=Runtime/Coordination

#22561 - [BP-1.17][FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException.

Pull Request - State: closed - Opened by XComp over 1 year ago - 5 comments
Labels: component=Runtime/Coordination

#22561 - [BP-1.17][FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException.

Pull Request - State: closed - Opened by XComp over 1 year ago - 5 comments
Labels: component=Runtime/Coordination

#22560 - [FLINK-32023][API / DataStream] Support negative Duration for special usage, such as -1ms for execution.buffer-timeout

Pull Request - State: open - Opened by Myracle over 1 year ago - 4 comments
Labels: component=API/DataStream

#22558 - [FLINK-28744][table] Upgrade Calcite to 1.31.0

Pull Request - State: open - Opened by snuyanzin over 1 year ago - 4 comments
Labels: component=TableSQL/API

#22558 - [FLINK-28744][table] Upgrade Calcite to 1.31.0

Pull Request - State: open - Opened by snuyanzin over 1 year ago - 3 comments
Labels: component=TableSQL/API

#22557 - [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml

Pull Request - State: closed - Opened by reswqa over 1 year ago - 4 comments
Labels: component=Connectors/Common

#22557 - [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml

Pull Request - State: closed - Opened by reswqa over 1 year ago - 4 comments
Labels: component=Connectors/Common

#22556 - [FLINK-32030][sql-client] Add URLs support for SQL Client gateway mode

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

#22556 - [FLINK-32030][sql-client] Add URLs support for SQL Client gateway mode

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

#22555 - [FLINK-31706] [runtime] The default source parallelism should be the same as ex…

Pull Request - State: closed - Opened by clownxc over 1 year ago - 7 comments
Labels: component=Runtime/Coordination

#22554 - [BP-1.17][FLINK-32027][runtime] Fix the potential concurrent reading bug of index file for SortMergeShuffle.

Pull Request - State: closed - Opened by reswqa over 1 year ago - 1 comment
Labels: component=Runtime/Network

#22553 - [BP-1.16][FLINK-32027][runtime] Fix the potential concurrent reading bug of index file for SortMergeShuffle.

Pull Request - State: closed - Opened by reswqa over 1 year ago - 1 comment
Labels: component=Runtime/Network

#22552 - [FLINK-30585][flamegraph] Collect the flame graph of a single subtask instead of all subtasks when viewing the flame graph of a single subtask

Pull Request - State: open - Opened by 1996fanrui over 1 year ago - 2 comments
Labels: component=Runtime/WebFrontend, component=Runtime/Task

#22552 - [FLINK-30585][flamegraph] Collect the flame graph of a single subtask instead of all subtasks when viewing the flame graph of a single subtask

Pull Request - State: open - Opened by 1996fanrui over 1 year ago - 2 comments
Labels: component=Runtime/WebFrontend, component=Runtime/Task

#22551 - [FLINK-31919][core] Only run closure cleaner if serialization fails

Pull Request - State: open - Opened by zentol over 1 year ago - 3 comments
Labels: component=API/Core

#22551 - [FLINK-31919][core] Only run closure cleaner if serialization fails

Pull Request - State: open - Opened by zentol over 1 year ago - 1 comment
Labels: component=API/Core

#22550 - [FLINK-31609][yarn][test] Extend log whitelist for expected AMRM heartbeat interrupt

Pull Request - State: closed - Opened by ferenc-csaky over 1 year ago - 5 comments
Labels: component=Deployment/YARN

#22549 - [FLINK-32027] Fix the potential concurrent reading bug of index file for SortMergeShuffle.

Pull Request - State: closed - Opened by reswqa over 1 year ago - 2 comments
Labels: component=Runtime/Network

#22548 - [FLINK-32039][test] Adds graceful shutdown to TestExecutorExtension and TestExecutorResource

Pull Request - State: open - Opened by XComp over 1 year ago - 1 comment
Labels: component=Runtime/Coordination

#22548 - [FLINK-32039][test] Adds graceful shutdown to TestExecutorExtension and TestExecutorResource

Pull Request - State: open - Opened by XComp over 1 year ago - 1 comment
Labels: component=Runtime/Coordination

#22547 - [FLINK-30081][runtime] Reset jvm-overhead.min/max for local executor

Pull Request - State: open - Opened by liuml07 over 1 year ago - 2 comments
Labels: component=Runtime/Configuration

#22547 - [FLINK-30081][runtime] Reset jvm-overhead.min/max for local executor

Pull Request - State: open - Opened by liuml07 over 1 year ago - 2 comments
Labels: component=Runtime/Configuration

#22546 - [FLINK-32032] Upgrade to flink-shaded 17.0

Pull Request - State: open - Opened by MartijnVisser over 1 year ago - 8 comments
Labels: component=<none>

#22546 - [FLINK-32032] Upgrade to flink-shaded 17.0

Pull Request - State: open - Opened by MartijnVisser over 1 year ago - 8 comments
Labels: component=<none>

#22545 - [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating wh…

Pull Request - State: closed - Opened by zoltar9264 over 1 year ago - 1 comment
Labels: component=Runtime/StateBackends

#22544 - [FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException

Pull Request - State: closed - Opened by XComp over 1 year ago - 3 comments
Labels: component=Runtime/Coordination

#22544 - [FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException

Pull Request - State: closed - Opened by XComp over 1 year ago - 3 comments
Labels: component=Runtime/Coordination

#22543 - [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating wh…

Pull Request - State: closed - Opened by zoltar9264 over 1 year ago - 1 comment
Labels: component=Runtime/StateBackends

#22543 - [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating wh…

Pull Request - State: closed - Opened by zoltar9264 over 1 year ago - 1 comment
Labels: component=Runtime/StateBackends

#22542 - [FLINK-31931][runtime] Prevent exception history page from linking to non-existent TM page.

Pull Request - State: open - Opened by JunRuiLee over 1 year ago - 1 comment
Labels: component=Runtime/WebFrontend

#22542 - [FLINK-31931][runtime] Prevent exception history page from linking to non-existent TM page.

Pull Request - State: open - Opened by JunRuiLee over 1 year ago - 1 comment
Labels: component=Runtime/WebFrontend

#22541 - [BP-1.16][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective

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

#22541 - [BP-1.16][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective

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

#22540 - [FLINK-31997] Upgrade to fabric8 6.5.1

Pull Request - State: open - Opened by gyfora over 1 year ago - 4 comments
Labels: component=Deployment/Kubernetes

#22540 - [FLINK-31997] Upgrade to fabric8 6.5.1

Pull Request - State: open - Opened by gyfora over 1 year ago - 4 comments
Labels: component=Deployment/Kubernetes

#22539 - [FLINK-31956][table] Extend the CompiledPlan to read from/write to Fl…

Pull Request - State: open - Opened by xishuaidelin over 1 year ago - 1 comment
Labels: component=TableSQL/Planner, component=TableSQL/Client

#22539 - [FLINK-31956][table] Extend the CompiledPlan to read from/write to Fl…

Pull Request - State: open - Opened by xishuaidelin over 1 year ago - 3 comments
Labels: component=TableSQL/Planner, component=TableSQL/Client

#22538 - [FLINK-31956][table] Extend the CompiledPlan to read from/write to Fl…

Pull Request - State: closed - Opened by xishuaidelin over 1 year ago - 1 comment
Labels: component=TableSQL/Planner, component=TableSQL/Client

#22538 - [FLINK-31956][table] Extend the CompiledPlan to read from/write to Fl…

Pull Request - State: closed - Opened by xishuaidelin over 1 year ago - 1 comment
Labels: component=TableSQL/Planner, component=TableSQL/Client

#22537 - [hotfix][table-planner] Replace empty hashset with EMPTY_SET

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

#22537 - [hotfix][table-planner] Replace empty hashset with EMPTY_SET

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

#22536 - [FLINK-31546][jdbc-driver] Close all statements when connection is closed

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

#22536 - [FLINK-31546][jdbc-driver] Close all statements when connection is closed

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

#22535 - [BP-1.16][FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.

Pull Request - State: closed - Opened by reswqa over 1 year ago - 1 comment
Labels: component=Runtime/Network

#22535 - [BP-1.16][FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.

Pull Request - State: closed - Opened by reswqa over 1 year ago - 1 comment
Labels: component=Runtime/Network