[GitHub] [flink] flinkbot commented on pull request #20246: [FLINK-28074][table-planner] show statistics details for DESCRIBE EXT…

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

[GitHub] [flink] fredia commented on pull request #20160: [FLINK-28286][state] move 'enablechangelog' constant to flink-core module

2022-07-11 Thread GitBox
fredia commented on PR #20160: URL: https://github.com/apache/flink/pull/20160#issuecomment-1181335690 Sure, Rebased. Thanks a lot for your review and patience! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED

2022-07-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28074: --- Labels: pull-request-available (was: ) > show statistics details for DESCRIBE EXTENDED >

[GitHub] [flink] swuferhong opened a new pull request, #20246: [FLINK-28074][table-planner] show statistics details for DESCRIBE EXT…

2022-07-11 Thread GitBox
swuferhong opened a new pull request, #20246: URL: https://github.com/apache/flink/pull/20246 …ENDED ## What is the purpose of the change - This pr aims to let syntax `DESCRIBE EXTENDED` support printing table statistics details. table stats Details including

[jira] [Assigned] (FLINK-28500) Add Transformer for Tokenizer

2022-07-11 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang reassigned FLINK-28500: - Assignee: Zhipeng Zhang > Add Transformer for Tokenizer >

[GitHub] [flink] wuchong merged pull request #20213: [hotfix][docs] Fix formatting in Chinese doc

2022-07-11 Thread GitBox
wuchong merged PR #20213: URL: https://github.com/apache/flink/pull/20213 -- 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] [Updated] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

2022-07-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-28499: - Priority: Major (was: Minor) > resource leak when job failed with unknown status In Application Mode >

[GitHub] [flink] 1996fanrui commented on pull request #20137: Just for CI

2022-07-11 Thread GitBox
1996fanrui commented on PR #20137: URL: https://github.com/apache/flink/pull/20137#issuecomment-1181305318 @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

[jira] [Created] (FLINK-28502) Add Transformer for RegexTokenizer

2022-07-11 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28502: - Summary: Add Transformer for RegexTokenizer Key: FLINK-28502 URL: https://issues.apache.org/jira/browse/FLINK-28502 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28501) Add Transformer and Estimator for VectorIndexer

2022-07-11 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28501: - Summary: Add Transformer and Estimator for VectorIndexer Key: FLINK-28501 URL: https://issues.apache.org/jira/browse/FLINK-28501 Project: Flink Issue

[jira] [Updated] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

2022-07-11 Thread lihe ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lihe ma updated FLINK-28499: Description: I found a job restarted for thousands of times, and jobmanager tried to create a new

[jira] [Updated] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

2022-07-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-28499: - Priority: Major (was: Minor) > resource leak when job failed with unknown status In Application Mode >

[jira] [Closed] (FLINK-28498) resource leak when job failed with unknown status In Application Mode

2022-07-11 Thread lihe ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lihe ma closed FLINK-28498. --- Resolution: Duplicate > resource leak when job failed with unknown status In Application Mode >

[jira] [Created] (FLINK-28500) Add Transformer for Tokenizer

2022-07-11 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28500: - Summary: Add Transformer for Tokenizer Key: FLINK-28500 URL: https://issues.apache.org/jira/browse/FLINK-28500 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-25545) [JUnit5 Migration] Module: flink-clients

2022-07-11 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565253#comment-17565253 ] Hang Ruan commented on FLINK-25545: --- [~RocMarshal] , thanks for your work. Please be free to take this

[jira] [Closed] (FLINK-28497) resource leak when job failed with unknown status In Application Mode

2022-07-11 Thread lihe ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lihe ma closed FLINK-28497. --- Resolution: Duplicate > resource leak when job failed with unknown status In Application Mode >

[jira] [Commented] (FLINK-25546) [JUnit5 Migration] Module: flink-connector-base

