yuxiqian commented on code in PR #3483:
URL: https://github.com/apache/flink-cdc/pull/3483#discussion_r1685267350
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkWriterOperator.java:
##
@@ -172,7 +172,6 @@ public void processElement(StreamR
yuxiqian commented on code in PR #3483:
URL: https://github.com/apache/flink-cdc/pull/3483#discussion_r1685267350
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkWriterOperator.java:
##
@@ -172,7 +172,6 @@ public void processElement(StreamR
[
https://issues.apache.org/jira/browse/FLINK-35857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867471#comment-17867471
]
chenyuzhi commented on FLINK-35857:
---
I have test the latest operator version, met with
[
https://issues.apache.org/jira/browse/FLINK-35857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35857:
---
Labels: pull-request-available (was: )
> Operator restart failed job without latest checkpo
chenyuzhi459 opened a new pull request, #855:
URL: https://github.com/apache/flink-kubernetes-operator/pull/855
## What is the purpose of the change
Fix operator won't use latest checkpoint as `execution.savepoint.path` for
restarted deployment.
## Brief cha
JingGe commented on code in PR #25091:
URL: https://github.com/apache/flink/pull/25091#discussion_r1684970706
##
docs/content.zh/release-notes/flink-1.20.md:
##
@@ -0,0 +1,434 @@
+---
+title: "Release Notes - Flink 1.20"
+---
+
+
+# Release notes - Flink 1.20
+
+These release no
dmariassy closed pull request #25107: Add protoc service and dynamic
deserializer skeleton
URL: https://github.com/apache/flink/pull/25107
--
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 specifi
flinkbot commented on PR #25107:
URL: https://github.com/apache/flink/pull/25107#issuecomment-2240092185
## CI report:
* e08aa9e72c30871890eab7d7700de1fafe007f32 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dmariassy opened a new pull request, #25107:
URL: https://github.com/apache/flink/pull/25107
## 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
jeyhunkarimov commented on PR #24997:
URL: https://github.com/apache/flink/pull/24997#issuecomment-2240014953
@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
dmariassy commented on PR #24482:
URL: https://github.com/apache/flink/pull/24482#issuecomment-2239843309
I started working on an alternative implementation over here:
https://github.com/Shopify/flink/tree/protobuf-confluent-dynamic-deser
--
This is an automated message from the Apache Gi
[
https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867370#comment-17867370
]
Kartikey Pant commented on FLINK-12450:
---
Hey [~lincoln.86xy], created a PR for the
[
https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35851:
---
Labels: pull-request-available (was: )
> autoscaler standlone mode use `GlobalConfiguration
huyuanfeng2018 commented on PR #853:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/853#issuecomment-2239462207
> Hi,
>
> The title of the PR references a Jira that is for a KDS connector bug:
>
> * https://issues.apache.org/jira/browse/FLINK-35815
>
> Wou
[
https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grzegorz Kołakowski updated FLINK-35869:
Description:
Background:
I have a stream of user information updates in Kafka top
[
https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grzegorz Kołakowski updated FLINK-35869:
Description:
Background:
I have a stream of user information updates in Kafka top
[
https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grzegorz Kołakowski updated FLINK-35869:
Description:
Background:
I have a stream of user information updates in Kafka top
[
https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grzegorz Kołakowski updated FLINK-35869:
Description:
Background:
I have a stream of user information updates in Kafka top
[
https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grzegorz Kołakowski updated FLINK-35869:
Description:
Background:
I have a stream of user information updates, but those u
[
https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grzegorz Kołakowski updated FLINK-35869:
Description:
Background:
I have a stream of user information updates, but those u
Grzegorz Kołakowski created FLINK-35869:
---
Summary: Right side columns of temporal left join are always null
when right side is filtered
Key: FLINK-35869
URL: https://issues.apache.org/jira/browse/FLINK-35869
dylanhz commented on code in PR #20746:
URL: https://github.com/apache/flink/pull/20746#discussion_r1684351449
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/BaseConversionUtils.java:
##
@@ -0,0 +1,175 @@
+/*
+ * Licensed to the Apache
nuno-c-afonso commented on PR #853:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/853#issuecomment-2239030064
Hi,
The title of the PR references a Jira that is for a KDS connector bug:
- https://issues.apache.org/jira/browse/FLINK-35815
Would it be possible t
[
https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866984#comment-17866984
]
dalongliu edited comment on FLINK-35832 at 7/19/24 12:17 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-35832.
---
Resolution: Fixed
> IFNULL returns incorrect result in Flink SQL
> -
[
https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866984#comment-17866984
]
dalongliu edited comment on FLINK-35832 at 7/19/24 12:17 PM:
-
lsyldliu merged PR #25105:
URL: https://github.com/apache/flink/pull/25105
--
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
lsyldliu merged PR #25106:
URL: https://github.com/apache/flink/pull/25106
--
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
Hi, there.
As requested by the flink project, we have created a Jira user account,
placeholder-flink, for you to use when reporting issues related to The Apache
Software Foundation's projects or products.
Go to https://issues.apache.org/jira/secure/ForgotLoginDetails.jspa
and select to have y
This email has been sent to you in order to verify the authenticity of a
request to create a
Jira account with The Apache Software Foundation. If you requested an account,
please visit
https://selfserve.apache.org/jira-account-verify.html?4c952a84-23a3-4728-854d-abe4d787c9cd
to verify your ema
[
https://issues.apache.org/jira/browse/FLINK-35860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867284#comment-17867284
]
Piotr Nowojski commented on FLINK-35860:
Thanks for closing the ticket [~Weijie
qg-lin commented on PR #3482:
URL: https://github.com/apache/flink-cdc/pull/3482#issuecomment-2238865439
resolve some problems from PR https://github.com/apache/flink-cdc/pull/3039,
thanks for @lvyanquan and @dufeng1010 and @yuxiqian
--
This is an automated message from the Apache Git Se
qg-lin opened a new pull request, #3482:
URL: https://github.com/apache/flink-cdc/pull/3482
(no comment)
--
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-m
[
https://issues.apache.org/jira/browse/FLINK-34865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34865:
---
Labels: github-import pull-request-available (was: github-import)
> [enhancement] [StarRock
yux created FLINK-35868:
---
Summary: Bump Mongo driver version to support Mongo 7.0+
Key: FLINK-35868
URL: https://issues.apache.org/jira/browse/FLINK-35868
Project: Flink
Issue Type: Improvement
dingxin-tech commented on PR #3414:
URL: https://github.com/apache/flink-cdc/pull/3414#issuecomment-2238818725
> > hi, @leonardBang, can you help to review again and merge this?
>
> I append one commit to polish the interface and package, Could you also
take a look ?
sure and l
leonardBang commented on PR #3414:
URL: https://github.com/apache/flink-cdc/pull/3414#issuecomment-2238808223
> hi, @leonardBang, can you help to review again and merge this?
I append one commit to polish the interface and package, Could you also take
a look ?
--
This is an automat
[
https://issues.apache.org/jira/browse/FLINK-31261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-31261.
-
Resolution: Fixed
Implemented in
caf9b23b3208c8b30cdb6c56ff6f334e2342ce5c..999b7a2f2e3a
rkhachatryan merged PR #22046:
URL: https://github.com/apache/flink/pull/22046
--
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.
rkhachatryan commented on PR #22046:
URL: https://github.com/apache/flink/pull/22046#issuecomment-2238758264
Thanks for the review!
Given https://github.com/apache/flink/pull/22046#discussion_r1681407852, I
think the improvement should be significant but not in all cases.
--
This is an
xintongsong commented on code in PR #751:
URL: https://github.com/apache/flink-web/pull/751#discussion_r1684056042
##
docs/data/flink.yml:
##
@@ -15,6 +15,16 @@
# specific language governing permissions and limitations
# under the License
+1.20:
Review Comment:
I'd sugge
[
https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867252#comment-17867252
]
Yue Ma commented on FLINK-35576:
[~roman] [~zakelly] I have read the descriptions of the
[
https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867223#comment-17867223
]
Leonard Xu commented on FLINK-35634:
Cool [~xiqian_yu] !, could we consider mysql to
reswqa commented on code in PR #24952:
URL: https://github.com/apache/flink/pull/24952#discussion_r1683974850
##
docs/content/docs/try-flink/local_installation.md:
##
@@ -141,7 +141,7 @@ You can view the data flow plan for the execution:
Here for the job execution, Flink has
[
https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867204#comment-17867204
]
yux commented on FLINK-35634:
-
Just implemented a primitive demo for `cdcup` in
https://git
[
https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867228#comment-17867228
]
yux commented on FLINK-35634:
-
Seems Paimon / Kafka sink are missing. Will add them soon.
>
dylanhz opened a new pull request, #25105:
URL: https://github.com/apache/flink/pull/25105
## What is the purpose of the change
Fix the incorrect output datatype of `IFNULL`.
## Brief change log
The `IfNullTypeStrategy` previously takes the datatype of nullReplace
flinkbot commented on PR #25105:
URL: https://github.com/apache/flink/pull/25105#issuecomment-2238335317
## CI report:
* 78a12db4db89951145fefa4570a624097291b25e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
showuon commented on code in PR #24952:
URL: https://github.com/apache/flink/pull/24952#discussion_r1684051651
##
docs/content/docs/try-flink/local_installation.md:
##
@@ -141,7 +141,7 @@ You can view the data flow plan for the execution:
Here for the job execution, Flink has
Lordeath commented on PR #3476:
URL: https://github.com/apache/flink-cdc/pull/3476#issuecomment-2238622216
重复修改，取消这次PR
--
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 un
Lordeath closed pull request #3476: add note **Please note that the lib here
refers to the lib of flink-c…
URL: https://github.com/apache/flink-cdc/pull/3476
--
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 t
showuon commented on code in PR #24952:
URL: https://github.com/apache/flink/pull/24952#discussion_r1683998141
##
docs/content/docs/try-flink/local_installation.md:
##
@@ -141,7 +141,7 @@ You can view the data flow plan for the execution:
Here for the job execution, Flink has
flinkbot commented on PR #25106:
URL: https://github.com/apache/flink/pull/25106#issuecomment-2238612503
## CI report:
* f826267f58ff5dcaed2837e1989110290d47ada4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dylanhz opened a new pull request, #25106:
URL: https://github.com/apache/flink/pull/25106
## What is the purpose of the change
Fix the incorrect output datatype of `IFNULL`.
## Brief change log
The `IfNullTypeStrategy` previously takes the datatype of nullReplacement
[
https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867226#comment-17867226
]
Leonard Xu commented on FLINK-35634:
Ignore my above comment, I saw you've did it, p
[
https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35634:
--
Assignee: yux
> Add a CDC quickstart utility
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867206#comment-17867206
]
Zakelly Lan commented on FLINK-35576:
-
[~roman] I read the description of those two,
57 matches
Mail list logo
