zhongqishang commented on code in PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#discussion_r1581741205
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/DataChangeEventSerializer.java:
##
@@ -76,28 +72,18 @@ public DataChangeEvent
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841427#comment-17841427
]
Roman Boyko commented on FLINK-34694:
-
Hi [~xu_shuai_] !
Could you please take a look on benchmark
caicancai commented on code in PR #116:
URL:
https://github.com/apache/flink-connector-jdbc/pull/116#discussion_r1581771380
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java:
##
@@ -77,17 +81,42 @@ public JdbcCatalog(
Wei Yuan created FLINK-35249:
Summary: Support DataGeneratorSource in PyFlink
Key: FLINK-35249
URL: https://issues.apache.org/jira/browse/FLINK-35249
Project: Flink
Issue Type: Improvement
HappyHacker123 commented on PR #2754:
URL: https://github.com/apache/flink-cdc/pull/2754#issuecomment-2080436418
> Hi @HappyHacker123, could you please rebase this PR with latest `master`
branch and trigger the CI? Thanks for your contribution!
Sure, I rebase it the latest branch :).
RocMarshal opened a new pull request, #24732:
URL: https://github.com/apache/flink/pull/24732
## What is the purpose of the change
[FLINK-32852][JUnit5 Migration] Migrate the scheduler package of
flink-runtime module to JUnit5
## Brief change log
RocMarshal commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1581796658
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -104,6 +122,7 @@ drwxr-xr-x 2 60 May 12 09:46
a6031ec7-ab3e-4b30-ba77-6498e58e6b7f
flinkbot commented on PR #24733:
URL: https://github.com/apache/flink/pull/24733#issuecomment-2080464738
## CI report:
* b897027bc10b1311e55343f114c77675d74aaeb0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841454#comment-17841454
]
slankka commented on FLINK-33424:
-
[[FLINK-29797][flink-yarn] Fix fs.default-scheme will accidentally
syhily commented on PR #90:
URL:
https://github.com/apache/flink-connector-pulsar/pull/90#issuecomment-2080596125
OK, LGTM. We need to get the CI pass, finally.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
RocMarshal closed pull request #24732: [FLINK-32852][JUnit5 Migration] Migrate
the scheduler package of flink-runtime module to JUnit5
URL: https://github.com/apache/flink/pull/24732
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot commented on PR #24734:
URL: https://github.com/apache/flink/pull/24734#issuecomment-2080721796
## CI report:
* 2b649b6a548b4d65f92e62af7a90726790bb1ed8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841485#comment-17841485
]
Juan Zifeng commented on FLINK-35250:
-
hi,[~jark] could you please assign this to me?
> Translate
[
https://issues.apache.org/jira/browse/FLINK-35250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juan Zifeng closed FLINK-35250.
---
Resolution: Fixed
> Translate the "Flink Operations Playground" page into Chinese
>
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1581788455
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1581788552
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1581788381
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -104,6 +122,7 @@ drwxr-xr-x 2 60 May 12 09:46
a6031ec7-ab3e-4b30-ba77-6498e58e6b7f
caicancai commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1581788600
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,78 +24,96 @@ specific language governing permissions and limitations
under the License.
flinkbot commented on PR #24732:
URL: https://github.com/apache/flink/pull/24732#issuecomment-2080447608
## CI report:
* 124041f083b50ff8d109ea59314b03f45cea3dde UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
slankka opened a new pull request, #24733:
URL: https://github.com/apache/flink/pull/24733
…se temporary flinkConfigFile treated as remote file. also fix [FLINK-33424]
## What is the purpose of the change
If user set fs.default-scheme to hdfs://namenode or s3://any, it will
[
https://issues.apache.org/jira/browse/FLINK-29797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841455#comment-17841455
]
slankka commented on FLINK-29797:
-
Please assign to me...
> can't run a job on yarn, if set
caicancai opened a new pull request, #24734:
URL: https://github.com/apache/flink/pull/24734
## 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
RocMarshal commented on PR #116:
URL:
https://github.com/apache/flink-connector-jdbc/pull/116#issuecomment-2080456998
Thanks @caicancai for the review.
Could @1996fanrui you help take a look if you had the free time ?
Thank you~
--
This is an automated message from the Apache Git
HCTommy closed pull request #24520: [FLINK-34721][Test]Correct
BarrierAlignmentUtilTest Exception explanation
URL: https://github.com/apache/flink/pull/24520
--
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
[
https://issues.apache.org/jira/browse/FLINK-29797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29797:
---
Labels: pull-request-available (was: )
> can't run a job on yarn, if set fs.default-scheme
caicancai commented on PR #24734:
URL: https://github.com/apache/flink/pull/24734#issuecomment-2080717766
@1996fanrui @RocMarshal If you have time, can you help me take a look at
this PR? Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message,
Juan Zifeng created FLINK-35250:
---
Summary: Translate the "Flink Operations Playground" page into
Chinese
Key: FLINK-35250
URL: https://issues.apache.org/jira/browse/FLINK-35250
Project: Flink
Qingsheng Ren created FLINK-35251:
-
Summary: SchemaDerivation serializes mapping incorrectly on
checkpoint
Key: FLINK-35251
URL: https://issues.apache.org/jira/browse/FLINK-35251
Project: Flink
IgnasD commented on code in PR #97:
URL:
https://github.com/apache/flink-connector-kafka/pull/97#discussion_r1581844568
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumeratorTest.java:
##
@@ -464,6 +466,87
GOODBOY008 commented on PR #90:
URL:
https://github.com/apache/flink-connector-pulsar/pull/90#issuecomment-2080904045
@syhily CI passed~
--
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-35251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35251:
---
Labels: pull-request-available (was: )
> SchemaDerivation serializes mapping incorrectly
jeyhunkarimov commented on PR #24600:
URL: https://github.com/apache/flink/pull/24600#issuecomment-2081151799
Hi @lsyldliu thanks for the review. I addressed your comments. Could you
please check in your available time? Thanks!
--
This is an automated message from the Apache Git Service.
jeyhunkarimov commented on code in PR #24600:
URL: https://github.com/apache/flink/pull/24600#discussion_r1581891157
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/program/DynamicPartitionPruningProgramTest.java:
##
@@ -81,6 +87,42
mas-chen commented on PR #97:
URL:
https://github.com/apache/flink-connector-kafka/pull/97#issuecomment-2081161614
Rerunning CI--seems to be flaky behavior in IT tests:
```
2024-04-27T19:26:47.5915234Z 19:26:47,500 [Flat Map (1/1)#0] WARN
[
https://issues.apache.org/jira/browse/FLINK-35251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841551#comment-17841551
]
Leonard Xu commented on FLINK-35251:
fixed in
master(3.2) via
aiwenmo commented on PR #3228:
URL: https://github.com/apache/flink-cdc/pull/3228#issuecomment-2081282383
Due to optimization of JaninoCompiler, this PR also solves the problem of
outputting empty values when there are only constants in the calculation column.
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-35253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841565#comment-17841565
]
Juan Zifeng commented on FLINK-35253:
-
Hi [~jark],could you assign this to me?
> State Processor
Juan Zifeng created FLINK-35253:
---
Summary: State Processor API
Key: FLINK-35253
URL: https://issues.apache.org/jira/browse/FLINK-35253
Project: Flink
Issue Type: Improvement
Myasuka commented on PR #24689:
URL: https://github.com/apache/flink/pull/24689#issuecomment-2081310552
> @Myasuka Thx u for your reply. Maybe we can create a new Jira to discuss
how to works in standalone env. Can you review this pr first？
Flink already supports self-profiling in
hongxu han created FLINK-35252:
--
Summary: Update the operators marked as deprecated in the instance
program on the official website
Key: FLINK-35252
URL: https://issues.apache.org/jira/browse/FLINK-35252
[
https://issues.apache.org/jira/browse/FLINK-35252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841559#comment-17841559
]
hongxu han commented on FLINK-35252:
i am willing to contribute, can you assign this translation
1996fanrui merged PR #818:
URL: https://github.com/apache/flink-kubernetes-operator/pull/818
--
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-35253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juan Zifeng updated FLINK-35253:
Summary: Translate "State Processor API "page into Chinese (was: State
Processor API )
>
RocMarshal commented on PR #116:
URL:
https://github.com/apache/flink-connector-jdbc/pull/116#issuecomment-2081320858
Hi, @eskabetxe Would you mind having take a look if you had the free time ?
Many thx!
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841547#comment-17841547
]
Kenneth William Krugler commented on FLINK-35215:
-
Hi [~fanrui] - thanks for the
[
https://issues.apache.org/jira/browse/FLINK-20400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841555#comment-17841555
]
Muhammet Orazov commented on FLINK-20400:
-
Hello [~jark], [~mapohl],
Could you please assign
xishuaidelin commented on code in PR #24703:
URL: https://github.com/apache/flink/pull/24703#discussion_r1581998200
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/StreamingMiniBatchJoinOperatorTest.java:
##
@@ -1953,4
xishuaidelin commented on code in PR #24703:
URL: https://github.com/apache/flink/pull/24703#discussion_r1581998200
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/stream/StreamingMiniBatchJoinOperatorTest.java:
##
@@ -1953,4
syhily commented on PR #90:
URL:
https://github.com/apache/flink-connector-pulsar/pull/90#issuecomment-2081289722
@tisonkun
--
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
mas-chen commented on code in PR #97:
URL:
https://github.com/apache/flink-connector-kafka/pull/97#discussion_r1581993642
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumeratorTest.java:
##
@@ -464,6
xieyi888 commented on PR #3265:
URL: https://github.com/apache/flink-cdc/pull/3265#issuecomment-2081280906
It seems the failed CI test was not caused by this 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
lsyldliu commented on code in PR #24600:
URL: https://github.com/apache/flink/pull/24600#discussion_r1581993829
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java:
##
@@ -236,6 +238,9 @@ private void
yuxiqian opened a new pull request, #3270:
URL: https://github.com/apache/flink-cdc/pull/3270
This PR fixes `route` definition YAML example in Flink CDC core concept
documentations.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
1996fanrui commented on code in PR #24653:
URL: https://github.com/apache/flink/pull/24653#discussion_r1582006329
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorFactory.java:
##
@@ -56,15 +64,32 @@
[
https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841564#comment-17841564
]
Juntao Hu commented on FLINK-33268:
---
Sorry to comment on a closed issue, but I wonder why ignoring
yuxiqian opened a new pull request, #3269:
URL: https://github.com/apache/flink-cdc/pull/3269
This PR fixes `route` definition YAML example in Flink CDC core concept
documentations.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Weijie Guo created FLINK-35254:
--
Summary: build_wheels_on_macos failed
Key: FLINK-35254
URL: https://issues.apache.org/jira/browse/FLINK-35254
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35254:
---
Description:
{code:java}
ERROR: THESE PACKAGES DO NOT MATCH THE HASHES FROM THE REQUIREMENTS FILE.
reswqa commented on PR #22026:
URL: https://github.com/apache/flink/pull/22026#issuecomment-2081341787
@davidradl IIRC, `SqlGatewayEndpointFacory` should be already present in
`release-1.18` 樂
see:
mas-chen commented on code in PR #97:
URL:
https://github.com/apache/flink-connector-kafka/pull/97#discussion_r1581993642
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumeratorTest.java:
##
@@ -464,6
[
https://issues.apache.org/jira/browse/FLINK-35253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-35253:
--
Assignee: Juan Zifeng
> Translate "State Processor API "page into Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-35253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841579#comment-17841579
]
Weijie Guo commented on FLINK-35253:
Thanks, you are assigned.
> Translate "State Processor API
yeezychao commented on PR #24689:
URL: https://github.com/apache/flink/pull/24689#issuecomment-2081342644
@Myasuka Sorry, I still don't understand what you mean, what do I need to
do. Because I tested the standalone cluster locally and could not use the
**async-profiler**. Is there any
leonardBang merged PR #3267:
URL: https://github.com/apache/flink-cdc/pull/3267
--
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-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841578#comment-17841578
]
Weijie Guo commented on FLINK-34273:
65 matches
Mail list logo