2022-07-11 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565252#comment-17565252 ] Hang Ruan commented on FLINK-25546: --- [~Sergey Nuyanzin] , Thanks for your work. [~renqs], could you

[jira] [Commented] (FLINK-28178) Show the delegated StateBackend and whether changelog is enabled in the UI

2022-07-11 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565251#comment-17565251 ] Feifan Wang commented on FLINK-28178: - Thanks [~yunta] , I got it. > Show the delegated

[GitHub] [flink] xintongsong commented on a diff in pull request #20100: [FLINK-27905][runtime] Introduce HsSpillingStrategy and HsSelectiveSpillingStrategy implementation

2022-07-11 Thread GitBox
xintongsong commented on code in PR #20100: URL: https://github.com/apache/flink/pull/20100#discussion_r918520765 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSpillingInfoProvider.java: ## @@ -0,0 +1,56 @@ +/* + * Licensed to the Apache

[GitHub] [flink] ruanhang1993 closed pull request #18113: [FLINK-25315][tests] add new extensions and utils to help the Junit5 migration

2022-07-11 Thread GitBox
ruanhang1993 closed pull request #18113: [FLINK-25315][tests] add new extensions and utils to help the Junit5 migration URL: https://github.com/apache/flink/pull/18113 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] ruanhang1993 commented on pull request #18113: [FLINK-25315][tests] add new extensions and utils to help the Junit5 migration

2022-07-11 Thread GitBox
ruanhang1993 commented on PR #18113: URL: https://github.com/apache/flink/pull/18113#issuecomment-1181282045 Closed by https://github.com/apache/flink/pull/20145 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] ruanhang1993 commented on pull request #18113: [FLINK-25315][tests] add new extensions and utils to help the Junit5 migration

2022-07-11 Thread GitBox
ruanhang1993 commented on PR #18113: URL: https://github.com/apache/flink/pull/18113#issuecomment-1181281616 Closed by #20145 -- 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

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #209: [FLINK-27103] Don't store redundant primary key fields

2022-07-11 Thread GitBox
JingsongLi commented on code in PR #209: URL: https://github.com/apache/flink-table-store/pull/209#discussion_r918515556 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/KeyValueSerializer.java: ## @@ -45,6 +49,13 @@ public class KeyValueSerializer

[jira] [Commented] (FLINK-28178) Show the delegated StateBackend and whether changelog is enabled in the UI

2022-07-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565246#comment-17565246 ] Yun Tang commented on FLINK-28178: -- [~Feifan Wang] sure, you can ping me on the github directly. >

[GitHub] [flink-web] lindong28 merged pull request #559: Rebuild website

2022-07-11 Thread GitBox
lindong28 merged PR #559: URL: https://github.com/apache/flink-web/pull/559 -- 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-web] lindong28 commented on pull request #559: Rebuild website

2022-07-11 Thread GitBox
lindong28 commented on PR #559: URL: https://github.com/apache/flink-web/pull/559#issuecomment-1181272522 LGTM. -- 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

[jira] [Created] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

2022-07-11 Thread lihe ma (Jira)
lihe ma created FLINK-28499: --- Summary: resource leak when job failed with unknown status In Application Mode Key: FLINK-28499 URL: https://issues.apache.org/jira/browse/FLINK-28499 Project: Flink

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #208: [FLINK-28483] Basic schema evolution for table store

2022-07-11 Thread GitBox
LadyForest commented on code in PR #208: URL: https://github.com/apache/flink-table-store/pull/208#discussion_r918514001 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaChange.java: ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-28498) resource leak when job failed with unknown status In Application Mode

2022-07-11 Thread lihe ma (Jira)
lihe ma created FLINK-28498: --- Summary: resource leak when job failed with unknown status In Application Mode Key: FLINK-28498 URL: https://issues.apache.org/jira/browse/FLINK-28498 Project: Flink

[jira] [Created] (FLINK-28497) resource leak when job failed with unknown status In Application Mode

