[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

2022-11-18 Thread zhanglu153 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635770#comment-17635770 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 6:05 AM:

[jira] [Updated] (FLINK-30076) hive join mysql error

2022-11-18 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck updated FLINK-30076: Description: There is no problem when reading hive table parquet alone, but after doing join with MySQL table, th

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

2022-11-18 Thread zhanglu153 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635734#comment-17635734 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 5:57 AM:

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

2022-11-18 Thread zhanglu153 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635696#comment-17635696 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 5:47 AM:

[jira] [Updated] (FLINK-30094) Flink Table Sotre's Lookup Join document may needs left table DDL example.

2022-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30094: --- Labels: pull-request-available (was: ) > Flink Table Sotre's Lookup Join document may needs

[GitHub] [flink-table-store] houhang1005 opened a new pull request, #393: [FLINK-30094] Append a left table DDL in Lookup Join character.

2022-11-18 Thread GitBox
houhang1005 opened a new pull request, #393: URL: https://github.com/apache/flink-table-store/pull/393 I guess it's better add a left table DDL in doc to help new users learn how to use lookup join easily. -- This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Created] (FLINK-30094) Flink Table Sotre's Lookup Join document may needs left table DDL example.

2022-11-18 Thread Hang HOU (Jira)
Hang HOU created FLINK-30094: Summary: Flink Table Sotre's Lookup Join document may needs left table DDL example. Key: FLINK-30094 URL: https://issues.apache.org/jira/browse/FLINK-30094 Project: Flink

[GitHub] [flink] zhuzhurk commented on pull request #21197: [FLINK-29801] OperatorCoordinator need open the way to operate metric…

2022-11-18 Thread GitBox
zhuzhurk commented on PR #21197: URL: https://github.com/apache/flink/pull/21197#issuecomment-1320802432 @ruanhang1993 would you work with @JerryYue-M on the FLIP? cc @PatrickRen -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] link3280 commented on pull request #21292: [FLINK-28617][SQL Gateway] Support stop job statement in SqlGatewayService

2022-11-18 Thread GitBox
link3280 commented on PR #21292: URL: https://github.com/apache/flink/pull/21292#issuecomment-1320789012 Rebased on the recent master to see if the test failure still exists. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

2022-11-18 Thread zhanglu153 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635635#comment-17635635 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 3:32 AM:

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

2022-11-18 Thread GitBox
SteNicholas commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027015305 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SnapshotManager.java: ## @@ -90,6 +90,22 @@ public boolean snapshotExists(lo

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

2022-11-18 Thread GitBox
SteNicholas commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027011255 ## flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ContinuousFileStoreITCase.java: ## @@ -114,6 +121,55 @@ public void test

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

2022-11-18 Thread GitBox
SteNicholas commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027010517 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java: ## @@ -130,4 +119,42 @@ public SplitEnumera

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

2022-11-18 Thread GitBox
SteNicholas commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027009308 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java: ## @@ -130,4 +119,42 @@ public SplitEnumera

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

2022-11-18 Thread GitBox
SteNicholas commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027005215 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java: ## @@ -130,4 +119,42 @@ public SplitEnumera

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #445: [FLINK-29939]Add metrics for Kubernetes Client Response 5xx count and…

2022-11-18 Thread GitBox
morhidi commented on PR #445: URL: https://github.com/apache/flink-kubernetes-operator/pull/445#issuecomment-1320720849 > ack - lemme add a flag for the additional metrics. These new metrics, along with kubernetes client metrics, are currently covered by `kubernetes.client.metrics.enabled`

[GitHub] [flink-table-store] JLLeitschuh opened a new pull request, #392: [SECURITY] Fix Temporary File Information Disclosure Vulnerability

2022-11-18 Thread GitBox
JLLeitschuh opened a new pull request, #392: URL: https://github.com/apache/flink-table-store/pull/392 # Security Vulnerability Fix This pull request fixes a Temporary File Information Disclosure Vulnerability, which existed in this project. ## Preamble The system te

[jira] [Commented] (FLINK-26088) Add Elasticsearch 8.0 support

2022-11-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17636058#comment-17636058 ] Martijn Visser commented on FLINK-26088: No, what should happen is: - Support fo

[jira] [Commented] (FLINK-30092) Improve Table API experience for Flink DOUBLE type

2022-11-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17636052#comment-17636052 ] Martijn Visser commented on FLINK-30092: [~liangtl] I think this is directly rel

[GitHub] [flink] rkhachatryan closed pull request #20722: [FLINK-29095][state] Improve logging in SharedStateRegistry

2022-11-18 Thread GitBox
rkhachatryan closed pull request #20722: [FLINK-29095][state] Improve logging in SharedStateRegistry URL: https://github.com/apache/flink/pull/20722 -- 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 t

[GitHub] [flink] rkhachatryan commented on pull request #20722: [FLINK-29095][state] Improve logging in SharedStateRegistry

2022-11-18 Thread GitBox
rkhachatryan commented on PR #20722: URL: https://github.com/apache/flink/pull/20722#issuecomment-1320539818 Superseeded by #21136. Thanks for taking this over @fredia! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[GitHub] [flink-kubernetes-operator] jiangzho commented on pull request #445: [FLINK-29939]Add metrics for Kubernetes Client Response 5xx count and…

2022-11-18 Thread GitBox
jiangzho commented on PR #445: URL: https://github.com/apache/flink-kubernetes-operator/pull/445#issuecomment-1320462341 ack - lemme add a flag for the additional metrics -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[GitHub] [flink] liuml07 commented on pull request #21343: [FLINK-30079][doc] Stop using deprecated TM options in doc

2022-11-18 Thread GitBox
liuml07 commented on PR #21343: URL: https://github.com/apache/flink/pull/21343#issuecomment-1320431644 Thank you @zentol. TIL! -- 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 commen

[jira] [Commented] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

2022-11-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635995#comment-17635995 ] Robert Metzger commented on FLINK-30093: [~maosuhan] Sorry for pinging you direc

[jira] [Updated] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

2022-11-18 Thread James Mcguire (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Mcguire updated FLINK-30093: -- Description: I am encountering an issue when trying to use Flink SQL to query a Kafka topic t

[jira] [Updated] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

2022-11-18 Thread James Mcguire (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Mcguire updated FLINK-30093: -- Description: I am encountering an issue when trying to use Flink SQL to query a Kafka topic t

[jira] [Updated] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

2022-11-18 Thread James Mcguire (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Mcguire updated FLINK-30093: -- Description: I am encountering an issue when trying to use Flink SQL to query a Kafka topic t

[jira] [Updated] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

2022-11-18 Thread James Mcguire (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Mcguire updated FLINK-30093: -- Attachment: taskmanager_172.22.0 (1).4_46291-40eec2_log > [Flink SQL][Protobuf] CompileExcepti

[jira] [Created] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

2022-11-18 Thread James Mcguire (Jira)
James Mcguire created FLINK-30093: - Summary: [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp Key: FLINK-30093 URL: https://issues.apache.org/jira/browse/FLINK-3009

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-18 Thread GitBox
hlteoh37 commented on code in PR #15: URL: https://github.com/apache/flink-connector-aws/pull/15#discussion_r1026762714 ## flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactoryTest.java: ## @@ -0,0 +1,267 @@ +package org.apa

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-18 Thread GitBox
hlteoh37 commented on code in PR #15: URL: https://github.com/apache/flink-connector-aws/pull/15#discussion_r1026733354 ## flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactoryTest.java: ## @@ -0,0 +1,267 @@ +package org.apa

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-18 Thread GitBox
hlteoh37 commented on code in PR #15: URL: https://github.com/apache/flink-connector-aws/pull/15#discussion_r1026732902 ## flink-sql-connector-dynamodb/pom.xml: ## @@ -77,12 +77,16 @@ under the License. or

[GitHub] [flink] flinkbot commented on pull request #21349: Support Maven 3.3+

2022-11-18 Thread GitBox
flinkbot commented on PR #21349: URL: https://github.com/apache/flink/pull/21349#issuecomment-1320351841 ## CI report: * c1795c4da33dab83dc1e0376c5d8b4ddb90457d0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-18 Thread GitBox
hlteoh37 commented on code in PR #15: URL: https://github.com/apache/flink-connector-aws/pull/15#discussion_r1026723923 ## flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactoryTest.java: ## @@ -0,0 +1,267 @@ +package org.apa

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-18 Thread GitBox
hlteoh37 commented on code in PR #15: URL: https://github.com/apache/flink-connector-aws/pull/15#discussion_r1026721301 ## flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbConfiguration.java: ## @@ -0,0 +1,44 @@ +/* + * Licensed to the Ap

[jira] [Updated] (FLINK-30091) mvn package verify fails with "Error creating shaded jar: duplicate entry"

2022-11-18 Thread Alex Sorokoumov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Sorokoumov updated FLINK-30091: Labels: pull-request-available (was: ) > mvn package verify fails with "Error creating sh

[jira] [Updated] (FLINK-29928) Allow sharing (RocksDB) memory between slots

2022-11-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29928: -- Description: h1. Background and motivation RocksDB is one of the main consumers of of

[jira] [Updated] (FLINK-29928) Allow sharing (RocksDB) memory between slots

2022-11-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29928: -- Release Note: Added new config parameters: - state.backend.rocksdb.memory.fixed-per-t

[jira] [Updated] (FLINK-29928) Allow sharing (RocksDB) memory between slots

2022-11-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29928: -- Description: h1. Background and motivation RocksDB is one of the main consumers of of

[GitHub] [flink-connector-aws] dannycranmer commented on a diff in pull request #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-18 Thread GitBox
dannycranmer commented on code in PR #15: URL: https://github.com/apache/flink-connector-aws/pull/15#discussion_r1026638166 ## flink-sql-connector-dynamodb/pom.xml: ## @@ -77,12 +77,16 @@ under the License.

[GitHub] [flink-connector-aws] dannycranmer commented on a diff in pull request #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-18 Thread GitBox
dannycranmer commented on code in PR #15: URL: https://github.com/apache/flink-connector-aws/pull/15#discussion_r1026625994 ## flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactoryTest.java: ## @@ -0,0 +1,267 @@ +package org

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-18 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635947#comment-17635947 ] Piotr Nowojski commented on FLINK-28695: I've assigned the ticket to you [~fanru

[jira] [Updated] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-18 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-28695: --- Priority: Critical (was: Major) > Fail to send partition request to restarted taskmanager >

[jira] [Assigned] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-18 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-28695: -- Assignee: Rui Fan > Fail to send partition request to restarted taskmanager > ---

[jira] [Commented] (FLINK-30091) mvn package verify fails with "Error creating shaded jar: duplicate entry"

2022-11-18 Thread Alex Sorokoumov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635943#comment-17635943 ] Alex Sorokoumov commented on FLINK-30091: - PR - [https://github.com/apache/flink

[jira] [Created] (FLINK-30092) Improve Table API experience for Flink DOUBLE type

2022-11-18 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-30092: --- Summary: Improve Table API experience for Flink DOUBLE type Key: FLINK-30092 URL: https://issues.apache.org/jira/browse/FLINK-30092 Project: Flink Issu

[GitHub] [flink-connector-aws] dannycranmer commented on a diff in pull request #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-18 Thread GitBox
dannycranmer commented on code in PR #15: URL: https://github.com/apache/flink-connector-aws/pull/15#discussion_r1026618568 ## flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataToAttributeValueConverter.java: ## @@ -0,0 +1,72 @@ +package or

[GitHub] [flink-connector-aws] dannycranmer commented on a diff in pull request #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-18 Thread GitBox
dannycranmer commented on code in PR #15: URL: https://github.com/apache/flink-connector-aws/pull/15#discussion_r1026589061 ## flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbConfiguration.java: ## @@ -0,0 +1,44 @@ +/* + * Licensed to th

[jira] [Created] (FLINK-30091) mvn package verify fails with "Error creating shaded jar: duplicate entry"

2022-11-18 Thread Alex Sorokoumov (Jira)
Alex Sorokoumov created FLINK-30091: --- Summary: mvn package verify fails with "Error creating shaded jar: duplicate entry" Key: FLINK-30091 URL: https://issues.apache.org/jira/browse/FLINK-30091 Proj

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #445: [FLINK-29939]Add metrics for Kubernetes Client Response 5xx count and…

2022-11-18 Thread GitBox
gyfora commented on PR #445: URL: https://github.com/apache/flink-kubernetes-operator/pull/445#issuecomment-1320192204 What do you think @morhidi @jiangzho , should we go with all or nothing (the current setup) or should we introduce a separate enable flag for the per status metrics? --

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #445: [FLINK-29939]Add metrics for Kubernetes Client Response 5xx count and…

2022-11-18 Thread GitBox
morhidi commented on PR #445: URL: https://github.com/apache/flink-kubernetes-operator/pull/445#issuecomment-1320192200 > This introduces quite a lot of new metrics by default. Do you think it would make sense to make the response code based metrics configurable? Just one flag to disable o

[jira] [Created] (FLINK-30090) Support timespan for TimerGauges

2022-11-18 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30090: -- Summary: Support timespan for TimerGauges Key: FLINK-30090 URL: https://issues.apache.org/jira/browse/FLINK-30090 Project: Flink Issue Type: Improvement

[GitHub] [flink] xintongsong commented on pull request #21137: [FLINK-29234][runtime] JobMasterServiceLeadershipRunner handle leader event in a separate executor to avoid dead lock

2022-11-18 Thread GitBox
xintongsong commented on PR #21137: URL: https://github.com/apache/flink/pull/21137#issuecomment-1320061643 @reswqa, as previously discussed, please remember to open a ticket for fixing the leader election service side and all other contenders. -- This is an automated message from the Apa

[jira] [Closed] (FLINK-29234) Dead lock in DefaultLeaderElectionService

2022-11-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29234. Fix Version/s: 1.17.0 1.16.1 1.15.4 Resolution: Fixed

[GitHub] [flink] xintongsong closed pull request #21137: [FLINK-29234][runtime] JobMasterServiceLeadershipRunner handle leader event in a separate executor to avoid dead lock

2022-11-18 Thread GitBox
xintongsong closed pull request #21137: [FLINK-29234][runtime] JobMasterServiceLeadershipRunner handle leader event in a separate executor to avoid dead lock URL: https://github.com/apache/flink/pull/21137 -- This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] flinkbot commented on pull request #21348: [FLINK-30089][kinesis] Remove dependency promotion

2022-11-18 Thread GitBox
flinkbot commented on PR #21348: URL: https://github.com/apache/flink/pull/21348#issuecomment-1320047457 ## CI report: * 6fcfde7549e14f1c965e0c346047ed6f0967e510 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30089) Remove dependency promotion from kinesis connector

2022-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30089: --- Labels: pull-request-available (was: ) > Remove dependency promotion from kinesis connector

[GitHub] [flink] zentol opened a new pull request, #21348: [FLINK-30089][kinesis] Remove dependency promotion

2022-11-18 Thread GitBox
zentol opened a new pull request, #21348: URL: https://github.com/apache/flink/pull/21348 Remove a special case in our shading setup. This shouldn't change the contents of the sql-connector-kinesis jar or the total set of dependencies visible to users of flink-connector-kinesis.. @

[jira] [Updated] (FLINK-30089) Remove dependency promotion from kinesis connector

2022-11-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30089: - Description: The shade-plugin in the kinesis connector is configured to promote transiti

[jira] [Created] (FLINK-30089) Remove dependency promotion from kinesis connector

2022-11-18 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30089: Summary: Remove dependency promotion from kinesis connector Key: FLINK-30089 URL: https://issues.apache.org/jira/browse/FLINK-30089 Project: Flink Is

[jira] [Commented] (FLINK-30088) Excessive state updates for TtlMapState and TtlListState

2022-11-18 Thread Roman Boyko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635875#comment-17635875 ] Roman Boyko commented on FLINK-30088: - The fix is ready - [https://github.com/rovbo

[GitHub] [flink-kubernetes-operator] tagarr commented on a diff in pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

2022-11-18 Thread GitBox
tagarr commented on code in PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420#discussion_r1026448880 ## helm/flink-kubernetes-operator/templates/flink-operator.yaml: ## @@ -79,7 +79,13 @@ spec: {{- end }} env: - name:

[GitHub] [flink] flinkbot commented on pull request #21347: [FLINK-29640][Client/Job Submission]Enhance the function configured by execution.shutdown-on-attached-exi…

2022-11-18 Thread GitBox
flinkbot commented on PR #21347: URL: https://github.com/apache/flink/pull/21347#issuecomment-1320008320 ## CI report: * a38d8aad5de4bc47af77a3b33506e267286b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29640) Enhance the function configured by execution.shutdown-on-attached-exit by heartbeat between client and dispatcher

2022-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29640: --- Labels: pull-request-available (was: ) > Enhance the function configured by execution.shutd

[GitHub] [flink] Myracle opened a new pull request, #21347: [FLINK-29640][Client/Job Submission]Enhance the function configured by execution.shutdown-on-attached-exi…

2022-11-18 Thread GitBox
Myracle opened a new pull request, #21347: URL: https://github.com/apache/flink/pull/21347 ## What is the purpose of the change *Enhance the behavior by building the heartbeat between the client and the job. Once the job can not received any heartbeat from the client, the job cancel

[GitHub] [flink] liyubin117 commented on pull request #21182: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-11-18 Thread GitBox
liyubin117 commented on PR #21182: URL: https://github.com/apache/flink/pull/21182#issuecomment-1319998371 @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] [Created] (FLINK-30088) Excessive state updates for TtlMapState and TtlListState

2022-11-18 Thread Roman Boyko (Jira)
Roman Boyko created FLINK-30088: --- Summary: Excessive state updates for TtlMapState and TtlListState Key: FLINK-30088 URL: https://issues.apache.org/jira/browse/FLINK-30088 Project: Flink Issue

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-11-18 Thread GitBox
reta commented on code in PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1026434221 ## pom.xml: ## @@ -327,6 +327,12 @@ under the License. + +

[GitHub] [flink-connector-opensearch] zentol commented on a diff in pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-11-18 Thread GitBox
zentol commented on code in PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1026411856 ## pom.xml: ## @@ -327,6 +327,12 @@ under the License. + +

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

2022-11-18 Thread GitBox
morhidi commented on code in PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420#discussion_r1026411500 ## helm/flink-kubernetes-operator/templates/flink-operator.yaml: ## @@ -79,7 +79,13 @@ spec: {{- end }} env: - name:

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #445: [FLINK-29939]Add metrics for Kubernetes Client Response 5xx count and…

2022-11-18 Thread GitBox
gyfora commented on PR #445: URL: https://github.com/apache/flink-kubernetes-operator/pull/445#issuecomment-1319968164 This introduces quite a lot of new metrics by default. Do you think it would make sense to make the response code based metrics configurable? We usually have similar

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #445: [FLINK-29939]Add metrics for Kubernetes Client Response 5xx count and…

2022-11-18 Thread GitBox
morhidi commented on PR #445: URL: https://github.com/apache/flink-kubernetes-operator/pull/445#issuecomment-1319963068 +1 for merging. Nice job @jiangzho! cc @gyfora -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink-connector-opensearch] zentol commented on a diff in pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-11-18 Thread GitBox
zentol commented on code in PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1026404137 ## flink-sql-connector-opensearch/pom.xml: ## @@ -0,0 +1,159 @@ + + +http://maven.apache.org/POM/4.0.0"; +xmlns:xsi="http://www.w3.org/2001

[jira] [Created] (FLINK-30087) sql-gateway-api is bundled twice in the distribution

2022-11-18 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30087: Summary: sql-gateway-api is bundled twice in the distribution Key: FLINK-30087 URL: https://issues.apache.org/jira/browse/FLINK-30087 Project: Flink

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #175: [FLINK-29602] Add Transformer for SQLTransformer

2022-11-18 Thread GitBox
lindong28 commented on code in PR #175: URL: https://github.com/apache/flink-ml/pull/175#discussion_r1026381410 ## flink-ml-lib/src/test/java/org/apache/flink/ml/feature/SQLTransformerTest.java: ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #175: [FLINK-29602] Add Transformer for SQLTransformer

2022-11-18 Thread GitBox
lindong28 commented on code in PR #175: URL: https://github.com/apache/flink-ml/pull/175#discussion_r1026381410 ## flink-ml-lib/src/test/java/org/apache/flink/ml/feature/SQLTransformerTest.java: ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] flinkbot commented on pull request #21346: [FLINK-26037][coordination] TMRunner waits for metric registry shutdown

2022-11-18 Thread GitBox
flinkbot commented on PR #21346: URL: https://github.com/apache/flink/pull/21346#issuecomment-1319901777 ## CI report: * 9ccc5dcbf7caf67981b803ed41db0da1aa4b3afa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26037: --- Labels: pull-request-available test-stability (was: test-stability) > TaskManagerRunnerTest

[GitHub] [flink] zentol opened a new pull request, #21346: [FLINK-26037][coordination] TMRunner waits for metric registry shutdown

2022-11-18 Thread GitBox
zentol opened a new pull request, #21346: URL: https://github.com/apache/flink/pull/21346 Fix an issue where the TaskManagerRunner shutdown sequence ignored the metric registry shutdown. This could result in the rpc system (and rpc classloader!) being closed while the metrics actor system i

[jira] [Assigned] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-11-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-26037: Assignee: Chesnay Schepler > TaskManagerRunnerTest JVM crash with exit code 239 >

[jira] [Commented] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-11-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635831#comment-17635831 ] Chesnay Schepler commented on FLINK-26037: -- Looks a bit like a fatal error occu

[GitHub] [flink] flinkbot commented on pull request #21345: [FLINK-30086][ci] DependencyTree includes classifier in key

2022-11-18 Thread GitBox
flinkbot commented on PR #21345: URL: https://github.com/apache/flink/pull/21345#issuecomment-1319888033 ## CI report: * ba042f281935344e1ee754893f1bdc7664e96abb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30086) Include classifier in DependencyTree tree

2022-11-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30086: --- Labels: pull-request-available (was: ) > Include classifier in DependencyTree tree > --

[GitHub] [flink] liyubin117 commented on pull request #21182: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-11-18 Thread GitBox
liyubin117 commented on PR #21182: URL: https://github.com/apache/flink/pull/21182#issuecomment-1319881055 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

[jira] [Commented] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

2022-11-18 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635815#comment-17635815 ] Gabor Somogyi commented on FLINK-20714: --- Now it's possible to add Hive token provi

[jira] [Created] (FLINK-30086) Include classifier in DependencyTree tree

2022-11-18 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30086: Summary: Include classifier in DependencyTree tree Key: FLINK-30086 URL: https://issues.apache.org/jira/browse/FLINK-30086 Project: Flink Issue Type:

[jira] [Commented] (FLINK-30048) MapState.remove(UK key) is better to return the old value.

2022-11-18 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635807#comment-17635807 ] Yanfei Lei commented on FLINK-30048: Sorry for the late reply. As [~masteryhx] menti

[GitHub] [flink] zentol commented on a diff in pull request #21344: [FLINK-30083] Bump maven-shade-plugin version

2022-11-18 Thread GitBox
zentol commented on code in PR #21344: URL: https://github.com/apache/flink/pull/21344#discussion_r1026171420 ## pom.xml: ## @@ -991,7 +991,7 @@ under the License. org.apach

[GitHub] [flink] gaborgsomogyi commented on pull request #21339: [FLINK-30024][tests] Build local test KDC docker image

2022-11-18 Thread GitBox
gaborgsomogyi commented on PR #21339: URL: https://github.com/apache/flink/pull/21339#issuecomment-1319806287 @MartijnVisser @zentol Thanks for taking care! -- 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

[jira] [Comment Edited] (FLINK-29878) Fail to use flink-sql-connector-hive-3.1.3

2022-11-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635789#comment-17635789 ] Chesnay Schepler edited comment on FLINK-29878 at 11/18/22 10:20 AM: -

[jira] [Reopened] (FLINK-29878) Fail to use flink-sql-connector-hive-3.1.3

2022-11-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-29878: -- The added dependency is nut bundled in the sql jar, since the shade-plugin artifactSet wa

[jira] [Updated] (FLINK-30085) JVM hanging after executing YARNSessionCapacitySchedulerITCase.testNonexistingQueueWARNmessage

2022-11-18 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-30085: -- Description: After some analysis I've concluded the following: the test submitted an app into

[jira] [Comment Edited] (FLINK-30085) JVM hanging after executing YARNSessionCapacitySchedulerITCase.testNonexistingQueueWARNmessage

2022-11-18 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635771#comment-17635771 ] Gabor Somogyi edited comment on FLINK-30085 at 11/18/22 9:57 AM: -

[jira] [Commented] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

2022-11-18 Thread zhanglu153 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635770#comment-17635770 ] zhanglu153 commented on FLINK-30075: This error is related to the hadoop version and

[jira] [Commented] (FLINK-30085) JVM hanging after executing YARNSessionCapacitySchedulerITCase.testNonexistingQueueWARNmessage

2022-11-18 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635771#comment-17635771 ] Gabor Somogyi commented on FLINK-30085: --- After some in-depth look we've found that

[jira] [Assigned] (FLINK-30085) JVM hanging after executing YARNSessionCapacitySchedulerITCase.testNonexistingQueueWARNmessage

2022-11-18 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30085: -- Assignee: Gabor Somogyi > JVM hanging after executing > YARNSessionCapacitySchedulerITCase.t

[jira] [Updated] (FLINK-29928) Allow sharing (RocksDB) memory between slots

2022-11-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29928: -- Description: h1. Background and motivation RocksDB is one of the main consumers of of

[jira] [Updated] (FLINK-29928) Allow sharing (RocksDB) memory between slots

2022-11-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29928: -- Description: h1. Background and motivation RocksDB is one of the main consumers of of

[jira] [Updated] (FLINK-29928) Allow sharing (RocksDB) memory between slots

2022-11-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29928: -- Description: h1. Background and motivation RocksDB is one of the main consumers of of

[jira] [Updated] (FLINK-29928) Allow sharing (RocksDB) memory between slots

2022-11-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29928: -- Description: h1. Background and motivation RocksDB is one of the main consumers of of

  1   2   >