You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2020/04/30 07:14:07 UTC
[GitHub] [flink] Myasuka opened a new pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Myasuka opened a new pull request #11957:
URL: https://github.com/apache/flink/pull/11957
## What is the purpose of the change
Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
## Brief change log
Add `cluster.io-executor.pool-size` option to let the pool size of io-executor for ClusterEntrypoint and MiniCluster could be configurable. The default behavior would still use the cpu cores of the hardware which the JVM access to.
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): no
- The public API, i.e., is any changed class annotated with `@Public(Evolving)`: no
- The serializers: no
- The runtime per-record code paths (performance sensitive): no
- Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn/Mesos, ZooKeeper: no
- The S3 file system connector: no
## Documentation
- Does this pull request introduce a new feature? yes
- If yes, how is the feature documented? docs
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-621670241
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1 UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] tillrohrmann commented on a change in pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
tillrohrmann commented on a change in pull request #11957:
URL: https://github.com/apache/flink/pull/11957#discussion_r425287489
##########
File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
##########
@@ -304,8 +305,12 @@ public void start() throws Exception {
RpcUtils.getHostname(commonRpcService),
ConfigurationUtils.getSystemResourceMetricsProbingInterval(configuration));
+ final int poolSize = configuration.getInteger(ClusterOptions.CLUSTER_IO_EXECUTOR_POOL_SIZE, Hardware.getNumberCPUCores());
+ Preconditions.checkArgument(poolSize > 0,
+ String.format("Illegal pool size (%s) of io-executor for mini cluster, please re-configure '%s'.",
+ poolSize, ClusterOptions.CLUSTER_IO_EXECUTOR_POOL_SIZE.key()));
Review comment:
The logic to obtain the `poolSize` and to verify it could be factored out into a method which is shared by the `MiniCluster` and the `ClusterEntrypoint`. This would avoid code duplication.
##########
File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServices.java
##########
@@ -157,8 +159,12 @@ public static JobManagerSharedServices fromConfiguration(
throw new IllegalConfigurationException(AkkaUtils.formatDurationParsingErrorMessage());
}
+ final int poolSize = config.getInteger(ClusterOptions.CLUSTER_IO_EXECUTOR_POOL_SIZE, Hardware.getNumberCPUCores());
+ Preconditions.checkArgument(poolSize > 0,
+ String.format("Illegal pool size (%s) of io-executor for cluster entry-point, please re-configure '%s'.",
+ poolSize, ClusterOptions.CLUSTER_IO_EXECUTOR_POOL_SIZE.key()));
final ScheduledExecutorService futureExecutor = Executors.newScheduledThreadPool(
- Hardware.getNumberCPUCores(),
+ poolSize,
new ExecutorThreadFactory("jobmanager-future"));
Review comment:
Instead of making the future executor of the `JobManager` configurable I would suggest to make the `ioExecutor` of the `ClusterEntrypoint` configurable: https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java#L263
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] Myasuka commented on a change in pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
Myasuka commented on a change in pull request #11957:
URL: https://github.com/apache/flink/pull/11957#discussion_r425844514
##########
File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServices.java
##########
@@ -157,8 +159,12 @@ public static JobManagerSharedServices fromConfiguration(
throw new IllegalConfigurationException(AkkaUtils.formatDurationParsingErrorMessage());
}
+ final int poolSize = config.getInteger(ClusterOptions.CLUSTER_IO_EXECUTOR_POOL_SIZE, Hardware.getNumberCPUCores());
+ Preconditions.checkArgument(poolSize > 0,
+ String.format("Illegal pool size (%s) of io-executor for cluster entry-point, please re-configure '%s'.",
+ poolSize, ClusterOptions.CLUSTER_IO_EXECUTOR_POOL_SIZE.key()));
final ScheduledExecutorService futureExecutor = Executors.newScheduledThreadPool(
- Hardware.getNumberCPUCores(),
+ poolSize,
new ExecutorThreadFactory("jobmanager-future"));
Review comment:
It's my fault, will fix this.
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] tillrohrmann closed pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
tillrohrmann closed pull request #11957:
URL: https://github.com/apache/flink/pull/11957
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-621670241
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "PENDING",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162898718",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
}, {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162898718) Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-621658572
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 progress of the review.
## Automated Checks
Last check on commit f5e06426a80cd204ea3dbae584e2912ec966c28d (Fri Oct 16 10:32:39 UTC 2020)
**Warnings:**
* No documentation files were touched! Remember to keep the Flink docs up to date!
<sub>Mention the bot in a comment to re-run the automated checks.</sub>
## Review Progress
* ❓ 1. The [description] looks good.
* ❓ 2. There is [consensus] that the contribution should go into to Flink.
* ❓ 3. Needs [attention] from.
* ❓ 4. The change fits into the overall [architecture].
* ❓ 5. Overall code [quality] is good.
Please see the [Pull Request Review Guide](https://flink.apache.org/contributing/reviewing-prs.html) for a full explanation of the review process.<details>
The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required <summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot approve description` to approve one or more aspects (aspects: `description`, `consensus`, `architecture` and `quality`)
- `@flinkbot approve all` to approve all aspects
- `@flinkbot approve-until architecture` to approve everything until `architecture`
- `@flinkbot attention @username1 [@username2 ..]` to require somebody's attention
- `@flinkbot disapprove architecture` to remove an approval you gave earlier
</details>
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-621670241
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162898718",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
}, {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162898718) Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-621670241
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162898718",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
}, {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
}, {
"hash" : "f5e06426a80cd204ea3dbae584e2912ec966c28d",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=1464",
"triggerID" : "f5e06426a80cd204ea3dbae584e2912ec966c28d",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* f5e06426a80cd204ea3dbae584e2912ec966c28d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=1464)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] tillrohrmann commented on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
tillrohrmann commented on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-629637596
Test failure is unrelated. Merging this PR now.
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-621658572
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 progress of the review.
## Automated Checks
Last check on commit a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1 (Thu Apr 30 07:17:37 UTC 2020)
**Warnings:**
* No documentation files were touched! Remember to keep the Flink docs up to date!
<sub>Mention the bot in a comment to re-run the automated checks.</sub>
## Review Progress
* ❓ 1. The [description] looks good.
* ❓ 2. There is [consensus] that the contribution should go into to Flink.
* ❓ 3. Needs [attention] from.
* ❓ 4. The change fits into the overall [architecture].
* ❓ 5. Overall code [quality] is good.
Please see the [Pull Request Review Guide](https://flink.apache.org/contributing/reviewing-prs.html) for a full explanation of the review process.<details>
The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required <summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot approve description` to approve one or more aspects (aspects: `description`, `consensus`, `architecture` and `quality`)
- `@flinkbot approve all` to approve all aspects
- `@flinkbot approve-until architecture` to approve everything until `architecture`
- `@flinkbot attention @username1 [@username2 ..]` to require somebody's attention
- `@flinkbot disapprove architecture` to remove an approval you gave earlier
</details>
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-621670241
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "PENDING",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162898718",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
}, {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162898718) Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-621670241
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162898718",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
}, {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
}, {
"hash" : "f5e06426a80cd204ea3dbae584e2912ec966c28d",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=1464",
"triggerID" : "f5e06426a80cd204ea3dbae584e2912ec966c28d",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162898718) Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462)
* f5e06426a80cd204ea3dbae584e2912ec966c28d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=1464)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11957: [FLINK-17248] Introduce configuration for pool size of io-executor for ClusterEntrypoint and MiniCluster
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11957:
URL: https://github.com/apache/flink/pull/11957#issuecomment-621670241
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162898718",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
}, {
"hash" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462",
"triggerID" : "a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1",
"triggerType" : "PUSH"
}, {
"hash" : "f5e06426a80cd204ea3dbae584e2912ec966c28d",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "f5e06426a80cd204ea3dbae584e2912ec966c28d",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* a2d3ce9c4f9a8ecafd3d111668e0d0ba9c7904b1 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162898718) Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=462)
* f5e06426a80cd204ea3dbae584e2912ec966c28d UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
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, please contact Infrastructure at:
users@infra.apache.org