2022-07-11 Thread lihe ma (Jira)
lihe ma created FLINK-28497: --- Summary: resource leak when job failed with unknown status In Application Mode Key: FLINK-28497 URL: https://issues.apache.org/jira/browse/FLINK-28497 Project: Flink

[GitHub] [flink-web] zhipeng93 opened a new pull request, #559: Rebuild website

2022-07-11 Thread GitBox
zhipeng93 opened a new pull request, #559: URL: https://github.com/apache/flink-web/pull/559 This is a hotfix of https://github.com/apache/flink-web/pull/558. In https://github.com/apache/flink-web/pull/558, some auto generated files are missing. -- This is an automated

[GitHub] [flink] Tartarus0zm commented on pull request #20223: [FLINK-28457][runtime] Introduce JobStatusHook

2022-07-11 Thread GitBox
Tartarus0zm commented on PR #20223: URL: https://github.com/apache/flink/pull/20223#issuecomment-1181267795 @lsyldliu @reswqa thanks for your review. I have addressed the comments left. Please take a look again. cc @gaoyunhaii -- This is an automated message from the Apache

[GitHub] [flink-web] lindong28 merged pull request #558: Release Flink ML 2.1.0

2022-07-11 Thread GitBox
lindong28 merged PR #558: URL: https://github.com/apache/flink-web/pull/558 -- 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-web] lindong28 commented on pull request #558: Release Flink ML 2.1.0

2022-07-11 Thread GitBox
lindong28 commented on PR #558: URL: https://github.com/apache/flink-web/pull/558#issuecomment-1181263032 Thank you for the fix. -- 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

[jira] [Updated] (FLINK-27103) Don't store redundant primary key fields

2022-07-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27103: --- Labels: pull-request-available (was: ) > Don't store redundant primary key fields >

[GitHub] [flink-table-store] SteNicholas opened a new pull request, #209: [FLINK-27103] Don't store redundant primary key fields

2022-07-11 Thread GitBox
SteNicholas opened a new pull request, #209: URL: https://github.com/apache/flink-table-store/pull/209 `ChangelogWithKeyFileStoreTable` currently stores the primary key redundantly in the file, which could directly use the primary key field in the original fields to avoid redundant

[GitHub] [flink] Tartarus0zm commented on a diff in pull request #20223: [FLINK-28457][runtime] Introduce JobStatusHook

2022-07-11 Thread GitBox
Tartarus0zm commented on code in PR #20223: URL: https://github.com/apache/flink/pull/20223#discussion_r918502121 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java: ## @@ -1544,6 +1552,30 @@ private void

[GitHub] [flink] Tartarus0zm commented on a diff in pull request #20223: [FLINK-28457][runtime] Introduce JobStatusHook

2022-07-11 Thread GitBox
Tartarus0zm commented on code in PR #20223: URL: https://github.com/apache/flink/pull/20223#discussion_r918501911 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java: ## @@ -1544,6 +1552,30 @@ private void

[GitHub] [flink] liuzhuang2017 commented on pull request #20208: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-07-11 Thread GitBox
liuzhuang2017 commented on PR #20208: URL: https://github.com/apache/flink/pull/20208#issuecomment-1181253936 @MartijnVisser , Sorry to bother you again, can you help me review this pr? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] liuzhuang2017 commented on pull request #20210: [FLINK-27205][docs-zh] Translate "Concepts -> Glossary" page into Chinese.

2022-07-11 Thread GitBox
liuzhuang2017 commented on PR #20210: URL: https://github.com/apache/flink/pull/20210#issuecomment-1181253412 @MartijnVisser , Sorry to bother you again, can you help me review this pr? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] liuzhuang2017 commented on pull request #20226: Fix Chinese document format errors.

2022-07-11 Thread GitBox
liuzhuang2017 commented on PR #20226: URL: https://github.com/apache/flink/pull/20226#issuecomment-1181253038 @MartijnVisser , Sorry to bother you again, can you help me review this pr? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-28178) Show the delegated StateBackend and whether changelog is enabled in the UI

