RocMarshal commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1566975727
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,86 +24,93 @@ specific language governing permissions and limitations
under the License.
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1566976014
##
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/ProcessingTimeManager.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834758#comment-17834758
]
ude edited comment on FLINK-35039 at 4/16/24 8:36 AM:
--
[~Yu Chen]，[~yunta]
snuyanzin commented on PR #23:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/23#issuecomment-2058526774
@joaquinfernandez131 could you please rebase to be sure that ci passes?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
Fei Feng created FLINK-35123:
Summary: Flink Kubernetes Operator should not do deleteHAData
Key: FLINK-35123
URL: https://issues.apache.org/jira/browse/FLINK-35123
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837579#comment-17837579
]
牛一凡 edited comment on FLINK-34752 at 4/16/24 8:09 AM:
--
Hi [~kunni] ，I am a Chinese
[ https://issues.apache.org/jira/browse/FLINK-34747 ]
牛一凡 deleted comment on FLINK-34747:
-
was (Author: JIRAUSER304780):
I am willing to do this.Can it be assigned to me?:)
> "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-31472.
---
Resolution: Fixed
> AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread
>
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837580#comment-17837580
]
Danny Cranmer commented on FLINK-31472:
---
I was waiting for the backports to be merged. Now merged:
dannycranmer merged PR #24668:
URL: https://github.com/apache/flink/pull/24668
--
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-34735 ]
牛一凡 deleted comment on FLINK-34735:
-
was (Author: JIRAUSER304780):
I am willing to do this.Can it be assigned to me?:)
> "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese
[
https://issues.apache.org/jira/browse/FLINK-32892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-32892:
--
Assignee: Mason Chen
> Handle Kafka clients JMX mBean errors by disabling JMX metrics
>
[
https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837582#comment-17837582
]
牛一凡 commented on FLINK-34749:
-
Hi [~kunni] ，I am a Chinese Speaker and glad to take this work , cloud you
[ https://issues.apache.org/jira/browse/FLINK-34749 ]
牛一凡 deleted comment on FLINK-34749:
-
was (Author: JIRAUSER304780):
I am willing to do this.Can it be assigned to me?:)
> "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837576#comment-17837576
]
牛一凡 edited comment on FLINK-34748 at 4/16/24 8:10 AM:
--
Hi [~kunni] ，I am a Chinese
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35111:
-
Assignee: Yun Tang
> Modify the spelling mistakes in the taskmanager html
>
dannycranmer commented on PR #24276:
URL: https://github.com/apache/flink/pull/24276#issuecomment-2058472281
In parallel, a Jira was created for this. Referencing here
https://issues.apache.org/jira/browse/FLINK-35111
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Component/s: Runtime / Web Frontend
(was: Documentation)
> Modify the
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Fix Version/s: 1.20.0
> Modify the spelling mistakes in the taskmanager html
>
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Fix Version/s: (was: 1.20.0)
> Modify the spelling mistakes in the taskmanager html
>
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837568#comment-17837568
]
Danny Cranmer commented on FLINK-35111:
---
Ok great, thanks for the update [~wczhu] . Resolving this
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Fix Version/s: (was: 1.19.0)
> Modify the spelling mistakes in the taskmanager html
>
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31472:
--
Fix Version/s: 1.18.2
1.19.1
> AsyncSinkWriterThrottlingTest failed with
[
https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837579#comment-17837579
]
牛一凡 commented on FLINK-34752:
-
I am willing to do this.Can it be assigned to me?:)
>
[
https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837578#comment-17837578
]
牛一凡 commented on FLINK-34749:
-
I am willing to do this.Can it be assigned to me?:)
>
dannycranmer merged PR #24669:
URL: https://github.com/apache/flink/pull/24669
--
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-31400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-31400:
--
Assignee: Mason Chen (was: Mason Chen)
> Add autoscaler integration for Iceberg source
>
[
https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837576#comment-17837576
]
牛一凡 commented on FLINK-34748:
-
I am willing to do this.Can it be assigned to me?:)
>
[
https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837575#comment-17837575
]
牛一凡 commented on FLINK-34747:
-
I am willing to do this.Can it be assigned to me?:)
>
[
https://issues.apache.org/jira/browse/FLINK-34735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837571#comment-17837571
]
牛一凡 commented on FLINK-34735:
-
I am willing to do this.Can it be assigned to me?:)
> "Developer Guide -
[
https://issues.apache.org/jira/browse/FLINK-34906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-34906.
-
Resolution: Fixed
> Don't start autoscaling when some tasks are not running
>
[
https://issues.apache.org/jira/browse/FLINK-34906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837557#comment-17837557
]
Rui Fan commented on FLINK-34906:
-
Merged to main(1.9.0) via : 75eb206e863993727b62bd7374adadbc4760e417
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837570#comment-17837570
]
Ahmed Hamdy commented on FLINK-31472:
-
Is there a reason why the issue is not Resolved?
>
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Component/s: Documentation
(was: Runtime / Web Frontend)
> Modify the
[
https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837569#comment-17837569
]
Mason Chen commented on FLINK-35088:
Watermark alignment was moved out of beta during the 1.18.0
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-35111.
---
Fix Version/s: 1.20.0
Resolution: Fixed
> Modify the spelling mistakes in the
Mason Chen created FLINK-35122:
--
Summary: Implement Watermark Alignment for DynamicKafkaSource
Key: FLINK-35122
URL: https://issues.apache.org/jira/browse/FLINK-35122
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-35122:
---
Component/s: Connectors / Kafka
> Implement Watermark Alignment for DynamicKafkaSource
>
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837562#comment-17837562
]
Aleksandr Pilipenko commented on FLINK-35115:
-
[~vadim.vararu] are you able to reproduce
1996fanrui merged PR #801:
URL: https://github.com/apache/flink-kubernetes-operator/pull/801
--
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:
1996fanrui commented on PR #801:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/801#issuecomment-2058446456
Hi @mxm , I merge this PR first, feel free to ping me if you have any
comment in the future, thanks~
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qishang Zhong updated FLINK-35119:
--
Description:
When DebeziumChangelogMode is upsert, the before of DataChangeEvent is null,
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837552#comment-17837552
]
Hongshun Wang commented on FLINK-35121:
---
[~renqs] , CC
> CDC pipeline connector should verify
Hongshun Wang created FLINK-35121:
-
Summary: CDC pipeline connector should verify requiredOptions and
optionalOptions
Key: FLINK-35121
URL: https://issues.apache.org/jira/browse/FLINK-35121
Project:
LadyForest commented on code in PR #24510:
URL: https://github.com/apache/flink/pull/24510#discussion_r1566868181
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/UncollectToTableFunctionScanRule.scala:
##
@@ -0,0 +1,100 @@
+/*
ljz2051 commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1566847884
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java:
##
@@ -0,0 +1,102 @@
+/*
+ *
1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566848357
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,66 @@ specific language governing permissions and limitations
under the
mas-chen commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1566845916
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
snuyanzin commented on PR #91:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/91#issuecomment-2058403397
@liuml07 thanks for the contribution
it seems the ci failed because of `spotless`
could you please apply spotless to the PR?
--
This is an automated message
zhongqishang commented on code in PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#discussion_r1566843014
##
1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566834001
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the
[
https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837538#comment-17837538
]
Wouter Zorgdrager commented on FLINK-35112:
---
[~dianfu] sure, I can submit a PR for this!
>
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566828007
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-35103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837541#comment-17837541
]
SwathiChandrashekar commented on FLINK-35103:
-
Thanks [~martijnvisser] . Have started a
yuxiqian commented on PR #3227:
URL: https://github.com/apache/flink-cdc/pull/3227#issuecomment-2058385113
cc @PatrickRen
--
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-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35120:
---
Labels: pull-request-available (was: )
> Add Doris Pipeline connector integration test
yuxiqian opened a new pull request, #3227:
URL: https://github.com/apache/flink-cdc/pull/3227
This closes [FLINK-35120](https://issues.apache.org/jira/browse/FLINK-35120).
Currently, Flink CDC Doris pipeline connector has very limited test cases
(which only covers row convertion).
LadyForest commented on PR #24510:
URL: https://github.com/apache/flink/pull/24510#issuecomment-2058380570
> Thanks for your review @LadyForest. I rebased and addressed your comments.
Could you please re-check the PR in your available time? Thanks
Apologies for the delayed response,
1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566817400
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837533#comment-17837533
]
Vadim Vararu commented on FLINK-35115:
--
FYI it's reproducible in Kinesis -> Flink -> S3 sink also.
1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566812379
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the
Xiqian YU created FLINK-35120:
-
Summary: Add Doris Pipeline connector integration test cases
Key: FLINK-35120
URL: https://issues.apache.org/jira/browse/FLINK-35120
Project: Flink
Issue Type:
1996fanrui commented on code in PR #814:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/814#discussion_r1566801016
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/JobListFetcher.java:
##
@@ -19,12 +19,19 @@
import
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837531#comment-17837531
]
Muhammet Orazov commented on FLINK-34508:
-
Hey [~mapohl],
On the GitHub CI, the S3
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837530#comment-17837530
]
Muhammet Orazov commented on FLINK-34508:
-
In the Azure Pipeline the YarnFileStageTestS3ITCase
[
https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-35089:
---
Description:
Currently the `lastRecordAttributes1` and `lastRecordAttributes2` in the
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-30081.
Fix Version/s: 1.20.0
Resolution: Fixed
master (1.20):
liuml07 commented on PR #96:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/96#issuecomment-2058320749
Have you checked this PR?
https://github.com/apache/flink-connector-elasticsearch/pull/91
--
This is an automated message from the Apache Git Service.
To respond to
xintongsong closed pull request #22547: [FLINK-30081][runtime] Reset unused
options like jvm-overhead.min/max for local executor
URL: https://github.com/apache/flink/pull/22547
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
xintongsong commented on code in PR #22547:
URL: https://github.com/apache/flink/pull/22547#discussion_r1566773890
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorResourceUtils.java:
##
@@ -285,4 +286,15 @@ private static void
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837486#comment-17837486
]
Muhammet Orazov edited comment on FLINK-34508 at 4/16/24 6:19 AM:
--
Hey
liuml07 commented on PR #91:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/91#issuecomment-2058316069
@reta Thanks for the advice. I have updated the patch accordingly. I think
the `allowInsecure` and the `sslContextSupplier` are mutually exclusive, so I
added some
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1566767092
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/input/FirstInputOfTwoInput.java:
##
@@ -54,4 +57,17 @@ public
[
https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-35089:
Assignee: Xuannan Su
> Two input AbstractStreamOperator may throw NPE when receiving
yunfengzhou-hub commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1566744878
##
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##
@@ -1085,6 +1085,54 @@ public void setUseSnapshotCompression(boolean
101 - 175 of 175 matches
Mail list logo
