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/02/28 13:06:09 UTC
[GitHub] [flink] dianfu opened a new pull request #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
dianfu opened a new pull request #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252
## What is the purpose of the change
*This pull request adds the relNodes and rules to support vectorized Python UDF in blink planner and old planner.*
## Brief change log
- *Introduce relNodes and rules to support vectorized Python UDF in blink planner such as StreamExecArrowPythonCalc, BatchExecArrowPythonCalc, etc *
- *Introduce relNodes and rules to support vectorized Python UDF in old planner such as DataStreamArrowPythonCalc*
- *Introduce PythonCalcSplitPandasInProjectionRule which is used to support use non-vectorized Python UDF and vectorized Python UDF in the same job*
## Verifying this change
This change added tests and can be verified as follows:
- *Added tests in PythonCalcSplitRuleTest*
## 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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* ec7775530fe0294d9cc2a32333d7227fb7f80461 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151024745) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738)
* 6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e 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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151480068) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151659712",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151949187",
"triggerID" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"triggerType" : "PUSH"
}, {
"hash" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5968",
"triggerID" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 43041585ccc2dd381baf70240aca178fef9c7b93 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151949187) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5968)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "PENDING",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 10b200479599a68fe39d0ed2f27c7630adf11f50 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151528978) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867)
* d90b0eb350b2062894d7c9da8230deda7e592b45 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151592119) Azure: [PENDING](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151659712",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 542c6f80de4976c204a68968f6d5af383dad1ac5 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151659712) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* d90b0eb350b2062894d7c9da8230deda7e592b45 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151592119) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* c1b8a9d54c2904627d0dce5676e29102197836fa Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151518626) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864)
<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
With regards,
Apache Git Services
[GitHub] [flink] dianfu commented on issue #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
dianfu commented on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-595204458
@hequn8128 Thanks a lot for your great review and suggestions. That makes much sense to me and have updated the PR accordingly. Regarding to the support of pandas udf for batch mode in old planner, I'd like to add it in a separate PR as the operator for this case is still not added. What's your thoughts?
----------------------------------------------------------------
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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* d90b0eb350b2062894d7c9da8230deda7e592b45 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151592119) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* c1b8a9d54c2904627d0dce5676e29102197836fa Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151518626) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864)
* 10b200479599a68fe39d0ed2f27c7630adf11f50 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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "PENDING",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151659712",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* d90b0eb350b2062894d7c9da8230deda7e592b45 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151592119) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885)
* 542c6f80de4976c204a68968f6d5af383dad1ac5 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151659712) Azure: [PENDING](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot commented on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot commented on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* ec7775530fe0294d9cc2a32333d7227fb7f80461 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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot commented on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot commented on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592505409
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 ec7775530fe0294d9cc2a32333d7227fb7f80461 (Fri Feb 28 13:09:25 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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 10b200479599a68fe39d0ed2f27c7630adf11f50 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151528978) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867)
* d90b0eb350b2062894d7c9da8230deda7e592b45 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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 10b200479599a68fe39d0ed2f27c7630adf11f50 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151528978) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867)
<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
With regards,
Apache Git Services
[GitHub] [flink] hequn8128 commented on a change in pull request #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
hequn8128 commented on a change in pull request #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252#discussion_r388113865
##########
File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/BatchExecArrowPythonCalcRule.scala
##########
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.table.planner.plan.rules.physical.batch
+
+import org.apache.calcite.plan.{RelOptRule, RelOptRuleCall}
+import org.apache.calcite.rel.RelNode
+import org.apache.calcite.rel.convert.ConverterRule
+import org.apache.flink.table.functions.python.PythonFunctionKind
+import org.apache.flink.table.planner.plan.nodes.FlinkConventions
+import org.apache.flink.table.planner.plan.nodes.logical.FlinkLogicalCalc
+import org.apache.flink.table.planner.plan.nodes.physical.batch.BatchExecArrowPythonCalc
+import org.apache.flink.table.planner.plan.utils.PythonUtil.containsPythonCall
+
+import scala.collection.JavaConverters._
+
+/**
+ * Rule that converts [[FlinkLogicalCalc]] to [[BatchExecArrowPythonCalc]].
+ */
+class BatchExecArrowPythonCalcRule
Review comment:
How about reusing the current PythonCalcRule and PythonCalRelNode? Most code between `PythonCalcRule` and `ArrowPythonCalcRule`, `PythonCalRelNode` and `ArrowPythonCalRelNode` are same. The Rules even don't need to be changed.
Besides, we may need to convert this class to Java? In the long term, it's better to avoid new scala classes. Also see discussion here: https://github.com/apache/flink/pull/11051#discussion_r379227379
What do you think?
----------------------------------------------------------------
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
With regards,
Apache Git Services
[GitHub] [flink] hequn8128 commented on a change in pull request #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
hequn8128 commented on a change in pull request #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252#discussion_r388123171
##########
File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/utils/UserDefinedTableFunctions.scala
##########
@@ -22,12 +22,10 @@ import org.apache.flink.api.java.tuple.Tuple3
import org.apache.flink.api.java.typeutils.RowTypeInfo
import org.apache.flink.api.scala.typeutils.Types
import org.apache.flink.table.api.ValidationException
-import org.apache.flink.table.functions.python.{PythonEnv, PythonFunction}
+import org.apache.flink.table.functions.python.{PythonEnv, PythonFunction, PythonFunctionKind}
import org.apache.flink.table.functions.{FunctionContext, ScalarFunction, TableFunction}
import org.apache.flink.types.Row
-
Review comment:
Unnecessary changes.
----------------------------------------------------------------
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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* ec7775530fe0294d9cc2a32333d7227fb7f80461 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151024745) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151659712",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 542c6f80de4976c204a68968f6d5af383dad1ac5 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/151659712) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890)
* 43041585ccc2dd381baf70240aca178fef9c7b93 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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151659712",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 542c6f80de4976c204a68968f6d5af383dad1ac5 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/151659712) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890)
<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
With regards,
Apache Git Services
[GitHub] [flink] hequn8128 commented on a change in pull request #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
hequn8128 commented on a change in pull request #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252#discussion_r388030258
##########
File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/PythonUtil.scala
##########
@@ -32,51 +33,85 @@ object PythonUtil {
* @param node the RexNode to check
* @return true if it contains the Python function call in the specified node.
*/
- def containsPythonCall(node: RexNode): Boolean = node.accept(new FunctionFinder(true, true))
+ def containsPythonCall(node: RexNode): Boolean =
Review comment:
How about merging the two `containsPythonCall `. I see two options:
- Add a default parameter for `pythonFunctionKind`.
- Add a GENERAL_PANDAS enum type in `PythonFunctionKind`.
----------------------------------------------------------------
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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 10b200479599a68fe39d0ed2f27c7630adf11f50 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151528978) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* ec7775530fe0294d9cc2a32333d7227fb7f80461 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151024745) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* c1b8a9d54c2904627d0dce5676e29102197836fa Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151518626) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "PENDING",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* ec7775530fe0294d9cc2a32333d7227fb7f80461 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151024745) Azure: [PENDING](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738)
<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
With regards,
Apache Git Services
[GitHub] [flink] hequn8128 commented on a change in pull request #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
hequn8128 commented on a change in pull request #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252#discussion_r388116049
##########
File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecArrowPythonCalc.scala
##########
@@ -0,0 +1,80 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.table.planner.plan.nodes.physical.batch
+
+import org.apache.calcite.plan.{RelOptCluster, RelTraitSet}
+import org.apache.calcite.rel.RelNode
+import org.apache.calcite.rel.`type`.RelDataType
+import org.apache.calcite.rel.core.Calc
+import org.apache.calcite.rex.RexProgram
+import org.apache.flink.api.dag.Transformation
+import org.apache.flink.configuration.{ConfigOption, Configuration, MemorySize}
+import org.apache.flink.table.dataformat.BaseRow
+import org.apache.flink.table.planner.delegation.BatchPlanner
+import org.apache.flink.table.planner.plan.nodes.common.CommonPythonCalc
+import org.apache.flink.table.planner.plan.nodes.exec.ExecNode
+
+/**
+ * Batch physical RelNode for Arrow Python ScalarFunctions.
+ */
+class BatchExecArrowPythonCalc(
+ cluster: RelOptCluster,
+ traitSet: RelTraitSet,
+ inputRel: RelNode,
+ calcProgram: RexProgram,
+ outputRowType: RelDataType)
+ extends BatchExecCalcBase(
+ cluster,
+ traitSet,
+ inputRel,
+ calcProgram,
+ outputRowType)
+ with CommonPythonCalc {
+
+ override def copy(traitSet: RelTraitSet, child: RelNode, program: RexProgram): Calc = {
+ new BatchExecArrowPythonCalc(cluster, traitSet, child, program, outputRowType)
+ }
+
+ override protected def translateToPlanInternal(planner: BatchPlanner): Transformation[BaseRow] = {
+ val inputTransform = getInputNodes.get(0).translateToPlan(planner)
+ .asInstanceOf[Transformation[BaseRow]]
+ val ret = createPythonOneInputTransformation(
+ inputTransform,
+ calcProgram,
+ "BatchExecArrowPythonCalc",
+ planner.getTableConfig.getConfiguration,
+ isArrow = true)
+
+ ExecNode.setManagedMemoryWeight(
+ ret, getPythonWorkerMemory(planner.getTableConfig.getConfiguration))
+ }
+
+ private def getPythonWorkerMemory(config: Configuration): Long = {
Review comment:
This method is copied from `BatchExecPythonCalc`. How about putting this method into the `CommonPythonCalc`?
----------------------------------------------------------------
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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151480068) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849)
* c1b8a9d54c2904627d0dce5676e29102197836fa 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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151659712",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151949187",
"triggerID" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"triggerType" : "PUSH"
}, {
"hash" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"status" : "PENDING",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5968",
"triggerID" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 542c6f80de4976c204a68968f6d5af383dad1ac5 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/151659712) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890)
* 43041585ccc2dd381baf70240aca178fef9c7b93 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151949187) Azure: [PENDING](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5968)
<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
With regards,
Apache Git Services
[GitHub] [flink] hequn8128 closed pull request #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
hequn8128 closed pull request #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252
----------------------------------------------------------------
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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "PENDING",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "PENDING",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* c1b8a9d54c2904627d0dce5676e29102197836fa Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151518626) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864)
* 10b200479599a68fe39d0ed2f27c7630adf11f50 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/151528978) Azure: [PENDING](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner][table-planner-blink] Add support of
vectorized Python UDF in blink planner and old planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner][table-planner-blink] Add support of vectorized Python UDF in blink planner and old planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5890",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151659712",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
}, {
"hash" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151949187",
"triggerID" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"triggerType" : "PUSH"
}, {
"hash" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5968",
"triggerID" : "43041585ccc2dd381baf70240aca178fef9c7b93",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 43041585ccc2dd381baf70240aca178fef9c7b93 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/151949187) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5968)
<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
With regards,
Apache Git Services
[GitHub] [flink] flinkbot edited a comment on issue #11252:
[FLINK-16337][python][table-planner-blink] Add support of vectorized Python
UDF in blink planner
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on issue #11252: [FLINK-16337][python][table-planner-blink] Add support of vectorized Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11252#issuecomment-592511050
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5738",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151024745",
"triggerID" : "ec7775530fe0294d9cc2a32333d7227fb7f80461",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5849",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151480068",
"triggerID" : "6b2979d187dd3adb21cdc6327bc3aaaf6f47fe7e",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151518626",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5864",
"triggerID" : "c1b8a9d54c2904627d0dce5676e29102197836fa",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151528978",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"status" : "DELETED",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5867",
"triggerID" : "10b200479599a68fe39d0ed2f27c7630adf11f50",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "FAILURE",
"url" : "https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"status" : "FAILURE",
"url" : "https://travis-ci.com/flink-ci/flink/builds/151592119",
"triggerID" : "d90b0eb350b2062894d7c9da8230deda7e592b45",
"triggerType" : "PUSH"
}, {
"hash" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "542c6f80de4976c204a68968f6d5af383dad1ac5",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* d90b0eb350b2062894d7c9da8230deda7e592b45 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/151592119) Azure: [FAILURE](https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_build/results?buildId=5885)
* 542c6f80de4976c204a68968f6d5af383dad1ac5 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
With regards,
Apache Git Services