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 @@
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305583#comment-17305583
]
giackgamba edited comment on FLINK-21696 at 3/20/21, 11:41 PM:
---
Actually
[
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:
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305583#comment-17305583
]
giackgamba commented on FLINK-21696:
Actually it has already been fixed in
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* cabe06381bf59e3b94936d879d5f2aa5c34c878e Azure:
flinkbot edited a comment on pull request #15303:
URL: https://github.com/apache/flink/pull/15303#issuecomment-803399784
## CI report:
* 59bef64ec3920e084eeeaa646bb053d22fb95c49 Azure:
flinkbot edited a comment on pull request #15097:
URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662
## CI report:
* d936a0072b1e8ad6243fa3352177cbc094c59e7d Azure:
[
https://issues.apache.org/jira/browse/FLINK-21589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305568#comment-17305568
]
David Anderson commented on FLINK-21589:
Yes, this should be documented.
Some upgrades are
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305560#comment-17305560
]
David Anderson commented on FLINK-21696:
[~giackgamba] Thank you for catching this. It does
[
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
flinkbot edited a comment on pull request #15297:
URL: https://github.com/apache/flink/pull/15297#issuecomment-803278367
## CI report:
* 502aec81372c26d89cd1a7cd90edd3a7b857e9a2 Azure:
[
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
[
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,
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 9e445296314a2bfde4c85b61f1a3d9ee892c97ba Azure:
flinkbot edited a comment on pull request #15304:
URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086
## CI report:
* d3660d4aad02129ce663ffcc96ca966b39703b21 Azure:
flinkbot edited a comment on pull request #15302:
URL: https://github.com/apache/flink/pull/15302#issuecomment-803359731
## CI report:
* 3a2be343e9a6b77c9d7535ea98b432b7e3f73902 Azure:
flinkbot edited a comment on pull request #15274:
URL: https://github.com/apache/flink/pull/15274#issuecomment-802519234
## CI report:
* 89f6aa9e4d9f715ab80c1607fefb62f5e74fc5c3 Azure:
flinkbot edited a comment on pull request #14678:
URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721
## CI report:
* cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN
* 9e445296314a2bfde4c85b61f1a3d9ee892c97ba Azure:
flinkbot edited a comment on pull request #15304:
URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086
## CI report:
* 4db272f0b2c59785fcf16492626b2cd4fec6844c Azure:
flinkbot edited a comment on pull request #15301:
URL: https://github.com/apache/flink/pull/15301#issuecomment-803353789
## CI report:
* b396325ab19ee75949e87d006c9e17096dbd50a2 Azure:
flinkbot edited a comment on pull request #15304:
URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086
## CI report:
* 4db272f0b2c59785fcf16492626b2cd4fec6844c Azure:
flinkbot edited a comment on pull request #15097:
URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662
## CI report:
* a3b522f30f4d14a0085ae101c579e4779cbea740 Azure:
[
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
[
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
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
flinkbot edited a comment on pull request #15097:
URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662
## CI report:
* a3b522f30f4d14a0085ae101c579e4779cbea740 Azure:
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?).
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
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
[
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
flinkbot edited a comment on pull request #15303:
URL: https://github.com/apache/flink/pull/15303#issuecomment-803399784
## CI report:
* 59bef64ec3920e084eeeaa646bb053d22fb95c49 Azure:
flinkbot edited a comment on pull request #15159:
URL: https://github.com/apache/flink/pull/15159#issuecomment-797005525
## CI report:
* 28bf753c82199c68f31a19234bc85b7fc03dc9cb Azure:
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
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:
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
flinkbot edited a comment on pull request #15300:
URL: https://github.com/apache/flink/pull/15300#issuecomment-803294398
## CI report:
* a31f1206c3db27ff052f9d9ebfb590c3a1d6a0b5 Azure:
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
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
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
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:
+ -
[
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
>
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
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:
flinkbot edited a comment on pull request #15299:
URL: https://github.com/apache/flink/pull/15299#issuecomment-803292047
## CI report:
* bfa3ce3fd34a725efef2af3c13f0e9014411ff7d Azure:
flinkbot edited a comment on pull request #15274:
URL: https://github.com/apache/flink/pull/15274#issuecomment-802519234
## CI report:
* 4dd5e4e8e3f0a1a89d1e05a1547217939c9ff703 Azure:
flinkbot edited a comment on pull request #15302:
URL: https://github.com/apache/flink/pull/15302#issuecomment-803359731
## CI report:
* 3a2be343e9a6b77c9d7535ea98b432b7e3f73902 Azure:
flinkbot edited a comment on pull request #15298:
URL: https://github.com/apache/flink/pull/15298#issuecomment-803288503
## CI report:
* 681e314e56a4778b586ae6ceae95d5c6620b3a07 Azure:
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
flinkbot edited a comment on pull request #15301:
URL: https://github.com/apache/flink/pull/15301#issuecomment-803353789
## CI report:
* b396325ab19ee75949e87d006c9e17096dbd50a2 Azure:
flinkbot edited a comment on pull request #15132:
URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449
## CI report:
* b01ec8679ce5ae6879c8dfd57e856bef9d0a8568 UNKNOWN
* a3847140a61ed2ecebd6d97dda9bfbbdbbd4451d Azure:
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
[
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
[
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=17305444#comment-17305444
]
Jark Wu commented on FLINK-21889:
-
I think the reason maybe there is null values in your kafka canal
[
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 *
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
[
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
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:
flinkbot edited a comment on pull request #15159:
URL: https://github.com/apache/flink/pull/15159#issuecomment-797005525
## CI report:
* 57d9b95fac95a649bd8295c294b77aeee5df12fc Azure:
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
[
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
flinkbot edited a comment on pull request #15285:
URL: https://github.com/apache/flink/pull/15285#issuecomment-802759840
## CI report:
* a1a412821af759801ce3aad0da00779f85a7c0d9 UNKNOWN
* 508be62bbbf9ef2485dd84f22555f8b0530fe225 Azure:
flinkbot edited a comment on pull request #15199:
URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245
## CI report:
* 33f5e95ff1020b26c602c44537f30cc890c07363 Azure:
flinkbot edited a comment on pull request #15159:
URL: https://github.com/apache/flink/pull/15159#issuecomment-797005525
## CI report:
* 57d9b95fac95a649bd8295c294b77aeee5df12fc Azure:
[
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
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,
flinkbot edited a comment on pull request #14538:
URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523
## CI report:
* af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN
* ca4df4a1316bd4a229e47979cce1aaebc03d6d0d Azure:
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
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 @@
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 @@
flinkbot edited a comment on pull request #15300:
URL: https://github.com/apache/flink/pull/15300#issuecomment-803294398
## CI report:
* a31f1206c3db27ff052f9d9ebfb590c3a1d6a0b5 Azure:
flinkbot edited a comment on pull request #15296:
URL: https://github.com/apache/flink/pull/15296#issuecomment-803269846
## CI report:
* 6070cf900acf0d4938d5b5cbc3f6ab2726f62ae1 Azure:
[
https://issues.apache.org/jira/browse/FLINK-21493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305411#comment-17305411
]
zhaoxing commented on FLINK-21493:
--
cc [~zhisheng] [~jark]
I am willing to do it. Can you assign it to
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
flinkbot edited a comment on pull request #15299:
URL: https://github.com/apache/flink/pull/15299#issuecomment-803292047
## CI report:
* bfa3ce3fd34a725efef2af3c13f0e9014411ff7d Azure:
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
[
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
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
flinkbot edited a comment on pull request #15298:
URL: https://github.com/apache/flink/pull/15298#issuecomment-803288503
## CI report:
* 681e314e56a4778b586ae6ceae95d5c6620b3a07 Azure:
flinkbot edited a comment on pull request #15132:
URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449
## CI report:
* d98424b40ed962803bf6151185119d4dc5affaf7 Azure:
[
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
[
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
[
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
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
[
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
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
flinkbot edited a comment on pull request #15132:
URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449
## CI report:
* d98424b40ed962803bf6151185119d4dc5affaf7 Azure:
[
https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305386#comment-17305386
]
zhaoxing edited comment on FLINK-21814 at 3/20/21, 10:34 AM:
-
hi, [~Peihui]I
1 - 100 of 138 matches
Mail list logo
