[jira] [Created] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

Tan Kim created FLINK-32900: --- Summary: Flink SQL doesn't find any built-in SQL functions Key: FLINK-32900 URL: https://issues.apache.org/jira/browse/FLINK-32900 Project: Flink Issue Type: Bug

[GitHub] [flink] xiangforever2014 opened a new pull request, #23246: Support dump pending savpeoint ids 1

xiangforever2014 opened a new pull request, #23246: URL: https://github.com/apache/flink/pull/23246 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferrin

[GitHub] [flink] luoyuxia commented on a diff in pull request #23166: [FLINK-32760][Connectors/Hive] Reshade parquet in flink-sql-connector-hive

luoyuxia commented on code in PR #23166: URL: https://github.com/apache/flink/pull/23166#discussion_r1299670087 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -223,6 +223,10 @@ under the License.

[jira] [Updated] (FLINK-32899) Can not access inner/nested objects in MATCH_RECOGNIZE DEFINE clause and in Aggregate function

[ https://issues.apache.org/jira/browse/FLINK-32899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krutik updated FLINK-32899: --- Summary: Can not access inner/nested objects in MATCH_RECOGNIZE DEFINE clause and in Aggregate function (wa

[GitHub] [flink] jiaoqingbo commented on pull request #23127: [FLINK-32223][runtime][security](followups) Fix compile failed in hadoop_313 stage

jiaoqingbo commented on PR #23127: URL: https://github.com/apache/flink/pull/23127#issuecomment-1685722974 Hi @gaborgsomogyi , would you mind helping take a look at this pr? thanks~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[jira] [Created] (FLINK-32899) Can not access inner/nested objects in MATCH_RECOGNIZE DFINE clause and in Aggregate function

Krutik created FLINK-32899: -- Summary: Can not access inner/nested objects in MATCH_RECOGNIZE DFINE clause and in Aggregate function Key: FLINK-32899 URL: https://issues.apache.org/jira/browse/FLINK-32899 Pro

[jira] [Comment Edited] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756690#comment-17756690 ] xy edited comment on FLINK-32871 at 8/21/23 6:18 AM: - engines I mean

[jira] [Comment Edited] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756690#comment-17756690 ] xy edited comment on FLINK-32871 at 8/21/23 6:16 AM: - engines I mean

[GitHub] [flink] wangzzu commented on a diff in pull request #23242: [FLINK-32851][runtime][JUnit5 Migration] The rest package of flink-runtime module

wangzzu commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1299653435 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/RestResponseUnmarshallingTestBase.java: ## @@ -0,0 +1,59 @@ +/* + * Licensed to the Apache Softwar

[jira] [Commented] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756690#comment-17756690 ] xy commented on FLINK-32871: engines I mean some engines in bigdata scope，such as presto、tri

[GitHub] [flink] flinkbot commented on pull request #23245: [FLINK-32881] support triggering savepoint in detach mode for CLI

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

[jira] [Updated] (FLINK-32881) Client supports making savepoints in detach mode

[ https://issues.apache.org/jira/browse/FLINK-32881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32881: --- Labels: detach-savepoint pull-request-available (was: detach-savepoint) > Client supports m

[GitHub] [flink] xiangforever2014 opened a new pull request, #23245: [FLINK-32881] support triggering savepoint in detach mode for CLI

xiangforever2014 opened a new pull request, #23245: URL: https://github.com/apache/flink/pull/23245 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferrin

[GitHub] [flink] singhravidutt commented on a diff in pull request #23226: [FLINK-32877]add HTTP options to gcs-cloud-storage client

singhravidutt commented on code in PR #23226: URL: https://github.com/apache/flink/pull/23226#discussion_r1299604745 ## docs/content/docs/deployment/filesystems/gcs.md: ## @@ -80,6 +80,8 @@ You can also set `gcs-connector` options directly in the Hadoop `core-site.xml` |-

[jira] [Commented] (FLINK-32418) ClassNotFoundException when using flink-protobuf with sql-client

[ https://issues.apache.org/jira/browse/FLINK-32418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756671#comment-17756671 ] Benchao Li commented on FLINK-32418: [~m-kay] Sorry that I missed this one, I'll try

[jira] [Commented] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756669#comment-17756669 ] Benchao Li commented on FLINK-32871: I don't think they are the same thing, and I be

[GitHub] [flink] dongwoo6kim commented on a diff in pull request #23166: [FLINK-32760][Connectors/Hive] Reshade parquet in flink-sql-connector-hive

dongwoo6kim commented on code in PR #23166: URL: https://github.com/apache/flink/pull/23166#discussion_r1299594649 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -223,6 +223,10 @@ under the License.

[jira] [Commented] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756663#comment-17756663 ] xy commented on FLINK-32871: other engines have no functions named to_timestamps，but have fu

[GitHub] [flink] dongwoo6kim commented on a diff in pull request #23166: [FLINK-32760][Connectors/Hive] Reshade parquet in flink-sql-connector-hive

dongwoo6kim commented on code in PR #23166: URL: https://github.com/apache/flink/pull/23166#discussion_r1299594649 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -223,6 +223,10 @@ under the License.

[jira] [Commented] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756662#comment-17756662 ] Benchao Li commented on FLINK-32871: {{timestamp '2012-10-31 01:00 UTC' AT TIME ZONE

[jira] [Commented] (FLINK-32418) ClassNotFoundException when using flink-protobuf with sql-client

[ https://issues.apache.org/jira/browse/FLINK-32418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756660#comment-17756660 ] Michael Kreis commented on FLINK-32418: --- [~libenchao] Could you may have a look at

[jira] [Updated] (FLINK-32418) ClassNotFoundException when using flink-protobuf with sql-client

[ https://issues.apache.org/jira/browse/FLINK-32418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Kreis updated FLINK-32418: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > ClassNotFoundEx

[jira] [Created] (FLINK-32898) Improvement of usability for Flink OLAP

xiangyu feng created FLINK-32898: Summary: Improvement of usability for Flink OLAP Key: FLINK-32898 URL: https://issues.apache.org/jira/browse/FLINK-32898 Project: Flink Issue Type: Improveme

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #250: [FLINK-32810] Improve memory allocation in ListStateWithCache

Fanoid commented on code in PR #250: URL: https://github.com/apache/flink-ml/pull/250#discussion_r1299581271 ## flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/OperatorScopeManagedMemoryManager.java: ## @@ -0,0 +1,56 @@ +/

[jira] [Updated] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xy updated FLINK-32871: --- Description: Support BuiltInMethod TO_TIMESTAMP with timezone options，TO_TIMESTAMPS now only use utc timezone，but m

[jira] [Assigned] (FLINK-32770) Fix the inaccurate backlog number of Hybrid Shuffle

[ https://issues.apache.org/jira/browse/FLINK-32770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32770: -- Assignee: Wencong Liu > Fix the inaccurate backlog number of Hybrid Shuffle > ---

[jira] [Closed] (FLINK-32770) Fix the inaccurate backlog number of Hybrid Shuffle

[ https://issues.apache.org/jira/browse/FLINK-32770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-32770. -- Resolution: Fixed master(1.18) via ed4937cbc0ee73e08856cc59bfbf788682c70a09. > Fix the inaccurate bac

[jira] [Updated] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xy updated FLINK-32871: --- Description: Support BuiltInMethod TO_TIMESTAMP with timezone options，TO_TIMESTAMP now only use utc timezone，but ma

[GitHub] [flink] reswqa merged pull request #23179: [FLINK-32770][network] Fix the inaccurate backlog number of Hybrid Shuffle

reswqa merged PR #23179: URL: https://github.com/apache/flink/pull/23179 -- 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: issues-unsubscr...@flink.apache

[jira] [Updated] (FLINK-32841) [JUnit5 Migration] The failure, filecache, hadoop, heartbeat, highavailability and instance packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32841: Summary: [JUnit5 Migration] The failure, filecache, hadoop, heartbeat, highavailability and instance packa

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #248: [FLINK-32704] Supports spilling to disk when feedback channel memory buffer is full

lindong28 commented on code in PR #248: URL: https://github.com/apache/flink-ml/pull/248#discussion_r1299531846 ## flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/feedback/SpillableFeedbackQueue.java: ## @@ -0,0 +1,115 @@ +/* + * Li

[GitHub] [flink] luoyuxia commented on a diff in pull request #23109: [FLINK-32475][docs] Add doc for time travel

luoyuxia commented on code in PR #23109: URL: https://github.com/apache/flink/pull/23109#discussion_r1299508111 ## docs/content/docs/dev/table/sql/queries/time-travel.md: ## @@ -0,0 +1,65 @@ +--- +title: Time Travel +weight: 18 +type: docs +--- + + +# Time Travel + +{{< label Ba

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

[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756636#comment-17756636 ] Rui Fan commented on FLINK-32895: - Hi [~zhuzh][~wanglijie], would you mind helping take

[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_r1299507064 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java: ## @@ -136,7 +136,7 @@ void testPeekPollOrder() { --la

[GitHub] [flink] loserwang1024 commented on a diff in pull request #23234: [FLINK-32668][e2e] fix up watchdog timeout error msg in common.sh

loserwang1024 commented on code in PR #23234: URL: https://github.com/apache/flink/pull/23234#discussion_r1299502919 ## flink-end-to-end-tests/test-scripts/common.sh: ## @@ -934,9 +934,13 @@ function extract_job_id_from_job_submission_return() { } kill_test_watchdog() { -

[GitHub] [flink] luoyuxia commented on a diff in pull request #23166: [FLINK-32760][Connectors/Hive] Reshade parquet in flink-sql-connector-hive

luoyuxia commented on code in PR #23166: URL: https://github.com/apache/flink/pull/23166#discussion_r1299495861 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -223,6 +223,10 @@ under the License.

[jira] [Created] (FLINK-32897) Kafka with nested array row type will get wrong result

Yunhong Zheng created FLINK-32897: - Summary: Kafka with nested array row type will get wrong result Key: FLINK-32897 URL: https://issues.apache.org/jira/browse/FLINK-32897 Project: Flink Issu

[jira] [Updated] (FLINK-29579) Flink parquet reader cannot read fully optional elements in a repeated list

[ https://issues.apache.org/jira/browse/FLINK-29579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-29579: --- Labels: SchemaValidation auto-deprioritized-major parquet parquetReader (was: SchemaValid

[jira] [Updated] (FLINK-29737) Support DataGen on waveform function

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

[jira] [Updated] (FLINK-29333) Flink SQL Planner Module doesn't read config from flink-conf.yaml

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

[jira] [Updated] (FLINK-29952) Using DROP TABLE XXX to drop a temporary table （or view） in sql-client can get an exception with incomplete explaination.

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

[jira] [Updated] (FLINK-29770) hbase connector supports out-of-order data

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

[jira] [Updated] (FLINK-30036) Force delete pod when k8s node is not ready

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

[jira] [Updated] (FLINK-26315) Stream job which have multily region would not recover when connection with zookeeper/hbase lost.

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

[jira] [Updated] (FLINK-26499) Azure hang due to unable to download akka artifact

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

[jira] [Updated] (FLINK-29956) Kafka-related test infrastructure code is scattered over multiple classes/environments

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

[jira] [Updated] (FLINK-29980) Wrap the HiveSource's bulkFormat to handle the partition keys

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

[jira] [Updated] (FLINK-29432) Replace GenericUDFNvl with GenericUDFCoalesce

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

[jira] [Updated] (FLINK-29553) Support UNIX_TIMESTAMP in Table API

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

[jira] [Updated] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.

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

[jira] [Updated] (FLINK-26091) SafetyNetCloseableRegistryTest.testNonBlockingClose failed on azure

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

[jira] [Updated] (FLINK-29587) Fail to generate code for SearchOperator

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

[jira] [Updated] (FLINK-29623) Bump Prometheus Java Client to 0.16.0

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

[jira] [Updated] (FLINK-26386) CassandraConnectorITCase.testCassandraTableSink failed on azure

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

[jira] [Updated] (FLINK-29594) RMQSourceITCase.testMessageDelivery timed out

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

[jira] [Updated] (FLINK-32305) History Server is slow at starting

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

[jira] [Updated] (FLINK-26459) Streaming File Sink s3 end-to-end test failed on azure due to not enough resource

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

[jira] [Updated] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

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

[jira] [Updated] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

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

[jira] [Updated] (FLINK-26563) HadoopS3RecoverableWriterITCase hang on azure

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

[jira] [Updated] (FLINK-26358) Operator maxParallelism is lost during chaining

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

[jira] [Updated] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

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

[jira] [Updated] (FLINK-26533) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee failed on azure due to delete topic timeout

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

[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_r1299397142 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/InternalPriorityQueueTestBase.java: ## @@ -136,7 +136,7 @@ void testPeekPollOrder() { --

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

Jiabao-Sun commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1299393443 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java: ## @@ -87,14 +79,19 @@ public void testConnectionTimeout() throws Exception {

[GitHub] [flink] flinkbot commented on pull request #23244: [FLINK-32846][runtime][JUnit5 Migration] The minicluster and net package of flink-runtime module

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

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

[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32895: Description: Currently, Flink has 3 restart strategies, they are: fixed-delay, failure-rate and exponenti

[GitHub] [flink] wangzzu opened a new pull request, #23244: [FLINK-32846][runtime][JUnit5 Migration] The minicluster and net package of flink-runtime module

wangzzu opened a new pull request, #23244: URL: https://github.com/apache/flink/pull/23244 ## What is the purpose of the change Migrate minicluster and net related tests under flink-runtime module to junit5 ## Brief change log Migrate minicluster and net related

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

Jiabao-Sun commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1299392539 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/RestResponseUnmarshallingTestBase.java: ## @@ -0,0 +1,59 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink-web] wuchong opened a new pull request, #672: Update Flink Roadmap

wuchong opened a new pull request, #672: URL: https://github.com/apache/flink-web/pull/672 This updates the roadmap of the website, as discussed in this thread: https://lists.apache.org/thread/szdr4ngrfcmo7zko4917393zbqhgw0v5 Note: The Chinese language version of the page needs to

[jira] [Updated] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector

[ https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32877: --- Labels: pull-request-available (was: ) > Support for HTTP connect and timeout options while

[GitHub] [flink] jayadeep-jayaraman commented on a diff in pull request #23226: [FLINK-32877]add HTTP options to gcs-cloud-storage client

jayadeep-jayaraman commented on code in PR #23226: URL: https://github.com/apache/flink/pull/23226#discussion_r1296172529 ## docs/content/docs/deployment/filesystems/gcs.md: ## @@ -80,6 +80,8 @@ You can also set `gcs-connector` options directly in the Hadoop `core-site.xml` |

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

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

[GitHub] [flink] flinkbot commented on pull request #23243: [FLINK-32846][runtime][JUnit5 Migration] The metrics package of flink-runtime module

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

[jira] [Updated] (FLINK-32846) [JUnit5 Migration] The metrics, minicluster and net packages of flink-runtime module

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

[GitHub] [flink] wangzzu opened a new pull request, #23243: [FLINK-32846][runtime][JUnit5 Migration] The metrics package of flink-runtime module

wangzzu opened a new pull request, #23243: URL: https://github.com/apache/flink/pull/23243 ## What is the purpose of the change Migrate metrics related tests under flink-runtime module to junit5 ## Brief change log Migrate metrics related tests under flink-runtim

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

Jiabao-Sun commented on code in PR #23241: URL: https://github.com/apache/flink/pull/23241#discussion_r1299383184 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java: ## @@ -37,23 +38,21 @@ import static org.apache.flink.runtime

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

[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32895: Description: Currently, Flink has 3 restart strategies, they are: fixed-delay, failure-rate and exponenti

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

1996fanrui commented on code in PR #23241: URL: https://github.com/apache/flink/pull/23241#discussion_r1299380633 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java: ## @@ -37,23 +38,21 @@ import static org.apache.flink.runtime

[GitHub] [flink] 1996fanrui commented on pull request #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

1996fanrui commented on PR #23233: URL: https://github.com/apache/flink/pull/23233#issuecomment-1685287085 Hi @wangzzu , would you mind helping review this PR in your free time? thanks~ There are too many test migration PRs are waiting for my review, and I don't have enough time to d

[GitHub] [flink] lsyldliu commented on a diff in pull request #23216: [FLINK-32831][table-planner] RuntimeFilterProgram should aware join type when looking for the build side

lsyldliu commented on code in PR #23216: URL: https://github.com/apache/flink/pull/23216#discussion_r1299354403 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/optimize/program/FlinkRuntimeFilterProgramTest.xml: ## @@ -430,6 +430,104 @@

[jira] [Updated] (FLINK-30108) ZooKeeperLeaderElectionConnectionHandlingTest.testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled times out

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

[jira] [Updated] (FLINK-26624) Running HA (hashmap, async) end-to-end test failed on azure due to unable to find master logs

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

[jira] [Updated] (FLINK-29926) File source continuous monitoring mode ignoring files during savepoint upgrade mode

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

[jira] [Updated] (FLINK-27285) CassandraConnectorITCase failed on azure due to NoHostAvailableException

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

[jira] [Updated] (FLINK-30196) Replace usage of deprecated Mockito's methods with advised by Mockito

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

[jira] [Updated] (FLINK-28076) StreamFaultToleranceTestBase runs into timeout

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

[jira] [Updated] (FLINK-30262) UpsertKafkaTableITCase failed when starting the container because waiting for a port timed out

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

[jira] [Updated] (FLINK-30309) Add the ability to supply custom SslContexts for netty client/servers.

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

[jira] [Updated] (FLINK-30514) HybridSource savepoint recovery sequence

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

[jira] [Updated] (FLINK-28321) HiveDialectQueryITCase fails with error code 137

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

[jira] [Updated] (FLINK-29545) kafka consuming stop when trigger first checkpoint

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

[jira] [Updated] (FLINK-30218) [Kafka Connector] java.lang.OutOfMemoryError: Metaspace

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

[jira] [Updated] (FLINK-26581) Job supports the HADOOP_USER_NAME

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

[jira] [Updated] (FLINK-30242) Push localHashAggregate pass the union node

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

[jira] [Updated] (FLINK-30475) Improved speed of RocksDBMapState clear() using rocksDB.deleteRange

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

[jira] [Updated] (FLINK-30488) OpenSearch implementation of Async Sink

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

[jira] [Updated] (FLINK-30327) Adding a values.schema.json to the Helm chart source to support schema validation on Helm chart configuration

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

[jira] [Updated] (FLINK-26566) FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed on azure

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

[jira] [Updated] (FLINK-30479) Document flink-connector-files for local execution

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

  1   2   >