liuml07 commented on PR #21744:
URL: https://github.com/apache/flink/pull/21744#issuecomment-2053512944
@fapaul @sky-walking could you 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 to go
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1563660363
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -0,0 +1,127 @@
+/*
+ *
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1563660215
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -51,26 +51,43 @@ public class AsyncExecutionController {
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1563659916
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -0,0 +1,127 @@
+/*
+ *
yunfengzhou-hub commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1563570370
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -51,26 +51,43 @@ public class
morazow commented on code in PR #24471:
URL: https://github.com/apache/flink/pull/24471#discussion_r1563396268
##
flink-end-to-end-tests/flink-batch-sql-test/src/test/java/org/apache/flink/sql/tests/BatchSQLTest.java:
##
@@ -114,104 +129,24 @@ public void
Laffery commented on PR #3208:
URL: https://github.com/apache/flink-cdc/pull/3208#issuecomment-2052692792
> @Laffery I left some suggestions.
Ohh it's really helpful on these details, I've commited again according to
your suggestions.
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836749#comment-17836749
]
Balint Bene commented on FLINK-33989:
-
Out of curiosity for my own understand, is there an advantage
David Perkins created FLINK-35097:
-
Summary: Table API Filesystem connector with 'raw' format repeats
last line
Key: FLINK-35097
URL: https://issues.apache.org/jira/browse/FLINK-35097
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-35096:
---
Component/s: Connectors / Opensearch
> Flink OpenSearch Connector
>
Harish Sharma created FLINK-35096:
-
Summary: Flink OpenSearch Connector
Key: FLINK-35096
URL: https://issues.apache.org/jira/browse/FLINK-35096
Project: Flink
Issue Type: Bug
z3d1k commented on code in PR #122:
URL:
https://github.com/apache/flink-connector-aws/pull/122#discussion_r1484534168
##
flink-formats-aws/flink-sql-avro-glue-schema-registry/src/main/resources/META-INF/NOTICE:
##
@@ -0,0 +1,28 @@
+link-sql-avro-glue-schema-registryu
Review
RyanSkraba commented on code in PR #24140:
URL: https://github.com/apache/flink/pull/24140#discussion_r1562627239
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/WindowAggregateReduceFunctionsRule.java:
##
@@ -0,0 +1,89 @@
+/*
flinkbot commented on PR #24657:
URL: https://github.com/apache/flink/pull/24657#issuecomment-2051847830
## CI report:
* 19779deb56730b3da7d0b9ba0898e42786a316ea UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35025:
---
Labels: pull-request-available (was: )
> Wire AsyncExecutionController to
Zakelly opened a new pull request, #24657:
URL: https://github.com/apache/flink/pull/24657
## What is the purpose of the change
As part of the async execution model of disaggregated state management,
this PR gives the basic definition of `StreamingOperator` integrated with async
ferenc-csaky commented on PR #1:
URL:
https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2051760104
I am not sure about the current failure with the 1.18.1 + JDK17 combo, I
could not reproduce it locally, maybe there is some flakiness here.
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836602#comment-17836602
]
Ryan Skraba commented on FLINK-35041:
-
Ok, I *can't* reproduce this by running
afedulov commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1562500243
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836586#comment-17836586
]
Ryan Skraba commented on FLINK-35041:
-
Ryan Skraba created FLINK-35095:
---
Summary: ExecutionEnvironmentImplTest.testFromSource failure on
GitHub CI
Key: FLINK-35095
URL: https://issues.apache.org/jira/browse/FLINK-35095
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836580#comment-17836580
]
Ryan Skraba commented on FLINK-35041:
-
1.20 Java 17: Test (module: core)
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836579#comment-17836579
]
Ryan Skraba commented on FLINK-34227:
-
1.18 AdaptiveScheduler: Test (module: table)
JustinLeesin commented on PR #24656:
URL: https://github.com/apache/flink/pull/24656#issuecomment-2051616395
Hi @luoyuxia , could you help to review？Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
yuxiqian commented on code in PR #3221:
URL: https://github.com/apache/flink-cdc/pull/3221#discussion_r1562397462
##
yuxiqian commented on PR #3221:
URL: https://github.com/apache/flink-cdc/pull/3221#issuecomment-2051530489
Resume token could be refreshed by processing any data record or heartbeat
event. When a resume token carried by a `ChangeStreamOffset` is found to be
expired, resume token field is
fredia commented on code in PR #24633:
URL: https://github.com/apache/flink/pull/24633#discussion_r1562344262
##
flink-runtime/src/test/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionControllerTest.java:
##
@@ -152,66 +148,168 @@ void testBasicRun() {
//
gaborgsomogyi commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1562336481
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -129,8 +133,10 @@ public boolean scaleResource(
gaborgsomogyi commented on PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#issuecomment-2051448683
@mxm can you plz have a second look? We've talked it through with @gyfora
and the changes are reflecting it.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-34961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836128#comment-17836128
]
Sergey Nuyanzin edited comment on FLINK-34961 at 4/12/24 9:45 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-34961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-34961:
Fix Version/s: jdbc-3.2.0
jdbc-3.1.3
kafka-3.1.1
>
snuyanzin merged PR #114:
URL: https://github.com/apache/flink-connector-jdbc/pull/114
--
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:
gaborgsomogyi commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1562302534
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -199,6 +214,85 @@ protected static boolean
[
https://issues.apache.org/jira/browse/FLINK-34127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836521#comment-17836521
]
Martijn Visser commented on FLINK-34127:
You should :)
> Kafka connector repo runs a duplicate
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836515#comment-17836515
]
Etienne Chauchot edited comment on FLINK-35035 at 4/12/24 9:10 AM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836515#comment-17836515
]
Etienne Chauchot commented on FLINK-35035:
--
I think [~dmvk] has started to think about that.
reswqa merged PR #24647:
URL: https://github.com/apache/flink/pull/24647
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-35094:
Description:
Currently it is reproduced for elastic search connector
all the ci jobs (for
yanspirit commented on PR #91:
URL:
https://github.com/apache/flink-connector-kafka/pull/91#issuecomment-2051339512
> Is it possible to add a test for this situation?
This test is a bit tricky as it requires simulating broker crash. I have
tested this locally, and it ignores partitions
snuyanzin merged PR #112:
URL: https://github.com/apache/flink-connector-jdbc/pull/112
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836508#comment-17836508
]
yuanfenghu commented on FLINK-35035:
> It is not slot per slot rescale, there will be only one
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836507#comment-17836507
]
Etienne Chauchot commented on FLINK-35035:
--
> if min-parallelism-increase=1 Then my job may
masteryhx commented on code in PR #24633:
URL: https://github.com/apache/flink/pull/24633#discussion_r1562207787
##
flink-runtime/src/test/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionControllerTest.java:
##
@@ -152,66 +148,168 @@ void testBasicRun() {
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836504#comment-17836504
]
yuanfenghu commented on FLINK-35035:
[~echauchot]
Thank you for your patience in tracking this
shibd closed pull request #87: [upgrade] fink to 1.18.1 and pulsar to 3.0.4
URL: https://github.com/apache/flink-connector-pulsar/pull/87
--
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
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-35094:
Description:
Currently it is reproduced for elastic search connector
all the ci jobs (for
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-35094:
Component/s: Tests
> SinkTestSuiteBase.testScaleDown is hanging for 1.20-SNAPSHOT
>
Sergey Nuyanzin created FLINK-35094:
---
Summary: SinkTestSuiteBase.testScaleDown is hanging for
1.20-SNAPSHOT
Key: FLINK-35094
URL: https://issues.apache.org/jira/browse/FLINK-35094
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-35094:
Labels: test-stability (was: )
> SinkTestSuiteBase.testScaleDown is hanging for
gaborgsomogyi commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1562195810
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -115,6 +119,17 @@ public boolean scaleResource(
[
https://issues.apache.org/jira/browse/FLINK-34953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836459#comment-17836459
]
Zhongqiang Gong edited comment on FLINK-34953 at 4/12/24 8:10 AM:
--
Hi
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836462#comment-17836462
]
Etienne Chauchot commented on FLINK-35035:
--
with adaptive scheduler, the jobMaster declares
snuyanzin merged PR #95:
URL: https://github.com/apache/flink-connector-kafka/pull/95
--
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:
[
https://issues.apache.org/jira/browse/FLINK-34953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836459#comment-17836459
]
Zhongqiang Gong commented on FLINK-34953:
-
Hi [~mapohl][~martijnvisser] , PR is ready, But
ljz2051 commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1562174418
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -547,4 +548,43 @@ private void
affo commented on code in PR #24471:
URL: https://github.com/apache/flink/pull/24471#discussion_r1562170708
##
flink-end-to-end-tests/flink-batch-sql-test/src/test/java/org/apache/flink/sql/tests/Generator.java:
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software
affo commented on code in PR #24471:
URL: https://github.com/apache/flink/pull/24471#discussion_r1562169902
##
flink-end-to-end-tests/flink-batch-sql-test/src/test/java/org/apache/flink/sql/tests/BatchSQLTest.java:
##
@@ -114,104 +129,24 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-35078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836449#comment-17836449
]
Qingsheng Ren commented on FLINK-35078:
---
flink-cdc master:
[
https://issues.apache.org/jira/browse/FLINK-35078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-35078.
---
Fix Version/s: cdc-3.1.0
Resolution: Fixed
> Include Flink CDC pipeline connector
PatrickRen merged PR #3220:
URL: https://github.com/apache/flink-cdc/pull/3220
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35090:
-
Assignee: Xiqian YU
> Doris sink fails to create table when database does not exist
>
gaborgsomogyi commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1562107810
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/topology/JobTopology.java:
##
@@ -97,10 +109,6 @@ public boolean
gaborgsomogyi commented on code in PR #789:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/789#discussion_r1562107436
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -254,7 +263,7 @@ private void
snuyanzin opened a new pull request, #813:
URL: https://github.com/apache/flink-kubernetes-operator/pull/813
## What is the purpose of the change
The problem with current GHA ci is that it has `CI` name which is the same
across multiple Flink projects and Apache INFRA doesn't
masteryhx commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1562071643
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/internal/InternalKvState.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software
Jiabao-Sun commented on code in PR #3221:
URL: https://github.com/apache/flink-cdc/pull/3221#discussion_r1560833766
##
masteryhx commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1562060617
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/internal/InternalKvState.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836395#comment-17836395
]
yuanfenghu edited comment on FLINK-35035 at 4/12/24 6:08 AM:
-
[~echauchot]
JustinLeesin opened a new pull request, #24656:
URL: https://github.com/apache/flink/pull/24656
1.19 backport for parent PR #24397
--
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
flinkbot commented on PR #24656:
URL: https://github.com/apache/flink/pull/24656#issuecomment-2051047110
## CI report:
* cf2c203cc40e921dd455cb3ec4bab0048400f029 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
70 matches
Mail list logo
