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 2022/02/15 16:49:07 UTC

[GitHub] [flink] godfreyhe opened a new pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

godfreyhe opened a new pull request #18785:
URL: https://github.com/apache/flink/pull/18785


   
   ## What is the purpose of the change
   
   *Explicitly set the partitioner for the sql operators whose shuffle and sort are removed*
   
   
   ## Brief change log
   
     - *Introduce InputSortedExecNode*
     - *Update ForwardHashExchangeProcessor to explicitly set Exchange for the nodes whose shuffle and sort are removed *
   
   
   ## Verifying this change
   
   
   
   This change added tests and can be verified as follows:
   
     - *Extended ForwardHashExchangeTest the verify the plan about the changes*
   
   ## Does this pull request potentially affect one of the following parts:
   
     - Dependencies (does it add or upgrade a dependency): (yes / **no**)
     - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (yes / **no**)
     - The serializers: (yes / **no** / don't know)
     - The runtime per-record code paths (performance sensitive): (yes / **no** / don't know)
     - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (yes / **no** / don't know)
     - The S3 file system connector: (yes / **no** / don't know)
   
   ## Documentation
   
     - Does this pull request introduce a new feature? (yes / **no**)
     - If yes, how is the feature documented? (not applicable / docs / JavaDocs / **not documented**)
   


-- 
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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] wenlong88 commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
wenlong88 commented on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1041828321


   LGTM


-- 
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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] wenlong88 commented on a change in pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
wenlong88 commented on a change in pull request #18785:
URL: https://github.com/apache/flink/pull/18785#discussion_r808030853



##########
File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecExchange.java
##########
@@ -136,25 +154,38 @@ public String getDescription() {
                 parallelism = ExecutionConfig.PARALLELISM_DEFAULT;
                 break;
             case KEEP_INPUT_AS_IS:
-                RequiredDistribution inputDistribution =
-                        ((KeepInputAsIsDistribution) requiredDistribution).getInputDistribution();
-                checkArgument(
-                        inputDistribution instanceof HashDistribution,
-                        "Only HashDistribution is supported now");
-                partitioner =
-                        new ForwardForConsecutiveHashPartitioner<>(
-                                createHashPartitioner(
-                                        ((HashDistribution) inputDistribution),
-                                        inputType,
-                                        planner));
+                KeepInputAsIsDistribution keepInputAsIsDistribution =
+                        (KeepInputAsIsDistribution) requiredDistribution;
+                if (keepInputAsIsDistribution.isStrict()) {
+                    // explicitly use ForwardPartitioner to guarantee the data distribution is
+                    // exactly the same as input
+                    partitioner = new ForwardPartitioner<>();
+                    requireUndefinedExchangeMode = true;
+                } else {
+                    RequiredDistribution inputDistribution =
+                            ((KeepInputAsIsDistribution) requiredDistribution)
+                                    .getInputDistribution();
+                    checkArgument(
+                            inputDistribution instanceof HashDistribution,
+                            "Only HashDistribution is supported now");
+                    partitioner =
+                            new ForwardForConsecutiveHashPartitioner<>(
+                                    createHashPartitioner(
+                                            ((HashDistribution) inputDistribution),
+                                            inputType,
+                                            planner));
+                }
                 parallelism = inputTransform.getParallelism();
                 break;
             default:
                 throw new TableException(distributionType + "is not supported now!");
         }
 
         final StreamExchangeMode exchangeMode =
-                getBatchStreamExchangeMode(planner.getConfiguration(), requiredExchangeMode);
+                requireUndefinedExchangeMode
+                        ? StreamExchangeMode.UNDEFINED

Review comment:
       why it is speical when it is forward partitioner? i think forward and ForwardForConsecutiveHashPartitioner shoudl required the same exchange mode?




-- 
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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] godfreyhe commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
godfreyhe commented on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1042612877


   @flinkbot run azure


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] godfreyhe closed pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
godfreyhe closed pull request #18785:
URL: https://github.com/apache/flink/pull/18785


   


-- 
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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574) 
   * 896383d69cc23dc38fa73e124538644de4db15aa Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040521796






-- 
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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 50789f74f16c2bd3e42a61754f426877a3376056 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608) 
   * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "triggerType" : "PUSH"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1041693363",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1042612877",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "f9b7ab0d7040a7ead20dd10af165a6d6ce31887a",
       "status" : "SUCCESS",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31779",
       "triggerID" : "f9b7ab0d7040a7ead20dd10af165a6d6ce31887a",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * f9b7ab0d7040a7ead20dd10af165a6d6ce31887a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31779) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 896383d69cc23dc38fa73e124538644de4db15aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589) 
   * 50789f74f16c2bd3e42a61754f426877a3376056 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] godfreyhe commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
godfreyhe commented on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1041345782


   @flinkbot run azure


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "triggerType" : "PUSH"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1041693363",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1042612877",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "f9b7ab0d7040a7ead20dd10af165a6d6ce31887a",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "f9b7ab0d7040a7ead20dd10af165a6d6ce31887a",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646) 
   * f9b7ab0d7040a7ead20dd10af165a6d6ce31887a UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565) 
   * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565) 
   * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 50789f74f16c2bd3e42a61754f426877a3376056 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608) 
   * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574) 
   * 896383d69cc23dc38fa73e124538644de4db15aa Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589) 
   * 50789f74f16c2bd3e42a61754f426877a3376056 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "triggerType" : "PUSH"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1041693363",
       "triggerType" : "MANUAL"
     } ]
   }-->
   ## CI report:
   
   * 50789f74f16c2bd3e42a61754f426877a3376056 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608) 
   * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] godfreyhe commented on a change in pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
