masteryhx commented on code in PR #24781:
URL: https://github.com/apache/flink/pull/24781#discussion_r1599461043
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/MapStateDescriptor.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1599450119
##
flink-core/src/main/java/org/apache/flink/api/common/operators/SlotSharingGroup.java:
##
@@ -137,6 +137,37 @@ public int hashCode() {
return result;
}
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1599437315
##
flink-core-api/src/main/java/org/apache/flink/api/common/operators/SlotSharingGroupDescriptor.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache Software Found
[
https://issues.apache.org/jira/browse/FLINK-35349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846183#comment-17846183
]
Hongshun Wang commented on FLINK-35349:
---
I'd like to do it.
> Use connection in o
Hongshun Wang created FLINK-35349:
-
Summary: Use connection in openJdbcConnection of
SqlServerDialect/Db2Dialect/OracleDialect
Key: FLINK-35349
URL: https://issues.apache.org/jira/browse/FLINK-35349
P
zhuzhurk commented on code in PR #24771:
URL: https://github.com/apache/flink/pull/24771#discussion_r1599433353
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java:
##
@@ -225,17 +308,831 @@ protected void startSchedulingIn
yuxiqian commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599426381
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:
###
yuxiqian commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599426381
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:
###
loserwang1024 commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599417206
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtil.java:
##
@@ -0,0 +
zhuzhurk commented on code in PR #24774:
URL: https://github.com/apache/flink/pull/24774#discussion_r1599414778
##
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java:
##
@@ -121,4 +122,21 @@ default
CompletableFuture> getAllPartitionWithM
loserwang1024 commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599410767
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtil.java:
##
@@ -0,0 +
loserwang1024 commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599410084
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java
[
https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846177#comment-17846177
]
Zhu Zhu commented on FLINK-35293:
-
The change is merged. Could you add release notes for
[
https://issues.apache.org/jira/browse/FLINK-35348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35348:
-
Assignee: Feng Jin
> Implement materialized table refresh rest api
> -
[
https://issues.apache.org/jira/browse/FLINK-35347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35347:
-
Assignee: dalongliu
> Implement InMemory workflow scheduler service and plugin to support
> ma
dalongliu created FLINK-35348:
-
Summary: Implement materialized table refresh rest api
Key: FLINK-35348
URL: https://issues.apache.org/jira/browse/FLINK-35348
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-35346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35346:
-
Assignee: dalongliu
> Introduce pluggable workflow scheduler interface for materialized table
>
dalongliu created FLINK-35347:
-
Summary: Implement InMemory workflow scheduler service and plugin
to support materialized table
Key: FLINK-35347
URL: https://issues.apache.org/jira/browse/FLINK-35347
Proj
dalongliu created FLINK-35346:
-
Summary: Introduce pluggable workflow scheduler interface for
materialized table
Key: FLINK-35346
URL: https://issues.apache.org/jira/browse/FLINK-35346
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35345:
-
Assignee: dalongliu
> FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materializ
flinkbot commented on PR #24781:
URL: https://github.com/apache/flink/pull/24781#issuecomment-2109314883
## CI report:
* 2f5f8598627c98bfa1bf88e7a6e0de51319748f2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35153:
---
Labels: pull-request-available (was: )
> Internal Async State Implementation and StateDescr
Zakelly opened a new pull request, #24781:
URL: https://github.com/apache/flink/pull/24781
## What is the purpose of the change
This PR provides the definition of `StateDescriptor` and simple
implementation for `List` and `Map` state in `State V2`.
## Brief change log
- Tes
[
https://issues.apache.org/jira/browse/FLINK-35334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Simon Lee updated FLINK-35334:
--
Priority: Blocker (was: Major)
> Code generation: init method exceeds 64 KB when there is a long arra
whhe commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599378513
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtil.java:
##
@@ -0,0 +1,132 @@
[
https://issues.apache.org/jira/browse/FLINK-32443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei closed FLINK-32443.
--
> Translate "State Processor API" page into Chinese
> -
>
[
https://issues.apache.org/jira/browse/FLINK-32443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-32443.
Resolution: Resolved
Merged into master via 26817092
> Translate "State Processor API" page into
yuxiqian commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599352772
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:
###
yuxiqian commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599352772
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:
###
dalongliu created FLINK-35345:
-
Summary: FLIP-448: Introduce Pluggable Workflow Scheduler
Interface for Materialized Table
Key: FLINK-35345
URL: https://issues.apache.org/jira/browse/FLINK-35345
Project:
yuxiqian commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599352772
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:
###
[
https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35344:
---
Labels: pull-request-available (was: )
> Move same code from multiple subclasses to JdbcSou
loserwang1024 opened a new pull request, #3319:
URL: https://github.com/apache/flink-cdc/pull/3319
Current, subclasses of JdbcSourceChunkSplitter almost share same code, but
each have one copy. It's hard for later maintenance.
Thus, this Jira aim to move same code from multiple subcl
[
https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846167#comment-17846167
]
Hongshun Wang commented on FLINK-35344:
---
I'd like to do it.
> Move same code from
fredia commented on PR #24780:
URL: https://github.com/apache/flink/pull/24780#issuecomment-2109222070
Hi @drymatini, thanks for your contribution, "State Processor API" was
already translated in master, I think documents do not need to be backported
to the historical release branch, maybe
Hongshun Wang created FLINK-35344:
-
Summary: Move same code from multiple subclasses to
JdbcSourceChunkSplitter
Key: FLINK-35344
URL: https://issues.apache.org/jira/browse/FLINK-35344
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846161#comment-17846161
]
chenyunde commented on FLINK-34756:
---
The range of server-id should be between 1 to 2 ^
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846157#comment-17846157
]
Gang Yang edited comment on FLINK-35296 at 5/14/24 3:28 AM:
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846157#comment-17846157
]
Gang Yang commented on FLINK-35296:
---
This abnormal situation occurs not only in sub-da
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846156#comment-17846156
]
Feng Jin commented on FLINK-35342:
--
{color:#00}This issue will be fixed in this PR.
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gang Yang updated FLINK-35296:
--
Attachment: image-2024-05-14-11-25-55-565.png
> Flink mysql-cdc connector stops reading data
> ---
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846153#comment-17846153
]
Gang Yang commented on FLINK-35296:
---
Yes, I have checked it. The maximum data volume o
[ https://issues.apache.org/jira/browse/FLINK-35296 ]
Gang Yang deleted comment on FLINK-35296:
---
was (Author: 清月):
是的，已经检查过，分表最大数据量是1315883，最小是443151，差距不超过三倍
> Flink mysql-cdc connector stops reading data
> ---
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846152#comment-17846152
]
Gang Yang commented on FLINK-35296:
---
是的，已经检查过，分表最大数据量是1315883，最小是443151，差距不超过三倍
> Fli
fredia commented on PR #24762:
URL: https://github.com/apache/flink/pull/24762#issuecomment-2109196919
> Thanks for the update! Overall LGTM. And will this `SpaceStat` report to
metrics?
Currently no, will report to metric in FLINK-32091.
--
This is an automated message from the Ap
Zakelly commented on code in PR #24762:
URL: https://github.com/apache/flink/pull/24762#discussion_r1599318520
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/PhysicalFile.java:
##
@@ -88,18 +88,34 @@ PhysicalFile perform(
*/
private boo
[
https://issues.apache.org/jira/browse/FLINK-35343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zyh updated FLINK-35343:
Environment:
* flink(1.17.2), local mode and deploy on k8s
* doris-flink-connector-1.17(1.6.0)
* Doris(2.1)
h2.
zyh created FLINK-35343:
---
Summary: NullPointerException in SourceReaderBase
Key: FLINK-35343
URL: https://issues.apache.org/jira/browse/FLINK-35343
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846141#comment-17846141
]
Roman Boyko commented on FLINK-34380:
-
[~xu_shuai_] , [~xuyangzhong] , could you ple
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846140#comment-17846140
]
Roman Boyko commented on FLINK-34694:
-
[~xu_shuai_] , please take a look.
> Delete
[
https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846137#comment-17846137
]
Zhu Zhu commented on FLINK-35293:
-
master: ddb5a5355f9aca3d223f1fff6581d83dd317c2de
> F
zhuzhurk merged PR #24764:
URL: https://github.com/apache/flink/pull/24764
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846135#comment-17846135
]
Feng Jin commented on FLINK-35342:
--
[~rskraba] {color:#00}Thank you for reporting t
[
https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846129#comment-17846129
]
Hang Ruan commented on FLINK-35109:
---
[~fpaul] Thanks for your quick reply. I will work
[
https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-35302:
Fix Version/s: 1.20.0
(was: 1.19.1)
> Flink REST server throws exception on unknown
JunRuiLee commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2109128178
> > Thanks, @venkata91, for your contribution! After reviewing this PR, I'm
concerned that it entirely removes limit that source parallelism should lower
than source jobVertex's max par
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846007#comment-17846007
]
Ryan Skraba commented on FLINK-35342:
-
[~hackergin] I found this failure in this new
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated FLINK-35342:
Affects Version/s: 1.20.0
> MaterializedTableStatementITCase test can check for wrong status
> ---
Ryan Skraba created FLINK-35342:
---
Summary: MaterializedTableStatementITCase test can check for wrong
status
Key: FLINK-35342
URL: https://issues.apache.org/jira/browse/FLINK-35342
Project: Flink
elon-X commented on code in PR #24757:
URL: https://github.com/apache/flink/pull/24757#discussion_r1598735613
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -201,8 +201,11 @@ void announceCombinedWatermark() {
//
empathy87 commented on PR #24659:
URL: https://github.com/apache/flink/pull/24659#issuecomment-2108124573
> @empathy87 please let me know once backports are ready, then we can merge
all of them
@snuyanzin, backport PRs are done, CI succeeded.
https://github.com/apache/flink/pull/24
venkata91 commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2108098806
> Thanks, @venkata91, for your contribution! After reviewing this PR, I'm
concerned that it entirely removes limit that source parallelism should lower
than source jobVertex's max paral
Lim Qing Wei created FLINK-35341:
Summary: Retraction stop working with Clock dependent function in
Filter
Key: FLINK-35341
URL: https://issues.apache.org/jira/browse/FLINK-35341
Project: Flink
vikramsinghchandel commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-2107813052
any updates here? This is a feature that is already available on Flink EMR
would be great to have it here too.
--
This is an automated message from the Apache Git Se
[
https://issues.apache.org/jira/browse/FLINK-35335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845948#comment-17845948
]
Ryan Skraba commented on FLINK-35335:
-
* 1.19 test_cron_adaptive_scheduler tests
ht
[
https://issues.apache.org/jira/browse/FLINK-35254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845946#comment-17845946
]
Ryan Skraba commented on FLINK-35254:
-
* 1.20 build_wheels_on_macos
https://dev.azu
[
https://issues.apache.org/jira/browse/FLINK-35284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845947#comment-17845947
]
Ryan Skraba commented on FLINK-35284:
-
* 1.20 AdaptiveScheduler / E2E (group 2)
htt
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845945#comment-17845945
]
Ryan Skraba commented on FLINK-35041:
-
Thanks so much! I've verified that I can no
[
https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845943#comment-17845943
]
Ryan Skraba commented on FLINK-35002:
-
* 1.18 AdaptiveScheduler / Compile
https://g
Neil Prasad created FLINK-35340:
---
Summary: Flink Kubernetes Operator CRDs not applying correctly
Key: FLINK-35340
URL: https://issues.apache.org/jira/browse/FLINK-35340
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845942#comment-17845942
]
Ryan Skraba commented on FLINK-34227:
-
* 1.19 AdaptiveScheduler / Test (module: tabl
[
https://issues.apache.org/jira/browse/FLINK-30644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845940#comment-17845940
]
Ryan Skraba commented on FLINK-30644:
-
* 1.19 test_cron_jdk17 tests
https://dev.azu
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845939#comment-17845939
]
Ryan Skraba commented on FLINK-28440:
-
* 1.18 Default (Java 8) / Test (module: tests
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845938#comment-17845938
]
Ryan Skraba commented on FLINK-26644:
-
* 1.18 Java 11 / Test (module: python)
https
[
https://issues.apache.org/jira/browse/FLINK-23577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845937#comment-17845937
]
Ryan Skraba commented on FLINK-23577:
-
Looks like this flaky test has made a reappea
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845936#comment-17845936
]
Ryan Skraba commented on FLINK-18476:
-
* 1.19 test_cron_hadoop313 misc
https://dev.
flinkbot commented on PR #24780:
URL: https://github.com/apache/flink/pull/24780#issuecomment-2107606610
## CI report:
* 557dcaa7bda5fd1b76e446f643012dc4d47a563c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Ryan Skraba created FLINK-35339:
---
Summary: Compilation timeout while building flink-dist
Key: FLINK-35339
URL: https://issues.apache.org/jira/browse/FLINK-35339
Project: Flink
Issue Type: Bug
drymatini commented on PR #24780:
URL: https://github.com/apache/flink/pull/24780#issuecomment-2107594814
@wuchong @reswqa Hi, I have finished the translation of the page.Could you
please verify my pull request?
--
This is an automated message from the Apache Git Service.
To respond to th
[
https://issues.apache.org/jira/browse/FLINK-35253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35253:
---
Labels: pull-request-available (was: )
> Translate "State Processor API "page into Chinese
drymatini opened a new pull request, #24780:
URL: https://github.com/apache/flink/pull/24780
## What is the purpose of the change
"State Processor API "page was newly released and it should be translated
into Chineses
## Brief change log
translate 'docs/content/docs/
lsyldliu commented on code in PR #24777:
URL: https://github.com/apache/flink/pull/24777#discussion_r1598351419
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlDropMaterializedTable.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Softwar
superdiaodiao commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2107498923
@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 comm
flinkbot commented on PR #24779:
URL: https://github.com/apache/flink/pull/24779#issuecomment-2107496417
## CI report:
* 87c26627c5431157f1e85d35b3ce466ff708ff40 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24778:
URL: https://github.com/apache/flink/pull/24778#issuecomment-2107479208
## CI report:
* d9dddcd7c6613169b95193b85fdefa29c726996b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845909#comment-17845909
]
yazgoo commented on FLINK-35138:
Hello, do you have an update on this ticket ?
Looks lik
[
https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845908#comment-17845908
]
Zakelly Lan commented on FLINK-35168:
-
Merged into master via 01586780
> Basic Stat
[
https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-35168.
-
Resolution: Fixed
> Basic State Iterator for async processing
>
Zakelly merged PR #24690:
URL: https://github.com/apache/flink/pull/24690
--
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-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-35336:
---
Issue Type: New Feature (was: Bug)
> SQL failed to restore from savepoint after change in d
[
https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845901#comment-17845901
]
Martijn Visser commented on FLINK-35336:
That's not a bug: changing the parallel
superdiaodiao commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2107400121
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845894#comment-17845894
]
Lorenzo Affetti commented on FLINK-16528:
-
[~jark] is this issue still valuable
flinkbot commented on PR #24777:
URL: https://github.com/apache/flink/pull/24777#issuecomment-2107395878
## CI report:
* 67ef2ca47615d5b36424af7bc12712071369e358 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on PR #24690:
URL: https://github.com/apache/flink/pull/24690#issuecomment-2107381572
> @Zakelly Thanks for the PR, I have a question about the overall design. It
seems that an iterator can actually be split into several executions. If other
UPDATE are inserted in the midd
[
https://issues.apache.org/jira/browse/FLINK-35126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-35126:
--
Assignee: Gyula Fora
> Improve checkpoint progress health check config and enable by default
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
request|https://github.com/apache/flink-kubernetes-operator/pull/
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
request|https://github.com/apache/flink-kubernetes-operator/pull/
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5193:
--
Labels: pull-request-available (was: )
> Recovering all jobs fails completely if a single reco
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
request|https://github.com/apache/flink-kubernetes-operator/pull/
1 - 100 of 168 matches
Mail list logo
