[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] azagrebin commented on issue #10124: [FLINK-14637] Introduce framework off heap memory config

azagrebin commented on issue #10124: [FLINK-14637] Introduce framework off heap memory config URL: https://github.com/apache/flink/pull/10124#issuecomment-554899044 merged into master by 306b83b2f6c64b37162a0aa3b6ce290c4b34bc4f --

[GitHub] [flink] azagrebin closed pull request #10124: [FLINK-14637] Introduce framework off heap memory config

azagrebin closed pull request #10124: [FLINK-14637] Introduce framework off heap memory config URL: https://github.com/apache/flink/pull/10124 This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Resolved] (FLINK-14637) Introduce framework off heap memory config

[ https://issues.apache.org/jira/browse/FLINK-14637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin resolved FLINK-14637. - Resolution: Done merged into master by 306b83b2f6c64b37162a0aa3b6ce290c4b34bc4f > Intro

[GitHub] [flink] TisonKun commented on a change in pull request #10194: [FLINK-14758] Add Executor-related interfaces and executor discovery.

TisonKun commented on a change in pull request #10194: [FLINK-14758] Add Executor-related interfaces and executor discovery. URL: https://github.com/apache/flink/pull/10194#discussion_r347239854 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environ

[jira] [Created] (FLINK-14836) Unable to set yarn container number for scala shell in yarn mode

Jeff Zhang created FLINK-14836: -- Summary: Unable to set yarn container number for scala shell in yarn mode Key: FLINK-14836 URL: https://issues.apache.org/jira/browse/FLINK-14836 Project: Flink

[jira] [Commented] (FLINK-14836) Unable to set yarn container number for scala shell in yarn mode

[ https://issues.apache.org/jira/browse/FLINK-14836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976344#comment-16976344 ] Jeff Zhang commented on FLINK-14836: [~vinoyang] [~trohrm...@apache.org] > Unable t

[jira] [Updated] (FLINK-14711) Add Alter Function and Show Functions in SQL Parser

[ https://issues.apache.org/jira/browse/FLINK-14711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-14711: -- Summary: Add Alter Function and Show Functions in SQL Parser (was: Create Alter Function and

[jira] [Assigned] (FLINK-14818) StreamNetworkBenchmarkEnvironment incorrectly setups a receiving InputGate

[ https://issues.apache.org/jira/browse/FLINK-14818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-14818: Assignee: Yingjie Cao > StreamNetworkBenchmarkEnvironment incorrectly setups a receiving InputGat

[jira] [Created] (FLINK-14837) Support Function DDL in TableEnvironment

Zhenqiu Huang created FLINK-14837: - Summary: Support Function DDL in TableEnvironment Key: FLINK-14837 URL: https://issues.apache.org/jira/browse/FLINK-14837 Project: Flink Issue Type: Sub-ta

[jira] [Updated] (FLINK-7151) Add create and drop function DDL in SQL Parser

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-7151: - Summary: Add create and drop function DDL in SQL Parser (was: Add a basic function SQL DDL) > A

[jira] [Commented] (FLINK-14836) Unable to set yarn container number for scala shell in yarn mode

[ https://issues.apache.org/jira/browse/FLINK-14836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976349#comment-16976349 ] vinoyang commented on FLINK-14836: -- IMO, we can not revert FLINK-12362, because "-n" ha

[GitHub] [flink] dawidwys closed pull request #10216: [FLINK-14750][configuration] Migrate duration and memory size ConfigOptions in RestartStrategyOptions

dawidwys closed pull request #10216: [FLINK-14750][configuration] Migrate duration and memory size ConfigOptions in RestartStrategyOptions URL: https://github.com/apache/flink/pull/10216 This is an automated message from th

[jira] [Closed] (FLINK-14750) Migrate duration and memory size ConfigOptions in RestartStrategyOptions

[ https://issues.apache.org/jira/browse/FLINK-14750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-14750. Resolution: Fixed Implemented in 6c4dfcf8a0ba9f53338ac62feacf9444fec72415 > Migrate durat

[jira] [Comment Edited] (FLINK-14836) Unable to set yarn container number for scala shell in yarn mode

[ https://issues.apache.org/jira/browse/FLINK-14836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976349#comment-16976349 ] vinoyang edited comment on FLINK-14836 at 11/18/19 8:23 AM:

[jira] [Created] (FLINK-14838) Cleanup the description about container number config option in Scala and python shell doc

vinoyang created FLINK-14838: Summary: Cleanup the description about container number config option in Scala and python shell doc Key: FLINK-14838 URL: https://issues.apache.org/jira/browse/FLINK-14838 Pr

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976354#comment-16976354 ] Caizhi Weng commented on FLINK-13943: - Hi dear Flink community. My ideas for this im

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347248101 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347247646 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347225437 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347191495 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347229401 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347191056 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347197002 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347197418 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347242788 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347226368 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347233893 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347191949 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347191842 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347247673 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347226073 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347197969 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347192810 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347194812 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347243297 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347198944 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347230376 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347199615 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[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] [Comment Edited] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976354#comment-16976354 ] Caizhi Weng edited comment on FLINK-13943 at 11/18/19 8:33 AM: ---

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347250063 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/ap

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347250856 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347251106 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/ap

[jira] [Commented] (FLINK-14814) Show the vertex that produces the backpressure source in the job

[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976364#comment-16976364 ] Piotr Nowojski commented on FLINK-14814: Having multiple output edges is I think

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347251399 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/ap

[GitHub] [flink] flinkbot edited a comment on issue #10231: [FLINK-14711][table] add alter and show function ddl

flinkbot edited a comment on issue #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#issuecomment-554720304 ## CI report: * 3dc398a62bfd6c3da7561cba9f5e6c7f43947369 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[jira] [Comment Edited] (FLINK-14814) Show the vertex that produces the backpressure source in the job

[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976364#comment-16976364 ] Piotr Nowojski edited comment on FLINK-14814 at 11/18/19 8:40 AM:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347252403 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[GitHub] [flink] JingsongLi commented on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource

JingsongLi commented on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource URL: https://github.com/apache/flink/pull/10210#issuecomment-554911636 Simple test: `createInputSplits` will take 1.1 s when the source table has 3 TB data in HDFS. ---

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347252190 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[jira] [Comment Edited] (FLINK-14814) Show the vertex that produces the backpressure source in the job

[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976364#comment-16976364 ] Piotr Nowojski edited comment on FLINK-14814 at 11/18/19 8:42 AM:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347253948 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/ap

[jira] [Commented] (FLINK-14815) Expose network pool usage in IOMetricsInfo

[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976365#comment-16976365 ] Piotr Nowojski commented on FLINK-14815: Regarding the aggregation of the metric

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347251972 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347255147 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] dawidwys commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table

dawidwys commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#discussion_r347253491 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/descriptors/Co

[GitHub] [flink] dawidwys commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table

dawidwys commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#discussion_r347255182 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/Desc

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347257364 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347257364 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347258906 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/ap

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347259729 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r347216837 ## File path: flink-

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r347240881 ## File path: flink-

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r347216494 ## File path: flink-

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r347247196 ## File path: flink-

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r347247820 ## File path: flink-

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r347258578 ## File path: flink-

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r347253021 ## File path: flink-

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r347216643 ## File path: flink-

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r347237461 ## File path: flink-p

[GitHub] [flink] hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs o

hequn8128 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r34721 ## File path: flink-

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347260241 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[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] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347261294 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347249023 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347256301 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347257825 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/test/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347255814 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347253756 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347251534 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347246081 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347246397 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347254097 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347241490 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347249615 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347241793 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347258165 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/test/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347256401 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r347249734 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/fli

[GitHub] [flink] wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

wuchong commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347262004 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wangyang0918 commented on issue #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

wangyang0918 commented on issue #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#issuecomment-554920993 @TisonKun I opened a dedicate JIRA [FLINK-14582](https://issues.apache.org/jira/browse/FLINK-1458

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347262484 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[GitHub] [flink] flinkbot edited a comment on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource

flinkbot edited a comment on issue #10210: [FLINK-14800][hive] Introduce parallelism inference for HiveSource URL: https://github.com/apache/flink/pull/10210#issuecomment-554238019 ## CI report: * 642c74d85bdc002a43307814307cc5fb4cba923c : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot edited a comment on issue #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

flinkbot edited a comment on issue #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#issuecomment-554384687 ## CI report: * f0ffbf0cff4a72ded1062772674408f58783cbfb : FAILURE [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5 :

[GitHub] [flink] flinkbot edited a comment on issue #10231: [FLINK-14711][table] add alter and show function ddl

flinkbot edited a comment on issue #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#issuecomment-554720304 ## CI report: * 3dc398a62bfd6c3da7561cba9f5e6c7f43947369 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347264543 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/ap

[GitHub] [flink] AT-Fieldless commented on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

AT-Fieldless commented on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#issuecomment-554923331 So, where should I create this Utils? In flink-core module? -

  1   2   3   4   5   6   >