2022-07-11 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565228#comment-17565228 ] Feifan Wang commented on FLINK-28178: - Hi [~yunta] , can you help me review the

[GitHub] [flink] swuferhong commented on pull request #20007: [FLINK-27989][table-planner] Csv format supports reporting statistics

2022-07-11 Thread GitBox
swuferhong commented on PR #20007: URL: https://github.com/apache/flink/pull/20007#issuecomment-1181245110 @godfreyhe CI passed, could you help me to merge it ! Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] Myasuka commented on pull request #19701: [FLINK-24786][state] Introduce and expose RocksDB statistics as metrics

2022-07-11 Thread GitBox
Myasuka commented on PR #19701: URL: https://github.com/apache/flink/pull/19701#issuecomment-1181241854 @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] luoyuxia commented on a diff in pull request #20227: [FLINK-28471]Translate hive_read_write.md into Chinese

2022-07-11 Thread GitBox
luoyuxia commented on code in PR #20227: URL: https://github.com/apache/flink/pull/20227#discussion_r918482407 ## docs/content.zh/docs/connectors/table/hive/hive_read_write.md: ## @@ -25,74 +25,63 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink-connector-elasticsearch] deadwind4 commented on pull request #24: [FLINK-18887][connectors/elasticsearch][docs][docs-zh] Add doc of Elasticsearch connector for Python DataStream API

2022-07-11 Thread GitBox
deadwind4 commented on PR #24: URL: https://github.com/apache/flink-connector-elasticsearch/pull/24#issuecomment-1181235582 @dianfu Please review it. -- 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

[GitHub] [flink] leozhangsr commented on pull request #20234: [FLINK-28475] [Connector/kafka] Stopping offset can be 0

2022-07-11 Thread GitBox
leozhangsr commented on PR #20234: URL: https://github.com/apache/flink/pull/20234#issuecomment-1181224833 > @leozhangsr Can you add a test for this situation? ok, I will add a test later -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

2022-07-11 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565208#comment-17565208 ] Yao Zhang commented on FLINK-27579: --- Hi [~wangyang0918] , Thank you very much for your suggestions

[jira] [Updated] (FLINK-26256) AWS SDK Async Event Loop Group Classloader Issue

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

[jira] [Assigned] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

2022-07-11 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov reassigned FLINK-27142: - Assignee: Alexander Fedulov (was: Alexander Preuss) > Remove bash tests

[GitHub] [flink] RyanSkraba commented on pull request #20230: [FLINK-28449][tests][JUnit5 migration] flink-parquet

2022-07-11 Thread GitBox
RyanSkraba commented on PR #20230: URL: https://github.com/apache/flink/pull/20230#issuecomment-1180875380 @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

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19679: [FLINK-23143][state/changelog] Support state migration for ChangelogS…

2022-07-11 Thread GitBox
rkhachatryan commented on code in PR #19679: URL: https://github.com/apache/flink/pull/19679#discussion_r918295754 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java: ## @@ -163,6 +170,32 @@ KeyGroupedInternalPriorityQueue create(

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
gyfora commented on PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#issuecomment-1180808724 cc @tweise @wangyang0918 -- 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-kubernetes-operator] morhidi commented on pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
morhidi commented on PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#issuecomment-1180789758 > > What is `FlinkDeployment.Lifecycle.State.STATE_NAME.Count: 0` ? > > @morhidi `STATE_NAME` is a placeholder in this example. In practice it's gonna be one of

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
gyfora commented on PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#issuecomment-1180786814 > What is `FlinkDeployment.Lifecycle.State.STATE_NAME.Count: 0` ? @morhidi `STATE_NAME` is a placeholder in this example. In practice it's gonna be one of CREATED,

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
gyfora commented on code in PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r918283173 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/ResourceLifecycleMetricsTest.java: ## @@ -0,0 +1,150

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
morhidi commented on PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#issuecomment-1180785668 I love this PR @gyfora added some minor comments -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
gyfora commented on code in PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r918282383 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/LifecycleMetrics.java: ## @@ -0,0 +1,205 @@ +/* + *

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
morhidi commented on code in PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r91828 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/ResourceLifecycleMetricsTest.java: ## @@ -0,0 +1,150

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
gyfora commented on code in PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r918282131 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/MetricManager.java: ## @@ -18,31 +18,37 @@ package

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
morhidi commented on code in PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r918277417 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/LifecycleMetrics.java: ## @@ -0,0 +1,205 @@ +/* + *

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
morhidi commented on code in PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r918274673 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/LifecycleMetrics.java: ## @@ -0,0 +1,205 @@ +/* + *

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
morhidi commented on code in PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#discussion_r918272226 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/MetricManager.java: ## @@ -18,31 +18,37 @@ package

