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 2021/03/24 12:41:29 UTC
[GitHub] [flink] dianfu opened a new pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
dianfu opened a new pull request #15362:
URL: https://github.com/apache/flink/pull/15362
## What is the purpose of the change
*This pull request support batch mode in Python DataStream API for process operation and reduce operation*
## Verifying this change
This change can be verified by tests test_reduce_function_without_data_types and test_reduce_with_state in BatchModeDataStreamTests.
## 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? (no)
- If yes, how is the feature documented? (not applicable)
--
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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "CANCELED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "CANCELED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"triggerType" : "PUSH"
}, {
"hash" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505",
"triggerID" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"triggerType" : "PUSH"
}, {
"hash" : "",
"status" : "DELETED",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "dc238be37f3ed7fa626540b4f84c276aeb5d0f96",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15516",
"triggerID" : "dc238be37f3ed7fa626540b4f84c276aeb5d0f96",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* e456383b0cafdeb67e8f37785783b3b35a6eaf47 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495)
* 5403d7cd9a65b24e0d53f7052c820d1cc91782ea Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505)
* dc238be37f3ed7fa626540b4f84c276aeb5d0f96 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15516)
<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] dianfu closed pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
dianfu closed pull request #15362:
URL: https://github.com/apache/flink/pull/15362
--
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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 7337a3e037f2b8742bf85b1f21a163d57401b525 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387)
<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] SteNicholas commented on a change in pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
SteNicholas commented on a change in pull request #15362:
URL: https://github.com/apache/flink/pull/15362#discussion_r600967800
##########
File path: flink-python/pyflink/datastream/tests/test_data_stream.py
##########
@@ -1068,6 +1013,35 @@ def on_timer(self, timestamp, ctx):
expected_result.sort()
self.assertEqual(expected_result, result)
+ def test_reduce_function_without_data_types(self):
Review comment:
Could this add `test_reduce_function_with_data_types` test case?
##########
File path: flink-python/pyflink/datastream/tests/test_data_stream.py
##########
@@ -1118,6 +1092,35 @@ def on_timer(self, timestamp, ctx):
expected_result.sort()
self.assertEqual(expected_result, result)
+ def test_reduce_function_without_data_types(self):
Review comment:
Could this add `test_reduce_function_with_data_types` test case?
--
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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
}, {
"hash" : "",
"status" : "CANCELED",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* Unknown: [CANCELED](TBD)
* e456383b0cafdeb67e8f37785783b3b35a6eaf47 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "",
"status" : "CANCELED",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* Unknown: [CANCELED](TBD)
* e456383b0cafdeb67e8f37785783b3b35a6eaf47 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] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "CANCELED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "CANCELED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"triggerType" : "PUSH"
}, {
"hash" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505",
"triggerID" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"triggerType" : "PUSH"
}, {
"hash" : "",
"status" : "DELETED",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
} ]
}-->
## CI report:
* e456383b0cafdeb67e8f37785783b3b35a6eaf47 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495)
* 5403d7cd9a65b24e0d53f7052c820d1cc91782ea Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 4b7ebaa8b37c538b8da78610cea36b04cdb111c4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 4b7ebaa8b37c538b8da78610cea36b04cdb111c4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429)
* f6339522b9b58acc617e3a91b434ecebd8207e49 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 7337a3e037f2b8742bf85b1f21a163d57401b525 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387)
* a46a6236b098fdc7b89755d4b072053134d42507 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 4b7ebaa8b37c538b8da78610cea36b04cdb111c4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429)
* f6339522b9b58acc617e3a91b434ecebd8207e49 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] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 7337a3e037f2b8742bf85b1f21a163d57401b525 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387)
* a46a6236b098fdc7b89755d4b072053134d42507 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] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* f65f9751b0e4a78d617f3c5a6d483d73580cfe0d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417)
* 4b7ebaa8b37c538b8da78610cea36b04cdb111c4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"triggerType" : "PUSH"
}, {
"hash" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"status" : "CANCELED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505",
"triggerID" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"triggerType" : "PUSH"
}, {
"hash" : "",
"status" : "DELETED",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "dc238be37f3ed7fa626540b4f84c276aeb5d0f96",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15516",
"triggerID" : "dc238be37f3ed7fa626540b4f84c276aeb5d0f96",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 5403d7cd9a65b24e0d53f7052c820d1cc91782ea Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505)
* dc238be37f3ed7fa626540b4f84c276aeb5d0f96 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15516)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "CANCELED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "CANCELED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"triggerType" : "PUSH"
}, {
"hash" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505",
"triggerID" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"triggerType" : "PUSH"
}, {
"hash" : "",
"status" : "DELETED",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "dc238be37f3ed7fa626540b4f84c276aeb5d0f96",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "dc238be37f3ed7fa626540b4f84c276aeb5d0f96",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* e456383b0cafdeb67e8f37785783b3b35a6eaf47 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495)
* 5403d7cd9a65b24e0d53f7052c820d1cc91782ea Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505)
* dc238be37f3ed7fa626540b4f84c276aeb5d0f96 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] dianfu commented on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
dianfu commented on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-807869485
@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 comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
}, {
"hash" : "",
"status" : "CANCELED",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"triggerType" : "PUSH"
}, {
"hash" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* Unknown: [CANCELED](TBD)
* e456383b0cafdeb67e8f37785783b3b35a6eaf47 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495)
* 5403d7cd9a65b24e0d53f7052c820d1cc91782ea 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] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* a46a6236b098fdc7b89755d4b072053134d42507 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394)
* f65f9751b0e4a78d617f3c5a6d483d73580cfe0d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417)
<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] dianfu commented on a change in pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
dianfu commented on a change in pull request #15362:
URL: https://github.com/apache/flink/pull/15362#discussion_r600982520
##########
File path: flink-python/pyflink/datastream/tests/test_data_stream.py
##########
@@ -1068,6 +1013,35 @@ def on_timer(self, timestamp, ctx):
expected_result.sort()
self.assertEqual(expected_result, result)
+ def test_reduce_function_without_data_types(self):
Review comment:
I'll rename it to test_reduce_function to avoid confusion.
--
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] dianfu commented on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
dianfu commented on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-806848794
@SteNicholas @HuangXingBo Thanks for your review. Have addressed your comments in the latest PR.
--
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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* f65f9751b0e4a78d617f3c5a6d483d73580cfe0d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417)
* 4b7ebaa8b37c538b8da78610cea36b04cdb111c4 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] flinkbot commented on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805789436
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 7337a3e037f2b8742bf85b1f21a163d57401b525 (Wed Mar 24 12:43:37 UTC 2021)
**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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"triggerType" : "PUSH"
}, {
"hash" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505",
"triggerID" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"triggerType" : "PUSH"
}, {
"hash" : "",
"status" : "DELETED",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "dc238be37f3ed7fa626540b4f84c276aeb5d0f96",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15516",
"triggerID" : "dc238be37f3ed7fa626540b4f84c276aeb5d0f96",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* dc238be37f3ed7fa626540b4f84c276aeb5d0f96 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15516)
<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] HuangXingBo commented on a change in pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
HuangXingBo commented on a change in pull request #15362:
URL: https://github.com/apache/flink/pull/15362#discussion_r601426371
##########
File path: docs/content/docs/dev/datastream/operators/overview.md
##########
@@ -756,4 +756,4 @@ someStream.filter(...).slotSharingGroup("name")
some_stream.filter(...).slot_sharing_group("name")
```
{{< /tab >}}
-{{< /tabs>}}
\ No newline at end of file
+{{< /tabs>}}
Review comment:
unnecessary change
##########
File path: flink-python/pyflink/datastream/data_stream.py
##########
@@ -851,28 +851,43 @@ def reduce(self, func: Union[Callable, ReduceFunction]) -> 'DataStream':
raise TypeError("The input func must be a ReduceFunction or a callable function.")
output_type = _from_java_type(self._original_data_type_info.get_java_type_info())
- class KeyedReduceFunctionWrapper(KeyedProcessFunction):
+ class KeyedReduceProcessFunction(KeyedProcessFunction):
Review comment:
Maybe we can rename other wrapper functions together
##########
File path: flink-python/pyflink/datastream/functions.py
##########
@@ -758,9 +760,7 @@ class KeyedProcessFunction(Function, ABC):
Note that access to keyed state and timers (which are also scoped to a key) is only available if
the KeyedProcessFunction is applied on a KeyedStream.
- """
- """
A function that process elements of a stream.
Review comment:
I think this useless comment also needs to be deleted.
--
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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* f65f9751b0e4a78d617f3c5a6d483d73580cfe0d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 7337a3e037f2b8742bf85b1f21a163d57401b525 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387)
<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 commented on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 7337a3e037f2b8742bf85b1f21a163d57401b525 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] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* a46a6236b098fdc7b89755d4b072053134d42507 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394)
* f65f9751b0e4a78d617f3c5a6d483d73580cfe0d 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] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
}, {
"hash" : "",
"status" : "CANCELED",
"url" : "TBD",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "807869485",
"triggerType" : "MANUAL"
}, {
"hash" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495",
"triggerID" : "e456383b0cafdeb67e8f37785783b3b35a6eaf47",
"triggerType" : "PUSH"
}, {
"hash" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505",
"triggerID" : "5403d7cd9a65b24e0d53f7052c820d1cc91782ea",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* Unknown: [CANCELED](TBD)
* e456383b0cafdeb67e8f37785783b3b35a6eaf47 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15495)
* 5403d7cd9a65b24e0d53f7052c820d1cc91782ea Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15505)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
}, {
"hash" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15417",
"triggerID" : "f65f9751b0e4a78d617f3c5a6d483d73580cfe0d",
"triggerType" : "PUSH"
}, {
"hash" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15429",
"triggerID" : "4b7ebaa8b37c538b8da78610cea36b04cdb111c4",
"triggerType" : "PUSH"
}, {
"hash" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469",
"triggerID" : "f6339522b9b58acc617e3a91b434ecebd8207e49",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* f6339522b9b58acc617e3a91b434ecebd8207e49 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15469)
<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 #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #15362:
URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15387",
"triggerID" : "7337a3e037f2b8742bf85b1f21a163d57401b525",
"triggerType" : "PUSH"
}, {
"hash" : "a46a6236b098fdc7b89755d4b072053134d42507",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394",
"triggerID" : "a46a6236b098fdc7b89755d4b072053134d42507",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* a46a6236b098fdc7b89755d4b072053134d42507 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=15394)
<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