[jira] [Updated] (FLINK-32866) Unify the TestLoggerExtension config of junit5

[ https://issues.apache.org/jira/browse/FLINK-32866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32866: Summary: Unify the TestLoggerExtension config of junit5 (was: Clean up the

[jira] [Created] (FLINK-32895) Introduce the max attempts for Exponential Delay Restart Strategy

Rui Fan created FLINK-32895: --- Summary: Introduce the max attempts for Exponential Delay Restart Strategy Key: FLINK-32895 URL: https://issues.apache.org/jira/browse/FLINK-32895 Project: Flink

[jira] [Updated] (FLINK-32661) OperationRelatedITCase.testOperationRelatedApis fails on AZP

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

[jira] [Updated] (FLINK-31493) helm upgrade does not work, because repo path does not follow helm standards

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

[jira] [Updated] (FLINK-31526) Various test failures in PyFlink

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

[jira] [Updated] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP

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

[jira] [Updated] (FLINK-31567) Promote release 1.17

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

[jira] [Updated] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in File Sink

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

[jira] [Updated] (FLINK-32393) NettyClientServerSslTest.testSslPinningForInvalidFingerprint fails with Address already in use

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

[jira] [Updated] (FLINK-32604) PyFlink end-to-end fails with kafka-server-stop.sh: No such file or directory

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

[jira] [Updated] (FLINK-31755) ROW function can not work with RewriteIntersectAllRule

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

[jira] [Updated] (FLINK-31928) flink-kubernetes works not properly in k8s with IPv6 stack

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

[jira] [Updated] (FLINK-30743) Improve Kubernetes HA Services docs

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

[jira] [Updated] (FLINK-22091) env.java.home option didn't take effect in resource negotiator

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

[jira] [Updated] (FLINK-31992) FlinkKafkaConsumer API is suggested to use as part of documentation, when that API is deprecated for flink version 1.14

[ https://issues.apache.org/jira/browse/FLINK-31992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31992: --- Labels: auto-deprioritized-major documentation documentation-update good-first-issue

[jira] [Updated] (FLINK-17488) JdbcSink has to support setting autoCommit mode of DB

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

[jira] [Updated] (FLINK-32101) FlinkKafkaInternalProducerITCase.testInitTransactionId test failed

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

[jira] [Updated] (FLINK-31595) MiniBatchLocalGroupAggFunction produces wrong aggregate results with state clean up

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

[jira] [Updated] (FLINK-32036) TableEnvironmentTest.test_explain is unstable on azure ci

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

[jira] [Updated] (FLINK-31877) StreamExecutionEnvironmentTests.test_from_collection_with_data_types is unstable

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

[jira] [Updated] (FLINK-32156) Int2AdaptiveHashJoinOperatorTest produced no output for 900s on AZP

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

[jira] [Updated] (FLINK-32269) CreateTableAsITCase.testCreateTableAsInStatementSet fails on AZP

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

[jira] [Updated] (FLINK-32151) 'Run kubernetes pyflink application test' fails while pulling image

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

[jira] [Updated] (FLINK-31862) KafkaSinkITCase.testStartFromSavepoint is unstable

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

[jira] [Updated] (FLINK-31756) KafkaTableITCase.testStartFromGroupOffsetsNone fails due to UnknownTopicOrPartitionException

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

[jira] [Updated] (FLINK-32553) ClusterEntrypointTest.testCloseAsyncShouldNotDeregisterApp failed on AZP

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

[jira] [Updated] (FLINK-32155) Multiple CIs jobs failed due to "Could not connect to azure.archive.ubuntu.com"

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

[jira] [Updated] (FLINK-31828) List field in a POJO data stream results in table program compilation failure

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

[jira] [Updated] (FLINK-28847) Typo in FileSinkProgram.java in file-sink-file-test module

[ https://issues.apache.org/jira/browse/FLINK-28847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28847: --- Labels: auto-deprioritized-minor easyfix (was: easyfix stale-minor) Priority: Not a

[jira] [Updated] (FLINK-29789) Fix flaky tests in CheckpointCoordinatorTest

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

[jira] [Updated] (FLINK-32113) TtlMapStateAllEntriesTestContext failure in generic types

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

[jira] [Updated] (FLINK-32138) SQLClientSchemaRegistryITCase fails with timeout on AZP

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

[jira] [Updated] (FLINK-18397) Translate "Table & SQL Connectors Overview" page into Chinese

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

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

[ https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28291: --- Labels: PatchAvailable auto-deprioritized-minor patch-available (was: PatchAvailable

[jira] [Updated] (FLINK-28750) Whether to add field comment for hive table

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

[jira] [Updated] (FLINK-28837) Translate "Hybrid Source" page of "DataStream Connectors" into Chinese

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

[jira] [Updated] (FLINK-28839) Incorrect english sentence in docs/content/docs/dev/dataset/iterations.md

[ https://issues.apache.org/jira/browse/FLINK-28839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28839: --- Labels: auto-deprioritized-minor easy-fix starter (was: easy-fix stale-minor starter)

[jira] [Updated] (FLINK-28358) when debug in local ,throw out "The system time period specification expects Timestamp type but is 'TIMESTAMP_WITH_LOCAL_TIME_ZONE' " exception

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

[jira] [Updated] (FLINK-30782) Use https for schemaLocations

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

[jira] [Updated] (FLINK-30817) ClassCastException in TestValuesTableFactory.TestValuesScanTableSourceWithoutProjectionPushDown

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

[jira] [Updated] (FLINK-20578) Cannot create empty array using ARRAY[]

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

[jira] [Updated] (FLINK-32159) Hudi Source throws NPE

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

[jira] [Updated] (FLINK-32188) Support to "where" query with a fixed-value array and simplify condition for an array-type filed.

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

[jira] [Updated] (FLINK-20350) Incompatible Connectors due to Guava conflict

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

[jira] [Updated] (FLINK-22484) Built-in functions for collections

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

[jira] [Updated] (FLINK-32627) Add support for dynamic time window function

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

[jira] [Updated] (FLINK-19589) Support per-connector FileSystem configuration

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

[jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs

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

[jira] [Updated] (FLINK-30483) Make Avro format support for TIMESTAMP_LTZ

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

[GitHub] [flink] Jiabao-Sun commented on pull request #23218: [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module

Jiabao-Sun commented on PR #23218: URL: https://github.com/apache/flink/pull/23218#issuecomment-1684311049 Thanks @ferenc-csaky for the detailed review and helpful suggestions. Most of the comments are fixed. Please help review it again when you have time. -- This is an automated

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23218: [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module

ferenc-csaky commented on code in PR #23218: URL: https://github.com/apache/flink/pull/23218#discussion_r1298747760 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java: ## @@ -355,44 +336,42 @@ public void

[GitHub] [flink-connector-elasticsearch] mtfelisb commented on a diff in pull request #53: [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support

mtfelisb commented on code in PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1298739730 ## flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8Sink.java: ## @@ -0,0 +1,119 @@ +/* + *

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23218: [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module

Jiabao-Sun commented on code in PR #23218: URL: https://github.com/apache/flink/pull/23218#discussion_r1298702048 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java: ## @@ -355,44 +336,42 @@ public void

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23218: [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module

Jiabao-Sun commented on code in PR #23218: URL: https://github.com/apache/flink/pull/23218#discussion_r1298701513 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java: ## @@ -355,44 +336,42 @@ public void

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23211: [FLINK-32835][runtime] Migrate unit tests in "accumulators" and "blob" packages to JUnit5

ferenc-csaky commented on code in PR #23211: URL: https://github.com/apache/flink/pull/23211#discussion_r1298692811 ## flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobCacheCleanupTest.java: ## @@ -317,20 +303,21 @@ public void testPermanentBlobDeferredCleanup()

[GitHub] [flink] ferenc-csaky commented on a diff in pull request #23218: [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module

ferenc-csaky commented on code in PR #23218: URL: https://github.com/apache/flink/pull/23218#discussion_r1296023473 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/AsyncSnapshotCallableTest.java: ## @@ -102,24 +103,20 @@ public void testExceptionRun() throws

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23227: [FLINK-32840][runtime][JUnit5 Migration] The executiongraph package of flink-runtime module

1996fanrui commented on code in PR #23227: URL: https://github.com/apache/flink/pull/23227#discussion_r1298640863 ## flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java: ## @@ -481,63 +480,61 @@ public static ExecutionAttemptID

[GitHub] [flink] flinkbot commented on pull request #23241: [FLINK-32837][JUnit5 Migration] Migrate the client and clusterframework packages of flink-runtime module to junit5

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

[GitHub] [flink] 1996fanrui commented on pull request #23241: [FLINK-32837][JUnit5 Migration] Migrate the client and clusterframework packages of flink-runtime module to junit5

1996fanrui commented on PR #23241: URL: https://github.com/apache/flink/pull/23241#issuecomment-1684163730 cc @Jiabao-Sun -- 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 the specific comment.

[jira] [Updated] (FLINK-32837) [JUnit5 Migration] The client, clusterframework and concurrent packages of flink-runtime module

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

[GitHub] [flink] 1996fanrui opened a new pull request, #23241: [FLINK-32837][JUnit5 Migration] Migrate the client and clusterframework packages of flink-runtime module to junit5

1996fanrui opened a new pull request, #23241: URL: https://github.com/apache/flink/pull/23241 [FLINK-32837][JUnit5 Migration] Migrate the client and clusterframework packages of flink-runtime module to junit5 -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23204: [FLINK-32855][flink-runtime][JUnit5 Migration] Module: The taskexecutor package of flink-runtime

Jiabao-Sun commented on code in PR #23204: URL: https://github.com/apache/flink/pull/23204#discussion_r1298630869 ## flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java: ## @@ -38,42 +38,50 @@ import

[GitHub] [flink] xuzifu666 commented on pull request #23220: [FLINK-32871][SQL] Support BuiltInMethod TO_TIMESTAMP with timezone options

xuzifu666 commented on PR #23220: URL: https://github.com/apache/flink/pull/23220#issuecomment-1684121514 cc @beyond1920 -- 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 the specific comment.

[GitHub] [flink] wangzzu commented on pull request #23227: [FLINK-32840][runtime][JUnit5 Migration] The executiongraph package of flink-runtime module

wangzzu commented on PR #23227: URL: https://github.com/apache/flink/pull/23227#issuecomment-1684110666 > Thanks @wangzzu for the contribution, and @wangzzu for the review! > > > Would you mind updating all change about these improvements? > > ``` > > * Make test classes

[GitHub] [flink] deepyaman commented on a diff in pull request #23141: [FLINK-32758][python] Remove PyFlink dependencies' upper bounds

deepyaman commented on code in PR #23141: URL: https://github.com/apache/flink/pull/23141#discussion_r1298543188 ## flink-python/dev/dev-requirements.txt: ## @@ -15,20 +15,20 @@ pip>=20.3 setuptools>=18.0 wheel -apache-beam==2.43.0 -cython==0.29.24

[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_r1298527676 ## flink-runtime/src/test/java/org/apache/flink/runtime/util/config/memory/ProcessMemoryUtilsTestBase.java: ## @@ -63,86 +62,83 @@ protected

[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_r1298445035 ## flink-runtime/src/test/java/org/apache/flink/runtime/util/config/memory/ProcessMemoryUtilsTestBase.java: ## @@ -63,86 +62,83 @@ protected

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

X-czh commented on code in PR #23199: URL: https://github.com/apache/flink/pull/23199#discussion_r1298523038 ## flink-runtime/src/test/java/org/apache/flink/runtime/util/config/memory/ProcessMemoryUtilsTestBase.java: ## @@ -63,86 +62,83 @@ protected ProcessMemoryUtilsTestBase(

[jira] [Resolved] (FLINK-32800) Release Testing: Verify FLINK-32548 - Make watermark alignment ready for production use

[ https://issues.apache.org/jira/browse/FLINK-32800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32800. - Resolution: Fixed > Release Testing: Verify FLINK-32548 - Make watermark alignment ready for >

[jira] [Commented] (FLINK-32801) Release Testing: Verify FLINK-32524 - Improve the watermark aggregation performance when enabling the watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-32801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755995#comment-17755995 ] Rui Fan commented on FLINK-32801: - FLINK-32524 did a performance improvement about watermark alignment,

[jira] [Resolved] (FLINK-32801) Release Testing: Verify FLINK-32524 - Improve the watermark aggregation performance when enabling the watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-32801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32801. - Resolution: Fixed > Release Testing: Verify FLINK-32524 - Improve the watermark aggregation >

[jira] [Commented] (FLINK-32800) Release Testing: Verify FLINK-32548 - Make watermark alignment ready for production use

[ https://issues.apache.org/jira/browse/FLINK-32800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755994#comment-17755994 ] Rui Fan commented on FLINK-32800: - FLINK-32548 fixed a series of bugs related to watermark alignment,

[GitHub] [flink] flinkbot commented on pull request #23240: Update local_installation.md

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

[GitHub] [flink] arthurlee opened a new pull request, #23240: Update local_installation.md

arthurlee opened a new pull request, #23240: URL: https://github.com/apache/flink/pull/23240 Add notes for jdk 17 and above is not supported yet ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server,

[jira] [Commented] (FLINK-32806) EmbeddedJobResultStore keeps the non-dirty job entries forever

[ https://issues.apache.org/jira/browse/FLINK-32806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755980#comment-17755980 ] Matthias Pohl commented on FLINK-32806: --- Thanks for picking it up. I assigned the issue to you. >

[jira] [Assigned] (FLINK-32806) EmbeddedJobResultStore keeps the non-dirty job entries forever

[ https://issues.apache.org/jira/browse/FLINK-32806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-32806: - Assignee: hk__lrzy > EmbeddedJobResultStore keeps the non-dirty job entries forever >

[GitHub] [flink] XComp commented on a diff in pull request #21289: [FLINK-29452] Allow unit tests to be executed independently

XComp commented on code in PR #21289: URL: https://github.com/apache/flink/pull/21289#discussion_r1298465139 ## flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/RetryOnExceptionExtensionTest.java: ## @@ -37,53 +41,77 @@

[GitHub] [flink] XComp commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

XComp commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1298453225 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java: ## @@ -392,7 +392,7 @@ private void forwardResultFuture(

[GitHub] [flink] XComp commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

XComp commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1298451802 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java: ## @@ -392,7 +392,7 @@ private void forwardResultFuture(

[GitHub] [flink] XComp commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

XComp commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1298451802 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java: ## @@ -392,7 +392,7 @@ private void forwardResultFuture(

[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_r1298421164 ## flink-runtime/src/test/java/org/apache/flink/runtime/util/BoundedFIFOQueueTest.java: ## @@ -18,90 +18,83 @@ package org.apache.flink.runtime.util; -import

[jira] [Updated] (FLINK-32890) Flink app rolled back with old savepoints (3 hours back in time) while some checkpoints have been taken in between

[ https://issues.apache.org/jira/browse/FLINK-32890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32890: --- Labels: pull-request-available (was: ) > Flink app rolled back with old savepoints (3

[GitHub] [flink-kubernetes-operator] ashangit opened a new pull request, #654: [FLINK-32890] Correct HA patch check for zookeeper metadata store

ashangit opened a new pull request, #654: URL: https://github.com/apache/flink-kubernetes-operator/pull/654 ## What is the purpose of the change * This pull request correct the path used to check if HA metadata are available in zookeeper. Previous path check was leading to

[GitHub] [flink] X-czh commented on pull request #23199: [FLINK-32858][tests][JUnit5 migration] Migrate flink-runtime/utils tests to JUnit5

X-czh commented on PR #23199: URL: https://github.com/apache/flink/pull/23199#issuecomment-1683862885 Thanks @Jiabao-Sun, I've addressed the missing comments and applied an improvement to assert exception messages with the `assertThat(ex).hasMessage(msg)` pattern. -- This is an

[jira] [Comment Edited] (FLINK-32888) File upload runs into EndOfDataDecoderException

[ https://issues.apache.org/jira/browse/FLINK-32888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755943#comment-17755943 ] Chesnay Schepler edited comment on FLINK-32888 at 8/18/23 12:27 PM:

[jira] [Closed] (FLINK-32888) File upload runs into EndOfDataDecoderException

[ https://issues.apache.org/jira/browse/FLINK-32888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-32888. Resolution: Fixed > File upload runs into EndOfDataDecoderException >

[GitHub] [flink] XComp commented on pull request #23238: [BP-1.16][FLINK-32751][runtime] Refactors close handling to CollectSinkOperatorCoordinator

XComp commented on PR #23238: URL: https://github.com/apache/flink/pull/23238#issuecomment-1683836093 @flinkbot run azure -- 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 the specific comment.

[GitHub] [flink] XComp commented on pull request #23237: [BP-1.17][FLINK-32751][runtime] Refactors close handling to CollectSinkOperatorCoordinator

XComp commented on PR #23237: URL: https://github.com/apache/flink/pull/23237#issuecomment-1683835984 @flinkbot run azure -- 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 the specific comment.

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755946#comment-17755946 ] Matthias Schwalbe commented on FLINK-26586: --- Hi [~masteryhx]  As much as I would like to see

[jira] [Closed] (FLINK-32880) Redundant taskManagers should always be fulfilled in FineGrainedSlotManager

[ https://issues.apache.org/jira/browse/FLINK-32880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng closed FLINK-32880. > Redundant taskManagers should always be fulfilled in FineGrainedSlotManager >

[jira] [Commented] (FLINK-32888) File upload runs into EndOfDataDecoderException

[ https://issues.apache.org/jira/browse/FLINK-32888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755943#comment-17755943 ] Chesnay Schepler commented on FLINK-32888: -- master: 9546f8243a24e7b45582b6de6702f819f1d73f97 >

[jira] [Comment Edited] (FLINK-32888) File upload runs into EndOfDataDecoderException

[ https://issues.apache.org/jira/browse/FLINK-32888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755943#comment-17755943 ] Chesnay Schepler edited comment on FLINK-32888 at 8/18/23 11:57 AM:

[jira] [Updated] (FLINK-32888) File upload runs into EndOfDataDecoderException

[ https://issues.apache.org/jira/browse/FLINK-32888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-32888: - Fix Version/s: 1.16.3 > File upload runs into EndOfDataDecoderException >

[GitHub] [flink] zentol merged pull request #23229: [FLINK-32888] Handle hasNext() throwing EndOfDataDecoderException

zentol merged PR #23229: URL: https://github.com/apache/flink/pull/23229 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot commented on pull request #23239: [FLINK-26585] replace implementation of MultiStateKeyIterator with Stream-free implementation

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

[jira] [Commented] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755934#comment-17755934 ] Matthias Schwalbe commented on FLINK-26585: --- [~masteryhx] : I opened this PR #23239 for

[jira] [Updated] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26585: --- Labels: pull-request-available (was: ) > State Processor API: Loading a state set buffers

[GitHub] [flink] RainerMatthiasS opened a new pull request, #23239: [FLINK-26585] replace implementation of MultiStateKeyIterator with Stream-free implementation

RainerMatthiasS opened a new pull request, #23239: URL: https://github.com/apache/flink/pull/23239 ## Contribution Checklist - `Pending:` Make sure that the change passes the automated tests, i.e., `mvn clean verify` passes. You can set up Azure Pipelines CI to do that following

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23211: [FLINK-32835][runtime] Migrate unit tests in "accumulators" and "blob" packages to JUnit5

Jiabao-Sun commented on code in PR #23211: URL: https://github.com/apache/flink/pull/23211#discussion_r1298315587 ## flink-runtime/src/test/java/org/apache/flink/runtime/accumulators/StringifiedAccumulatorResultTest.java: ## @@ -71,16 +70,16 @@ public void

[GitHub] [flink] lincoln-lil commented on a diff in pull request #23209: [FLINK-32824] Port Calcite's fix for the sql like operator

lincoln-lil commented on code in PR #23209: URL: https://github.com/apache/flink/pull/23209#discussion_r1298299922 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/CalcITCase.scala: ## @@ -410,6 +410,30 @@ class CalcITCase

  1   2   >