[jira] [Created] (FLINK-28496) Expose label selector support in k8s operator

2022-07-11 Thread Jira
Márton Balassi created FLINK-28496: -- Summary: Expose label selector support in k8s operator Key: FLINK-28496 URL: https://issues.apache.org/jira/browse/FLINK-28496 Project: Flink Issue

[jira] [Assigned] (FLINK-28496) Expose label selector support in k8s operator

2022-07-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-28496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-28496: -- Assignee: Márton Balassi > Expose label selector support in k8s operator >

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
morhidi commented on PR #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311#issuecomment-1180771363 What is `FlinkDeployment.Lifecycle.State.STATE_NAME.Count: 0` ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-28479) Add latency histogram for resource state transitions

2022-07-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28479: --- Labels: pull-request-available (was: ) > Add latency histogram for resource state

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #311: [FLINK-28479] Add metrics for resource lifecycle state transitions

2022-07-11 Thread GitBox
gyfora opened a new pull request, #311: URL: https://github.com/apache/flink-kubernetes-operator/pull/311 ## What is the purpose of the change Introduce histogram metrics for tracking how long resource lifecycle state transitions take between the following states: - CREATED

[jira] [Updated] (FLINK-28476) Add metrics for Kubernetes API server access

2022-07-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28476: --- Labels: pull-request-available (was: ) > Add metrics for Kubernetes API server access >

[GitHub] [flink-kubernetes-operator] morhidi opened a new pull request, #310: [FLINK-28476] Add metrics for Kubernetes API server access

2022-07-11 Thread GitBox
morhidi opened a new pull request, #310: URL: https://github.com/apache/flink-kubernetes-operator/pull/310 ## What is the purpose of the change This pull request adds metrics and KPIs related to Kubernetes API server access. Metrics can be enabled by

[jira] [Updated] (FLINK-28472) Add JmStatus as a group for JobManagerDeploymentStatus count metrics

2022-07-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28472: --- Labels: pull-request-available (was: ) > Add JmStatus as a group for

[GitHub] [flink-kubernetes-operator] morhidi opened a new pull request, #309: [FLINK-28472] Add JMDeploymentStatus as a group for JobManagerDeploymentStatuscount metrics

2022-07-11 Thread GitBox
morhidi opened a new pull request, #309: URL: https://github.com/apache/flink-kubernetes-operator/pull/309 ## What is the purpose of the change Add JMDeploymentStatus as a group for JobManagerDeploymentStatuscount metrics. ## Brief change log Before: ```

[GitHub] [flink-docker] alpinegizmo opened a new pull request, #124: [readme] explicitly mention that the full GPG fingerprint is required

2022-07-11 Thread GitBox
alpinegizmo opened a new pull request, #124: URL: https://github.com/apache/flink-docker/pull/124 My pull request against official-images wasn't accepted until I updated it to refer to commits in this repo that build images that use the full GPG fingerprint of my signing key. This

[jira] [Updated] (FLINK-26621) ChangelogPeriodicMaterializationITCase crashes JVM on CI in RocksDB cleanup

