[GitHub] [flink] X-czh opened a new pull request, #23465: [FLINK-33147] Introduce endpoint field in REST API and deprecate host field

2023-09-25 Thread via GitHub
X-czh opened a new pull request, #23465: URL: https://github.com/apache/flink/pull/23465 ## What is the purpose of the change First step towards [[FLIP-363: Unify the Representation of TaskManager Location in REST API and Web

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

2023-09-25 Thread Asha Boyapati (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Asha Boyapati updated FLINK-33156: -- Description: This issue is similar to: https://issues.apache.org/jira/browse/FLINK-32963 We

[GitHub] [flink] asha-boyapati opened a new pull request, #23464: Remove flakiness from tests in OperatorStateBackendTest.java

2023-09-25 Thread via GitHub
asha-boyapati opened a new pull request, #23464: URL: https://github.com/apache/flink/pull/23464 ## What is the purpose of the change This PR is similar to the following PR which was accepted: https://github.com/apache/flink/pull/23298 This PR makes the following tests

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

2023-09-25 Thread Asha Boyapati (Jira)
Asha Boyapati created FLINK-33156: - Summary: Remove flakiness from tests in OperatorStateBackendTest.java Key: FLINK-33156 URL: https://issues.apache.org/jira/browse/FLINK-33156 Project: Flink

[jira] [Commented] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

2023-09-25 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769014#comment-17769014 ] tanjialiang commented on FLINK-28303: - [~martijnvisser] I had already check the latest kafka

[GitHub] [flink] xintongsong commented on a diff in pull request #23456: [FLINK-33144][datastream]Deprecate Iteration API in DataStream

2023-09-25 Thread via GitHub
xintongsong commented on code in PR #23456: URL: https://github.com/apache/flink/pull/23456#discussion_r1336633757 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java: ## @@ -526,8 +526,14 @@ public DataStream global() { * in

[GitHub] [flink-kubernetes-operator] 1996fanrui commented on a diff in pull request #677: [FLINK-33097][autoscaler] Initialize the generic autoscaler module and interfaces

2023-09-25 Thread via GitHub
1996fanrui commented on code in PR #677: URL: https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1336584237 ## flink-autoscaler/pom.xml: ## @@ -45,6 +45,32 @@ under the License. provided + +org.projectlombok +

[GitHub] [flink] xiangyuf commented on a diff in pull request #23455: [FLINK-25015][Table SQL/Client] change job name to sql when submitting queries using client

2023-09-25 Thread via GitHub
xiangyuf commented on code in PR #23455: URL: https://github.com/apache/flink/pull/23455#discussion_r1336585759 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -1050,10 +1052,15 @@ private

[GitHub] [flink] victor9309 commented on pull request #23451: [FLINK-32108][test] KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message

2023-09-25 Thread via GitHub
victor9309 commented on PR #23451: URL: https://github.com/apache/flink/pull/23451#issuecomment-1734762519 failure -- 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

[GitHub] [flink] victor9309 closed pull request #23451: [FLINK-32108][test] KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message

2023-09-25 Thread via GitHub
victor9309 closed pull request #23451: [FLINK-32108][test] KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message URL: https://github.com/apache/flink/pull/23451 -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink-kubernetes-operator] XComp commented on a diff in pull request #677: [FLINK-33097][autoscaler] Initialize the generic autoscaler module and interfaces

2023-09-25 Thread via GitHub
XComp commented on code in PR #677: URL: https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1336571925 ## flink-autoscaler/pom.xml: ## @@ -45,6 +45,32 @@ under the License. provided + +org.projectlombok +

[GitHub] [flink] flinkbot commented on pull request #23463: Revert "[FLINK-33064][table-planner] Improve the error message when the lookup source is used as the scan source"

2023-09-25 Thread via GitHub
flinkbot commented on PR #23463: URL: https://github.com/apache/flink/pull/23463#issuecomment-1734753507 ## CI report: * 14e35b26265249609fb92f82c02d598f1c29ce7e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] swuferhong opened a new pull request, #23463: Revert "[FLINK-33064][table-planner] Improve the error message when the lookup source is used as the scan source"

2023-09-25 Thread via GitHub
swuferhong opened a new pull request, #23463: URL: https://github.com/apache/flink/pull/23463 ## What is the purpose of the change After testing different sql pattern, found that `FLINK-33064` can cause serious bugs in views and subquery scenarios. So this pr is aims

[GitHub] [flink-connector-pulsar] minchowang commented on pull request #16: [BK-3.0][FLINK-30552][Connector/Pulsar] drop batch message size assertion, better set the cursor position.

2023-09-25 Thread via GitHub
minchowang commented on PR #16: URL: https://github.com/apache/flink-connector-pulsar/pull/16#issuecomment-1734745307 @syhily Hi, Whether can apply to develop-1.14 [develop-flink-1.14](https://github.com/streamnative/flink/tree/develop) for this PR. -- This is an automated message from

[GitHub] [flink] swuferhong closed pull request #23457: [FLINK-33143][table-planner] Fix wrongly throw error while temporary table join with invalidScan lookup source and selected as view

2023-09-25 Thread via GitHub
swuferhong closed pull request #23457: [FLINK-33143][table-planner] Fix wrongly throw error while temporary table join with invalidScan lookup source and selected as view URL: https://github.com/apache/flink/pull/23457 -- This is an automated message from the Apache Git Service. To respond

[jira] [Closed] (FLINK-33143) Wrongly throw error while temporary table join with invalidScan lookup source and selected as view

2023-09-25 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng closed FLINK-33143. - Resolution: Resolved > Wrongly throw error while temporary table join with invalidScan lookup

[jira] [Commented] (FLINK-33143) Wrongly throw error while temporary table join with invalidScan lookup source and selected as view

2023-09-25 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768969#comment-17768969 ] Yunhong Zheng commented on FLINK-33143: --- This fix way cannot cover all sql pattern, like subQuery,

[GitHub] [flink] xbthink commented on pull request #23454: [FLINK-33130]reuse source and sink operator io metrics for task

2023-09-25 Thread via GitHub
xbthink commented on PR #23454: URL: https://github.com/apache/flink/pull/23454#issuecomment-1734723928 @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] flinkbot commented on pull request #23462: [BP-1.18][FLINK-32976][runtime] Fix NullPointException when starting flink cluster in standalone mode

2023-09-25 Thread via GitHub
flinkbot commented on PR #23462: URL: https://github.com/apache/flink/pull/23462#issuecomment-1734714992 ## CI report: * a630fd02f8232d8bbd9f521bdc7990dfd8d79e21 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2023-09-25 Thread Zhaoyang Shao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768959#comment-17768959 ] Zhaoyang Shao commented on FLINK-33129: --- In DataStructureConverters, there is similar

[GitHub] [flink] hackergin opened a new pull request, #23462: [BP-1.18][FLINK-32976][runtime] Fix NullPointException when starting flink cluster in standalone mode

2023-09-25 Thread via GitHub
hackergin opened a new pull request, #23462: URL: https://github.com/apache/flink/pull/23462 BP https://github.com/apache/flink/pull/23446 -- 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

[GitHub] [flink] Sxnan commented on pull request #22897: [FLINK-32476][runtime] Support configuring object-reuse for internal operators

2023-09-25 Thread via GitHub
Sxnan commented on PR #22897: URL: https://github.com/apache/flink/pull/22897#issuecomment-1734709549 @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] [Updated] (FLINK-33129) Can't create RowDataToAvroConverter for LocalZonedTimestampType logical type

2023-09-25 Thread Zhaoyang Shao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhaoyang Shao updated FLINK-33129: -- Priority: Critical (was: Blocker) > Can't create RowDataToAvroConverter for

[GitHub] [flink] yigress commented on a diff in pull request #23425: [FLINK-33090][checkpointing] CheckpointsCleaner clean individual chec…

2023-09-25 Thread via GitHub
yigress commented on code in PR #23425: URL: https://github.com/apache/flink/pull/23425#discussion_r1336513394 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java: ## @@ -368,6 +373,34 @@ public void discard() throws Exception {

[GitHub] [flink] yigress commented on a diff in pull request #23425: [FLINK-33090][checkpointing] CheckpointsCleaner clean individual chec…

2023-09-25 Thread via GitHub
yigress commented on code in PR #23425: URL: https://github.com/apache/flink/pull/23425#discussion_r1336513096 ## flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java: ## @@ -109,6 +109,20 @@ public class CheckpointingOptions {

[GitHub] [flink] yigress commented on a diff in pull request #23425: [FLINK-33090][checkpointing] CheckpointsCleaner clean individual chec…

2023-09-25 Thread via GitHub
yigress commented on code in PR #23425: URL: https://github.com/apache/flink/pull/23425#discussion_r1336512951 ## flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java: ## @@ -109,6 +109,20 @@ public class CheckpointingOptions {

[GitHub] [flink] yigress commented on a diff in pull request #23425: [FLINK-33090][checkpointing] CheckpointsCleaner clean individual chec…

2023-09-25 Thread via GitHub
yigress commented on code in PR #23425: URL: https://github.com/apache/flink/pull/23425#discussion_r1336512772 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java: ## @@ -368,6 +373,34 @@ public void discard() throws Exception {

[GitHub] [flink] yigress commented on a diff in pull request #23425: [FLINK-33090][checkpointing] CheckpointsCleaner clean individual chec…

2023-09-25 Thread via GitHub
yigress commented on code in PR #23425: URL: https://github.com/apache/flink/pull/23425#discussion_r1336512189 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorFailureTest.java: ## @@ -72,7 +72,7 @@ class CheckpointCoordinatorFailureTest {

[jira] [Updated] (FLINK-32471) IS_NOT_NULL can add to SUITABLE_FILTER_TO_PUSH

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

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

2023-09-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768878#comment-17768878 ] Matthias Pohl commented on FLINK-33149: --- I think my previous investigation is not enough: It seems

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

2023-09-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768867#comment-17768867 ] Matthias Pohl commented on FLINK-33149: --- Thanks for looking into it. I did a code investigation to

[GitHub] [flink-connector-aws] dependabot[bot] opened a new pull request, #98: Bump org.xerial.snappy:snappy-java from 1.1.10.1 to 1.1.10.4

2023-09-25 Thread via GitHub
dependabot[bot] opened a new pull request, #98: URL: https://github.com/apache/flink-connector-aws/pull/98 Bumps [org.xerial.snappy:snappy-java](https://github.com/xerial/snappy-java) from 1.1.10.1 to 1.1.10.4. Release notes Sourced from

[GitHub] [flink-statefun] dependabot[bot] opened a new pull request, #340: Bump org.xerial.snappy:snappy-java from 1.1.10.1 to 1.1.10.4 in /statefun-flink

2023-09-25 Thread via GitHub
dependabot[bot] opened a new pull request, #340: URL: https://github.com/apache/flink-statefun/pull/340 Bumps [org.xerial.snappy:snappy-java](https://github.com/xerial/snappy-java) from 1.1.10.1 to 1.1.10.4. Release notes Sourced from

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

2023-09-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-33149: - Assignee: Ryan Skraba > Bump snappy-java to 1.1.10.4 > >

[GitHub] [flink] XComp commented on pull request #23461: [BP-1.18][FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
XComp commented on PR #23461: URL: https://github.com/apache/flink/pull/23461#issuecomment-1734177907 ``` 16:26:18.071 [ERROR] Failed to execute goal com.github.eirslett:frontend-maven-plugin:1.11.0:install-node-and-npm (install node and npm) on project flink-runtime-web: Could not

[GitHub] [flink] flinkbot commented on pull request #23461: [BP-1.18][FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
flinkbot commented on PR #23461: URL: https://github.com/apache/flink/pull/23461#issuecomment-1734057845 ## CI report: * 71309fb4cba1e09de71b03a2ad190137e76eab2d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #23460: [BP-1.17][FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
flinkbot commented on PR #23460: URL: https://github.com/apache/flink/pull/23460#issuecomment-1734056213 ## CI report: * 3907cb98c6ec3a08e5c1c6ba86fd8f69e774e08d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #23459: [BP-1.16][FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
flinkbot commented on PR #23459: URL: https://github.com/apache/flink/pull/23459#issuecomment-1734054047 ## CI report: * ea9b0a0cff9ae7889e246989b2e5d27779f9eb0e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] RyanSkraba opened a new pull request, #23461: [BP-1.18][FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
RyanSkraba opened a new pull request, #23461: URL: https://github.com/apache/flink/pull/23461 ## What is the purpose of the change Backport of https://github.com/apache/flink/pull/23458 to `release-1.18` Bump the version of snappy to address a vulnerability. ## Brief

[GitHub] [flink] RyanSkraba opened a new pull request, #23460: [FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
RyanSkraba opened a new pull request, #23460: URL: https://github.com/apache/flink/pull/23460 ## What is the purpose of the change Backport of https://github.com/apache/flink/pull/23458 to `release-1.17` Bump the version of snappy to address a vulnerability. ## Brief

[GitHub] [flink] RyanSkraba opened a new pull request, #23459: [BP-1.16][FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
RyanSkraba opened a new pull request, #23459: URL: https://github.com/apache/flink/pull/23459 ## What is the purpose of the change Backport of https://github.com/apache/flink/pull/23458 to `release-1.16` Bump the version of snappy to address a vulnerability. ## Brief

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

2023-09-25 Thread Matthias Schwalbe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768751#comment-17768751 ] Matthias Schwalbe edited comment on FLINK-26585 at 9/25/23 3:41 PM:

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

2023-09-25 Thread Matthias Schwalbe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768751#comment-17768751 ] Matthias Schwalbe commented on FLINK-26585: --- Thanks [~masteryhx] , ... Jira somehow swallowed

[jira] [Updated] (FLINK-33150) add the processing logic for the long type

2023-09-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33150: --- Fix Version/s: (was: 1.15.4) > add the processing logic for the long type >

[GitHub] [flink] jgagnon1 commented on pull request #23453: [FLINK-33128] Add converter.open() method call on TestValuesRuntimeFunctions

2023-09-25 Thread via GitHub
jgagnon1 commented on PR #23453: URL: https://github.com/apache/flink/pull/23453#issuecomment-1733850068 @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] snuyanzin commented on pull request #23458: [FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
snuyanzin commented on PR #23458: URL: https://github.com/apache/flink/pull/23458#issuecomment-1733693205 @RyanSkraba thanks for the contribution looks ok from my side could you please also provide backports to 1.16.x, 1.17.x, 1.18.x ? -- This is an automated message from the Apache

[jira] [Commented] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768679#comment-17768679 ] Yang Wang commented on FLINK-33155: --- Thanks for your comments.   > Changing the default behavior

[jira] [Commented] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

2023-09-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768680#comment-17768680 ] Martijn Visser commented on FLINK-28303: [~tanjialiang] It would be good to double check this in

[jira] [Comment Edited] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-25 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768665#comment-17768665 ] Gabor Somogyi edited comment on FLINK-33155 at 9/25/23 12:20 PM: - Not

[jira] [Commented] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-25 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768665#comment-17768665 ] Gabor Somogyi commented on FLINK-33155: --- Not updating

[jira] [Updated] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-33155: -- Description: When Kerberos enabled(with key tab) and after one day(the container token expired),

[jira] [Updated] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-33155: -- Description: When Kerberos enabled(with key tab) and after one day(the container token expired),

[jira] [Updated] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-33155: -- Component/s: Deployment / YARN > Flink ResourceManager continuously fails to start TM container on

[jira] [Created] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2023-09-25 Thread Yang Wang (Jira)
Yang Wang created FLINK-33155: - Summary: Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled Key: FLINK-33155 URL: https://issues.apache.org/jira/browse/FLINK-33155

[jira] [Commented] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

2023-09-25 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768637#comment-17768637 ] tanjialiang commented on FLINK-28303: - Maybe this this is the reason?

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

2023-09-25 Thread Monody (Jira)
Monody created FLINK-33154: -- Summary: flink on k8s,An error occurred during consuming rocketmq Key: FLINK-33154 URL: https://issues.apache.org/jira/browse/FLINK-33154 Project: Flink Issue Type:

[jira] [Commented] (FLINK-33153) Kafka using latest-offset maybe missing data

2023-09-25 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768631#comment-17768631 ] tanjialiang commented on FLINK-33153: - It relate to

[jira] [Updated] (FLINK-33153) Kafka using latest-offset maybe missing data

2023-09-25 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-33153: External issue URL: (was: https://issues.apache.org/jira/browse/FLINK-28303) > Kafka using

[jira] [Updated] (FLINK-33153) Kafka using latest-offset maybe missing data

2023-09-25 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-33153: External issue URL: https://issues.apache.org/jira/browse/FLINK-28303 Release Note:

[jira] [Closed] (FLINK-33153) Kafka using latest-offset maybe missing data

2023-09-25 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang closed FLINK-33153. --- Release Note: realte to https://issues.apache.org/jira/browse/FLINK-28303 Resolution:

[GitHub] [flink] FangYongs commented on a diff in pull request #23455: [FLINK-25015][Table SQL/Client] change job name to sql when submitting queries using client

2023-09-25 Thread via GitHub
FangYongs commented on code in PR #23455: URL: https://github.com/apache/flink/pull/23455#discussion_r1335703134 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -1050,10 +1052,15 @@ private

[GitHub] [flink] FangYongs commented on a diff in pull request #23455: [FLINK-25015][Table SQL/Client] change job name to sql when submitting queries using client

2023-09-25 Thread via GitHub
FangYongs commented on code in PR #23455: URL: https://github.com/apache/flink/pull/23455#discussion_r1335701445 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -1050,10 +1052,15 @@ private

[jira] [Created] (FLINK-33153) Kafka using latest-offset maybe missing data

2023-09-25 Thread tanjialiang (Jira)
tanjialiang created FLINK-33153: --- Summary: Kafka using latest-offset maybe missing data Key: FLINK-33153 URL: https://issues.apache.org/jira/browse/FLINK-33153 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-33127) HeapKeyedStateBackend: use buffered I/O to speed up local recovery

2023-09-25 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768610#comment-17768610 ] Hangxiang Yu commented on FLINK-33127: -- Actually I have taked a second review last month but not

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

2023-09-25 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768607#comment-17768607 ] Hangxiang Yu commented on FLINK-26585: -- [~Matthias Schwalbe] I have taked a second review last

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

2023-09-25 Thread Matthias Schwalbe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768604#comment-17768604 ] Matthias Schwalbe commented on FLINK-26585: --- Hi [~masteryhx] , The PR

[jira] [Commented] (FLINK-33127) HeapKeyedStateBackend: use buffered I/O to speed up local recovery

2023-09-25 Thread Matthias Schwalbe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768602#comment-17768602 ] Matthias Schwalbe commented on FLINK-33127: --- [~masteryhx] : I actually want to finish

[jira] [Resolved] (FLINK-33151) Prometheus Sink Connector - Create Github Repo

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33151. --- Resolution: Done > Prometheus Sink Connector - Create Github Repo >

[jira] [Commented] (FLINK-33151) Prometheus Sink Connector - Create Github Repo

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17768596#comment-17768596 ] Danny Cranmer commented on FLINK-33151: --- https://github.com/apache/flink-connector-prometheus >

[jira] [Updated] (FLINK-33152) Prometheus Sink Connector - Integration tests

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33152: -- Component/s: Connectors / Prometheus > Prometheus Sink Connector - Integration tests >

[jira] [Updated] (FLINK-31757) FLIP-370: Support Balanced Tasks Scheduling

2023-09-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31757: Description: This is an umbrella JIRA of [FLIP-370|https://cwiki.apache.org/confluence/x/U56zDw]. (was:

[jira] [Updated] (FLINK-33139) Prometheus Sink Connector - Table API support

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33139: -- Fix Version/s: prometheus-connector-1.0.0 > Prometheus Sink Connector - Table API support >

[jira] [Updated] (FLINK-33152) Prometheus Sink Connector - Integration tests

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33152: -- Fix Version/s: prometheus-connector-1.0.0 > Prometheus Sink Connector - Integration tests >

[jira] [Updated] (FLINK-33151) Prometheus Sink Connector - Create Github Repo

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33151: -- Component/s: Connectors / Prometheus > Prometheus Sink Connector - Create Github Repo >

[jira] [Updated] (FLINK-33151) Prometheus Sink Connector - Create Github Repo

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33151: -- Fix Version/s: prometheus-connector-1.0.0 > Prometheus Sink Connector - Create Github Repo >

[jira] [Updated] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33141: -- Fix Version/s: (was: prometheus-connector-1.0.0) > Promentheus Sink Connector - Amazon

[jira] [Updated] (FLINK-33139) Prometheus Sink Connector - Table API support

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33139: -- Component/s: Connectors / Prometheus > Prometheus Sink Connector - Table API support >

[jira] [Updated] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33141: -- Fix Version/s: prometheus-connector-1.0.0 > Promentheus Sink Connector - Amazon Managed

[jira] [Updated] (FLINK-33138) Prometheus Connector Sink - DataStream API implementation

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33138: -- Fix Version/s: prometheus-connector-1.0.0 > Prometheus Connector Sink - DataStream API

[jira] [Updated] (FLINK-33138) Prometheus Connector Sink - DataStream API implementation

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33138: -- Component/s: Connectors / Prometheus > Prometheus Connector Sink - DataStream API

[jira] [Updated] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33137: -- Component/s: Connectors / Prometheus > FLIP-312: Prometheus Sink Connector >

[jira] [Updated] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33137: -- Fix Version/s: prometheus-connector-1.0.0 > FLIP-312: Prometheus Sink Connector >

[GitHub] [flink] flinkbot commented on pull request #23458: [FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
flinkbot commented on PR #23458: URL: https://github.com/apache/flink/pull/23458#issuecomment-1733193724 ## CI report: * 4debb4036b86485b39be61cb284e7ba6e8daaba7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31757) FLIP-370: Support Balanced Tasks Scheduling

2023-09-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31757: Summary: FLIP-370: Support Balanced Tasks Scheduling (was: Support Balanced Tasks Scheduling) >

[jira] [Updated] (FLINK-31757) Support Balanced Tasks Scheduling

2023-09-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31757: Description: This is a umbrella JIRA of [FLIP-370|https://cwiki.apache.org/confluence/x/U56zDw].  

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

2023-09-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33149: --- Labels: pull-request-available (was: ) > Bump snappy-java to 1.1.10.4 >

[GitHub] [flink] RyanSkraba opened a new pull request, #23458: [FLINK-33149][build] Bump snappy to 1.1.10.4

2023-09-25 Thread via GitHub
RyanSkraba opened a new pull request, #23458: URL: https://github.com/apache/flink/pull/23458 ## What is the purpose of the change Bump the version of snappy to address a vulnerability. ## Brief change log ## Verifying this change This change is already covered by

[jira] [Created] (FLINK-33152) Prometheus Sink Connector - Integration tests

2023-09-25 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33152: -- Summary: Prometheus Sink Connector - Integration tests Key: FLINK-33152 URL: https://issues.apache.org/jira/browse/FLINK-33152 Project: Flink Issue

[jira] [Updated] (FLINK-33140) Prometheus Sink Connector - E2E example on AWS

2023-09-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-33140: --- Summary: Prometheus Sink Connector - E2E example on AWS (was: Prometheus Sink Connector -

[jira] [Updated] (FLINK-33140) Prometheus Sink Connector - E2E example on AWS

2023-09-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-33140: --- Description: End-to-end example application, deployable on Amazon Managed Service for

[jira] [Updated] (FLINK-33140) Prometheus Sink Connector - E2E example

2023-09-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-33140: --- Summary: Prometheus Sink Connector - E2E example (was: Prometheus Sink Connector - E2E

[jira] [Updated] (FLINK-33140) Prometheus Sink Connector - E2E example

2023-09-25 Thread Lorenzo Nicora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lorenzo Nicora updated FLINK-33140: --- Description: End-to-end example application, to be deployed on Amazon Managed Service for

[jira] [Created] (FLINK-33151) Prometheus Sink Connector - Create Github Repo

2023-09-25 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-33151: - Summary: Prometheus Sink Connector - Create Github Repo Key: FLINK-33151 URL: https://issues.apache.org/jira/browse/FLINK-33151 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-33151) Prometheus Sink Connector - Create Github Repo

2023-09-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-33151: - Assignee: Danny Cranmer > Prometheus Sink Connector - Create Github Repo >

[jira] [Created] (FLINK-33150) add the processing logic for the long type

2023-09-25 Thread wenhao.yu (Jira)
wenhao.yu created FLINK-33150: - Summary: add the processing logic for the long type Key: FLINK-33150 URL: https://issues.apache.org/jira/browse/FLINK-33150 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2023-09-25 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33137: --- Assignee: Lorenzo Nicora > FLIP-312: Prometheus Sink Connector >

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

2023-09-25 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-33149: --- Summary: Bump snappy-java to 1.1.10.4 Key: FLINK-33149 URL: https://issues.apache.org/jira/browse/FLINK-33149 Project: Flink Issue Type: Bug

[GitHub] [flink] echauchot commented on pull request #23443: [FLINK-33059] Support transparent compression for file-connector for all file input formats

2023-09-25 Thread via GitHub
echauchot commented on PR #23443: URL: https://github.com/apache/flink/pull/23443#issuecomment-1733119379 Hi @rmetzger, I saw you authored parts of this code, can you please do a review or point me to another reviewer ? -- This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-33107) Update stable-spec upgrade mode on reconciled-spec change

2023-09-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-33107. -- Fix Version/s: kubernetes-operator-1.7.0 Resolution: Fixed merged to main

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #681: [FLINK-33107] Use correct upgrade mode when executing rollback, simpl…

2023-09-25 Thread via GitHub
gyfora merged PR #681: URL: https://github.com/apache/flink-kubernetes-operator/pull/681 -- 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:

  1   2   >