宇宙先生 created FLINK-34925:
Summary: flinkCDC 抽取SQLSERVER 报错
Key: FLINK-34925
URL: https://issues.apache.org/jira/browse/FLINK-34925
Project: Flink
Issue Type: Bug
Components: Flink CDC
[
https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
宇宙先生 updated FLINK-34925:
-
Summary: FlinkCDC 3.0 for extracting data from sqlserver, errors occur
(was: flinkCDC 抽取SQLSERVER 报错)
> Fli
morazow commented on code in PR #182:
URL: https://github.com/apache/flink-docker/pull/182#discussion_r1536816965
##
.github/workflows/ci.yml:
##
@@ -17,14 +17,22 @@ name: "CI"
on: [push, pull_request]
+env:
+ TAR_URL:
"https://s3.amazonaws.com/flink-nightly/flink-1.20-SN
morazow commented on PR #182:
URL: https://github.com/apache/flink-docker/pull/182#issuecomment-2016815995
@XComp please have a look again. If this looks good, I will backport to
other branches accordingly, thanks 🙏
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830254#comment-17830254
]
Muhammet Orazov commented on FLINK-33707:
-
Hello,
Would this affect the Flink 1
[
https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830257#comment-17830257
]
Muhammet Orazov commented on FLINK-34487:
-
Hello [~mapohl], could you please hav
XComp commented on PR #24557:
URL: https://github.com/apache/flink/pull/24557#issuecomment-2016827592
CI with AdaptiveScheduler was
[successful](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=58516)
--
This is an automated message from the A
XComp commented on PR #24558:
URL: https://github.com/apache/flink/pull/24558#issuecomment-2016827477
CI with AdaptiveScheduler was
[successful](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=58517)
--
This is an automated message from the A
lincoln-lil commented on PR #24517:
URL: https://github.com/apache/flink/pull/24517#issuecomment-2016860210
@snuyanzin sorry to ping you here, do you still remember this data
generation during 1.18 release ( https://github.com/apache/flink/pull/23710)?
Is there any exception when do `gen
Xingcan Cui created FLINK-34926:
---
Summary: Adaptive auto parallelism doesn't work for a query
Key: FLINK-34926
URL: https://issues.apache.org/jira/browse/FLINK-34926
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-34926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-34926:
Description:
We have the following query running in batch mode.
{code:java}
WITH FEATURE_INCLUSION
[
https://issues.apache.org/jira/browse/FLINK-34926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-34926:
Attachment: (was: image_720.png)
> Adaptive auto parallelism doesn't work for a query
> --
[
https://issues.apache.org/jira/browse/FLINK-34926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-34926:
Description:
We have the following query running in batch mode.
{code:java}
WITH FEATURE_INCLUSION
[
https://issues.apache.org/jira/browse/FLINK-34926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-34926:
Attachment: image.png
> Adaptive auto parallelism doesn't work for a query
> -
xleoken commented on PR #3110:
URL: https://github.com/apache/flink-cdc/pull/3110#issuecomment-2017024741
cc @leonardBang @PatrickRen @Jiabao-Sun
--
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
[
https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830310#comment-17830310
]
Hongshun Wang commented on FLINK-34925:
---
Debezium 2.0 is a major version upgrade w
[
https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830313#comment-17830313
]
Zhanghao Chen commented on FLINK-34239:
---
[~mallikarjuna] Thanks for the PR, I'll t
[
https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-34915:
-
Assignee: Yubin Li
> Support `DESCRIBE CATALOG` syntax
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-34916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-34916:
-
Assignee: Yubin Li
> Support `ALTER CATALOG` syntax
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-34918:
-
Assignee: Yubin Li
> Introduce the support of Catalog for comments
> --
[
https://issues.apache.org/jira/browse/FLINK-34917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan reassigned FLINK-34917:
-
Assignee: Yubin Li
> Support enhanced `CREATE CATALOG` syntax
> ---
Zakelly commented on code in PR #24513:
URL: https://github.com/apache/flink/pull/24513#discussion_r1536996545
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -278,7 +300,11 @@ public SegmentFileStateHandl
Zakelly commented on code in PR #24513:
URL: https://github.com/apache/flink/pull/24513#discussion_r1536996545
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -278,7 +300,11 @@ public SegmentFileStateHandl
Caican Cai created FLINK-34927:
--
Summary: Translate flink-kubernetes-operator documentation
Key: FLINK-34927
URL: https://issues.apache.org/jira/browse/FLINK-34927
Project: Flink
Issue Type: New
Zakelly commented on code in PR #24513:
URL: https://github.com/apache/flink/pull/24513#discussion_r1536996692
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -278,7 +300,11 @@ public SegmentFileStateHandl
[
https://issues.apache.org/jira/browse/FLINK-34732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34732:
--
Assignee: Zhongqiang Gong
> Add document dead link check for Flink CDC Documentation
> --
[
https://issues.apache.org/jira/browse/FLINK-34927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830325#comment-17830325
]
Caican Cai commented on FLINK-34927:
[~fanrui] [~gyfora] Hello, you can check to see
[
https://issues.apache.org/jira/browse/FLINK-34841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34841:
--
Assignee: Zhongqiang Gong
> [3.1][pipeline-connectors] Add jdbc pipeline sink
>
1996fanrui commented on PR #726:
URL: https://github.com/apache/flink-web/pull/726#issuecomment-2017117505
> @1996fanrui I'm going to merge. Please feel free to comment on the PR. We
can still correct any mistakes or further improve the post!
Sorry for the late response! `1.7.0` is th
[
https://issues.apache.org/jira/browse/FLINK-34927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34927:
Affects Version/s: (was: 1.19.0)
> Translate flink-kubernetes-operator documentation
> ---
[
https://issues.apache.org/jira/browse/FLINK-34927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34927:
Fix Version/s: kubernetes-operator-1.9.0
(was: 2.0.0)
> Translate flink-kubernetes-
[
https://issues.apache.org/jira/browse/FLINK-34927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830328#comment-17830328
]
Rui Fan commented on FLINK-34927:
-
Thanks [~caicancai] driving it!
Translating flink-k
1996fanrui merged PR #802:
URL: https://github.com/apache/flink-kubernetes-operator/pull/802
--
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-unsu
1996fanrui commented on PR #802:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/802#issuecomment-2017134638
Thanks @czy006 and @mxm for the review!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
1996fanrui commented on PR #799:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/799#issuecomment-2017142562
Thanks @mxm for the patient reply and clarification!
> You mentioned the adaptive scheduler. Frankly, the use of the adaptive
scheduler with autoscaling isn't fu
1996fanrui commented on PR #801:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/801#issuecomment-2017164952
Thanks @mxm for the review and discussion!
> > This issue only affects the standalone autoscaler as the kubernetes
operator has this logic already in place for s
liuyongvs commented on code in PR #24375:
URL: https://github.com/apache/flink/pull/24375#discussion_r1537071891
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/WindowGroupReorderRule.java:
##
@@ -0,0 +1,192 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-33121:
---
Description:
We make the assumption that Global Failures (with null Task nam
pgaref commented on PR #23440:
URL: https://github.com/apache/flink/pull/23440#issuecomment-2017246294
> I suppose this can work but it seems rather brittle and may obfuscate the
underlying failure cause. If the reality is that multiple global failures can
occur or that global failures can
liuyongvs commented on PR #24526:
URL: https://github.com/apache/flink/pull/24526#issuecomment-2017314639
>
https://clickhouse.com/docs/en/sql-reference/functions/array-functions#arrayintersectarr
from my side, it is not a good idea.
because we can use array_intersect(array_interse
[
https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830356#comment-17830356
]
宇宙先生 commented on FLINK-34925:
--
[~loserwang1024] thanks for ur replay, may I have your d
[
https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830356#comment-17830356
]
宇宙先生 edited comment on FLINK-34925 at 3/25/24 6:34 AM:
---
[~loserwan
1996fanrui commented on code in PR #785:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/785#discussion_r1537108398
##
flink-autoscaler-standalone/pom.xml:
##
@@ -163,6 +163,12 @@ under the License.
test
+
Review Comment:
It's
[
https://issues.apache.org/jira/browse/FLINK-34927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830364#comment-17830364
]
Gyula Fora commented on FLINK-34927:
I think this would be great, I won't be able to
44 matches
Mail list logo
