LadyForest commented on code in PR #208:
URL: https://github.com/apache/flink-table-store/pull/208#discussion_r918611551
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/FlinkCatalog.java:
##
@@ -178,40 +206,75 @@ public void createTable(Object
[
https://issues.apache.org/jira/browse/FLINK-24901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-24901:
Fix Version/s: 1.17.0
(was: 1.16.0)
> Some further improvements of the plug
LadyForest commented on code in PR #208:
URL: https://github.com/apache/flink-table-store/pull/208#discussion_r918611551
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/FlinkCatalog.java:
##
@@ -178,40 +206,75 @@ public void createTable(Object
Biao Geng created FLINK-28503:
-
Summary: Fix invalid link in Python FAQ Document
Key: FLINK-28503
URL: https://issues.apache.org/jira/browse/FLINK-28503
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-27905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27905:
---
Summary: Introduce HsSpillingStrategy and Implement
SelectiveSpillingStrategy、FullSpillingStrategy
[
https://issues.apache.org/jira/browse/FLINK-28483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28483:
-
Parent: FLINK-27365
Issue Type: Sub-task (was: New Feature)
> Basic schema evolution fo
[
https://issues.apache.org/jira/browse/FLINK-27904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27904:
---
Summary: Introduce HsMemoryDataManager (was: Introduce HsDataBuffer)
> Introduce HsMemoryDataManage
[
https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565310#comment-17565310
]
Martijn Visser commented on FLINK-28499:
[~frozen stone] Without logs and withou
reswqa commented on code in PR #20100:
URL: https://github.com/apache/flink/pull/20100#discussion_r918596608
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSelectiveSpillingStrategy.java:
##
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27399:
---
Fix Version/s: 1.16.0
> Pulsar connector didn't set start consuming position correctly
> ---
[
https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27399:
---
Priority: Blocker (was: Critical)
> Pulsar connector didn't set start consuming position co
[
https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-27399:
---
Priority: Critical (was: Major)
> Pulsar connector didn't set start consuming position corr
[
https://issues.apache.org/jira/browse/FLINK-28482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565308#comment-17565308
]
Jingsong Lee commented on FLINK-28482:
--
Maybe we should introduce a compaction.max-
reswqa commented on code in PR #20100:
URL: https://github.com/apache/flink/pull/20100#discussion_r918600252
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HybridShuffleConfiguration.java:
##
@@ -74,4 +88,82 @@ public int getMaxBuffersReadAhe
[
https://issues.apache.org/jira/browse/FLINK-28176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reopened FLINK-28176:
Re-opened, a new failed run:
https://dev.azure.com/apache-flink/apache-flink/_build/results?b
[
https://issues.apache.org/jira/browse/FLINK-26456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565306#comment-17565306
]
Martijn Visser commented on FLINK-26456:
https://dev.azure.com/apache-flink/apac
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565304#comment-17565304
]
Martijn Visser commented on FLINK-28440:
https://dev.azure.com/apache-flink/apac
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28440:
---
Priority: Critical (was: Major)
> EventTimeWindowCheckpointingITCase.testSlidingTimeWindow
[
https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565302#comment-17565302
]
Martijn Visser commented on FLINK-25813:
https://dev.azure.com/apache-flink/apac
[
https://issues.apache.org/jira/browse/FLINK-28267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565300#comment-17565300
]
Martijn Visser commented on FLINK-28267:
https://dev.azure.com/apache-flink/apac
reswqa commented on code in PR #20100:
URL: https://github.com/apache/flink/pull/20100#discussion_r918596608
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSelectiveSpillingStrategy.java:
##
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache
luoyuxia commented on PR #20130:
URL: https://github.com/apache/flink/pull/20130#issuecomment-1181370132
@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.
masteryhx commented on code in PR #19679:
URL: https://github.com/apache/flink/pull/19679#discussion_r918587896
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java:
##
@@ -163,6 +170,32 @@ KeyGroupedInternalPriorityQueue create(
flinkbot commented on PR #20247:
URL: https://github.com/apache/flink/pull/20247#issuecomment-1181361644
## CI report:
* b91d6b86f094c1d0e4debdaafbd74e1df056d3d8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa commented on code in PR #20100:
URL: https://github.com/apache/flink/pull/20100#discussion_r918587520
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSpillingInfoProvider.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Softwa
luoyuxia opened a new pull request, #20247:
URL: https://github.com/apache/flink/pull/20247
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them o
[
https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565282#comment-17565282
]
Jark Wu commented on FLINK-27142:
-
Hi [~twalthr], I also don't understand the two major
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`
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 a
[
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
> --
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
rowCount、
[
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
> -
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: issues-unsubscr...@flink.apach
[
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
>
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 comment
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
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 Type:
[
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 taskman
[
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
>
[
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
>
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
[
https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565253#comment-17565253
]
Hang Ruan commented on FLINK-25545:
---
[~RocMarshal] , thanks for your work. Please be f
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-25546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565252#comment-17565252
]
Hang Ruan commented on FLINK-25546:
---
[~Sergey Nuyanzin] , Thanks for your work.
[~ren
[
https://issues.apache.org/jira/browse/FLINK-28178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565251#comment-17565251
]
Feifan Wang commented on FLINK-28178:
-
Thanks [~yunta] , I got it.
> Show the deleg
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 S
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
U
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
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 comment.
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 exten
[
https://issues.apache.org/jira/browse/FLINK-28178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565246#comment-17565246
]
Yun Tang commented on FLINK-28178:
--
[~Feifan Wang] sure, you can ping me on the github
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: issues-unsubscr...@flink.apa
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 unsubscri
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
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 Softwa
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
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
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 message
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 Gi
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: issues-unsubscr...@flink.apa
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 comme
[
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
> ---
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 storage.
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 notifyJobStatusChange(JobSt
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 notifyJobStatusChange(JobSt
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, plea
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, plea
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, plea
[
https://issues.apache.org/jira/browse/FLINK-28178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565228#comment-17565228
]
Feifan Wang commented on FLINK-28178:
-
Hi [~yunta] , can you help me review the
[pr
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
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.
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.
--
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 go
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
[
https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565208#comment-17565208
]
Yao Zhang commented on FLINK-27579:
---
Hi [~wangyang0918] ,
Thank you very much for you
[
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 [Flink
[
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 depend
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 com
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(
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 t
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 CRE
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, U
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 @@
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
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 @@
+/*
+ * Lic
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 @
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 org.apache.fl
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 @@
+/*
+ * Li
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 @@
+/*
+ * Li
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 org.apache.f
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 Type:
[
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
> --
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
[
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 transitio
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
[
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
> ---
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
`kubernetes.operator.kubernetes.c
[
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 JobManagerDeploymentSt
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:
```
localhost
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 P
1 - 100 of 339 matches
Mail list logo
