lihaosky commented on code in PR #26603:
URL: https://github.com/apache/flink/pull/26603#discussion_r2114497294
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RexModelCall.java:
##
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the Apache Software
lihaosky commented on PR #26603:
URL: https://github.com/apache/flink/pull/26603#issuecomment-2920339341
I made most of the changes except reusing `SqlModelOperator`, I feel it's
not clean to pass it along the stack and `RexTableArgCall` also use a new one:
https://github.com/apache/flink/b
kgeis commented on PR #142:
URL:
https://github.com/apache/flink-connector-jdbc/pull/142#issuecomment-2920348142
Any chance of this getting into 4.1? The underlying issue blocks me from
using Flink.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
dianfu merged PR #25017:
URL: https://github.com/apache/flink/pull/25017
--
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
davidradl commented on code in PR #26594:
URL: https://github.com/apache/flink/pull/26594#discussion_r2113953620
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryArrayData.java:
##
@@ -372,7 +372,11 @@ public void setDecimal(int pos, Decim
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113921440
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113916485
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113900960
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113913733
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113929309
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113939989
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113943819
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
davidradl commented on code in PR #26590:
URL: https://github.com/apache/flink/pull/26590#discussion_r2114054135
##
docs/content.zh/docs/dev/python/installation.md:
##
@@ -29,11 +29,11 @@ under the License.
## 环境要求
-注意 PyFlink 需要 Python 3.7 以上版本（3.8, 3.9 或
3.10）。请运行以下命令，以确
davidradl commented on code in PR #26590:
URL: https://github.com/apache/flink/pull/26590#discussion_r2114049551
##
docs/content.zh/docs/dev/python/installation.md:
##
@@ -29,11 +29,11 @@ under the License.
## 环境要求
-注意 PyFlink 需要 Python 3.7 以上版本（3.8, 3.9 或
3.10）。请运行以下命令，以确
mohsenrezaeithe commented on code in PR #211:
URL:
https://github.com/apache/flink-connector-aws/pull/211#discussion_r2114711567
##
.github/workflows/nightly.yml:
##
@@ -25,8 +25,8 @@ jobs:
if: github.repository_owner == 'apache'
strategy:
matrix:
-flin
[
https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-34487:
-
Fix Version/s: 1.19.3
1.20.2
> Integrate tools/azure-pipelines/build-python-w
davidradl commented on code in PR #26590:
URL: https://github.com/apache/flink/pull/26590#discussion_r2114217710
##
docs/content.zh/docs/dev/python/installation.md:
##
@@ -29,11 +29,11 @@ under the License.
## 环境要求
-注意 PyFlink 需要 Python 3.7 以上版本（3.8, 3.9 或
3.10）。请运行以下命令，以确
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113909906
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
autophagy commented on code in PR #26590:
URL: https://github.com/apache/flink/pull/26590#discussion_r2114153613
##
docs/content.zh/docs/dev/python/installation.md:
##
@@ -29,11 +29,11 @@ under the License.
## 环境要求
-注意 PyFlink 需要 Python 3.7 以上版本（3.8, 3.9 或
3.10）。请运行以下命令，以确
autophagy commented on code in PR #26590:
URL: https://github.com/apache/flink/pull/26590#discussion_r2114163442
##
docs/content.zh/docs/dev/python/installation.md:
##
@@ -29,11 +29,11 @@ under the License.
## 环境要求
-注意 PyFlink 需要 Python 3.7 以上版本（3.8, 3.9 或
3.10）。请运行以下命令，以确
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113916485
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
dianfu commented on PR #25017:
URL: https://github.com/apache/flink/pull/25017#issuecomment-2919355092
Verified in my GHA: https://github.com/dianfu/flink/actions/runs/15324318599
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113911595
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113907400
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
rionmonster commented on code in PR #26608:
URL: https://github.com/apache/flink/pull/26608#discussion_r2114280386
##
flink-end-to-end-tests/flink-file-sink-test/src/main/java/org/apache/flink/connector/file/sink/FileSinkProgram.java:
##
@@ -55,7 +55,6 @@
* a complete sequence
rionmonster commented on code in PR #26608:
URL: https://github.com/apache/flink/pull/26608#discussion_r2114280386
##
flink-end-to-end-tests/flink-file-sink-test/src/main/java/org/apache/flink/connector/file/sink/FileSinkProgram.java:
##
@@ -55,7 +55,6 @@
* a complete sequence
davidradl commented on PR #26614:
URL: https://github.com/apache/flink/pull/26614#issuecomment-2919327151
@liangyu-1 I am curious what this 0 file change is about?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
davidradl commented on code in PR #26611:
URL: https://github.com/apache/flink/pull/26611#discussion_r2113912494
##
docs/content/docs/dev/table/functions/udfs.md:
##
@@ -1172,6 +1173,153 @@ If you intend to implement or call functions in Python,
please refer to the [Pyt
{{<
davidradl commented on code in PR #26590:
URL: https://github.com/apache/flink/pull/26590#discussion_r2114049551
##
docs/content.zh/docs/dev/python/installation.md:
##
@@ -29,11 +29,11 @@ under the License.
## 环境要求
-注意 PyFlink 需要 Python 3.7 以上版本（3.8, 3.9 或
3.10）。请运行以下命令，以确
davidradl commented on code in PR #26590:
URL: https://github.com/apache/flink/pull/26590#discussion_r2114054135
##
docs/content.zh/docs/dev/python/installation.md:
##
@@ -29,11 +29,11 @@ under the License.
## 环境要求
-注意 PyFlink 需要 Python 3.7 以上版本（3.8, 3.9 或
3.10）。请运行以下命令，以确
venkata91 commented on PR #26592:
URL: https://github.com/apache/flink/pull/26592#issuecomment-2920166933
> > > Thanks for the patch. It is a good catch.
> > > I understand it might be a little tricky to do unit test. but we may
be able to do integration test. We can do the following:
liangyu-1 opened a new pull request, #26614:
URL: https://github.com/apache/flink/pull/26614
## 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
liangyu-1 commented on PR #26614:
URL: https://github.com/apache/flink/pull/26614#issuecomment-2918929054
@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 #26614:
URL: https://github.com/apache/flink/pull/26614#issuecomment-2918944306
## CI report:
* fbe74919614077591c8659c082cc5dd00877221a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liangyu-1 commented on PR #26614:
URL: https://github.com/apache/flink/pull/26614#issuecomment-2918974408
@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.
[
https://issues.apache.org/jira/browse/FLINK-37869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-37869:
-
Description:
When I run a bounded sql job on Kuberentes cluster, after the job finished the
ope
[
https://issues.apache.org/jira/browse/FLINK-37869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-37869:
-
Description:
When I run a bounded sql job on Kuberentes cluster, after the job finished the
ope
lvyanquan commented on code in PR #4027:
URL: https://github.com/apache/flink-cdc/pull/4027#discussion_r2113774103
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java:
##
fsk119 commented on code in PR #26603:
URL: https://github.com/apache/flink/pull/26603#discussion_r2113420207
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RexModelCall.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Fo
fsk119 commented on PR #26603:
URL: https://github.com/apache/flink/pull/26603#issuecomment-2918668599
I write my idea here. You can take a look 0.0
https://github.com/apache/flink/compare/master...fsk119:flink:converter2?expand=1
--
This is an automated message from the Apache Git
Rui Fan created FLINK-37870:
---
Summary: Unaligned checkpoint is disabled unexpectedly
Key: FLINK-37870
URL: https://issues.apache.org/jira/browse/FLINK-37870
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-37869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-37869:
---
Assignee: junzhong qin
> FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator
> -
Zakelly Lan created FLINK-37867:
---
Summary: ForSt StateBackend fail to clean up files of the
half-uploaded checkpoint when using path copying
Key: FLINK-37867
URL: https://issues.apache.org/jira/browse/FLINK-37867
yuxiqian commented on code in PR #4015:
URL: https://github.com/apache/flink-cdc/pull/4015#discussion_r2113803393
##
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaEvolveTest.java:
##
@@ -2561,6 +2561,66 @@ tableId, buildRecord(INT, 1
JunRuiLee opened a new pull request, #26613:
URL: https://github.com/apache/flink/pull/26613
[FLINK-37761][runtime] Fix unstable test
testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot.
--
This is an automated message from the Apache Git Service.
To respond to the messag
flinkbot commented on PR #26613:
URL: https://github.com/apache/flink/pull/26613#issuecomment-2918570071
## CI report:
* f47a75261d5026088132589c226d2482481e2c89 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly Lan created FLINK-37868:
---
Summary: Respect the `maxTransferBytes` when using path copying in
ForSt
Key: FLINK-37868
URL: https://issues.apache.org/jira/browse/FLINK-37868
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-37866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-37866:
---
Fix Version/s: aws-connector-5.2.0
> Migrate glue schema registry e2e test to use aws-kinesis-stream
[
https://issues.apache.org/jira/browse/FLINK-37866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-37866:
---
Fix Version/s: aws-connector-6.0.0
> Migrate glue schema registry e2e test to use aws-kinesis-stream
[
https://issues.apache.org/jira/browse/FLINK-37866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-37866:
---
Fix Version/s: (was: aws-connector-5.2.0)
> Migrate glue schema registry e2e test to use aws-kin
[
https://issues.apache.org/jira/browse/FLINK-37869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-37869:
-
Description:
When I run a bounded sql job on Kuberentes cluster, the operator will not
cleanup
[
https://issues.apache.org/jira/browse/FLINK-37869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-37869:
-
Description:
When I run a bounded sql job on Kuberentes cluster, after the job finished the
ope
[
https://issues.apache.org/jira/browse/FLINK-37869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-37869:
-
Summary: FINISHED bouned job can't be cleanup by the Flink Kuberenetes
Operator (was: Bouned jo
junzhong qin created FLINK-37869:
Summary: Bouned job can't be cleanup by the Flink Kuberenetes
Operator
Key: FLINK-37869
URL: https://issues.apache.org/jira/browse/FLINK-37869
Project: Flink
AHeise commented on PR #26601:
URL: https://github.com/apache/flink/pull/26601#issuecomment-2918630014
@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.
T
Daren Wong created FLINK-37866:
--
Summary: Migrate glue schema registry e2e test to use
aws-kinesis-streams connector
Key: FLINK-37866
URL: https://issues.apache.org/jira/browse/FLINK-37866
Project: Flink
davidradl commented on code in PR #26608:
URL: https://github.com/apache/flink/pull/26608#discussion_r2113549093
##
flink-end-to-end-tests/flink-file-sink-test/src/main/java/org/apache/flink/connector/file/sink/FileSinkProgram.java:
##
@@ -55,7 +55,6 @@
* a complete sequence f
JunRuiLee merged PR #26613:
URL: https://github.com/apache/flink/pull/26613
--
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
[
https://issues.apache.org/jira/browse/FLINK-37761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17953409#comment-17953409
]
Junrui Lee edited comment on FLINK-37761 at 5/29/25 9:14 AM:
-
Sai Sharath Dandi created FLINK-37872:
-
Summary: Autoscaler computes negative true processing rate
Key: FLINK-37872
URL: https://issues.apache.org/jira/browse/FLINK-37872
Project: Flink
I
lihaosky commented on code in PR #26603:
URL: https://github.com/apache/flink/pull/26603#discussion_r2114847910
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaModel.java:
##
@@ -85,4 +109,34 @@ private static RelDataType sche
[
https://issues.apache.org/jira/browse/FLINK-37703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955091#comment-17955091
]
dalongliu commented on FLINK-37703:
---
It's the problem of the case dependent on HDFS, n
[
https://issues.apache.org/jira/browse/FLINK-37842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955090#comment-17955090
]
dalongliu edited comment on FLINK-37842 at 5/30/25 4:08 AM:
snuyanzin commented on code in PR #26547:
URL: https://github.com/apache/flink/pull/26547#discussion_r2114863909
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -8001,6 +8003,8 @@ SqlPostfixOperator PostfixRowOperator() :
| < DATETIME_INTERVAL_PREC
rovboyko commented on code in PR #26313:
URL: https://github.com/apache/flink/pull/26313#discussion_r2115155616
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/MultiJoinStateViews.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Lice
rovboyko commented on code in PR #26313:
URL: https://github.com/apache/flink/pull/26313#discussion_r2115155616
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/MultiJoinStateViews.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Lice
lihaosky commented on code in PR #26603:
URL: https://github.com/apache/flink/pull/26603#discussion_r2114885735
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaModel.java:
##
@@ -85,4 +109,34 @@ private static RelDataType sche
snuyanzin opened a new pull request, #26615:
URL: https://github.com/apache/flink/pull/26615
## What is the purpose of the change
The PR removes `FlinkRelMdUtil#getJoinDistinctRowCount` since after movement
to 1.33+ Calcite we can reuse `RelMdUtil#getJoinDistinctRowCount` instead
snuyanzin commented on code in PR #26547:
URL: https://github.com/apache/flink/pull/26547#discussion_r2114863719
##
flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/type/FlinkCalciteTableMappingRule.java:
##
@@ -0,0 +1,80 @@
+/*
+ * Licensed to the Apache Sof
snuyanzin commented on code in PR #26547:
URL: https://github.com/apache/flink/pull/26547#discussion_r2114867387
##
flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/StandardConvertletTable.java:
##
@@ -265,6 +277,19 @@ private StandardConvertletTable() {
snuyanzin commented on code in PR #26547:
URL: https://github.com/apache/flink/pull/26547#discussion_r2114886304
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/LiteralAggFunction.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed
lihaosky commented on code in PR #26603:
URL: https://github.com/apache/flink/pull/26603#discussion_r2114885735
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaModel.java:
##
@@ -85,4 +109,34 @@ private static RelDataType sche
Sergey Nuyanzin created FLINK-37871:
---
Summary: Remove FlinkRelMdUtil#getJoinDistinctRowCount
Key: FLINK-37871
URL: https://issues.apache.org/jira/browse/FLINK-37871
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-37871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37871:
---
Labels: pull-request-available (was: )
> Remove FlinkRelMdUtil#getJoinDistinctRowCount
> --
snuyanzin commented on code in PR #26547:
URL: https://github.com/apache/flink/pull/26547#discussion_r2114868899
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/LiteralAggFunction.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed
lsyldliu commented on PR #26614:
URL: https://github.com/apache/flink/pull/26614#issuecomment-2921040705
> @liangyu-1 I am curious what this 0 file change is about?
Hi, @davidradl we are locate the root cause of
https://issues.apache.org/jira/browse/FLINK-37703
--
This is an automa
rovboyko commented on code in PR #26313:
URL: https://github.com/apache/flink/pull/26313#discussion_r2115155616
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/MultiJoinStateViews.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-37842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955109#comment-17955109
]
dalongliu commented on FLINK-37842:
---
Hi [~mapohl], can you help take a look for this c
dianfu commented on code in PR #177:
URL:
https://github.com/apache/flink-connector-kafka/pull/177#discussion_r2115181116
##
flink-python/pyflink/datastream/connectors/kafka.py:
##
@@ -41,6 +43,157 @@
'KafkaTopicSelector'
]
+# DynamicKafkaSource
+
+
+class Dyn
[
https://issues.apache.org/jira/browse/FLINK-37604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-37604:
---
Affects Version/s: cdc-3.4.0
cdc-3.2.1
cdc-3.3.0
> Fli
lvyanquan merged PR #3977:
URL: https://github.com/apache/flink-cdc/pull/3977
--
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
[
https://issues.apache.org/jira/browse/FLINK-37604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv resolved FLINK-37604.
Fix Version/s: cdc-3.5.0
Resolution: Fixed
Fixed in master via e8f9ff01ab4f149949509013e422
github-actions[bot] commented on PR #26003:
URL: https://github.com/apache/flink/pull/26003#issuecomment-2921355454
This PR has been closed since it has not had any activity in 120 days.
If you feel like this was a mistake, or you would like to continue working
on it,
please feel fre
github-actions[bot] closed pull request #26003: [FLINK-37159][runtime] Fix the
test timeout by yielding Modifier thread
URL: https://github.com/apache/flink/pull/26003
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
venkata91 commented on PR #26592:
URL: https://github.com/apache/flink/pull/26592#issuecomment-2920638048
> > > > Thanks for the patch. It is a good catch.
> > > > I understand it might be a little tricky to do unit test. but we may
be able to do integration test. We can do the following:
flinkbot commented on PR #26615:
URL: https://github.com/apache/flink/pull/26615#issuecomment-2920660292
## CI report:
* e1e7909347e65222b16439d0bdff3ef301c8eb31 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955083#comment-17955083
]
Xin Chen edited comment on FLINK-37873 at 5/30/25 3:14 AM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-37249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu reassigned FLINK-37249:
-
Assignee: Zhanghao Chen
> Remove unnecessary --add-opens/--add-exports for java.base/sun.net.ut
[
https://issues.apache.org/jira/browse/FLINK-36188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955079#comment-17955079
]
Xin Chen commented on FLINK-36188:
--
I have a question here. If I have enabled the buffe
Xin Chen created FLINK-37873:
Summary: 【Hbase-connector】Enable buffer flush, specify a
non-existent table when writing data to hbase, the Flink task displays
successful
Key: FLINK-37873
URL: https://issues.apache.org
[
https://issues.apache.org/jira/browse/FLINK-37873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Chen updated FLINK-37873:
-
Description:
If I have enabled the buffer flush, such as setting
''sink.buffer-flush.max-rows'='1000',
liangyu-1 closed pull request #26614: Flink 36112- testing
URL: https://github.com/apache/flink/pull/26614
--
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
lvyanquan commented on PR #3894:
URL: https://github.com/apache/flink-cdc/pull/3894#issuecomment-2921139863
Rebase to solve the conflict.
--
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 speci
lvyanquan opened a new pull request, #795:
URL: https://github.com/apache/flink-web/pull/795
Update the slack invitation link
--
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
[
https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-34487.
---
Resolution: Fixed
1.20: b714db4dadf8de6a21c147b6a3568bf78b6ca8eb
1.19: 0b1b88b1cb1dc13bf600b848c2ca35cda19e6
chenyuzhi459 commented on PR #956:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2921169602
Because `flink.client.io.threads=60` specifies the number of EventExecutors
that handle event in NioEventLoopGroup, when creating NioEventLoopGroup, a
corresponding
[
https://issues.apache.org/jira/browse/FLINK-37842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955090#comment-17955090
]
dalongliu commented on FLINK-37842:
---
After a deep dive into the test case, I think thi
[
https://issues.apache.org/jira/browse/FLINK-37842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955076#comment-17955076
]
dalongliu commented on FLINK-37842:
---
https://dev.azure.com/apache-flink/apache-flink/_
[
https://issues.apache.org/jira/browse/FLINK-37767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950836#comment-17950836
]
Weijie Guo edited comment on FLINK-37767 at 5/30/25 1:52 AM:
-
reswqa merged PR #26605:
URL: https://github.com/apache/flink/pull/26605
--
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
1 - 100 of 102 matches
Mail list logo
