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
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:
[
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
[
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-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.
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-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841578#comment-17841578
]
Weijie Guo commented on FLINK-34273:
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
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 @@
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
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
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
[
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 )
>
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
[
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
[
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
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:
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
[
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
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
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
[
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
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
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
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
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
[
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
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-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
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
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
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.
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
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
[
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
>
[
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
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
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`
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,
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 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
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
[
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
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-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
[
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
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
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
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
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 #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`
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
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.
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_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_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
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 :).
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(
[
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
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
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
65 matches
Mail list logo