[jira] [Commented] (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:comment-tabpanel=17770291#comment-17770291 ] xiangyu feng commented on FLINK-15959: -- [~zhuzh] Hi, the

[jira] [Commented] (FLINK-33124) Kafka Connector not working for table

[ https://issues.apache.org/jira/browse/FLINK-33124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770279#comment-17770279 ] Martijn Visser commented on FLINK-33124: [~aarsh33] This all depends on what's necessary in your

[jira] [Updated] (FLINK-33129) Can't create RowDataToAvroConverter for LocalZonedTimestampType logical type

[ https://issues.apache.org/jira/browse/FLINK-33129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33129: --- Fix Version/s: (was: 1.17.1) > Can't create RowDataToAvroConverter for

[jira] [Commented] (FLINK-33154) flink on k8s，An error occurred during consuming rocketmq

[ https://issues.apache.org/jira/browse/FLINK-33154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770278#comment-17770278 ] Martijn Visser commented on FLINK-33154: I would think this isn't necessarily a Kubernetes

[jira] [Commented] (FLINK-33104) Nightly run for Flink Kafka connector fails due to architecture tests failing

[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770274#comment-17770274 ] Martijn Visser commented on FLINK-33104: [~mason6345] I don't think we have to update to JUnit5

[jira] [Updated] (FLINK-31615) Fix some parts forgot to translate in "Table API" page of "Table API & SQL"

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

[GitHub] [flink] bvarghese1 commented on a diff in pull request #23223: [FLINK-32873][table] - Add config to allow disabling QUERY hints

bvarghese1 commented on code in PR #23223: URL: https://github.com/apache/flink/pull/23223#discussion_r1340705768 ## flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java: ## @@ -777,6 +781,16 @@ protected void convertSelectImpl(final

[GitHub] [flink] bvarghese1 commented on a diff in pull request #23223: [FLINK-32873][table] - Add config to allow disabling QUERY hints

bvarghese1 commented on code in PR #23223: URL: https://github.com/apache/flink/pull/23223#discussion_r1340705119 ## docs/layouts/shortcodes/generated/table_config_configuration.html: ## @@ -62,6 +62,12 @@ String The local time zone defines current

[jira] [Comment Edited] (FLINK-33104) Nightly run for Flink Kafka connector fails due to architecture tests failing

[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770197#comment-17770197 ] Mason Chen edited comment on FLINK-33104 at 9/28/23 6:39 PM: -

[jira] [Commented] (FLINK-33104) Nightly run for Flink Kafka connector fails due to architecture tests failing

[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770197#comment-17770197 ] Mason Chen commented on FLINK-33104: [~martijnvisser] do we need any help with updating the

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770162#comment-17770162 ] Martijn Visser commented on FLINK-30238: [~tzulitai] Shall we move this topic to the Dev ML? >

[GitHub] [flink] bvarghese1 commented on a diff in pull request #23223: [FLINK-32873][table] - Add config to allow disabling QUERY hints

bvarghese1 commented on code in PR #23223: URL: https://github.com/apache/flink/pull/23223#discussion_r1340412583 ## docs/layouts/shortcodes/generated/table_config_configuration.html: ## @@ -62,6 +62,12 @@ String The local time zone defines current

[jira] [Closed] (FLINK-33157) Support AWS SDK V2 for Flink's S3 FileSystem

[ https://issues.apache.org/jira/browse/FLINK-33157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33157. -- Resolution: Duplicate > Support AWS SDK V2 for Flink's S3 FileSystem >

[jira] [Comment Edited] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770126#comment-17770126 ] Martijn Visser edited comment on FLINK-33018 at 9/28/23 3:34 PM: - Fixed

[jira] [Closed] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33018. -- Fix Version/s: gcp-pubsub-3.0.2 Resolution: Fixed Fixed in:

[GitHub] [flink-connector-gcp-pubsub] boring-cyborg[bot] commented on pull request #19: [FLINK-33018][Tests] Fix flaky test when cancelling source

boring-cyborg[bot] commented on PR #19: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/19#issuecomment-1739543022 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-connector-gcp-pubsub] MartijnVisser merged pull request #19: [FLINK-33018][Tests] Fix flaky test when cancelling source

MartijnVisser merged PR #19: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/19 -- 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 #23476: [FLINK-33166][core][config] Make root logger level configurable

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

[jira] [Updated] (FLINK-33166) Support setting root logger level by config

[ https://issues.apache.org/jira/browse/FLINK-33166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33166: --- Labels: pull-request-available (was: ) > Support setting root logger level by config >

[GitHub] [flink] X-czh opened a new pull request, #23476: [FLINK-33166][core][config] Make root logger level configurable

X-czh opened a new pull request, #23476: URL: https://github.com/apache/flink/pull/23476 ## What is the purpose of the change Make root logger level configurable for better usability. ## Brief change log Introduce a new config `env.log.level` that defines the

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770080#comment-17770080 ] Jayadeep Jayaraman commented on FLINK-33018: Hi [~rskraba] - I looked at the PR and tested

[jira] [Assigned] (FLINK-32873) Add configuration to allow disabling SQL query hints

[ https://issues.apache.org/jira/browse/FLINK-32873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-32873: Assignee: Bonnie Varghese > Add configuration to allow disabling SQL query hints

[jira] [Commented] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

[ https://issues.apache.org/jira/browse/FLINK-33073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770043#comment-17770043 ] Danny Cranmer commented on FLINK-33073: --- [~hong] AWS e2e tests did not run on main build, can we

[jira] [Updated] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

[ https://issues.apache.org/jira/browse/FLINK-33073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33073: -- Fix Version/s: aws-connector-4.2.0 (was: 2.0.0) > Implement end-to-end

[jira] [Commented] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

[ https://issues.apache.org/jira/browse/FLINK-33073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17770031#comment-17770031 ] Danny Cranmer commented on FLINK-33073: --- Merged commit

[GitHub] [flink-connector-aws] dannycranmer merged pull request #94: [FLINK-33073][Connectors/AWS] Implement end-to-end tests for KinesisS…

dannycranmer merged PR #94: URL: https://github.com/apache/flink-connector-aws/pull/94 -- 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:

[jira] [Comment Edited] (FLINK-33165) Flink UI stack trace popup continually displayed when a job is deleted

[ https://issues.apache.org/jira/browse/FLINK-33165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769998#comment-17769998 ] david radley edited comment on FLINK-33165 at 9/28/23 11:07 AM: [~Sergey

[jira] [Updated] (FLINK-33165) Flink UI stack trace popup continually displayed when a job is deleted

[ https://issues.apache.org/jira/browse/FLINK-33165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] david radley updated FLINK-33165: - Affects Version/s: 1.17.1 > Flink UI stack trace popup continually displayed when a job is

[jira] [Commented] (FLINK-33165) Flink UI stack trace popup continually displayed when a job is deleted

[ https://issues.apache.org/jira/browse/FLINK-33165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769998#comment-17769998 ] david radley commented on FLINK-33165: -- [~Sergey Nuyanzin] thanks - good spot. It was a mistake I

[jira] [Updated] (FLINK-33165) Flink UI stack trace popup continually displayed when a job is deleted

[ https://issues.apache.org/jira/browse/FLINK-33165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] david radley updated FLINK-33165: - Fix Version/s: (was: 1.7.3) > Flink UI stack trace popup continually displayed when a job

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #94: [FLINK-33073][Connectors/AWS] Implement end-to-end tests for KinesisS…

hlteoh37 commented on code in PR #94: URL: https://github.com/apache/flink-connector-aws/pull/94#discussion_r1339937142 ## flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-streams-e2e-tests/src/test/java/org/apache/flink/connector/kinesis/testutils/AWSEndToEndTestUtils.java:

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #94: [FLINK-33073][Connectors/AWS] Implement end-to-end tests for KinesisS…

hlteoh37 commented on code in PR #94: URL: https://github.com/apache/flink-connector-aws/pull/94#discussion_r1339936462 ## flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-streams-e2e-tests/src/test/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkITCase.java:

[GitHub] [flink-connector-aws] hlteoh37 merged pull request #98: Bump org.xerial.snappy:snappy-java from 1.1.10.1 to 1.1.10.4

hlteoh37 merged PR #98: URL: https://github.com/apache/flink-connector-aws/pull/98 -- 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:

[jira] [Created] (FLINK-33167) Run IT tests against Kinesalite if AWS credentials are not present

Hong Liang Teoh created FLINK-33167: --- Summary: Run IT tests against Kinesalite if AWS credentials are not present Key: FLINK-33167 URL: https://issues.apache.org/jira/browse/FLINK-33167 Project:

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #94: [FLINK-33073][Connectors/AWS] Implement end-to-end tests for KinesisS…

hlteoh37 commented on code in PR #94: URL: https://github.com/apache/flink-connector-aws/pull/94#discussion_r1339849608 ##

[GitHub] [flink] ljw-hit commented on a diff in pull request #23162: [FLINK-32650][protobuf]Added the ability to split flink-protobuf code…

ljw-hit commented on code in PR #23162: URL: https://github.com/apache/flink/pull/23162#discussion_r1339801205 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/BigProtoBufCodeSpiltterTest.java: ## @@ -0,0 +1,70 @@ +/* + * Licensed to the Apache

[jira] [Assigned] (FLINK-33156) Remove flakiness from tests in OperatorStateBackendTest.java

[ https://issues.apache.org/jira/browse/FLINK-33156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-33156: Assignee: Asha Boyapati > Remove flakiness from tests in OperatorStateBackendTest.java >

[jira] [Updated] (FLINK-33160) Log the remote address when an exception occurs in the PartitionRequestQueue

[ https://issues.apache.org/jira/browse/FLINK-33160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dizhou cao updated FLINK-33160: --- Summary: Log the remote address when an exception occurs in the PartitionRequestQueue (was: Print

[jira] [Assigned] (FLINK-33166) Support setting root logger level by config

[ https://issues.apache.org/jira/browse/FLINK-33166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33166: - Assignee: Zhanghao Chen > Support setting root logger level by config >

[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=17769942#comment-17769942 ] Hangxiang Yu commented on FLINK-26586: -- {quote} * it can not be configured (enabling/buffer

[GitHub] [flink] dawidwys commented on a diff in pull request #23223: [FLINK-32873][table] - Add config to allow disabling QUERY hints

dawidwys commented on code in PR #23223: URL: https://github.com/apache/flink/pull/23223#discussion_r1339654177 ## flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java: ## @@ -777,6 +781,16 @@ protected void convertSelectImpl(final

[jira] [Commented] (FLINK-33149) Bump snappy-java to 1.1.10.4

[ https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769933#comment-17769933 ] Ryan Skraba commented on FLINK-33149: - Thanks for taking a look!  I'm going through the Flink

[GitHub] [flink] dawidwys commented on a diff in pull request #23223: [FLINK-32873][table] - Add config to allow disabling QUERY hints

dawidwys commented on code in PR #23223: URL: https://github.com/apache/flink/pull/23223#discussion_r1339651834 ## docs/layouts/shortcodes/generated/table_config_configuration.html: ## @@ -62,6 +62,12 @@ String The local time zone defines current

[GitHub] [flink-connector-kafka] tzulitai commented on pull request #52: [FLINK-28303] Support LatestOffsetsInitializer to avoid latest-offset strategy lose data

tzulitai commented on PR #52: URL: https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1738590569 @Tan-JiaLiang there's something that doesn't quite add up here that I'm trying to understand. The scenario that is being fixed is the following, if I'm understanding

[GitHub] [flink] masteryhx commented on a diff in pull request #23239: [FLINK-26585][state-processor-api] replace implementation of MultiStateKeyIterator with Stream-free implementation

masteryhx commented on code in PR #23239: URL: https://github.com/apache/flink/pull/23239#discussion_r1339585015 ## flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/MultiStateKeyIterator.java: ## @@ -31,13 +31,17 @@ import

[jira] [Commented] (FLINK-33166) Support setting root logger level by config

[ https://issues.apache.org/jira/browse/FLINK-33166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769915#comment-17769915 ] Zhanghao Chen commented on FLINK-33166: --- [~fangyong] Could you assign it to me if you think it

[jira] [Updated] (FLINK-33166) Support setting root logger level by config

[ https://issues.apache.org/jira/browse/FLINK-33166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33166: -- Description: Users currently cannot change logging level by config and have to modify the

[jira] [Created] (FLINK-33166) Support setting root logger level by config

Zhanghao Chen created FLINK-33166: - Summary: Support setting root logger level by config Key: FLINK-33166 URL: https://issues.apache.org/jira/browse/FLINK-33166 Project: Flink Issue Type: