Airblader merged pull request #18619:
URL: https://github.com/apache/flink/pull/18619
--
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-unsub
Airblader merged pull request #18620:
URL: https://github.com/apache/flink/pull/18620
--
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-unsub
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
imaffe commented on a change in pull request #17452:
URL: https://github.com/apache/flink/pull/17452#discussion_r800452443
##
File path:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java
##
@@ -0,0 +1,203 @@
+
imaffe commented on a change in pull request #17452:
URL: https://github.com/apache/flink/pull/17452#discussion_r800452443
##
File path:
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java
##
@@ -0,0 +1,203 @@
+
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487953#comment-17487953
]
Yang Wang edited comment on FLINK-24897 at 2/7/22, 9:17 AM:
[
https://issues.apache.org/jira/browse/FLINK-25782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487985#comment-17487985
]
baisike commented on FLINK-25782:
-
[~RocMarshal] Hi, i‘d like to help with this task. p
KarmaGYZ commented on pull request #18417:
URL: https://github.com/apache/flink/pull/18417#issuecomment-1031238179
Thanks for the review @xintongsong . PR updated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
flinkbot edited a comment on pull request #18641:
URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534
## CI report:
* 4b24b89fae2e59414932476cca62fa6a444ade9a Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo closed FLINK-25741.
--
Resolution: Fixed
> Ignore buffer pools which have no floating buffer in buffer redistributing
> -
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487984#comment-17487984
]
Yangze Guo commented on FLINK-25741:
master: 855348a9ac482f141131c302b21d4a67e4c3e0c
KarmaGYZ closed pull request #18433:
URL: https://github.com/apache/flink/pull/18433
--
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-unsubs
[
https://issues.apache.org/jira/browse/FLINK-25761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487980#comment-17487980
]
baisike commented on FLINK-25761:
-
Hi, [~RocMarshal] I submit a pr
[#18641|https://gith
flinkbot commented on pull request #18641:
URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534
## CI report:
* 4b24b89fae2e59414932476cca62fa6a444ade9a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18641:
URL: https://github.com/apache/flink/pull/18641#issuecomment-1031233276
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pr
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25761:
---
Labels: chinese-translation pull-request-available (was:
chinese-translation)
> Translate
zentol commented on pull request #18566:
URL: https://github.com/apache/flink/pull/18566#issuecomment-1031230801
> Streaming jobs can have multiple pipelined regions, some regions may be
deploying(especially in failure recovery) and others **can be making progress**.
You could argue
MrWhiteSike opened a new pull request #18641:
URL: https://github.com/apache/flink/pull/18641
## 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 the
zentol commented on pull request #18566:
URL: https://github.com/apache/flink/pull/18566#issuecomment-1031229601
> Should the deploying time also include SCHEDULED time?
I don't think so; I'd rather have separate metrics for the scheduling (and
initialization for that matter).
Thi
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483689#comment-17483689
]
Biao Geng edited comment on FLINK-24897 at 2/7/22, 9:07 AM:
KarmaGYZ commented on a change in pull request #18360:
URL: https://github.com/apache/flink/pull/18360#discussion_r800442967
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/ExecutionGraphInfoStoreTest.java
##
@@ -0,0 +1,254 @@
+/*
+ * Licensed to
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483689#comment-17483689
]
Biao Geng edited comment on FLINK-24897 at 2/7/22, 9:05 AM:
KarmaGYZ commented on a change in pull request #18360:
URL: https://github.com/apache/flink/pull/18360#discussion_r800388531
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MemoryExecutionGraphInfoStore.java
##
@@ -20,26 +20,72 @@
import org.ap
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487971#comment-17487971
]
Martijn Visser commented on FLINK-25738:
[~baisike] Please let us know which tic
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18439:
URL: https://github.com/apache/flink/pull/18439#issuecomment-1018359750
## CI report:
* ef3a4f559335916ebd9b98903f717651cfc48c41 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18439:
URL: https://github.com/apache/flink/pull/18439#issuecomment-1018359750
## CI report:
* ef3a4f559335916ebd9b98903f717651cfc48c41 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
Yun Gao created FLINK-25972:
---
Summary:
org.apache.calcite.rel.metadata.JaninoRelMetadataProvider#HANDLERS might cause
class leaks
Key: FLINK-25972
URL: https://issues.apache.org/jira/browse/FLINK-25972
Pro
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-25895.
Fix Version/s: 1.15.0
Resolution: Fixed
Fixed in master: 2e910a66a92c3bfec2dd4abfa8d0d7a01b
Yun Gao created FLINK-25971:
---
Summary:
org.apache.flink.table.planner.plan.nodes.exec.serde.JsonSerdeUtil#OBJECT_MAPPER_INSTANCE
might cause class leaks
Key: FLINK-25971
URL: https://issues.apache.org/jira/browse/FLINK
flinkbot edited a comment on pull request #18540:
URL: https://github.com/apache/flink/pull/18540#issuecomment-1023208881
## CI report:
* c55c49cd2b7b66849f6efaa5f640c304da0b1238 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
twalthr closed pull request #18572:
URL: https://github.com/apache/flink/pull/18572
--
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-unsubsc
[
https://issues.apache.org/jira/browse/FLINK-25970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-25970:
-
Labels: starter (was: )
> SerializedThrowable should record type of the original throwable.
> -
dannycranmer commented on a change in pull request #18613:
URL: https://github.com/apache/flink/pull/18613#discussion_r800416433
##
File path:
flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java
##
flinkbot edited a comment on pull request #18573:
URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917
## CI report:
* e585a55d07664fa73c253973d26c45bb0ed89b5d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18540:
URL: https://github.com/apache/flink/pull/18540#issuecomment-1023208881
## CI report:
* c55c49cd2b7b66849f6efaa5f640c304da0b1238 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
zentol commented on a change in pull request #18566:
URL: https://github.com/apache/flink/pull/18566#discussion_r800416870
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/metrics/DeploymentStateTimeMetrics.java
##
@@ -0,0 +1,168 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-25944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25944:
--
Issue Type: Bug (was: New Feature)
> Intermittent Failures on KDF AZP
> -
Xintong Song created FLINK-25970:
Summary: SerializedThrowable should record type of the original
throwable.
Key: FLINK-25970
URL: https://issues.apache.org/jira/browse/FLINK-25970
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-25970:
-
Priority: Minor (was: Major)
> SerializedThrowable should record type of the original throwable
[
https://issues.apache.org/jira/browse/FLINK-25965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487957#comment-17487957
]
Martijn Visser commented on FLINK-25965:
[~nir.tsruya] Please keep in mind that
zhuzhurk edited a comment on pull request #18566:
URL: https://github.com/apache/flink/pull/18566#issuecomment-1031190700
Thanks for opening this PR! @zentol
I think it can be quite helpful if users can see the deploying time. In my
understanding, it can well measure how fast a job can
xuzifu666 commented on pull request #18562:
URL: https://github.com/apache/flink/pull/18562#issuecomment-1031194114
@StephanEwen have a review please, thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
Yun Gao created FLINK-25969:
---
Summary: org.apache.flink.table.runtime.generated.CompileUtils
might cause class leaks
Key: FLINK-25969
URL: https://issues.apache.org/jira/browse/FLINK-25969
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487953#comment-17487953
]
Yang Wang commented on FLINK-24897:
---
[~bgeng777] IIUC, you mean that {{tryFindUserLibD
zhuzhurk edited a comment on pull request #18566:
URL: https://github.com/apache/flink/pull/18566#issuecomment-1031190700
Thanks for opening this PR! @zentol
I think it can be quite helpful if users can see the deploying time. In my
understanding, it can well measure how fast a job can
[
https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487955#comment-17487955
]
Martijn Visser commented on FLINK-25825:
[~RocMarshal] This is happening when ru
xuzifu666 commented on pull request #18562:
URL: https://github.com/apache/flink/pull/18562#issuecomment-1031192356
@hadronzoo
--
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 comme
zhuzhurk edited a comment on pull request #18566:
URL: https://github.com/apache/flink/pull/18566#issuecomment-1031190700
Thanks for opening this PR! @zentol
I think it can be quite helpful if users can see the deploying time. In my
understanding, it can well measure how fast a job can
Yun Gao created FLINK-25968:
---
Summary: Possible class leaks in flink-table / sql modules
Key: FLINK-25968
URL: https://issues.apache.org/jira/browse/FLINK-25968
Project: Flink
Issue Type: Bug
zhuzhurk commented on pull request #18566:
URL: https://github.com/apache/flink/pull/18566#issuecomment-1031190700
Thanks for opening this PR! @zentol
I think it can be quite helpful if users can see the deploying time. In my
understanding, it can well measure how fast a job can start w
[
https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487943#comment-17487943
]
baisike commented on FLINK-25738:
-
Hi, [~RocMarshal] [~MartijnVisser] i may offer some h
501 - 566 of 566 matches
Mail list logo