[
https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zheng_shengsheng updated FLINK-35852:
-
Description:
When I use CDC's yaml mode to collect MySQL data to Doris, I use the latest
[
https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zheng_shengsheng updated FLINK-35852:
-
Description:
When I use CDC's yaml mode to collect MySQL data to Doris, I use the latest
[
https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zheng_shengsheng updated FLINK-35852:
-
Description:
When I use CDC's yaml mode to collect MySQL data to Doris, I use the latest
RocMarshal commented on PR #25134:
URL: https://github.com/apache/flink/pull/25134#issuecomment-2266352507
@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
jeyhunkarimov commented on PR #24997:
URL: https://github.com/apache/flink/pull/24997#issuecomment-2266239143
@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
jeyhunkarimov commented on PR #24997:
URL: https://github.com/apache/flink/pull/24997#issuecomment-226622
@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
eskabetxe commented on PR #108:
URL:
https://github.com/apache/flink-connector-jdbc/pull/108#issuecomment-2265871686
@Mrart can you rebase and add a test?
--
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
kellydkim commented on PR #23725:
URL: https://github.com/apache/flink/pull/23725#issuecomment-2265826957
Hi @Samrat002,
I am seeing that this bug also impacts `CompressWriterFactory` as it creates
a `NoCompressionBulkWriter` which also uses a `FSDataOutputStream` thus has the
same i
zakhalex commented on PR #3445:
URL: https://github.com/apache/flink-cdc/pull/3445#issuecomment-2265783357
@ChengJie1053 - I have opened a pull request to your master branch, as well
as to apache master branch with a list of fixes and changes to the code your
proposed - my pull request to a
zakhalex opened a new pull request, #3507:
URL: https://github.com/apache/flink-cdc/pull/3507
This pull request reuses the contribution under
https://github.com/apache/flink-cdc/pull/3445 and fixes the outstanding issues
in the underlying code to get it fully operational.
--
This is an a
mateczagany commented on PR #821:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/821#issuecomment-2265719872
I rebased the branch on top of main, but I also pushed commit
566caf9ba7220e8a53dc520822621db2928eafa4
--
This is an automated message from the Apache Git Service.
gaborgsomogyi commented on PR #25149:
URL: https://github.com/apache/flink/pull/25149#issuecomment-2265710501
@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
19priyadhingra commented on PR #141:
URL:
https://github.com/apache/flink-connector-aws/pull/141#issuecomment-2265687290
> > Do you have any suggestion on how can I fix my test case without
reverting that PR?
>
> Hi @19priyadhingra, we can either debug the local stack issue, or consi
flinkbot commented on PR #25150:
URL: https://github.com/apache/flink/pull/25150#issuecomment-2265680671
## CI report:
* 548ffab03f77ac5c1c137c79b29b8912f3db9a69 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35934:
---
Labels: pull-request-available (was: )
> Add CompiledPlan annotations to BatchExecValues
>
jnh5y opened a new pull request, #25150:
URL: https://github.com/apache/flink/pull/25150
## What is the purpose of the change
* In addition to the annotations, implement a BatchRestoreTest for this
operator.
* Moves the ValuesTestPrograms to a common package for re-use between
str
[
https://issues.apache.org/jira/browse/FLINK-34840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870577#comment-17870577
]
Andrew Otto commented on FLINK-34840:
-
I would love to see this! At the Wikimedia F
flinkbot commented on PR #25149:
URL: https://github.com/apache/flink/pull/25149#issuecomment-2265557660
## CI report:
* 13ee40c5fdad32dd273464ea1623c46922cb63f1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35969:
---
Labels: pull-request-available (was: )
> Remove deprecated dataset based API from State Pro
gaborgsomogyi opened a new pull request, #25149:
URL: https://github.com/apache/flink/pull/25149
## What is the purpose of the change
This PR removes deprecated dataset based API from State Processor API.
## Brief change log
Remove deprecated dataset based API from State
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-26050.
-
Resolution: Fixed
Merged as
[cd722033fb326837a80a6233603d12ad176da15c|https://github.co
[
https://issues.apache.org/jira/browse/FLINK-35970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-35970:
--
Summary: Update documentation about FLINK-26050 (merging small SST files)
(was: Updat
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-26050:
--
Fix Version/s: 1.20.0
(was: 2.0.0)
> Too many small sst files i
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870541#comment-17870541
]
Roman Khachatryan edited comment on FLINK-26050 at 8/2/24 2:29 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870541#comment-17870541
]
Roman Khachatryan commented on FLINK-26050:
---
[~Weijie Guo] I created a separat
[
https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870541#comment-17870541
]
Roman Khachatryan edited comment on FLINK-26050 at 8/2/24 2:29 PM:
---
Roman Khachatryan created FLINK-35970:
-
Summary: Update documentation about FLINK-26050 (small file
compaction)
Key: FLINK-35970
URL: https://issues.apache.org/jira/browse/FLINK-35970
Project: Fli
wuchong commented on PR #25112:
URL: https://github.com/apache/flink/pull/25112#issuecomment-2265359276
Hi @MartijnVisser , This is mainly for shading protobuf dependency in SQL
format jars (ORC, protobuf) and flink-python. They are all not in the default
distribution. So no changes in Flin
[
https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-35877:
---
Assignee: zhuanshenbsj1
> Shade protobuf in flink
> ---
>
> Key
[
https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-35877:
Fix Version/s: 2.0.0
(was: 1.19.2)
> Shade protobuf in flink
>
[
https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-35877:
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
(was: BuildSystem / Shad
reswqa commented on PR #200:
URL: https://github.com/apache/flink-docker/pull/200#issuecomment-2265293796
Hi @EladLeev,thanks for reminding me, otherwise I wouldn't have noticed this.
But this image is uploaded by docker official, would you mind also posting
this issue to https://gith
EladLeev commented on PR #200:
URL: https://github.com/apache/flink-docker/pull/200#issuecomment-2265216886
Hey @reswqa @1996fanrui -- have you noticed that the `amd` build is missing?
It's in the metadata file, but not on Docker Hub:
https://github.com/user-attachments/assets/473d2794-d4
[
https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-35969:
-
Assignee: Gabor Somogyi
> Remove deprecated dataset based API from State Processor API
Gabor Somogyi created FLINK-35969:
-
Summary: Remove deprecated dataset based API from State Processor
API
Key: FLINK-35969
URL: https://issues.apache.org/jira/browse/FLINK-35969
Project: Flink
rmetzger commented on PR #25147:
URL: https://github.com/apache/flink/pull/25147#issuecomment-2265125302
Minor note: the commit message does not include the `[hotfix]` prefix.
I don't understand how this change is fixing the npm build issue. Can you
explain?
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-35933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-35933.
-
Resolution: Fixed
cdf43aecafa33a50a4b4b6841c4cf505b195994a
> Skip distributing maxAllow
rkhachatryan merged PR #25136:
URL: https://github.com/apache/flink/pull/25136
--
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.
[
https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870454#comment-17870454
]
Jiabao Sun commented on FLINK-35968:
Thanks [~loserwang1024] for the volunteering, a
[
https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun reassigned FLINK-35968:
--
Assignee: Hongshun Wang
> Remove flink-cdc-runtime depedency from connectors
> --
[
https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870453#comment-17870453
]
Hongshun Wang commented on FLINK-35968:
---
[~Leonard] , [~ruanhang1993] , [~jiabaosu
Hongshun Wang created FLINK-35968:
-
Summary: Remove flink-cdc-runtime depedency from connectors
Key: FLINK-35968
URL: https://issues.apache.org/jira/browse/FLINK-35968
Project: Flink
Issue Ty
yuxiqian commented on PR #3506:
URL: https://github.com/apache/flink-cdc/pull/3506#issuecomment-2265007350
Could @Jiabao-Sun @loserwang1024 please 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 ab
ruanhang1993 merged PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319
--
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...@flin
flinkbot commented on PR #25148:
URL: https://github.com/apache/flink/pull/25148#issuecomment-2264988127
## CI report:
* 603514127980c4ad15105353a62e061bc18a3f7f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa opened a new pull request, #25148:
URL: https://github.com/apache/flink/pull/25148
(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-mai
[
https://issues.apache.org/jira/browse/FLINK-35957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-35957.
Resolution: Done
> Other announcements
> ---
>
> Key: FLINK-35957
[
https://issues.apache.org/jira/browse/FLINK-35954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-35954.
Resolution: Done
> Merge website pull request
> --
>
> Key
flinkbot commented on PR #25147:
URL: https://github.com/apache/flink/pull/25147#issuecomment-2264953408
## CI report:
* 77a55b95c7f6fd9bbd767dbf275e69822aeead47 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-35956.
Resolution: Done
> Apache mailing lists announcements
> --
>
>
dylanhz commented on PR #25137:
URL: https://github.com/apache/flink/pull/25137#issuecomment-2264916761
@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.
dylanhz commented on PR #25146:
URL: https://github.com/apache/flink/pull/25146#issuecomment-2264915459
@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.
Samrat002 opened a new pull request, #25147:
URL: https://github.com/apache/flink/pull/25147
## 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
Zakelly commented on code in PR #25135:
URL: https://github.com/apache/flink/pull/25135#discussion_r1701529111
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -179,9 +181,12 @@ public
1996fanrui merged PR #752:
URL: https://github.com/apache/flink-web/pull/752
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-35678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870069#comment-17870069
]
Rui Fan edited comment on FLINK-35678 at 8/2/24 8:33 AM:
-
Merged
[
https://issues.apache.org/jira/browse/FLINK-35678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-35678.
-
Resolution: Fixed
> [Release-1.20] Review and update documentation
> ---
1996fanrui merged PR #25140:
URL: https://github.com/apache/flink/pull/25140
--
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.ap
GOODBOY008 commented on PR #3497:
URL: https://github.com/apache/flink-cdc/pull/3497#issuecomment-2264851637
@LiPL2017 I make some change about uuid compare method by refering to MS
source code. Can you doule check ?
--
This is an automated message from the Apache Git Service.
To respond
1996fanrui opened a new pull request, #752:
URL: https://github.com/apache/flink-web/pull/752
Rebuild website for 1.20 announcement.
--
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 c
fredia commented on code in PR #25135:
URL: https://github.com/apache/flink/pull/25135#discussion_r1701487658
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -179,9 +181,12 @@ public
dylanhz commented on code in PR #25137:
URL: https://github.com/apache/flink/pull/25137#discussion_r1701484163
##
docs/data/sql_functions.yml:
##
@@ -304,7 +304,13 @@ string:
not exceed the number of the defined groups.
E.g. REGEXP_EXTRACT('foothebar', 'foo(.*?)(
zhuanshenbsj1 commented on PR #25112:
URL: https://github.com/apache/flink/pull/25112#issuecomment-2264822929
> Thanks for the contribution. I left 2 minor comments.
Done~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
loserwang1024 commented on PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#issuecomment-2264818839
Just rebase this pr to master.
--
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
[
https://issues.apache.org/jira/browse/FLINK-35965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870403#comment-17870403
]
Eaugene Thomas commented on FLINK-35965:
Sure [~dylanhz]
> Add ENDSWITH functi
superdiaodiao commented on code in PR #25137:
URL: https://github.com/apache/flink/pull/25137#discussion_r1701430328
##
docs/data/sql_functions.yml:
##
@@ -304,7 +304,13 @@ string:
not exceed the number of the defined groups.
E.g. REGEXP_EXTRACT('foothebar', 'foo
superdiaodiao commented on code in PR #25137:
URL: https://github.com/apache/flink/pull/25137#discussion_r1701430328
##
docs/data/sql_functions.yml:
##
@@ -304,7 +304,13 @@ string:
not exceed the number of the defined groups.
E.g. REGEXP_EXTRACT('foothebar', 'foo
[
https://issues.apache.org/jira/browse/FLINK-35864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867725#comment-17867725
]
Dylan He edited comment on FLINK-35864 at 8/2/24 7:22 AM:
--
The
luotianyou349 commented on PR #25146:
URL: https://github.com/apache/flink/pull/25146#issuecomment-2264734633
Wow!
--
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 unsubs
reswqa merged PR #751:
URL: https://github.com/apache/flink-web/pull/751
--
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
70 matches
Mail list logo