flinkbot edited a comment on pull request #18415:
URL: https://github.com/apache/flink/pull/18415#issuecomment-1017200363
## CI report:
* b6b983201168ccd9a5c4c019094562867855d1fb Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18413:
URL: https://github.com/apache/flink/pull/18413#issuecomment-1017179392
## CI report:
* 9d960019b5f391580eb36849b8a42d45721c517a Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
Airblader commented on a change in pull request #18413:
URL: https://github.com/apache/flink/pull/18413#discussion_r788463913
##
File path:
flink-runtime-web/web-dashboard/src/app/share/customize/job-badge/job-badge.component.spec.ts
##
@@ -22,10 +22,8 @@ import { JobBadgeComp
flinkbot edited a comment on pull request #18413:
URL: https://github.com/apache/flink/pull/18413#issuecomment-1017179392
## CI report:
* 9d960019b5f391580eb36849b8a42d45721c517a Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479153#comment-17479153
]
Martijn Visser commented on FLINK-11838:
Thanks for taking of this [~galenwarren
flinkbot edited a comment on pull request #18415:
URL: https://github.com/apache/flink/pull/18415#issuecomment-1017200363
## CI report:
* b6b983201168ccd9a5c4c019094562867855d1fb Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
dawidwys commented on pull request #18405:
URL: https://github.com/apache/flink/pull/18405#issuecomment-1017202257
@paul8263 I investigated it a bit further and I posted a comment in JIRA.
Could you please take a look there?
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479152#comment-17479152
]
Dawid Wysakowicz commented on FLINK-25683:
--
Sorry, I have not spotted that befo
flinkbot commented on pull request #18415:
URL: https://github.com/apache/flink/pull/18415#issuecomment-1017200363
## CI report:
* b6b983201168ccd9a5c4c019094562867855d1fb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18137:
URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034
## CI report:
* 66280958ba0046cbef940e575fc61a4ec6d62253 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
yangjunhan commented on a change in pull request #18413:
URL: https://github.com/apache/flink/pull/18413#discussion_r788451618
##
File path:
flink-runtime-web/web-dashboard/src/app/share/customize/job-badge/job-badge.component.spec.ts
##
@@ -22,10 +22,8 @@ import { JobBadgeCom
flinkbot commented on pull request #18415:
URL: https://github.com/apache/flink/pull/18415#issuecomment-1017198785
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 #18137:
URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034
## CI report:
* 66280958ba0046cbef940e575fc61a4ec6d62253 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Jesuitry opened a new pull request #18415:
URL: https://github.com/apache/flink/pull/18415
If Flink 1.10 is used, this JobListener is not used after it is created, so
the Hook does not take effect. It can take effect after adding the following
code.
JobListener listener = factory.create
PatrickRen commented on pull request #18137:
URL: https://github.com/apache/flink/pull/18137#issuecomment-1017194128
@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 speci
PatrickRen commented on pull request #18137:
URL: https://github.com/apache/flink/pull/18137#issuecomment-1017193996
Thanks for the reminder @leonardBang ! I made some force pushes and the CI
has been green in my own pipeline. I will trigger another CI run via flinkbot.
--
This is an aut
flinkbot edited a comment on pull request #18324:
URL: https://github.com/apache/flink/pull/18324#issuecomment-1009752905
## CI report:
* d07846bf2cc1c1925b7cacc1f9d7f186ba58b0e0 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu
[
https://issues.apache.org/jira/browse/FLINK-25660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-25660.
--
Resolution: Not A Bug
> Failed to build flink-runtime-web
> -
>
>
Airblader commented on a change in pull request #18413:
URL: https://github.com/apache/flink/pull/18413#discussion_r788439553
##
File path:
flink-runtime-web/web-dashboard/src/app/share/customize/job-badge/job-badge.component.spec.ts
##
@@ -22,10 +22,8 @@ import { JobBadgeComp
[
https://issues.apache.org/jira/browse/FLINK-25660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479140#comment-17479140
]
Aitozi commented on FLINK-25660:
[~guoyangze] , [~junhany] Thanks for your guidance, I h
dawidwys commented on a change in pull request #18405:
URL: https://github.com/apache/flink/pull/18405#discussion_r788440766
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
##
@@ -323,7 +323,9 @@ protected b
[
https://issues.apache.org/jira/browse/FLINK-25200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479139#comment-17479139
]
Yun Tang commented on FLINK-25200:
--
[~akalashnikov] I think we should run tests to mock
flinkbot edited a comment on pull request #18324:
URL: https://github.com/apache/flink/pull/18324#issuecomment-1009752905
## CI report:
* ce08a46add96553021558f2af3ecebc74a93e4e4 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18137:
URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034
## CI report:
* 66280958ba0046cbef940e575fc61a4ec6d62253 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #18324:
URL: https://github.com/apache/flink/pull/18324#issuecomment-1009752905
## CI report:
* ce08a46add96553021558f2af3ecebc74a93e4e4 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479115#comment-17479115
]
Yun Gao edited comment on FLINK-24163 at 1/20/22, 7:22 AM:
---
Th
paul8263 commented on a change in pull request #18405:
URL: https://github.com/apache/flink/pull/18405#discussion_r788434023
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
##
@@ -323,7 +323,9 @@ protected b
gaoyunhaii closed pull request #18403:
URL: https://github.com/apache/flink/pull/18403
--
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-unsu
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r788432483
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
##
@@ -368
flinkbot edited a comment on pull request #18414:
URL: https://github.com/apache/flink/pull/18414#issuecomment-1017182067
## CI report:
* 3c3aedefda07bea1b5cf7223b4f0305f469d9e15 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18405:
URL: https://github.com/apache/flink/pull/18405#issuecomment-1017071379
## CI report:
* 6229193f6adeedd62e7d5f0dcee9e6098e49ed9e Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
simenliuxing commented on pull request #18414:
URL: https://github.com/apache/flink/pull/18414#issuecomment-1017183560
@wenlong88 hello, can you help me review the code
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
yangjunhan commented on pull request #18413:
URL: https://github.com/apache/flink/pull/18413#issuecomment-1017183214
I have to explicitly add `@ant-design/icons-angular` as a dependency for
`flink-runtime-web` even thought it is a dependency for NG-ZORRO.
When I ran `npm install` und
flinkbot commented on pull request #18414:
URL: https://github.com/apache/flink/pull/18414#issuecomment-1017182067
## CI report:
* 3c3aedefda07bea1b5cf7223b4f0305f469d9e15 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18413:
URL: https://github.com/apache/flink/pull/18413#issuecomment-1017179392
## CI report:
* 9d960019b5f391580eb36849b8a42d45721c517a Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
Zakelly commented on pull request #18402:
URL: https://github.com/apache/flink/pull/18402#issuecomment-1017181880
Thanks for the PR! Overall it looks good to me. Would you mind removing the
"No thread-safe" from the java doc of this class? Thanks.
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-25700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479129#comment-17479129
]
simenliuxing commented on FLINK-25700:
--
[~wenlong.lwl] Thank you for your reply, I
flinkbot commented on pull request #18414:
URL: https://github.com/apache/flink/pull/18414#issuecomment-1017180731
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 commented on pull request #18413:
URL: https://github.com/apache/flink/pull/18413#issuecomment-1017179392
## CI report:
* 9d960019b5f391580eb36849b8a42d45721c517a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #18413:
URL: https://github.com/apache/flink/pull/18413#issuecomment-1017179083
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
simenliuxing opened a new pull request #18414:
URL: https://github.com/apache/flink/pull/18414
## What is the purpose of the change
Aliases need to be used under Cascading Window Aggregation, otherwise an
error will be reported, but there is no such thing in the documentation, so I
[
https://issues.apache.org/jira/browse/FLINK-24768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24768:
---
Labels: pull-request-available (was: )
> Upgrade Web Frontend to Angular v13 and NG-Zorro v
yangjunhan opened a new pull request #18413:
URL: https://github.com/apache/flink/pull/18413
## What is the purpose of the change
Upgrade Flink Runtime Web's dependencies Angular and NG-ZORRO versions to
13. Close [FLINK-24768](https://issues.apache.org/jira/browse/FLINK-2476
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r788418063
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateObject.java
##
@@ -63,4 +63,14 @@
* @return Size of the state in byte
Myasuka commented on a change in pull request #18324:
URL: https://github.com/apache/flink/pull/18324#discussion_r788417725
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java
##
@@ -204,6 +203,21 @@ public long getSt
lindong28 edited a comment on pull request #54:
URL: https://github.com/apache/flink-ml/pull/54#issuecomment-1017123834
Thanks for the PR.
Before we continue to add more and more algorithm, what's our plan to make
sure these algorithm's implementation could meet our performance targe
lindong28 edited a comment on pull request #56:
URL: https://github.com/apache/flink-ml/pull/56#issuecomment-1017123440
Thanks for the PR.
Before we continue to add more and more algorithm, what's our plan to make
sure these algorithm's implementation could meet our performance targe
dawidwys commented on a change in pull request #18405:
URL: https://github.com/apache/flink/pull/18405#discussion_r788410349
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
##
@@ -323,7 +323,9 @@ protected b
ruanhang1993 commented on a change in pull request #17994:
URL: https://github.com/apache/flink/pull/17994#discussion_r788393552
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java
##
@
ruanhang1993 commented on a change in pull request #17994:
URL: https://github.com/apache/flink/pull/17994#discussion_r788383759
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java
##
@
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479121#comment-17479121
]
Dawid Wysakowicz commented on FLINK-18356:
--
[~trohrmann] No, we have not merged
[
https://issues.apache.org/jira/browse/FLINK-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo reassigned FLINK-15455:
--
Assignee: Yangze Guo
> Enable TCP connection reuse across multiple jobs.
> --
flinkbot edited a comment on pull request #18388:
URL: https://github.com/apache/flink/pull/18388#issuecomment-1015205179
## CI report:
* 669c93d03ad065091bd30bbd9d3032244ee075df Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479115#comment-17479115
]
Yun Gao commented on FLINK-24163:
-
Thanks [~roman] for the PR! I'll have a look~
> Par
flinkbot edited a comment on pull request #18404:
URL: https://github.com/apache/flink/pull/18404#issuecomment-1017066728
## CI report:
* 511330acce13b111458ea01a6182ab2749d1d1a6 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
chen-yu342 edited a comment on pull request #8400:
URL: https://github.com/apache/flink/pull/8400#issuecomment-1017157122
> @zhengyifanvp
需要Yarn最低版本为2.6.0；https://github.com/jiasheng55/flink/blob/5517d47329aa62c0046db3df1109fc273f07051a/flink-yarn/src/main/java/org/apache/flink/yarn/Abstrac
chen-yu342 edited a comment on pull request #8400:
URL: https://github.com/apache/flink/pull/8400#issuecomment-1017157122
> @zhengyifanvp
需要Yarn最低版本为2.6.0；https://github.com/jiasheng55/flink/blob/5517d47329aa62c0046db3df1109fc273f07051a/flink-yarn/src/main/java/org/apache/flink/yarn/Abstrac
LadyForest commented on a change in pull request #18394:
URL: https://github.com/apache/flink/pull/18394#discussion_r788392600
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flink/table/connector/source/TestManagedTableSource.java
##
@@ -0,0 +1,69 @@
+/*
weibozhao commented on pull request #56:
URL: https://github.com/apache/flink-ml/pull/56#issuecomment-1017159409
I get your idea
--
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
ZhangChaoming commented on pull request #18386:
URL: https://github.com/apache/flink/pull/18386#issuecomment-1017159215
@wuchong Hi, Could you please help give a review ? Thanks very much !
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
chen-yu342 edited a comment on pull request #8400:
URL: https://github.com/apache/flink/pull/8400#issuecomment-1017157122
> @zhengyifanvp
需要Yarn最低版本为2.6.0；https://github.com/jiasheng55/flink/blob/5517d47329aa62c0046db3df1109fc273f07051a/flink-yarn/src/main/java/org/apache/flink/yarn/Abstrac
chen-yu342 edited a comment on pull request #8400:
URL: https://github.com/apache/flink/pull/8400#issuecomment-1017157122
> @zhengyifanvp
需要Yarn最低版本为2.6.0；https://github.com/jiasheng55/flink/blob/5517d47329aa62c0046db3df1109fc273f07051a/flink-yarn/src/main/java/org/apache/flink/yarn/Abstrac
wenlong88 commented on pull request #18331:
URL: https://github.com/apache/flink/pull/18331#issuecomment-1017157780
@lmagic233 could you help create another issue to track fix of other
operators.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
chen-yu342 commented on pull request #8400:
URL: https://github.com/apache/flink/pull/8400#issuecomment-1017157122
> @zhengyifanvp
需要Yarn最低版本为2.6.0；https://github.com/jiasheng55/flink/blob/5517d47329aa62c0046db3df1109fc273f07051a/flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnCl
flinkbot edited a comment on pull request #18137:
URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034
## CI report:
* a51d94fece908d30c5295d2046b8e19807972dcb Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-25700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479110#comment-17479110
]
Wenlong Lyu commented on FLINK-25700:
-
[~simen] it is not a bug actually, you should
JingsongLi commented on a change in pull request #12:
URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788380094
##
File path:
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/manifest/ManifestEntry.java
##
@@ -38,6 +38,7 @@
priva
JingsongLi commented on a change in pull request #12:
URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788377304
##
File path:
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreCommitImpl.java
##
@@ -0,0 +1,376 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-21789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao reassigned FLINK-21789:
---
Assignee: Yuxin Tan
> Make FileChannelManagerImpl#getNextPathNum select data directories fa
LadyForest commented on a change in pull request #18394:
URL: https://github.com/apache/flink/pull/18394#discussion_r788376320
##
File path:
flink-table/flink-table-planner/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory
##
@@ -13,8 +13,8 @@
# Se
JingsongLi commented on a change in pull request #12:
URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788375580
##
File path:
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/Snapshot.java
##
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-21790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao reassigned FLINK-21790:
---
Assignee: Yuxin Tan
> Shuffle data directories to make directory selection of different
>
JingsongLi commented on a change in pull request #12:
URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788375174
##
File path:
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/Snapshot.java
##
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the
JingsongLi commented on a change in pull request #12:
URL: https://github.com/apache/flink-table-store/pull/12#discussion_r788374933
##
File path:
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/Snapshot.java
##
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the
flinkbot edited a comment on pull request #18412:
URL: https://github.com/apache/flink/pull/18412#issuecomment-1017147201
## CI report:
* 91a7a1406e7d09b6914bff1caeaf4ec92a798d8d Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
LadyForest commented on a change in pull request #18394:
URL: https://github.com/apache/flink/pull/18394#discussion_r788373476
##
File path: flink-formats/flink-orc/pom.xml
##
@@ -145,6 +145,19 @@ under the License.
test
test-jar
flinkbot commented on pull request #18412:
URL: https://github.com/apache/flink/pull/18412#issuecomment-1017147201
## CI report:
* 91a7a1406e7d09b6914bff1caeaf4ec92a798d8d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #18412:
URL: https://github.com/apache/flink/pull/18412#issuecomment-1017146317
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
[
https://issues.apache.org/jira/browse/FLINK-25184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-25184.
Resolution: Duplicate
> Introduce setDeliveryCallback to KafkaWriter
> ---
[
https://issues.apache.org/jira/browse/FLINK-25696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25696:
---
Labels: pull-request-available (was: )
> Introduce MetadataPublisher interface to SinkWrite
JingsongLi opened a new pull request #18412:
URL: https://github.com/apache/flink/pull/18412
## What is the purpose of the change
In Table Store, we want to get the offsets of kafka writer, only the offset
returned by the callback inside the KafkaWriter is accurate, so we need this
[
https://issues.apache.org/jira/browse/FLINK-25696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-25696:
-
Component/s: Connectors / Kafka
> Introduce MetadataPublisher interface to SinkWriter
>
flinkbot edited a comment on pull request #18411:
URL: https://github.com/apache/flink/pull/18411#issuecomment-1017137635
## CI report:
* b4fc1c8ab69a6bfaec27d5044d1aef7c1453b2ac Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18411:
URL: https://github.com/apache/flink/pull/18411#issuecomment-1017137635
## CI report:
* b4fc1c8ab69a6bfaec27d5044d1aef7c1453b2ac UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18410:
URL: https://github.com/apache/flink/pull/18410#issuecomment-1017135994
## CI report:
* f93c8b81862c1b744c3599c706a482186e541ae9 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18411:
URL: https://github.com/apache/flink/pull/18411#issuecomment-1017137392
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 commented on pull request #18410:
URL: https://github.com/apache/flink/pull/18410#issuecomment-1017135994
## CI report:
* f93c8b81862c1b744c3599c706a482186e541ae9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
imaffe opened a new pull request #18411:
URL: https://github.com/apache/flink/pull/18411
## What is the purpose of the change
1. change the pulsar IT to generate fixed test data
2. change the TestDataMatcher to validate both size and data.
## Brief change log
flinkbot commented on pull request #18410:
URL: https://github.com/apache/flink/pull/18410#issuecomment-1017135283
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 #18409:
URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626
## CI report:
* 6243757360488011ac597bf09956ee48fd2fa826 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18408:
URL: https://github.com/apache/flink/pull/18408#issuecomment-1017132556
## CI report:
* 98deafafc7a332577c3172844e38b98c445be6b9 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #18324:
URL: https://github.com/apache/flink/pull/18324#issuecomment-1009752905
## CI report:
* ce08a46add96553021558f2af3ecebc74a93e4e4 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
EugeneChung opened a new pull request #18410:
URL: https://github.com/apache/flink/pull/18410
## What is the purpose of the change
To clarify description about the part file name
## Brief change log
introduce file_uid for in-progress files
## Verifying this change
This
JingsongLi commented on a change in pull request #18394:
URL: https://github.com/apache/flink/pull/18394#discussion_r788360886
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala
##
@@ -701,6 +701,23 @@ abstract
flinkbot commented on pull request #18409:
URL: https://github.com/apache/flink/pull/18409#issuecomment-1017133076
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 commented on pull request #18409:
URL: https://github.com/apache/flink/pull/18409#issuecomment-1017132626
## CI report:
* 6243757360488011ac597bf09956ee48fd2fa826 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #18408:
URL: https://github.com/apache/flink/pull/18408#issuecomment-1017132556
## CI report:
* 98deafafc7a332577c3172844e38b98c445be6b9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18324:
URL: https://github.com/apache/flink/pull/18324#issuecomment-1009752905
## CI report:
* ce08a46add96553021558f2af3ecebc74a93e4e4 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot commented on pull request #18408:
URL: https://github.com/apache/flink/pull/18408#issuecomment-1017131827
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
[
https://issues.apache.org/jira/browse/FLINK-24865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24865:
---
Labels: pull-request-available (was: )
> Support MATCH_RECOGNIZE in Batch mode
> --
1 - 100 of 594 matches
Mail list logo
