[
https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673238#comment-15673238
]
Manu Zhang commented on FLINK-5061:
---
We will always see elements with timestamp > watermark T. I think
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673253#comment-15673253
]
Xiaogang Shi commented on FLINK-5053:
-
[~srichter] Do you have a more detailed plan about incremental
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673253#comment-15673253
]
Xiaogang Shi edited comment on FLINK-5053 at 11/17/16 9:41 AM:
---
[~srichter]
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2818
Code looks good. We should check the updated Janino dependency though.
+1 to merge if that is OK.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user fpompermaier commented on the issue:
https://github.com/apache/flink/pull/2790
Any other feedback on this?could it be merged?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673355#comment-15673355
]
ASF GitHub Bot commented on FLINK-4491:
---
Github user fpompermaier commented on the issue:
Theodore Vasiloudis created FLINK-5087:
--
Summary: Additional steps needed for the Java quickstart guide
Key: FLINK-5087
URL: https://issues.apache.org/jira/browse/FLINK-5087
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673313#comment-15673313
]
ASF GitHub Bot commented on FLINK-4263:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673397#comment-15673397
]
ASF GitHub Bot commented on FLINK-4263:
---
Github user ex00 commented on a diff in the pull request:
Github user ex00 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2818#discussion_r88429597
--- Diff: flink-libraries/flink-table/pom.xml ---
@@ -45,7 +45,7 @@ under the License.
org.codehaus.janino
[
https://issues.apache.org/jira/browse/FLINK-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673233#comment-15673233
]
ASF GitHub Bot commented on FLINK-5063:
---
Github user tillrohrmann closed the pull request at:
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2813
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2821
Thanks for the fix @mindprince.
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Xiaogang Shi created FLINK-5086:
---
Summary: Clean dead snapshot files produced by the tasks failing
to acknowledge checkpoints
Key: FLINK-5086
URL: https://issues.apache.org/jira/browse/FLINK-5086
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673142#comment-15673142
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88406527
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/TableFunction.scala
---
@@ -0,0 +1,119 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673143#comment-15673143
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673186#comment-15673186
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2653
Maybe one more thing to add. @twalthr recently added some tooling to write
unit tests that check the translation from SQL / Table API to `DataSetRel` and
`DataStreamRel` nodes, i.e., exclude the
[
https://issues.apache.org/jira/browse/FLINK-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov resolved FLINK-5006.
-
Resolution: Fixed
> SystemProcessingTimeServiceTest.testTimerSorting fails
>
[
https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673130#comment-15673130
]
Anton Solovev commented on FLINK-2186:
--
I suppose we need to create another one CsvInputFormat, and
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88406551
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/UserDefinedTableFunctionITCase.java
---
@@ -0,0 +1,201 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673151#comment-15673151
]
ASF GitHub Bot commented on FLINK-4260:
---
Github user miaoever commented on a diff in the pull
Github user miaoever commented on a diff in the pull request:
https://github.com/apache/flink/pull/2758#discussion_r88407392
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/sql/SqlITCase.java
---
@@ -118,4 +119,39 @@ public void testJoin()
[
https://issues.apache.org/jira/browse/FLINK-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5006:
-
Assignee: Boris Osipov
> SystemProcessingTimeServiceTest.testTimerSorting fails
>
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673413#comment-15673413
]
ASF GitHub Bot commented on FLINK-5008:
---
Github user thvasilo commented on the issue:
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/2764
IIRC @vasia is using Eclipse to develop, maybe she can chime in.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15667131#comment-15667131
]
Anton Mushin edited comment on FLINK-4832 at 11/17/16 12:45 PM:
Ok.
Could
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r88434427
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala
---
@@ -0,0 +1,158 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r88432940
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala
---
@@ -0,0 +1,88 @@
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673482#comment-15673482
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673480#comment-15673480
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673479#comment-15673479
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r88435196
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala
---
@@ -0,0 +1,158 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r88430946
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala
---
@@ -0,0 +1,88 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r88434958
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/sql/JoinITCase.scala
---
@@ -314,4 +315,18 @@ class JoinITCase(
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673483#comment-15673483
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r88433730
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala
---
@@ -0,0 +1,88 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r88434876
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/sql/CalcITCase.scala
---
@@ -270,6 +271,24 @@ class CalcITCase(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r88429682
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala
---
@@ -0,0 +1,88 @@
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
Hi @fhueske , you mentioned two ways to reduce IT cases. One is comparing
the logical plans of two tables, this can reduce Java IT cases. Another is
using `TableTestBase` tool to write unit tests,
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673462#comment-15673462
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2811
Thanks for the pull request @AlexanderShoshin! The overall approach is
good. We need to fix a few things in the optimizer rule and I would like to use
a `Map` instead of a `Cross` to execute the
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2653
I think we should convert the tests for the Java String-based Table API to
check the logical plans of queries against the logical plan of a corresponding
Scala Expression-based Table API query.
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673481#comment-15673481
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673474#comment-15673474
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673476#comment-15673476
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673478#comment-15673478
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673477#comment-15673477
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Sokur reassigned FLINK-5050:
---
Assignee: Sergey Sokur
> JSON.org license is CatX
>
>
>
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2818
Thanks @fhueske and @ex00. I will merge this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673760#comment-15673760
]
ASF GitHub Bot commented on FLINK-4263:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4263.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 836fe9786631f35953c1423e2d92128e9f292621.
[
https://issues.apache.org/jira/browse/FLINK-4886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lim Chee Hau closed FLINK-4886.
---
Resolution: Duplicate
> Example in Machine Learning Quickstart Guide causes error
>
[
https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673716#comment-15673716
]
ASF GitHub Bot commented on FLINK-4872:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-4872:
---
Assignee: Timo Walther
> Type erasure problem exclusively on cluster execution
>
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2823
[FLINK-4872] [types] Type erasure problem exclusively on cluster execution
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
[
https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673725#comment-15673725
]
Timo Walther commented on FLINK-4872:
-
[~mju] thank you very much for reporting this issue and
Ufuk Celebi created FLINK-5088:
--
Summary: Add option to limit subpartition queue length
Key: FLINK-5088
URL: https://issues.apache.org/jira/browse/FLINK-5088
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673721#comment-15673721
]
Kostas Kloudas commented on FLINK-3053:
---
another instance:
[
https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673775#comment-15673775
]
ASF GitHub Bot commented on FLINK-4263:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2818
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673940#comment-15673940
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673942#comment-15673942
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r88464767
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/AvroDeserializationSchemaTest.java
---
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673943#comment-15673943
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673941#comment-15673941
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673944#comment-15673944
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673939#comment-15673939
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r88461076
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowSerializationSchema.java
---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r88451554
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java
---
@@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r88461322
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowDeserializationSchema.java
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r88451582
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java
---
@@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2762#discussion_r88463790
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/AvroRowDeserializationSchema.java
Paris Carbone created FLINK-5089:
Summary: Introduce Loop functions and Enforce Nesting on Data
Streams
Key: FLINK-5089
URL: https://issues.apache.org/jira/browse/FLINK-5089
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674172#comment-15674172
]
ASF GitHub Bot commented on FLINK-5050:
---
GitHub user bitchelov opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674230#comment-15674230
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674216#comment-15674216
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in the pull
GitHub user bitchelov opened a pull request:
https://github.com/apache/flink/pull/2824
[FLINK-5050] JSON.org license is CatX
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674912#comment-15674912
]
Maximilian Michels commented on FLINK-3133:
---
Hi [~AlexanderShoshin]! I've adjusted the
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3133:
--
Description:
The DataSet API's methods {{collect()}}, {{count()}}, and {{print()}}
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674899#comment-15674899
]
Maximilian Michels commented on FLINK-3133:
---
I've made some improvements in the description.
>
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3133:
--
Summary: Introduce collect()/count()/print() methods in DataStream API
(was: Introduce
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674176#comment-15674176
]
ASF GitHub Bot commented on FLINK-5085:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674111#comment-15674111
]
Stephan Ewen commented on FLINK-4587:
-
[~RenkaiGe] Is this issue still valid, or has it been resolved
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88491436
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -611,6 +612,130 @@ class Table(
}
/**
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88477894
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -451,6 +452,28 @@ object
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88491682
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -611,6 +612,130 @@ class Table(
}
/**
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88491270
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/FlinkTableFunctionImpl.scala
---
@@ -0,0 +1,77 @@
+/*
+
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88465942
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/TableEnvironment.scala
---
@@ -152,21 +153,40 @@ abstract class
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88488325
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkCorrelate.scala
---
@@ -0,0 +1,161 @@
+/*
+ *
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88483086
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -162,24 +191,107 @@
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88472140
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala
---
@@ -542,11 +563,14 @@ class CodeGenerator(
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88483859
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -162,24 +191,107 @@
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674223#comment-15674223
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674210#comment-15674210
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674213#comment-15674213
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674209#comment-15674209
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674226#comment-15674226
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15674215#comment-15674215
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in the pull
1 - 100 of 197 matches
Mail list logo
