[GitHub] [flink] zjffdu commented on a change in pull request #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient

zjffdu commented on a change in pull request #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient URL: https://github.com/apache/flink/pull/10320#discussion_r350576393 ## File path:

[jira] [Updated] (FLINK-14760) Documentation links check failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14760: - Fix Version/s: (was: 1.10.0) > Documentation links check failed on travis >

[GitHub] [flink] flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner

flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner URL: https://github.com/apache/flink/pull/10315#issuecomment-558221318 ## CI report: * 05b30617c280796e80e8569dae48b726cddb23d8 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient

flinkbot commented on issue #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient URL: https://github.com/apache/flink/pull/10320#issuecomment-558499094 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] zjffdu commented on a change in pull request #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient

zjffdu commented on a change in pull request #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient URL: https://github.com/apache/flink/pull/10320#discussion_r350576393 ## File path:

[jira] [Updated] (FLINK-14936) Introduce MemoryManager#computeMemorySize to calculate managed memory from a fraction

[ https://issues.apache.org/jira/browse/FLINK-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14936: Summary: Introduce MemoryManager#computeMemorySize to calculate managed memory from a fraction (was:

[GitHub] [flink] TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350563329 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350563213 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350562960 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350562286 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350559045 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350558859 ## File path:

[jira] [Resolved] (FLINK-14892) Add documentation for checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14892. - Resolution: Fixed Fixed in 1.10.0: 5984d52f6a3f39447879a026fd34485362e03ab9 > Add documentation for

[GitHub] [flink] wuchong merged pull request #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

wuchong merged pull request #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350560496 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10294: [FLINK-14913][table] refactor CatalogFunction to remove properties

flinkbot edited a comment on issue #10294: [FLINK-14913][table] refactor CatalogFunction to remove properties URL: https://github.com/apache/flink/pull/10294#issuecomment-557607647 ## CI report: * 579e382633f5e4f262179e8ca3018a39f80b7af9 : FAILURE

[GitHub] [flink] lirui-apache commented on a change in pull request #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

lirui-apache commented on a change in pull request #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#discussion_r350568825 ## File path:

[jira] [Updated] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-14946: --- Attachment: screenshot-2.png > Retraction infer would result in bad plan under corner case in blink

[jira] [Updated] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-14946: --- Attachment: screenshot-3.png > Retraction infer would result in bad plan under corner case in blink

[GitHub] [flink] godfreyhe commented on issue #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics

godfreyhe commented on issue #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics URL: https://github.com/apache/flink/pull/10174#issuecomment-558479874 LGTM, cc @KurtYoung

[jira] [Commented] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982179#comment-16982179 ] Jark Wu commented on FLINK-14941: - Hi [~modavis], I checked the API and the {{withStartRow}} is in

[jira] [Updated] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14941: Component/s: Connectors / HBase > The AbstractTableInputFormat#nextRecord in hbase connector will handle

[jira] [Assigned] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14941: --- Assignee: Zheng Hu > The AbstractTableInputFormat#nextRecord in hbase connector will handle the >

[GitHub] [flink] flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49.

flinkbot edited a comment on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. URL: https://github.com/apache/flink/pull/10161#issuecomment-552882313 ## CI report: * 2c0501f41bea1da031777069dd46eb17c5ae8038 : FAILURE

[jira] [Assigned] (FLINK-14947) Implement LocalExecutor as new Executor interface

[ https://issues.apache.org/jira/browse/FLINK-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14947: - Assignee: (was: Zili Chen) > Implement LocalExecutor as new Executor interface >

[GitHub] [flink] TsReaper commented on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

TsReaper commented on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558473091 > @TsReaper I think it would be better to add method `Table.collect` to expose this functionality,

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10294: [FLINK-14913][table] refactor CatalogFunction to remove properties

flinkbot edited a comment on issue #10294: [FLINK-14913][table] refactor CatalogFunction to remove properties URL: https://github.com/apache/flink/pull/10294#issuecomment-557607647 ## CI report: * 579e382633f5e4f262179e8ca3018a39f80b7af9 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199 ## CI report: * 0b265d192e2a6024e5817317be0317136208ccaf : SUCCESS

[jira] [Commented] (FLINK-14936) Introduce MemoryManager#computeMemorySize to calculate managed memory from a fraction

[ https://issues.apache.org/jira/browse/FLINK-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982195#comment-16982195 ] Zhu Zhu commented on FLINK-14936: - Thanks [~azagrebin] for the explanation. I think you are right that

[jira] [Comment Edited] (FLINK-14936) Introduce MemoryManager#computeMemorySize to calculate managed memory from a fraction

[ https://issues.apache.org/jira/browse/FLINK-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982195#comment-16982195 ] Zhu Zhu edited comment on FLINK-14936 at 11/26/19 7:08 AM: --- Thanks

[jira] [Commented] (FLINK-14813) Expose the new mechanism implemented in FLINK-14472 as a "is back-pressured" metric

[ https://issues.apache.org/jira/browse/FLINK-14813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982205#comment-16982205 ] lining commented on FLINK-14813: [~pnowojski] Could you help to review it? > Expose the new mechanism

[jira] [Created] (FLINK-14947) Implement LocalExecutor as new Executor interface

Zili Chen created FLINK-14947: - Summary: Implement LocalExecutor as new Executor interface Key: FLINK-14947 URL: https://issues.apache.org/jira/browse/FLINK-14947 Project: Flink Issue Type:

[jira] [Closed] (FLINK-14865) Unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-14865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14865. --- Resolution: Fixed > Unstable tests >

[jira] [Created] (FLINK-14948) Implement shutDownCluster for MiniClusterClient

Zili Chen created FLINK-14948: - Summary: Implement shutDownCluster for MiniClusterClient Key: FLINK-14948 URL: https://issues.apache.org/jira/browse/FLINK-14948 Project: Flink Issue Type:

[jira] [Created] (FLINK-14949) Task cancellation can be stuck against out-of-thread error

Hwanju Kim created FLINK-14949: -- Summary: Task cancellation can be stuck against out-of-thread error Key: FLINK-14949 URL: https://issues.apache.org/jira/browse/FLINK-14949 Project: Flink Issue

[jira] [Updated] (FLINK-14947) Implement LocalExecutor as new Executor interface

[ https://issues.apache.org/jira/browse/FLINK-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14947: -- Description: We can replace {{PlanExecutor}} things with new Executor interface. One of this series

[jira] [Updated] (FLINK-14947) Implement LocalExecutor as new Executor interface

[ https://issues.apache.org/jira/browse/FLINK-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14947: -- Description: We can replace {{PlanExecutor}} things with new Executor interface. One of this series

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[jira] [Commented] (FLINK-10538) standalone-job.sh causes Classpath issues

[ https://issues.apache.org/jira/browse/FLINK-10538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982216#comment-16982216 ] limbo commented on FLINK-10538: --- I think the dependencies have been shaded, issue could be closed >

[GitHub] [flink] TisonKun commented on a change in pull request #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient

TisonKun commented on a change in pull request #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient URL: https://github.com/apache/flink/pull/10320#discussion_r350578624 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10319: [FLINK-14945] [runtime] simplify some code

flinkbot edited a comment on issue #10319: [FLINK-14945] [runtime] simplify some code URL: https://github.com/apache/flink/pull/10319#issuecomment-558473837 ## CI report: * b695eaeb18c267335f7f608602f747f3aec35ee3 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute

flinkbot edited a comment on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute URL: https://github.com/apache/flink/pull/10316#issuecomment-558248395 ## CI report: * 3624bce085de9f708f4d5fb4a8a7617884c0adf8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : FAILURE

[jira] [Commented] (FLINK-14947) Implement LocalExecutor as new Executor interface

[ https://issues.apache.org/jira/browse/FLINK-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1698#comment-1698 ] Aljoscha Krettek commented on FLINK-14947: -- I think [~kkl0u]] has already started working on

[GitHub] [flink] TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r350551175 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[jira] [Assigned] (FLINK-14865) Unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-14865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14865: --- Assignee: Wei Zhong > Unstable tests >

[jira] [Commented] (FLINK-14865) Unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-14865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982150#comment-16982150 ] Hequn Cheng commented on FLINK-14865: - Resolved in 1.10.0 via

[GitHub] [flink] TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

TisonKun commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r350555630 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] hequn8128 closed pull request #10310: [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

hequn8128 closed pull request #10310: [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2 URL: https://github.com/apache/flink/pull/10310 This is an automated

[GitHub] [flink] TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350558703 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

TisonKun commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350562168 ## File path:

[jira] [Created] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

Jing Zhang created FLINK-14946: -- Summary: Retraction infer would result in bad plan under corner case in blink planner Key: FLINK-14946 URL: https://issues.apache.org/jira/browse/FLINK-14946 Project:

[GitHub] [flink] flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199 ## CI report: * 0b265d192e2a6024e5817317be0317136208ccaf : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute

flinkbot edited a comment on issue #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute URL: https://github.com/apache/flink/pull/10316#issuecomment-558248395 ## CI report: * 3624bce085de9f708f4d5fb4a8a7617884c0adf8 : FAILURE

[jira] [Comment Edited] (FLINK-14936) Introduce MemoryManager#computeMemorySize to calculate managed memory from a fraction

[ https://issues.apache.org/jira/browse/FLINK-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982195#comment-16982195 ] Zhu Zhu edited comment on FLINK-14936 at 11/26/19 7:15 AM: --- Thanks

[jira] [Updated] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-14946: --- Attachment: screenshot-5.png > Retraction infer would result in bad plan under corner case in blink

[jira] [Comment Edited] (FLINK-14947) Implement LocalExecutor as new Executor interface

[ https://issues.apache.org/jira/browse/FLINK-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982227#comment-16982227 ] Zili Chen edited comment on FLINK-14947 at 11/26/19 7:56 AM: - OK I will

[jira] [Commented] (FLINK-14947) Implement LocalExecutor as new Executor interface

[ https://issues.apache.org/jira/browse/FLINK-14947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982227#comment-16982227 ] Zili Chen commented on FLINK-14947: --- OK I will un-assign the issue. Besides, I think it would be

[jira] [Updated] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-14946: --- Attachment: screenshot-4.png > Retraction infer would result in bad plan under corner case in blink

[GitHub] [flink] flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-555964030 ## CI report: * 72414aad5f654b834205103f23fbbfc3d5466748 : FAILURE

[jira] [Updated] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-14946: --- Attachment: RetractionRules1Test.scala > Retraction infer would result in bad plan under corner

[GitHub] [flink] flinkbot edited a comment on issue #10319: [FLINK-14945] [runtime] simplify some code

flinkbot edited a comment on issue #10319: [FLINK-14945] [runtime] simplify some code URL: https://github.com/apache/flink/pull/10319#issuecomment-558473837 ## CI report: * b695eaeb18c267335f7f608602f747f3aec35ee3 : SUCCESS

[GitHub] [flink] lirui-apache commented on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

lirui-apache commented on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#issuecomment-558504806 @dawidwys Thanks for the update. +1 to have self contained dialect flag in view definition. The PR looks

[GitHub] [flink] flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner

flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner URL: https://github.com/apache/flink/pull/10315#issuecomment-558221318 ## CI report: * 05b30617c280796e80e8569dae48b726cddb23d8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199 ## CI report: * 0b265d192e2a6024e5817317be0317136208ccaf : SUCCESS

[GitHub] [flink] aljoscha commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

aljoscha commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350585143 ## File path:

[GitHub] [flink] flinkbot commented on issue #10319: [FLINK-14945] [runtime] simplify some code

flinkbot commented on issue #10319: [FLINK-14945] [runtime] simplify some code URL: https://github.com/apache/flink/pull/10319#issuecomment-558473837 ## CI report: * b695eaeb18c267335f7f608602f747f3aec35ee3 : UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Updated] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-14946: --- Description: Retractions rule would result in bad plan under some case, I simplify the case like

[jira] [Updated] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-14946: --- Attachment: screenshot-1.png > Retraction infer would result in bad plan under corner case in blink

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10294: [FLINK-14913][table] refactor CatalogFunction to remove properties

flinkbot edited a comment on issue #10294: [FLINK-14913][table] refactor CatalogFunction to remove properties URL: https://github.com/apache/flink/pull/10294#issuecomment-557607647 ## CI report: * 579e382633f5e4f262179e8ca3018a39f80b7af9 : FAILURE

[jira] [Updated] (FLINK-14948) Implement shutDownCluster for MiniClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14948: --- Labels: pull-request-available (was: ) > Implement shutDownCluster for MiniClusterClient >

[GitHub] [flink] TisonKun opened a new pull request #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient

TisonKun opened a new pull request #10320: [FLINK-14948][client] Implement shutDownCluster for MiniClusterClient URL: https://github.com/apache/flink/pull/10320 ## What is the purpose of the change Indeed, we *can* implement proper `shutDownCluster` method for `MiniClusterClient`

[GitHub] [flink] flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-555964030 ## CI report: * 72414aad5f654b834205103f23fbbfc3d5466748 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

flinkbot edited a comment on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#issuecomment-518729517 ## CI report: * c2adafa7ee87b18ba6af0b5f518251150a8da386 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10308: [FLINK-14904][table] Rename ANY type to RAW type

flinkbot commented on issue #10308: [FLINK-14904][table] Rename ANY type to RAW type URL: https://github.com/apache/flink/pull/10308#issuecomment-558058824 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] zhuzhurk opened a new pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

zhuzhurk opened a new pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309 ## What is the purpose of the change This PR is to let tasks in a batch get scheduled in topological

[GitHub] [flink] zhijiangW commented on a change in pull request #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle)

zhijiangW commented on a change in pull request #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle) URL: https://github.com/apache/flink/pull/10180#discussion_r350038437 ## File path: flink-docs/README.md ## @@ -1,4 +1,4 @@

[GitHub] [flink] HuangXingBo commented on issue #10103: [FLINK-14506][python][build] Improve the release script for Python API release package

HuangXingBo commented on issue #10103: [FLINK-14506][python][build] Improve the release script for Python API release package URL: https://github.com/apache/flink/pull/10103#issuecomment-558043625 @hequn8128 Thanks a lot for review, I have addressed the comments at latest commit.

[jira] [Created] (FLINK-14938) Flink elasticsearch failure handler re-add indexrequest causes ConcurrentModificationException

Shengnan YU created FLINK-14938: --- Summary: Flink elasticsearch failure handler re-add indexrequest causes ConcurrentModificationException Key: FLINK-14938 URL: https://issues.apache.org/jira/browse/FLINK-14938

[GitHub] [flink] flinkbot commented on issue #10307: [FLINK-14903][table] Relax structured types constraints

flinkbot commented on issue #10307: [FLINK-14903][table] Relax structured types constraints URL: https://github.com/apache/flink/pull/10307#issuecomment-558047235 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] flinkbot edited a comment on issue #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics

flinkbot edited a comment on issue #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics URL: https://github.com/apache/flink/pull/10174#issuecomment-553372516 ## CI report: * 0877da16f10eef830aafb9d6b3328df1c1b461a0

[GitHub] [flink] flinkbot edited a comment on issue #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics

flinkbot edited a comment on issue #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics URL: https://github.com/apache/flink/pull/10174#issuecomment-553372516 ## CI report: * 0877da16f10eef830aafb9d6b3328df1c1b461a0

[jira] [Updated] (FLINK-14904) Rename ANY type to RAW type

[ https://issues.apache.org/jira/browse/FLINK-14904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14904: --- Labels: pull-request-available (was: ) > Rename ANY type to RAW type >

[GitHub] [flink] twalthr opened a new pull request #10308: [FLINK-14904][table] Rename ANY type to RAW type

twalthr opened a new pull request #10308: [FLINK-14904][table] Rename ANY type to RAW type URL: https://github.com/apache/flink/pull/10308 ## What is the purpose of the change Renames the `ANY` type to `RAW` type. ## Brief change log Updates docs, parser, logical

[jira] [Updated] (FLINK-14909) Let tasks in a batch get scheduled in topological order and subtaskIndex ascending pattern

[ https://issues.apache.org/jira/browse/FLINK-14909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14909: --- Labels: pull-request-available (was: ) > Let tasks in a batch get scheduled in topological

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[GitHub] [flink] yanghua edited a comment on issue #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation

yanghua edited a comment on issue #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation URL: https://github.com/apache/flink/pull/10215#issuecomment-558063394 @aljoscha So, what should I do now? I removed the relevant documentation because I

[GitHub] [flink] yanghua commented on issue #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation

yanghua commented on issue #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation URL: https://github.com/apache/flink/pull/10215#issuecomment-558068355 > I don't see `TaskManagerOptions#NETWORK_NUM_BUFFERS` in the current master branch. >

[GitHub] [flink] flinkbot commented on issue #10308: [FLINK-14904][table] Rename ANY type to RAW type

flinkbot commented on issue #10308: [FLINK-14904][table] Rename ANY type to RAW type URL: https://github.com/apache/flink/pull/10308#issuecomment-558068050 ## CI report: * aecadb0df6ee41fc76943e030073b4a93d267aac : UNKNOWN Bot commands The @flinkbot bot supports

[GitHub] [flink] flinkbot commented on issue #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

flinkbot commented on issue #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#issuecomment-558068110 ## CI report: * 51e86fe9d2397879945677aee80da5983402afca : UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #10307: [FLINK-14903][table] Relax structured types constraints

flinkbot edited a comment on issue #10307: [FLINK-14903][table] Relax structured types constraints URL: https://github.com/apache/flink/pull/10307#issuecomment-558055598 ## CI report: * 73831c7af91e2ec54c8af39cd649024ef3c4ac81 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" URL: https://github.com/apache/flink/pull/10126#issuecomment-551413525 ## CI report: *

[GitHub] [flink] yanghua commented on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc

yanghua commented on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc URL: https://github.com/apache/flink/pull/10304#issuecomment-558046370 cc @tillrohrmann @GJL

[jira] [Updated] (FLINK-14903) Relax structured types constraints

[ https://issues.apache.org/jira/browse/FLINK-14903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14903: --- Labels: pull-request-available (was: ) > Relax structured types constraints >

[GitHub] [flink] twalthr opened a new pull request #10307: [FLINK-14903][table] Relax structured types constraints

twalthr opened a new pull request #10307: [FLINK-14903][table] Relax structured types constraints URL: https://github.com/apache/flink/pull/10307 ## What is the purpose of the change In order to allow type extraction of structured types that are not registered in a catalog, we need

[GitHub] [flink] aljoscha commented on issue #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation

aljoscha commented on issue #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation URL: https://github.com/apache/flink/pull/10215#issuecomment-558061228 Yes, because the setting is not removed in the code. If anyone re-generates the

[jira] [Closed] (FLINK-14873) Make PackagedProgram#savepointSettings final

[ https://issues.apache.org/jira/browse/FLINK-14873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14873. Resolution: Fixed Merged on master in a6d6778b11c0ad12a427344c140360b5472ef661 > Make

[GitHub] [flink] aljoscha commented on issue #10274: [FLINK-14873][client] Make PackagedProgram#savepointSettings final

aljoscha commented on issue #10274: [FLINK-14873][client] Make PackagedProgram#savepointSettings final URL: https://github.com/apache/flink/pull/10274#issuecomment-558060626 I merged this.  This is an automated message from

  1   2   3   4   5   >