[jira] [Created] (FLINK-32862) Support INIT operation type to be compatible with DTS on Alibaba Cloud

Hang Ruan created FLINK-32862: - Summary: Support INIT operation type to be compatible with DTS on Alibaba Cloud Key: FLINK-32862 URL: https://issues.apache.org/jira/browse/FLINK-32862 Project: Flink

[GitHub] [flink] reswqa commented on a diff in pull request #23179: [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle

reswqa commented on code in PR #23179: URL: https://github.com/apache/flink/pull/23179#discussion_r1293008011 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionConsumerMemoryDataManager.java: ## @@ -43,6 +44,9 @@ public class HsSub

[GitHub] [flink] Myasuka commented on pull request #21835: [FLINK-30854][state] Support periodic compaction for RocksdbCompactFilterCleanupStrategy

Myasuka commented on PR #21835: URL: https://github.com/apache/flink/pull/21835#issuecomment-1676731441 It seems the CI is still broken @masteryhx -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Commented] (FLINK-32833) Rocksdb CacheIndexAndFilterBlocks must be true when using shared memory

[ https://issues.apache.org/jira/browse/FLINK-32833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753907#comment-17753907 ] Yun Tang commented on FLINK-32833: -- FLINK-7289 is the original ticket to introduce thes

[GitHub] [flink] WencongLiu commented on a diff in pull request #23058: Remove parameter in RichFunction#open

WencongLiu commented on code in PR #23058: URL: https://github.com/apache/flink/pull/23058#discussion_r1289525904 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/AbstractRowTimeUnboundedPrecedingOver.java: ## @@ -96,7 +96,7 @@ publi

[GitHub] [flink] reswqa commented on a diff in pull request #23179: [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle

reswqa commented on code in PR #23179: URL: https://github.com/apache/flink/pull/23179#discussion_r1293004006 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyPayloadQueue.java: ## @@ -0,0 +1,66 @@ +/* + * Licensed to the Apac

[jira] [Closed] (FLINK-31259) Gateway supports initialization of catalog at startup

[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-31259. - Resolution: Fixed See https://issues.apache.org/jira/browse/FLINK-32427 > Gateway supports initializati

[GitHub] [flink] WencongLiu commented on a diff in pull request #23179: [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle

WencongLiu commented on code in PR #23179: URL: https://github.com/apache/flink/pull/23179#discussion_r1292974453 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageResultSubpartitionView.java: ## @@ -94,14 +93,14 @@ pub

[GitHub] [flink] WencongLiu commented on a diff in pull request #23179: [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle

WencongLiu commented on code in PR #23179: URL: https://github.com/apache/flink/pull/23179#discussion_r1292974002 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyPayloadQueue.java: ## @@ -0,0 +1,66 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #23206: [hotfix][state] Fix the class referenced by the logger

flinkbot commented on PR #23206: URL: https://github.com/apache/flink/pull/23206#issuecomment-1676675397 ## CI report: * 21edd7e011fc358f7822c856470f22550c3d05fb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] WencongLiu commented on a diff in pull request #23179: [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle

WencongLiu commented on code in PR #23179: URL: https://github.com/apache/flink/pull/23179#discussion_r1292971564 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageResultSubpartitionViewTest.java: ## @@ -115,18 +113,18

[GitHub] [flink] TBCCC opened a new pull request, #23206: [hotfix][state] Fix the class referenced by the logger

TBCCC opened a new pull request, #23206: URL: https://github.com/apache/flink/pull/23206 ## What is the purpose of the change *Fix typo the class referenced by the logger* ## Brief change log Fix typo the class referenced by the logger ## Verifying

[GitHub] [flink] flinkbot commented on pull request #23205: [hotfix][docs] Add missing style options for `sql-client.display.color-schema` in docs

flinkbot commented on PR #23205: URL: https://github.com/apache/flink/pull/23205#issuecomment-1676632048 ## CI report: * b3ede381fe8121a9c3fed9c4464baf2ba4ddc768 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32752) Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-32752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753887#comment-17753887 ] Hang Ruan commented on FLINK-32752: --- Hi, [~Sergey Nuyanzin] . I have raise a PR(https

[GitHub] [flink] ruanhang1993 opened a new pull request, #23205: [hotfix][docs] Add missing style options for `sql-client.display.color-schema` in docs

ruanhang1993 opened a new pull request, #23205: URL: https://github.com/apache/flink/pull/23205 ## What is the purpose of the change Add missing style options for `sql-client.display.color-schema` in docs ## Brief change log Add missing style options for `sql-client.displ

[jira] [Updated] (FLINK-32752) Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-32752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32752: -- Attachment: part1.png part2.png > Release Testing: Verify FLINK-24909 SQL syntax highl

[jira] [Commented] (FLINK-32752) Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-32752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753884#comment-17753884 ] Hang Ruan commented on FLINK-32752: --- Hi, all. I have tested this feature and it looks

[jira] [Created] (FLINK-32861) Batch mode, sink to multables the task graph of web page monitor jobs , lack sink task graph block

zhengyuan created FLINK-32861: - Summary: Batch mode, sink to multables the task graph of web page monitor jobs , lack sink task graph block Key: FLINK-32861 URL: https://issues.apache.org/jira/browse/FLINK-32861

[jira] [Assigned] (FLINK-32771) Remove the invalid config option slotmanager.request-timeout

[ https://issues.apache.org/jira/browse/FLINK-32771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-32771: - Assignee: Weihua Hu (was: Weihua Hu) > Remove the invalid config option slotmanager.request-ti

[jira] [Resolved] (FLINK-32786) Release Testing: Verify FLIP-302: Support TRUNCATE TABLE statement in batch mode

[ https://issues.apache.org/jira/browse/FLINK-32786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-32786. -- Resolution: Fixed [~ruanhang1993] Thanks for helping verifing.  > Release Testing: Verify FLIP-302: S

[jira] [Comment Edited] (FLINK-32786) Release Testing: Verify FLIP-302: Support TRUNCATE TABLE statement in batch mode

[ https://issues.apache.org/jira/browse/FLINK-32786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753875#comment-17753875 ] Hang Ruan edited comment on FLINK-32786 at 8/14/23 3:04 AM:

[jira] [Updated] (FLINK-32786) Release Testing: Verify FLIP-302: Support TRUNCATE TABLE statement in batch mode

[ https://issues.apache.org/jira/browse/FLINK-32786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32786: -- Attachment: after.png before.png truncate.png > Release Testing: Verif

[jira] [Commented] (FLINK-32786) Release Testing: Verify FLIP-302: Support TRUNCATE TABLE statement in batch mode

[ https://issues.apache.org/jira/browse/FLINK-32786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753875#comment-17753875 ] Hang Ruan commented on FLINK-32786: --- I have implemented the interface in JDBC connecto

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753869#comment-17753869 ] Feifan Wang commented on FLINK-30863: - Since [~Yanfei Lei]  is still working on the

[jira] [Updated] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-30863: Labels: pull-request-available (was: pull-request-available stale-assigned) > Register local reco

[jira] [Created] (FLINK-32860) Add missing visibility annotation for Table APIs

Jane Chan created FLINK-32860: - Summary: Add missing visibility annotation for Table APIs Key: FLINK-32860 URL: https://issues.apache.org/jira/browse/FLINK-32860 Project: Flink Issue Type: Improv

[jira] [Updated] (FLINK-28424) JdbcExactlyOnceSinkE2eTest hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-28424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28424: --- Labels: auto-deprioritized-critical stale-major test-stability (was: auto-deprioritized-cri

[jira] [Updated] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28697: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-28455) pyflink tableResult collect result to local timeout

[ https://issues.apache.org/jira/browse/FLINK-28455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28455: --- Labels: flink pyflink stale-major (was: flink pyflink) I am the [Flink Jira Bot|https://git

[jira] [Updated] (FLINK-27952) Table UDF fails when using Double.POSITIVE_INFINITY as parameters

[ https://issues.apache.org/jira/browse/FLINK-27952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27952: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-28395) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi fails with Elasticsearch exception [type=index_not_found_exception, reason=no such index]

[ https://issues.apache.org/jira/browse/FLINK-28395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28395: --- Labels: auto-deprioritized-critical pull-request-available stale-major test-stability (was:

[jira] [Updated] (FLINK-25737) Chinese Translation - Add documentation for Firehose Async Sink

[ https://issues.apache.org/jira/browse/FLINK-25737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25737: --- Labels: auto-deprioritized-major chinese-translation stale-minor (was: auto-deprioritized-m

[jira] [Updated] (FLINK-28741) Unexpected result if insert 'false' to boolean column

[ https://issues.apache.org/jira/browse/FLINK-28741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28741: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25695: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was: auto-deprioritize

[jira] [Updated] (FLINK-25747) UdfStreamOperatorCheckpointingITCase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25747: --- Labels: auto-deprioritized-critical auto-deprioritized-major stale-minor test-stability (wa

[jira] [Updated] (FLINK-25768) Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25768: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-27449) The comment is lost when creating a Table from Datastream and Schema

[ https://issues.apache.org/jira/browse/FLINK-27449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27449: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-25765) Kubernetes: flink's configmap and flink's actual config are out of sync

[ https://issues.apache.org/jira/browse/FLINK-25765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25765: --- Labels: auto-deprioritized-major stale-minor usability (was: auto-deprioritized-major usabi

[jira] [Updated] (FLINK-27883) KafkaSubscriberTest failed with NPC

[ https://issues.apache.org/jira/browse/FLINK-27883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27883: --- Labels: auto-deprioritized-major stale-major test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-27482) Dashboard not showing after installation

[ https://issues.apache.org/jira/browse/FLINK-27482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27482: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

[ https://issues.apache.org/jira/browse/FLINK-27550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27550: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-25675) UnalignedCheckpointCompatibilityITCase.test hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25675: --- Labels: auto-deprioritized-critical auto-deprioritized-major stale-minor test-stability (wa

[jira] [Updated] (FLINK-28034) ClassCastException occurred in creating a checkpoint with merge windows

[ https://issues.apache.org/jira/browse/FLINK-28034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28034: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-28319) ResumeCheckpointManuallyITCase gets stuck

[ https://issues.apache.org/jira/browse/FLINK-28319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28319: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-25835) The task initialization duration is recorded in logs

[ https://issues.apache.org/jira/browse/FLINK-25835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25835: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was: auto-deprioritize

[jira] [Updated] (FLINK-30702) Introduce ElasticDialect

[ https://issues.apache.org/jira/browse/FLINK-30702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30702: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-27918) SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed with Expected RuntimeException after snapshot creation

[ https://issues.apache.org/jira/browse/FLINK-27918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27918: --- Labels: auto-deprioritized-critical stale-major test-stability (was: auto-deprioritized-cri

[jira] [Updated] (FLINK-25736) Chinese Translation - Update documentation for Kinesis Table Api

[ https://issues.apache.org/jira/browse/FLINK-25736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25736: --- Labels: auto-deprioritized-major chinese-translation stale-minor (was: auto-deprioritized-m

[jira] [Updated] (FLINK-25814) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed

[ https://issues.apache.org/jira/browse/FLINK-25814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25814: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-28503) Fix invalid link in Python FAQ Document

[ https://issues.apache.org/jira/browse/FLINK-28503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28503: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-28530) Improvement of extraction of conditions that can be pushed into join inputs

[ https://issues.apache.org/jira/browse/FLINK-28530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28530: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30863: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-30854) Expose periodic compaction to RocksdbCompactFilterCleanupStrategy

[ https://issues.apache.org/jira/browse/FLINK-30854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30854: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-28545) FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not present in m

[ https://issues.apache.org/jira/browse/FLINK-28545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28545: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-25730) Fix chaining strategy (and typo?) in RowTimeMiniBatchAssginerOperator

[ https://issues.apache.org/jira/browse/FLINK-25730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25730: --- Labels: pull-request-available stale-minor (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-30649) Shutting down MiniCluster times out

[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30649: --- Labels: stale-assigned starter test-stability (was: starter test-stability) I am the [Flink

[jira] [Updated] (FLINK-30503) KafkaSourceITCase$IntegrationTests.testSavepoint failed with timeout

[ https://issues.apache.org/jira/browse/FLINK-30503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30503: --- Labels: stale-assigned test-stability (was: test-stability) I am the [Flink Jira Bot|https:

[jira] [Updated] (FLINK-30513) HA storage dir leaks on cluster termination

[ https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30513: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-25938) SynchronousCheckpointITCase.taskDispatcherThreadPoolAllowsForSynchronousCheckpoints fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25938: --- Labels: auto-deprioritized-critical auto-deprioritized-major stale-minor test-stability (wa

[jira] [Updated] (FLINK-30519) Add e2e tests for operator dynamic config

[ https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30519: --- Labels: stale-assigned starter (was: starter) I am the [Flink Jira Bot|https://github.com/a

[jira] [Updated] (FLINK-30556) Improve the logic for enumerating splits for Hive source to avoid potential OOM

[ https://issues.apache.org/jira/browse/FLINK-30556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30556: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-30578) Publish SBOM artifacts

[ https://issues.apache.org/jira/browse/FLINK-30578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30578: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-30613) Improve resolving schema compatibility -- Milestone one

[ https://issues.apache.org/jira/browse/FLINK-30613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30613: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-30810) Rework the CliClientITCase to extend AbstractSqlGatewayStatementITCase

[ https://issues.apache.org/jira/browse/FLINK-30810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-30810: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[GitHub] [flink] flinkbot commented on pull request #23204: [FLINK-32855][flink-runtime][JUnit5 Migration] Module: The taskexecutor package of flink-runtime

flinkbot commented on PR #23204: URL: https://github.com/apache/flink/pull/23204#issuecomment-1676433733 ## CI report: * 77acbaad5e7d4194d3ad0b7ade0af233d43a9c0a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32855) [JUnit5 Migration] The taskexecutor package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32855: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] The taskexecutor package of fli

[GitHub] [flink] Jiabao-Sun opened a new pull request, #23204: [FLINK-32855][flink-runtime][JUnit5 Migration] Module: The taskexecutor package of flink-runtime

Jiabao-Sun opened a new pull request, #23204: URL: https://github.com/apache/flink/pull/23204 [FLINK-32855][flink-runtime][JUnit5 Migration] Module: The taskexecutor package of flink-runtime ## What is the purpose of the change [flink-runtime][JUnit5 Migration] Module:

[GitHub] [flink] flinkbot commented on pull request #23203: [FLINK-32859][scheduler] Introduce the StateWithoutExecutionGraph

flinkbot commented on PR #23203: URL: https://github.com/apache/flink/pull/23203#issuecomment-1676415608 ## CI report: * 2dc4548e92340efda292585ef71fc47a973d989b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32859) Improve the state of adaptive sheduler with StateWithoutExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-32859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32859: --- Labels: pull-request-available (was: ) > Improve the state of adaptive sheduler with StateW

[GitHub] [flink] 1996fanrui opened a new pull request, #23203: [FLINK-32859][scheduler] Introduce the StateWithoutExecutionGraph

1996fanrui opened a new pull request, #23203: URL: https://github.com/apache/flink/pull/23203 ## What is the purpose of the change Currently, most of states of adaptive scheduler extends StateWithExecutionGraph, and it can reduce a lots of repeated code. We can define the State

[GitHub] [flink] flinkbot commented on pull request #23202: [FLINK-32564][table]bytes-to-number & number-to-bytes

flinkbot commented on PR #23202: URL: https://github.com/apache/flink/pull/23202#issuecomment-1676408995 ## CI report: * bca6a27cd3cb23e87a8da345891f783ecb06c632 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23202: bytes-to-number & number-to-bytes

hanyuzheng7 opened a new pull request, #23202: URL: https://github.com/apache/flink/pull/23202 ### What is the purpose of the change Implement` CAST` from `BINARY`/`VARBINART`/`BYTES `to `NUMBER` Implement` CAST` from `NUMBER` to `BINARY`/`VARBINART`/`BYTES ` ### Brief change log

[jira] [Updated] (FLINK-32859) Improve the state of adaptive sheduler with StateWithoutExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-32859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32859: Description: Currently, most of states of adaptive scheduler extends StateWithExecutionGraph, and it can

[jira] [Created] (FLINK-32859) Improve the state of adaptive sheduler with StateWithoutExecutionGraph

Rui Fan created FLINK-32859: --- Summary: Improve the state of adaptive sheduler with StateWithoutExecutionGraph Key: FLINK-32859 URL: https://issues.apache.org/jira/browse/FLINK-32859 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #23201: [FLINK-15959] Add min number of slots configuration to limit total number of slots

flinkbot commented on PR #23201: URL: https://github.com/apache/flink/pull/23201#issuecomment-1676398917 ## CI report: * 30ba094c60abd82f3e33913177d2619b12d60dbf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15959: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-avail

[GitHub] [flink] xiangyuf opened a new pull request, #23201: [FLINK-15959] Add min number of slots configuration to limit total number of slots

xiangyuf opened a new pull request, #23201: URL: https://github.com/apache/flink/pull/23201 ## What is the purpose of the change Add min number of slots configuration to limit total number of slots ## Brief change log - Introduce "slotmanager.number-of-slots.min" conf

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23199: [FLINK-32858][tests][JUnit5 migration] Migrate flink-runtime/utils tests to JUnit5

1996fanrui commented on code in PR #23199: URL: https://github.com/apache/flink/pull/23199#discussion_r1292785807 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/util/TestLogger.java: ## @@ -31,7 +31,10 @@ /** * Adds automatic test name loggin

[GitHub] [flink] Jiabao-Sun commented on pull request #23200: [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

Jiabao-Sun commented on PR #23200: URL: https://github.com/apache/flink/pull/23200#issuecomment-1676364957 > Thanks @Jiabao-Sun for the quick contribution! > > Would you mind updating all change about these improvements? > > * Update the `isEqualTo(0)` to `isZero()` > * Updat

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23200: [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

1996fanrui commented on code in PR #23200: URL: https://github.com/apache/flink/pull/23200#discussion_r1292790559 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPoolTest.java: ## @@ -172,20 +171,20 @@ public void testBufferFulfilledByRecycl

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23199: [FLINK-32858][tests][JUnit5 migration] Migrate flink-runtime/utils tests to JUnit5

1996fanrui commented on code in PR #23199: URL: https://github.com/apache/flink/pull/23199#discussion_r1292784420 ## flink-runtime/src/test/java/org/apache/flink/runtime/util/BlockingShutdownTest.java: ## @@ -96,7 +95,7 @@ public void testProcessExitsDespiteBlockingShutdownHook(

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20990: [FLINK-29050][JUnit5 Migration] Module: flink-hadoop-compatibility

1996fanrui commented on code in PR #20990: URL: https://github.com/apache/flink/pull/20990#discussion_r1292783464 ## flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/AbstractTestBaseJUnit5.java: ## @@ -0,0 +1,125 @@ +/* + * Licensed to the Apache

[GitHub] [flink] 1996fanrui commented on pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

1996fanrui commented on PR #20232: URL: https://github.com/apache/flink/pull/20232#issuecomment-1676337619 > How about using "Host:port" in the title in both the subtask details panel and tasks manager details panel? Sounds make sense to me. -- This is an automated message from the

[jira] [Commented] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753725#comment-17753725 ] Feifan Wang commented on FLINK-31139: - Hi [~roman] , is there any method to re-run  

[jira] [Assigned] (FLINK-32848) [JUnit5 Migration] The persistence, query, registration, rpc and shuffle packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32848: --- Assignee: Zhanghao Chen > [JUnit5 Migration] The persistence, query, registration, rpc and shuffle

[jira] [Commented] (FLINK-32848) [JUnit5 Migration] The persistence, query, registration, rpc and shuffle packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753724#comment-17753724 ] Rui Fan commented on FLINK-32848: - Assigned, thanks for your warm! :) > [JUnit5 Migrati

[jira] [Assigned] (FLINK-32855) [JUnit5 Migration] The taskexecutor package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32855: --- Assignee: Jiabao Sun > [JUnit5 Migration] The taskexecutor package of flink-runtime module > --

[jira] [Commented] (FLINK-32855) [JUnit5 Migration] The taskexecutor package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753723#comment-17753723 ] Rui Fan commented on FLINK-32855: - Assigned, thanks for your warm! :) > [JUnit5 Migrati

[jira] [Commented] (FLINK-32854) [JUnit5 Migration] The state package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753722#comment-17753722 ] Rui Fan commented on FLINK-32854: - Assigned, thanks for your warm! :) > [JUnit5 Migrati

[jira] [Assigned] (FLINK-32854) [JUnit5 Migration] The state package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32854: --- Assignee: Jiabao Sun > [JUnit5 Migration] The state package of flink-runtime module > -

[jira] [Updated] (FLINK-26133) Kafka Source Web Deserializer Java Code is Error

[ https://issues.apache.org/jira/browse/FLINK-26133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26133: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was: auto-deprioritize

[jira] [Updated] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31080: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-28756) Can't write nested object to parquet flink 1.15.1

[ https://issues.apache.org/jira/browse/FLINK-28756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28756: --- Labels: Flink Flink-parquet Flink-table-api TableAPI flink-formats stale-major (was: Flink

[jira] [Updated] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

[ https://issues.apache.org/jira/browse/FLINK-28984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28984: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-29125) Placeholder in Apache Flink Web Frontend to display some "tags" to distinguish between frontends of different clusters

[ https://issues.apache.org/jira/browse/FLINK-29125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29125: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-26009) ArchUnit for Flink

[ https://issues.apache.org/jira/browse/FLINK-26009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26009: --- Labels: Umbrella stale-minor (was: Umbrella) I am the [Flink Jira Bot|https://github.com/ap

[jira] [Updated] (FLINK-26104) KeyError: 'type_info' in PyFlink test

[ https://issues.apache.org/jira/browse/FLINK-26104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26104: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-29261) Use FAIL_ON_UNKNOWN_PROPERTIES=false in ReconciliationUtils

[ https://issues.apache.org/jira/browse/FLINK-29261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29261: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-26083) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink failed on azure due to table exists

[ https://issues.apache.org/jira/browse/FLINK-26083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26083: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-25939) PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots

[ https://issues.apache.org/jira/browse/FLINK-25939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25939: --- Labels: auto-deprioritized-critical auto-deprioritized-major stale-minor test-stability (wa

  1   2   >