2022-07-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26621: - Issue Type: Technical Debt (was: Bug) > ChangelogPeriodicMaterializationITCase crashes

[jira] [Closed] (FLINK-26621) ChangelogPeriodicMaterializationITCase crashes JVM on CI in RocksDB cleanup

2022-07-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-26621. Resolution: Fixed > ChangelogPeriodicMaterializationITCase crashes JVM on CI in RocksDB

[jira] [Comment Edited] (FLINK-26621) ChangelogPeriodicMaterializationITCase crashes JVM on CI in RocksDB cleanup

2022-07-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565119#comment-17565119 ] Chesnay Schepler edited comment on FLINK-26621 at 7/11/22 5:45 PM: ---

[jira] [Commented] (FLINK-26621) ChangelogPeriodicMaterializationITCase crashes JVM on CI in RocksDB cleanup

2022-07-11 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565119#comment-17565119 ] Chesnay Schepler commented on FLINK-26621: -- master: c1d0c8fac16988c22f4ce4781e4a92a1de4b61fc >

[GitHub] [flink] flinkbot commented on pull request #20245: [FLINK-28487][connectors] Introduce configurable RateLimitingStrategy…

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

[GitHub] [flink] zentol merged pull request #20240: [FLINK-26621][tests] Close delegate keyed state backend

2022-07-11 Thread GitBox
zentol merged PR #20240: URL: https://github.com/apache/flink/pull/20240 -- 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 #20244: [FLINK-28487][connectors] Introduce configurable RateLimitingStrategy…

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

[GitHub] [flink] hlteoh37 opened a new pull request, #20245: [FLINK-28487][connectors] Introduce configurable RateLimitingStrategy…

2022-07-11 Thread GitBox
hlteoh37 opened a new pull request, #20245: URL: https://github.com/apache/flink/pull/20245 … for AsyncSinkWriter ## What is the purpose of the change This pull request makes the RateLimitingStrategy used in AsyncSinkWriter configurable by the sink implementer. That way a sink

[GitHub] [flink] hlteoh37 closed pull request #20244: [FLINK-28487][connectors] Introduce configurable RateLimitingStrategy…

2022-07-11 Thread GitBox
hlteoh37 closed pull request #20244: [FLINK-28487][connectors] Introduce configurable RateLimitingStrategy… URL: https://github.com/apache/flink/pull/20244 -- 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

[jira] [Updated] (FLINK-28487) Introduce configurable RateLimitingStrategy for Async Sink

2022-07-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28487: --- Labels: pull-request-available (was: ) > Introduce configurable RateLimitingStrategy for

[GitHub] [flink] hlteoh37 opened a new pull request, #20244: [FLINK-28487][connectors] Introduce configurable RateLimitingStrategy…

2022-07-11 Thread GitBox
hlteoh37 opened a new pull request, #20244: URL: https://github.com/apache/flink/pull/20244 … for AsyncSinkWriter ## What is the purpose of the change This pull request makes the RateLimitingStrategy used in AsyncSinkWriter configurable by the sink implementer. That way a sink

[GitHub] [flink] reswqa commented on a diff in pull request #20100: [FLINK-27905][runtime] Introduce HsSpillingStrategy and HsSelectiveSpillingStrategy implementation

2022-07-11 Thread GitBox
reswqa commented on code in PR #20100: URL: https://github.com/apache/flink/pull/20100#discussion_r918178186 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSelectiveSpillingStrategy.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache

[jira] [Closed] (FLINK-28402) Create FailureHandlingResultSnapshot with the truly failed execution

2022-07-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28402. --- Resolution: Done Done via edd10a1d8fd09f8a5e296ecdf0201945d77d5ff2 > Create FailureHandlingResultSnapshot

[GitHub] [flink] zhuzhurk closed pull request #20221: [FLINK-28402] Create FailureHandlingResultSnapshot with the truly failed execution