godfreyhe commented on a change in pull request #18785:
URL: https://github.com/apache/flink/pull/18785#discussion_r808121812



##########
File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecExchange.java
##########
@@ -136,25 +154,38 @@ public String getDescription() {
                 parallelism = ExecutionConfig.PARALLELISM_DEFAULT;
                 break;
             case KEEP_INPUT_AS_IS:
-                RequiredDistribution inputDistribution =
-                        ((KeepInputAsIsDistribution) requiredDistribution).getInputDistribution();
-                checkArgument(
-                        inputDistribution instanceof HashDistribution,
-                        "Only HashDistribution is supported now");
-                partitioner =
-                        new ForwardForConsecutiveHashPartitioner<>(
-                                createHashPartitioner(
-                                        ((HashDistribution) inputDistribution),
-                                        inputType,
-                                        planner));
+                KeepInputAsIsDistribution keepInputAsIsDistribution =
+                        (KeepInputAsIsDistribution) requiredDistribution;
+                if (keepInputAsIsDistribution.isStrict()) {
+                    // explicitly use ForwardPartitioner to guarantee the data distribution is
+                    // exactly the same as input
+                    partitioner = new ForwardPartitioner<>();
+                    requireUndefinedExchangeMode = true;
+                } else {
+                    RequiredDistribution inputDistribution =
+                            ((KeepInputAsIsDistribution) requiredDistribution)
+                                    .getInputDistribution();
+                    checkArgument(
+                            inputDistribution instanceof HashDistribution,
+                            "Only HashDistribution is supported now");
+                    partitioner =
+                            new ForwardForConsecutiveHashPartitioner<>(
+                                    createHashPartitioner(
+                                            ((HashDistribution) inputDistribution),
+                                            inputType,
+                                            planner));
+                }
                 parallelism = inputTransform.getParallelism();
                 break;
             default:
                 throw new TableException(distributionType + "is not supported now!");
         }
 
         final StreamExchangeMode exchangeMode =
-                getBatchStreamExchangeMode(planner.getConfiguration(), requiredExchangeMode);
+                requireUndefinedExchangeMode
+                        ? StreamExchangeMode.UNDEFINED

Review comment:
       consider the chain logic in `StreamingJobGraphGenerator`, the exchange mode of forward partitioner should not be `BATCH`, otherwise the operators can be chained. while for `ForwardForConsecutiveHashPartitioner`, if it is converted to hash shuffle and the exchange mode is set as `ALL_EDGES_BLOCKING` through `table.exec.shuffle-mode`, its final shuffle mode should be batch. the chain logic for ForwardForConsecutiveHashPartitioner will be updated in FLINK-26168.




-- 
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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] godfreyhe commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
godfreyhe commented on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1041693363


   @flinkbot run azure


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565) 
   * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565) 
   * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "triggerType" : "PUSH"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1041693363",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1042612877",
       "triggerType" : "MANUAL"
     } ]
   }-->
   ## CI report:
   
   * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "triggerType" : "PUSH"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1041693363",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1042612877",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "f9b7ab0d7040a7ead20dd10af165a6d6ce31887a",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31779",
       "triggerID" : "f9b7ab0d7040a7ead20dd10af165a6d6ce31887a",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646) 
   * f9b7ab0d7040a7ead20dd10af165a6d6ce31887a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31779) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "triggerType" : "PUSH"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1041693363",
       "triggerType" : "MANUAL"
     } ]
   }-->
   ## CI report:
   
   * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040521796


   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 d320883121e6d4949afb0030d74e14b4fa941a34 (Tue Feb 15 16:54:37 UTC 2022)
   
   **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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574) 
   * 896383d69cc23dc38fa73e124538644de4db15aa UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * d320883121e6d4949afb0030d74e14b4fa941a34 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565) 
   * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "triggerType" : "PUSH"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "CANCELED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1041693363",
       "triggerType" : "MANUAL"
     }, {
       "hash" : "15dc3494e8378bd67fd2ca859eeb317d88d45c95",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646",
       "triggerID" : "1042612877",
       "triggerType" : "MANUAL"
     } ]
   }-->
   ## CI report:
   
   * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31646) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 50789f74f16c2bd3e42a61754f426877a3376056 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     }, {
       "hash" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31589",
       "triggerID" : "896383d69cc23dc38fa73e124538644de4db15aa",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "triggerType" : "PUSH"
     }, {
       "hash" : "50789f74f16c2bd3e42a61754f426877a3376056",
       "status" : "PENDING",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608",
       "triggerID" : "1041345782",
       "triggerType" : "MANUAL"
     } ]
   }-->
   ## CI report:
   
   * 50789f74f16c2bd3e42a61754f426877a3376056 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31608) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147






-- 
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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #18785:
URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147


   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "status" : "DELETED",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31565",
       "triggerID" : "d320883121e6d4949afb0030d74e14b4fa941a34",
       "triggerType" : "PUSH"
     }, {
       "hash" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "status" : "FAILURE",
       "url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574",
       "triggerID" : "9282d2538dc9e9bfb0be8ab81b7928fc4230f924",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 9282d2538dc9e9bfb0be8ab81b7928fc4230f924 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=31574) 
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@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.

To unsubscribe, e-mail: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org