godfrey he created FLINK-21890:
--
Summary: Rename DAGProcessor to ExecNodeGraphProcessor
Key: FLINK-21890
URL: https://issues.apache.org/jira/browse/FLINK-21890
Project: Flink
Issue Type: Improve
zuston commented on a change in pull request #15131:
URL: https://github.com/apache/flink/pull/15131#discussion_r598208920
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
##
@@ -344,6 +344,13 @@
.withDescri
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305583#comment-17305583
]
giackgamba edited comment on FLINK-21696 at 3/20/21, 11:41 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
giackgamba closed FLINK-21696.
--
Release Note: duplicate of https://issues.apache.org/jira/browse/FLINK-21722
Resolution: Duplicat
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305583#comment-17305583
]
giackgamba commented on FLINK-21696:
Actually it has already been fixed in
https://
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* cabe06381bf59e3b94936d879d5f2aa5c34c878e Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #15303:
URL: https://github.com/apache/flink/pull/15303#issuecomment-803399784
## CI report:
* 59bef64ec3920e084eeeaa646bb053d22fb95c49 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15097:
URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662
## CI report:
* d936a0072b1e8ad6243fa3352177cbc094c59e7d Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305568#comment-17305568
]
David Anderson commented on FLINK-21589:
Yes, this should be documented.
Some u
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-21696:
---
Fix Version/s: 1.13.0
> scala code in "Writing WatermarkGenerators" documentation missing/de
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-21696:
---
Affects Version/s: 1.13.0
1.12.2
> scala code in "Writing WatermarkGe
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305560#comment-17305560
]
David Anderson commented on FLINK-21696:
[~giackgamba] Thank you for catching th
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson reassigned FLINK-21696:
--
Assignee: giackgamba
> scala code in "Writing WatermarkGenerators" documentation miss
flinkbot edited a comment on pull request #15297:
URL: https://github.com/apache/flink/pull/15297#issuecomment-803278367
## CI report:
* 502aec81372c26d89cd1a7cd90edd3a7b857e9a2 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson resolved FLINK-21885.
Fix Version/s: 1.13.0
Resolution: Fixed
Closed in master with 49a3b4d311d6d537841b0
[
https://issues.apache.org/jira/browse/FLINK-21885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson reassigned FLINK-21885:
--
Assignee: Rion Williams
> Minor Typo Fix in JDBC Connector Documentation
> --
alpinegizmo merged pull request #15295:
URL: https://github.com/apache/flink/pull/15295
--
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.
For queries about this service, pl
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 9e445296314a2bfde4c85b61f1a3d9ee892c97ba Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #15304:
URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086
## CI report:
* d3660d4aad02129ce663ffcc96ca966b39703b21 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15302:
URL: https://github.com/apache/flink/pull/15302#issuecomment-803359731
## CI report:
* 3a2be343e9a6b77c9d7535ea98b432b7e3f73902 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15274:
URL: https://github.com/apache/flink/pull/15274#issuecomment-802519234
## CI report:
* 89f6aa9e4d9f715ab80c1607fefb62f5e74fc5c3 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 9e445296314a2bfde4c85b61f1a3d9ee892c97ba Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #15304:
URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086
## CI report:
* 4db272f0b2c59785fcf16492626b2cd4fec6844c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15301:
URL: https://github.com/apache/flink/pull/15301#issuecomment-803353789
## CI report:
* b396325ab19ee75949e87d006c9e17096dbd50a2 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15304:
URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086
## CI report:
* 4db272f0b2c59785fcf16492626b2cd4fec6844c Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15097:
URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662
## CI report:
* a3b522f30f4d14a0085ae101c579e4779cbea740 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jianyun Zhao closed FLINK-20728.
Release Note: SourceFunction and SinkFunction interfaces will be deprecated
in future versions and
[
https://issues.apache.org/jira/browse/FLINK-20727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jianyun Zhao closed FLINK-20727.
Release Note: SourceFunction and SinkFunction interfaces will be deprecated
in future versions and
flinkbot commented on pull request #15304:
URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086
## CI report:
* 4db272f0b2c59785fcf16492626b2cd4fec6844c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #15097:
URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662
## CI report:
* a3b522f30f4d14a0085ae101c579e4779cbea740 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
jianyun8023 edited a comment on pull request #14622:
URL: https://github.com/apache/flink/pull/14622#issuecomment-803429679
> @jianyun8023 Sorry I have probably missed the new PRs and can't find them
through PR search, could you please link them to me (or add me as a reviewer?).
@AHe
jianyun8023 commented on pull request #14622:
URL: https://github.com/apache/flink/pull/14622#issuecomment-803429679
> @jianyun8023 Sorry I have probably missed the new PRs and can't find them
through PR search, could you please link them to me (or add me as a reviewer?).
@AHeise Sorry i
flinkbot commented on pull request #15304:
URL: https://github.com/apache/flink/pull/15304#issuecomment-803428922
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 pro
[
https://issues.apache.org/jira/browse/FLINK-20731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20731:
---
Labels: pull-request-available (was: )
> Pulsar Source
> -
>
>
jianyun8023 opened a new pull request #15304:
URL: https://github.com/apache/flink/pull/15304
## What is the purpose of the change
Add the `Source` implementation of Pulsar to the connector.
## Brief change log
- Add Pulsar Source implementation
- Supports exactly-one
flinkbot edited a comment on pull request #15303:
URL: https://github.com/apache/flink/pull/15303#issuecomment-803399784
## CI report:
* 59bef64ec3920e084eeeaa646bb053d22fb95c49 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15159:
URL: https://github.com/apache/flink/pull/15159#issuecomment-797005525
## CI report:
* 28bf753c82199c68f31a19234bc85b7fc03dc9cb Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #15303:
URL: https://github.com/apache/flink/pull/15303#issuecomment-803399784
## CI report:
* 59bef64ec3920e084eeeaa646bb053d22fb95c49 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #15297:
URL: https://github.com/apache/flink/pull/15297#issuecomment-803278367
## CI report:
* Unknown: [CANCELED](TBD)
* 502aec81372c26d89cd1a7cd90edd3a7b857e9a2 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620
flinkbot edited a comment on pull request #15297:
URL: https://github.com/apache/flink/pull/15297#issuecomment-803278367
## CI report:
* Unknown: [CANCELED](TBD)
* 502aec81372c26d89cd1a7cd90edd3a7b857e9a2 UNKNOWN
Bot commands
The @flinkbot bot supports the fol
flinkbot edited a comment on pull request #15300:
URL: https://github.com/apache/flink/pull/15300#issuecomment-803294398
## CI report:
* a31f1206c3db27ff052f9d9ebfb590c3a1d6a0b5 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wuchong commented on pull request #15230:
URL: https://github.com/apache/flink/pull/15230#issuecomment-803393124
Thanks @LadyForest for the detailed documentation. It already looks in a
good shape. I only left some minor comments.
--
This is an automated message from the Apache Git Servi
wuchong commented on a change in pull request #15230:
URL: https://github.com/apache/flink/pull/15230#discussion_r598127716
##
File path: docs/content.zh/docs/dev/table/modules.md
##
@@ -55,25 +55,358 @@ the `ModuleFactory` interface.
A module factory defines a set of properti
flinkbot commented on pull request #15303:
URL: https://github.com/apache/flink/pull/15303#issuecomment-803392443
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 pro
wuchong commented on a change in pull request #15230:
URL: https://github.com/apache/flink/pull/15230#discussion_r598126455
##
File path: docs/content.zh/docs/dev/table/sql/unload.md
##
@@ -0,0 +1,115 @@
+---
+title: "UNLOAD 语句"
+weight: 13
+type: docs
+aliases:
+ - /zh/dev/ta
[
https://issues.apache.org/jira/browse/FLINK-21713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21713:
---
Labels: pull-request-available (was: )
> Correct function
> CURRENT_TIMESTAMP/CURRENT_TIME
leonardBang opened a new pull request #15303:
URL: https://github.com/apache/flink/pull/15303
## What is the purpose of the change
* This pull request correct temporal functions evaluation timepoint and
function return type.
## Brief change log
- Correct CURRENT_TIMESTAM
xinggit commented on pull request #15297:
URL: https://github.com/apache/flink/pull/15297#issuecomment-803385829
@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
flinkbot edited a comment on pull request #15274:
URL: https://github.com/apache/flink/pull/15274#issuecomment-802519234
## CI report:
* 4dd5e4e8e3f0a1a89d1e05a1547217939c9ff703 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15299:
URL: https://github.com/apache/flink/pull/15299#issuecomment-803292047
## CI report:
* bfa3ce3fd34a725efef2af3c13f0e9014411ff7d Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15274:
URL: https://github.com/apache/flink/pull/15274#issuecomment-802519234
## CI report:
* 4dd5e4e8e3f0a1a89d1e05a1547217939c9ff703 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15302:
URL: https://github.com/apache/flink/pull/15302#issuecomment-803359731
## CI report:
* 3a2be343e9a6b77c9d7535ea98b432b7e3f73902 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15298:
URL: https://github.com/apache/flink/pull/15298#issuecomment-803288503
## CI report:
* 681e314e56a4778b586ae6ceae95d5c6620b3a07 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #15302:
URL: https://github.com/apache/flink/pull/15302#issuecomment-803359731
## CI report:
* 3a2be343e9a6b77c9d7535ea98b432b7e3f73902 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #15301:
URL: https://github.com/apache/flink/pull/15301#issuecomment-803353789
## CI report:
* b396325ab19ee75949e87d006c9e17096dbd50a2 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15132:
URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449
## CI report:
* b01ec8679ce5ae6879c8dfd57e856bef9d0a8568 UNKNOWN
* a3847140a61ed2ecebd6d97dda9bfbbdbbd4451d Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot commented on pull request #15302:
URL: https://github.com/apache/flink/pull/15302#issuecomment-803356955
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 pro
[
https://issues.apache.org/jira/browse/FLINK-21789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21789:
---
Labels: pull-request-available (was: )
> Make FileChannelManagerImpl#getNextPathNum select
wsry opened a new pull request #15302:
URL: https://github.com/apache/flink/pull/15302
## What is the purpose of the change
FileChannelManagerImpl#getNextPathNum is not atomic which may cause
unfairness of data directory selection. This patch makes the selection of data
directories
[
https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21814:
Component/s: Table SQL / Ecosystem
API / DataStream
> flink CollectSink error info unfrie
[
https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21814:
Description:
org.apache.flink.streaming.experimental.CollectSink initialization need host
and port. When
[
https://issues.apache.org/jira/browse/FLINK-21889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305444#comment-17305444
]
Jark Wu commented on FLINK-21889:
-
I think the reason maybe there is null values in your
[
https://issues.apache.org/jira/browse/FLINK-21889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21889:
Description:
sourceTable:canal-cdc , sinkTable:upsert-kafka, print the result of
executesql("select * fr
flinkbot commented on pull request #15301:
URL: https://github.com/apache/flink/pull/15301#issuecomment-803353789
## CI report:
* b396325ab19ee75949e87d006c9e17096dbd50a2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-21887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-21887:
---
Assignee: Shengkai Fang
> Add show views test in CliClientITCase
>
[
https://issues.apache.org/jira/browse/FLINK-21789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-21789:
Summary: Make FileChannelManagerImpl#getNextPathNum select data directories
fairly (was: Make Fil
Carl created FLINK-21889:
Summary: source:canal-cdc , sink:upsert-kafka, print "select *
from sinkTable", throw NullException
Key: FLINK-21889
URL: https://issues.apache.org/jira/browse/FLINK-21889
Project: F
flinkbot edited a comment on pull request #15159:
URL: https://github.com/apache/flink/pull/15159#issuecomment-797005525
## CI report:
* 57d9b95fac95a649bd8295c294b77aeee5df12fc Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #15301:
URL: https://github.com/apache/flink/pull/15301#issuecomment-803318751
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 pro
[
https://issues.apache.org/jira/browse/FLINK-21888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21888:
---
Labels: pull-request-available (was: )
> Maintain our own ASTNode class
> -
lirui-apache opened a new pull request #15301:
URL: https://github.com/apache/flink/pull/15301
## What is the purpose of the change
Add our own ASTNode. This is needed to support hive dialect for different
hive versions.
## Brief change log
- Add `HivePars
flinkbot edited a comment on pull request #15285:
URL: https://github.com/apache/flink/pull/15285#issuecomment-802759840
## CI report:
* a1a412821af759801ce3aad0da00779f85a7c0d9 UNKNOWN
* 508be62bbbf9ef2485dd84f22555f8b0530fe225 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #15199:
URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245
## CI report:
* 33f5e95ff1020b26c602c44537f30cc890c07363 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15159:
URL: https://github.com/apache/flink/pull/15159#issuecomment-797005525
## CI report:
* 57d9b95fac95a649bd8295c294b77aeee5df12fc Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-21869.
--
Resolution: Fixed
Fixed in 1.13.0: 8075f10f08f15d2ad0a8bc7db11d1701ab21c79f
> Support StreamExecTempo
godfreyhe closed pull request #15284:
URL: https://github.com/apache/flink/pull/15284
--
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.
For queries about this service, plea
flinkbot edited a comment on pull request #14538:
URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523
## CI report:
* af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN
* ca4df4a1316bd4a229e47979cce1aaebc03d6d0d Azure:
[SUCCESS](https://dev.azure.com/apache-fl
Rui Li created FLINK-21888:
--
Summary: Maintain our own ASTNode class
Key: FLINK-21888
URL: https://issues.apache.org/jira/browse/FLINK-21888
Project: Flink
Issue Type: Sub-task
Components:
lirui-apache commented on a change in pull request #15274:
URL: https://github.com/apache/flink/pull/15274#discussion_r598104930
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java
##
@@ -217,12 +218,27 @@ priv
lirui-apache commented on a change in pull request #15131:
URL: https://github.com/apache/flink/pull/15131#discussion_r598104451
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
##
@@ -344,6 +344,13 @@
.with
flinkbot edited a comment on pull request #15300:
URL: https://github.com/apache/flink/pull/15300#issuecomment-803294398
## CI report:
* a31f1206c3db27ff052f9d9ebfb590c3a1d6a0b5 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15296:
URL: https://github.com/apache/flink/pull/15296#issuecomment-803269846
## CI report:
* 6070cf900acf0d4938d5b5cbc3f6ab2726f62ae1 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305411#comment-17305411
]
zhaoxing commented on FLINK-21493:
--
cc [~zhisheng] [~jark]
I am willing to do it. Can
yuruguo commented on pull request #14538:
URL: https://github.com/apache/flink/pull/14538#issuecomment-803296818
@tillrohrmann @songxintong Can you review the code？THX！
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
flinkbot commented on pull request #15300:
URL: https://github.com/apache/flink/pull/15300#issuecomment-803294398
## CI report:
* a31f1206c3db27ff052f9d9ebfb590c3a1d6a0b5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #15299:
URL: https://github.com/apache/flink/pull/15299#issuecomment-803292047
## CI report:
* bfa3ce3fd34a725efef2af3c13f0e9014411ff7d Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #15300:
URL: https://github.com/apache/flink/pull/15300#issuecomment-803293222
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 pro
[
https://issues.apache.org/jira/browse/FLINK-21790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21790:
---
Labels: pull-request-available (was: )
> Shuffle data directories to make directory selecti
wsry opened a new pull request #15300:
URL: https://github.com/apache/flink/pull/15300
## What is the purpose of the change
Currently, different TaskManagers select shuffle data directory in the same
order and if there are multiple disks, some disks may stores more data than
others
flinkbot commented on pull request #15299:
URL: https://github.com/apache/flink/pull/15299#issuecomment-803292047
## CI report:
* bfa3ce3fd34a725efef2af3c13f0e9014411ff7d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #15298:
URL: https://github.com/apache/flink/pull/15298#issuecomment-803288503
## CI report:
* 681e314e56a4778b586ae6ceae95d5c6620b3a07 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15132:
URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449
## CI report:
* d98424b40ed962803bf6151185119d4dc5affaf7 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-21790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-21790:
Summary: Shuffle data directories to make directory selection of different
TaskManagers fairer (w
[
https://issues.apache.org/jira/browse/FLINK-21790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-21790:
Summary: Shuffle shuffle data directories to make directory selection of
different TaskManagers fa
[
https://issues.apache.org/jira/browse/FLINK-21790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-21790:
Summary: Shuffle data directories to make data directory selection of
different TaskManagers faire
flinkbot commented on pull request #15299:
URL: https://github.com/apache/flink/pull/15299#issuecomment-803288988
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 pro
[
https://issues.apache.org/jira/browse/FLINK-21788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21788:
---
Labels: pull-request-available (was: )
> Throw PartitionNotFoundException if the partition
wsry opened a new pull request #15299:
URL: https://github.com/apache/flink/pull/15299
## What is the purpose of the change
Currently, if the partition file has been lost for blocking shuffle,
FileNotFoundException will be thrown and the partition data is not regenerated.
This patch
flinkbot commented on pull request #15298:
URL: https://github.com/apache/flink/pull/15298#issuecomment-803288503
## CI report:
* 681e314e56a4778b586ae6ceae95d5c6620b3a07 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #15132:
URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449
## CI report:
* d98424b40ed962803bf6151185119d4dc5affaf7 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
1 - 100 of 136 matches
Mail list logo