2022-07-11 Thread GitBox
zhuzhurk closed pull request #20221: [FLINK-28402] Create FailureHandlingResultSnapshot with the truly failed execution URL: https://github.com/apache/flink/pull/20221 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] zhuzhurk commented on pull request #20221: [FLINK-28402] Create FailureHandlingResultSnapshot with the truly failed execution

2022-07-11 Thread GitBox
zhuzhurk commented on PR #20221: URL: https://github.com/apache/flink/pull/20221#issuecomment-1180611626 Thanks for reviewing! @wanglijie95 Merging. -- 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

[GitHub] [flink] reswqa commented on a diff in pull request #20229: [FLINK-28399] Refactor CheckedThread to accept runnable via constructor

2022-07-11 Thread GitBox
reswqa commented on code in PR #20229: URL: https://github.com/apache/flink/pull/20229#discussion_r918116847 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/CheckedThread.java: ## @@ -18,26 +18,42 @@ package

[jira] [Updated] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

2022-07-11 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-28495: -- Description: 1. "how you can migrate your job from an older Flink version to Flink-1.3." -> "how you

[jira] [Updated] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

2022-07-11 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-28495: -- Description: 1. "how you can migrate your job from an older Flink version to Flink-1.3." -> "how you

[jira] [Updated] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

2022-07-11 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-28495: -- Description: "how you can migrate your job from an older Flink version to Flink-1.3." -> "how you

[jira] [Closed] (FLINK-28144) Let JobMaster support blocklist mechanism

2022-07-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28144. --- Fix Version/s: 1.16.0 Resolution: Done Done via: f2f83e1956eccecaa2371b21bddaf7778bb4f819

[jira] [Updated] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

2022-07-11 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-28495: -- Component/s: Library / CEP > Fix typos or mistakes of Flink CEP Document in the official website >

[GitHub] [flink] reswqa commented on a diff in pull request #20229: [FLINK-28399] Refactor CheckedThread to accept runnable via constructor

2022-07-11 Thread GitBox
reswqa commented on code in PR #20229: URL: https://github.com/apache/flink/pull/20229#discussion_r918081449 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/CheckedThread.java: ## @@ -18,26 +18,42 @@ package

[jira] [Created] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

2022-07-11 Thread Biao Geng (Jira)
Biao Geng created FLINK-28495: - Summary: Fix typos or mistakes of Flink CEP Document in the official website Key: FLINK-28495 URL: https://issues.apache.org/jira/browse/FLINK-28495 Project: Flink

[GitHub] [flink] reswqa commented on a diff in pull request #20229: [FLINK-28399] Refactor CheckedThread to accept runnable via constructor

2022-07-11 Thread GitBox
reswqa commented on code in PR #20229: URL: https://github.com/apache/flink/pull/20229#discussion_r918081449 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/CheckedThread.java: ## @@ -18,26 +18,42 @@ package

[GitHub] [flink] reswqa commented on a diff in pull request #20229: [FLINK-28399] Refactor CheckedThread to accept runnable via constructor

2022-07-11 Thread GitBox
reswqa commented on code in PR #20229: URL: https://github.com/apache/flink/pull/20229#discussion_r918081449 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/CheckedThread.java: ## @@ -18,26 +18,42 @@ package

[GitHub] [flink] zhuzhurk closed pull request #20153: [FLINK-28144][runtime] Let JobMaster support blocklist.

2022-07-11 Thread GitBox
zhuzhurk closed pull request #20153: [FLINK-28144][runtime] Let JobMaster support blocklist. URL: https://github.com/apache/flink/pull/20153 -- 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

[GitHub] [flink] zhuzhurk commented on pull request #20221: [FLINK-28402] Create FailureHandlingResultSnapshot with the truly failed execution

2022-07-11 Thread GitBox
zhuzhurk commented on PR #20221: URL: https://github.com/apache/flink/pull/20221#issuecomment-1180561038 @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.

  1   2   3   4   >