[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Affects Version/s: 2.0-preview
> document of python elasticsearch connector exeample has a mis
reswqa opened a new pull request, #210:
URL: https://github.com/apache/flink-docker/pull/210
(no comment)
--
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-
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Affects Version/s: (was: 1.17.0)
(was: 1.18.0)
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Description:
There is no method named "ElasticsearchEmitter.static", it should be
"Elasticsea
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Description:
"ElasticsearchEmitter" has no method named "ElasticsearchEmitter.static", it
sho
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Description:
"ElasticsearchEmitter" has no method named "static", it should be
"static_index"
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhang Hechuan updated FLINK-37265:
--
Description:
"ElasticsearchEmitter" has not method named "static", it should be
"static_index
Zhang Hechuan created FLINK-37265:
-
Summary: document of python elasticsearch connector exeample has a
mistake
Key: FLINK-37265
URL: https://issues.apache.org/jira/browse/FLINK-37265
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-37205.
---
Fix Version/s: 2.0.0
1.19.2
1.20.2
Resolution: Fixed
Fixed in:
dianfu merged PR #26060:
URL: https://github.com/apache/flink/pull/26060
--
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.apache
dianfu merged PR #26059:
URL: https://github.com/apache/flink/pull/26059
--
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.apache
dianfu merged PR #26058:
URL: https://github.com/apache/flink/pull/26058
--
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.apache
flinkbot commented on PR #26112:
URL: https://github.com/apache/flink/pull/26112#issuecomment-2639023195
## CI report:
* e0f529506e5225fce4b103fcb81eabc903ebea4f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37264:
---
Labels: pull-request-available (was: )
> two bugs of DSv2
>
>
>
codenohup opened a new pull request, #26112:
URL: https://github.com/apache/flink/pull/26112
## What is the purpose of the change
Fix two bugs of DataStream V2:
1. When joining two tuple DataStreams using JoinExtension, an exception is
thrown "Tuple needs to be parameterized by usi
lsyldliu commented on code in PR #26064:
URL: https://github.com/apache/flink/pull/26064#discussion_r1944182747
##
docs/content.zh/docs/dev/table/materialized-table/statements.md:
##
@@ -326,6 +328,67 @@ ALTER MATERIALIZED TABLE my_materialized_table REFRESH
PARTITION (ds='2024
yuxiqian commented on PR #3911:
URL: https://github.com/apache/flink-cdc/pull/3911#issuecomment-2638961294
Would @leonardBang and @whhe like to take a look?
--
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
xuhuang created FLINK-37264:
---
Summary: two bugs of DSv2
Key: FLINK-37264
URL: https://issues.apache.org/jira/browse/FLINK-37264
Project: Flink
Issue Type: New Feature
Components: API / Da
[
https://issues.apache.org/jira/browse/FLINK-37234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37234.
Resolution: Fixed
Fixed via master(3.3-SNAPSHOT): 81e6a4a329498ddd9ff63d9db8ddbcf22882a7fc
> Add
leonardBang merged PR #154:
URL: https://github.com/apache/flink-connector-jdbc/pull/154
--
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
[
https://issues.apache.org/jira/browse/FLINK-37234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37234:
--
Assignee: Yanquan Lv
> Add timeout for test case to avoid Infinite waiting
> ---
[
https://issues.apache.org/jira/browse/FLINK-37234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37234:
---
Labels: pull-request-available (was: )
> Add timeout for test case to avoid Infinite waitin
boring-cyborg[bot] commented on PR #154:
URL:
https://github.com/apache/flink-connector-jdbc/pull/154#issuecomment-2638952636
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
whhe closed pull request #3909: [hotfix][ci] Use raise to fix uncaught throw
URL: https://github.com/apache/flink-cdc/pull/3909
--
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.
yuxiqian commented on PR #3884:
URL: https://github.com/apache/flink-cdc/pull/3884#issuecomment-2638951176
Closed in favor of #3911.
--
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 c
yuxiqian closed pull request #3884: [tests][ci] Miscellaneous improvements on
CI robustness
URL: https://github.com/apache/flink-cdc/pull/3884
--
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 spe
yuxiqian opened a new pull request, #3911:
URL: https://github.com/apache/flink-cdc/pull/3911
This PR mainly focuses on improving test case effectiveness by:
* Single-stage CI failure should not cause the whole matrix got cancelled
* Removed vulnerable & unmaintained FastJson from t
Weijie Guo created FLINK-37263:
--
Summary: AggregateITCase.testConstantGroupKeyWithUpsertSink failed
Key: FLINK-37263
URL: https://issues.apache.org/jira/browse/FLINK-37263
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924371#comment-17924371
]
Weijie Guo commented on FLINK-33555:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-37262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37262:
---
Labels: pull-request-available (was: )
> MySQL CDC connector could not configure the
> `sc
yuxiqian opened a new pull request, #3910:
URL: https://github.com/apache/flink-cdc/pull/3910
This closes FLINK-37262 by adding `PARSE_ONLINE_SCHEMA_CHANGES` into
optional configs list.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
[
https://issues.apache.org/jira/browse/FLINK-37231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37231.
Resolution: Fixed
via master: 7717779ebff3d5900c3adcd06bc860949d543f97
> Add doc for newly added
leonardBang merged PR #3897:
URL: https://github.com/apache/flink-cdc/pull/3897
--
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
[
https://issues.apache.org/jira/browse/FLINK-37231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37231:
--
Assignee: Yanquan Lv
> Add doc for newly added source metric statistics
> ---
leonardBang commented on code in PR #155:
URL:
https://github.com/apache/flink-connector-jdbc/pull/155#discussion_r1944150943
##
flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/dialect/PostgresDialect.java:
##
@@ -73,8 +74,10 @@ pub
[
https://issues.apache.org/jira/browse/FLINK-37262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924366#comment-17924366
]
yux commented on FLINK-37262:
-
I'll prepare a fix for this ticket.
> MySQL CDC connector co
yux created FLINK-37262:
---
Summary: MySQL CDC connector could not configure the
`scan.parse.online.schema.changes.enabled` option
Key: FLINK-37262
URL: https://issues.apache.org/jira/browse/FLINK-37262
Project:
lincoln-lil merged PR #26110:
URL: https://github.com/apache/flink/pull/26110
--
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.a
whhe opened a new pull request, #3909:
URL: https://github.com/apache/flink-cdc/pull/3909
(no comment)
--
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-mai
[
https://issues.apache.org/jira/browse/FLINK-37251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37251:
--
Assignee: Yanquan Lv
> Add download link for pipeline connector.
> -
[
https://issues.apache.org/jira/browse/FLINK-37251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37251.
Resolution: Implemented
Implemented via master: 8d54be65c01a07c73b361a744b76cf51e4760027
> Add do
[
https://issues.apache.org/jira/browse/FLINK-37251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37251:
---
Labels: pull-request-available (was: )
> Add download link for pipeline connector.
> -
leonardBang merged PR #3900:
URL: https://github.com/apache/flink-cdc/pull/3900
--
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
[
https://issues.apache.org/jira/browse/FLINK-37218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924356#comment-17924356
]
Junrui Lee commented on FLINK-37218:
release-2.0:4e2bc4d05ffc2911c0347cc0c7ec306
JunRuiLee merged PR #26078:
URL: https://github.com/apache/flink/pull/26078
--
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
yuxiqian commented on PR #3902:
URL: https://github.com/apache/flink-cdc/pull/3902#issuecomment-2638736051
Seems `testBinlogOffsetCompareWithSnapshotAndBinlogPhase` is failing due to
this change. DataStream migration test is irrelevant, and should be fixed in
#3884.
--
This is an automat
yuxiqian commented on code in PR #3902:
URL: https://github.com/apache/flink-cdc/pull/3902#discussion_r1944038007
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java:
##
yuxiqian commented on code in PR #3902:
URL: https://github.com/apache/flink-cdc/pull/3902#discussion_r1944038007
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java:
##
lvyanquan commented on code in PR #3897:
URL: https://github.com/apache/flink-cdc/pull/3897#discussion_r1944036837
##
docs/content.zh/docs/connectors/pipeline-connectors/mysql.md:
##
@@ -343,6 +343,25 @@ source:
# ...
```
+### 可用的指标
+
+指标系统能够帮助了解分片分发的进展， 下面列举出了支持的 Flink 指标
[
https://issues.apache.org/jira/browse/FLINK-37163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu closed FLINK-37163.
--
Resolution: Fixed
> Add documents for recently merged PRs in FlinkCDC 3.3
> --
[
https://issues.apache.org/jira/browse/FLINK-35687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924353#comment-17924353
]
macdoor615 commented on FLINK-35687:
[~dwysakowicz] I applied this PR to branch rele
[
https://issues.apache.org/jira/browse/FLINK-35495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei closed FLINK-35495.
--
Resolution: Not A Problem
> The native metrics for column family are not reported
> --
lvyanquan commented on PR #3872:
URL: https://github.com/apache/flink-cdc/pull/3872#issuecomment-2638714059
closed by https://github.com/apache/flink-cdc/pull/3899.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
lvyanquan closed pull request #3872: [FLINK-37163] Add documents for recently
merged PRs in FlinkCDC 3.3.
URL: https://github.com/apache/flink-cdc/pull/3872
--
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
lsyldliu commented on code in PR #26073:
URL: https://github.com/apache/flink/pull/26073#discussion_r1944013609
##
docs/content.zh/docs/dev/table/materialized-table/deployment.md:
##
@@ -0,0 +1,220 @@
+---
+title: 部署
+weight: 3
+type: docs
+aliases:
+- /dev/table/materialized-ta
leonardBang commented on code in PR #3897:
URL: https://github.com/apache/flink-cdc/pull/3897#discussion_r1944021017
##
docs/content.zh/docs/connectors/pipeline-connectors/mysql.md:
##
@@ -343,6 +343,25 @@ source:
# ...
```
+### 可用的指标
+
+指标系统能够帮助了解分片分发的进展， 下面列举出了支持的 Flink
[
https://issues.apache.org/jira/browse/FLINK-37231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37231:
---
Labels: pull-request-available (was: )
> Add doc for newly added source metric statistics
>
leonardBang commented on code in PR #3897:
URL: https://github.com/apache/flink-cdc/pull/3897#discussion_r1944020399
##
docs/content.zh/docs/connectors/pipeline-connectors/mysql.md:
##
@@ -343,6 +343,25 @@ source:
# ...
```
+### 可用的指标
+
+指标系统能够帮助了解分片分发的进展， 下面列举出了支持的 Flink
[
https://issues.apache.org/jira/browse/FLINK-37224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37224.
Resolution: Resolved
Resolved via master: 6aeb5e8c9fb2a59b46adc3bf2349a59e9deac2f7
> Add the miss
leonardBang merged PR #3895:
URL: https://github.com/apache/flink-cdc/pull/3895
--
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
[
https://issues.apache.org/jira/browse/FLINK-37224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37224:
--
Assignee: Yanquan Lv
> Add the missing content of MongoDB CDC to the Chinese document.
>
[
https://issues.apache.org/jira/browse/FLINK-37261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37261:
--
Description:
It is reasonable to expect some functions like `JSON_VALUE(numeric[, string])`,
JSON_EXI
ryanvanhuuksloot commented on PR #25888:
URL: https://github.com/apache/flink/pull/25888#issuecomment-2638686440
@davidradl Do you know any committer we could get to merge this? We'd love
it to be merged in 2.0
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-37252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37252.
Resolution: Fixed
Fixed via master: 1fa762dd632dfa8cf52bbe491e2e42ce44860e38
> Align Chinese docu
leonardBang merged PR #3903:
URL: https://github.com/apache/flink-cdc/pull/3903
--
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
[
https://issues.apache.org/jira/browse/FLINK-37252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37252:
--
Assignee: Yanquan Lv
> Align Chinese document of Postgres CDC Connector with English document
[
https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-34729.
Resolution: Resolved
Resolved via master: d1d334d13a18a58b6997caaef35c764bc2ca13d6
> "Core Concep
[
https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34729:
---
Affects Version/s: cdc-3.3.0
> "Core Concept" Pages for Flink CDC Chinese Documentation
> --
[
https://issues.apache.org/jira/browse/FLINK-34729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34729:
---
Fix Version/s: cdc-3.4.0
> "Core Concept" Pages for Flink CDC Chinese Documentation
> --
leonardBang merged PR #3901:
URL: https://github.com/apache/flink-cdc/pull/3901
--
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
leonardBang commented on PR #3872:
URL: https://github.com/apache/flink-cdc/pull/3872#issuecomment-2638658606
A rebase action is required @lvyanquan
--
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
JunboWang created FLINK-37261:
-
Summary: Provide JSON series functions in YAML pipeline
Key: FLINK-37261
URL: https://issues.apache.org/jira/browse/FLINK-37261
Project: Flink
Issue Type: Improvem
lsyldliu commented on code in PR #26064:
URL: https://github.com/apache/flink/pull/26064#discussion_r1943961810
##
docs/content/docs/dev/table/materialized-table/statements.md:
##
@@ -326,6 +328,69 @@ ALTER MATERIALIZED TABLE my_materialized_table REFRESH
PARTITION (ds='2024-06
[
https://issues.apache.org/jira/browse/FLINK-37254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37254:
--
Assignee: He Wang
> Flink CDC OceanBase Connector Throws Exception for Column Default Value
Shawn-Hx opened a new pull request, #3908:
URL: https://github.com/apache/flink-cdc/pull/3908
License of some files need to be updated.
--
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 specifi
911432 created FLINK-37260:
--
Summary: Change MySQL Connector address
Key: FLINK-37260
URL: https://issues.apache.org/jira/browse/FLINK-37260
Project: Flink
Issue Type: Improvement
Componen
[
https://issues.apache.org/jira/browse/FLINK-37260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
911432 updated FLINK-37260:
---
Description:
I think " If “MySQL Connector Java” is 8.0.x, there won’t be any major problems.
[https://night
[
https://issues.apache.org/jira/browse/FLINK-37192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-37192.
---
Fix Version/s: 2.0.0
Release Note: (was: [pyflink] Replace deprecated avro-python3 with avro)
R
[
https://issues.apache.org/jira/browse/FLINK-37192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-37192:
Summary: Replace deprecated avro-python3 with avro (was: [pyflink] Replace
deprecated avro-python3 with a
[
https://issues.apache.org/jira/browse/FLINK-37192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-37192:
---
Assignee: Mina Asham
> [pyflink] Replace deprecated avro-python3 with avro
> --
dianfu closed pull request #26008: [FLINK-37192] [pyflink] Replace deprecated
avro-python3 with avro
URL: https://github.com/apache/flink/pull/26008
--
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
dianfu commented on PR #26008:
URL: https://github.com/apache/flink/pull/26008#issuecomment-2638415603
Merged to master via
https://github.com/apache/flink/commit/aef8c868545d70b743ee5cf29e17489f8a3bd848
--
This is an automated message from the Apache Git Service.
To respond to the messag
lincoln-lil commented on PR #26110:
URL: https://github.com/apache/flink/pull/26110#issuecomment-2638374908
> Please could we have a test case for this change.
@davidradl I did try to add a case(see #26108), but it doesn't actually
affect the optimization results(this is also the reas
lincoln-lil commented on PR #26110:
URL: https://github.com/apache/flink/pull/26110#issuecomment-2638376868
@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 commen
vahmed-hamdy commented on code in PR #26111:
URL: https://github.com/apache/flink/pull/26111#discussion_r1943418379
##
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java:
##
@@ -1225,7 +1257,16 @@ public void testOverridingJobVertexParallelisms()
mxm commented on PR #941:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/941#issuecomment-2637573408
Tried it out on a local k8s cluster with various Flink versions:
https://github.com/user-attachments/assets/f6909e9d-5710-4965-9645-55ce8b06fe82";
/>
https://github.
pnowojski commented on PR #26051:
URL: https://github.com/apache/flink/pull/26051#issuecomment-2637506032
@Zakelly / @xuyangzhong I'm struggling with some failures in tests.
`DeduplicateITCase#testFirstRowOnRowtime` fails for mini batch in a very weird
way.
```
[ERROR] Run 3: Dedup
davidradl commented on code in PR #26111:
URL: https://github.com/apache/flink/pull/26111#discussion_r1943263854
##
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java:
##
@@ -1225,7 +1257,16 @@ public void testOverridingJobVertexParallelisms() th
davidradl commented on code in PR #26111:
URL: https://github.com/apache/flink/pull/26111#discussion_r1943263854
##
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java:
##
@@ -1225,7 +1257,16 @@ public void testOverridingJobVertexParallelisms() th
XComp commented on PR #26095:
URL: https://github.com/apache/flink/pull/26095#issuecomment-2637380110
@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.
To
XComp commented on PR #26095:
URL: https://github.com/apache/flink/pull/26095#issuecomment-2637379727
Created FLINK-37259 to cover [CI
failure](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=65800)
--
This is an automated message from the Ap
Matthias Pohl created FLINK-37259:
-
Summary: StreamCheckpointingITCase times out
Key: FLINK-37259
URL: https://issues.apache.org/jira/browse/FLINK-37259
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-37258:
--
Fix Version/s: (was: 2.1.0)
> Order Flink Job list in Flink UI with start time
> -
[
https://issues.apache.org/jira/browse/FLINK-37242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-37242.
--
Assignee: thanh tung dao
Resolution: Fixed
merged to main 67aa78b1cc52acba4e73dc348d98196617464c
gyfora merged PR #939:
URL: https://github.com/apache/flink-kubernetes-operator/pull/939
--
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
vahmed-hamdy commented on code in PR #26111:
URL: https://github.com/apache/flink/pull/26111#discussion_r1943227152
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java:
##
@@ -878,8 +879,12 @@ public CompletableFuture
requestMultipleJobDetails(Dur
[
https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-37258:
--
Affects Version/s: 1.20.0
> Order Flink Job list in Flink UI with start time
> ---
gyfora commented on PR #926:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/926#issuecomment-2637293777
I am wondering if this is a good use of the metric system in Flink. We are
introducing an explosion of new metrics and we are using a large number of
gauges to represent E
[
https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-37258:
--
Affects Version/s: 2.0.0
> Order Flink Job list in Flink UI with start time
>
[
https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-37258:
-
Assignee: Ahmed Hamdy
> Order Flink Job list in Flink UI with start time
>
1 - 100 of 195 matches
Mail list logo
