Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5347
---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5347#discussion_r163880920
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/CorrelateUtil.scala
---
@@ -0,0 +1,79 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5347#discussion_r163880994
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/CorrelateUtil.scala
---
@@ -0,0 +1,79 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5347#discussion_r163879206
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala
---
@@ -141,6 +143,7 @@ trait CommonCalc {
}
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5347#discussion_r163877879
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala
---
@@ -149,26 +152,42 @@ trait CommonCalc {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5347#discussion_r163878119
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala
---
@@ -149,26 +152,42 @@ trait CommonCalc {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5347#discussion_r163880732
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/CorrelateUtil.scala
---
@@ -0,0 +1,79 @@
+/*
+ *
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/5347
[FLINK-8492][table] Fix calc cost bug
## What is the purpose of the change
Fix calc cost bug. Currently, unsupported exception will be thrown when
multi calc existing between
