Github user mylog00 commented on the issue:
https://github.com/apache/flink/pull/3325
TravisCI passed build.
https://travis-ci.org/mylog00/flink/builds/201929462
---
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
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869440#comment-15869440
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101461418
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerat
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869423#comment-15869423
]
sunjincheng commented on FLINK-5804:
Hi,guys，I made a preliminary implementation of th
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869422#comment-15869422
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101460153
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869420#comment-15869420
]
sunjincheng commented on FLINK-5803:
Hi,guys，I made a preliminary implementation of th
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869418#comment-15869418
]
sunjincheng commented on FLINK-4557:
[~fhueske] Thanks for converter the "FLINK-5803"
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869413#comment-15869413
]
Fabian Hueske commented on FLINK-5792:
--
Ah, great. Thanks for pointing to the PR [~ja
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5804:
-
Description:
The goal of this issue is to add support for OVER RANGE aggregations on
processing t
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5803:
-
Description:
The goal of this issue is to add support for OVER RANGE aggregations on
processing t
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101458924
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerat
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869407#comment-15869407
]
Fabian Hueske commented on FLINK-4557:
--
Hi [~sunjincheng121], I think your last two c
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869405#comment-15869405
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869404#comment-15869404
]
Jark Wu commented on FLINK-5792:
Hi [~fhueske], [~sunjincheng121] has create a PR for this
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5804:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-4557
> Add [non-partitioned] proces
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5803:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-4557
> Add [partitioned] processing
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5804:
-
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-5657)
> Add [non-partitio
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5803:
-
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-5657)
> Add [partitioned]
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869395#comment-15869395
]
Fabian Hueske commented on FLINK-5792:
--
I agree, it makes sense to ship a serialized
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869376#comment-15869376
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101456205
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
Shaoxuan Wang created FLINK-5813:
Summary: code generation for user-defined aggregate functions
Key: FLINK-5813
URL: https://issues.apache.org/jira/browse/FLINK-5813
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869355#comment-15869355
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user huawei-flink commented on a dif
Github user huawei-flink commented on a diff in the pull request:
https://github.com/apache/flink/pull/3271#discussion_r101455204
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/calcite/functions/FlinkStreamFunctionCatalog.java
---
@@ -0,0 +1,39 @@
+
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869351#comment-15869351
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101455043
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerat
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869346#comment-15869346
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user huawei-flink commented on a dif
Github user huawei-flink commented on a diff in the pull request:
https://github.com/apache/flink/pull/3271#discussion_r101454598
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ProcTimeCallGen.scala
---
@@ -0,0 +1,40 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869285#comment-15869285
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869286#comment-15869286
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101450383
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@ o
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101450405
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5803:
---
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-5657
> Add [partitioned] processing tim
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5804:
---
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-5657
> Add [non-partitioned] processing
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869275#comment-15869275
]
sunjincheng commented on FLINK-4557:
Hi,guys，I made a preliminary implementation of th
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869276#comment-15869276
]
sunjincheng commented on FLINK-4557:
Hi,guys，I made a preliminary implementation of th
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5804:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-5657)
> Add [non-partitioned]
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5803:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-5657)
> Add [partitioned] pro
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869263#comment-15869263
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101448753
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,75 @@
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869246#comment-15869246
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r101447660
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package org.apache.fl
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869236#comment-15869236
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101447400
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,75
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101447054
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@ o
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869227#comment-15869227
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869216#comment-15869216
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101446744
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerat
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
Thanks to all @fhueske , @tonycox and @wuchong for helping in getting this
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
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869214#comment-15869214
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the iss
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101446163
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,75 @@
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101446217
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,80 @
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869195#comment-15869195
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869196#comment-15869196
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101445690
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@ object U
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869191#comment-15869191
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869192#comment-15869192
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101445424
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101445544
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@ object U
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869193#comment-15869193
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101445785
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@ object U
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869194#comment-15869194
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869182#comment-15869182
]
sunjincheng commented on FLINK-5657:
Yes, agree with you. I'll do that.
> Add process
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3330
[FLINK-5795][TableAPI&SQL] Improve UDTF to support constructor with pâ¦
â¦arameter.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the foll
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869095#comment-15869095
]
ASF GitHub Bot commented on FLINK-5795:
---
GitHub user sunjincheng121 opened a pull re
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869047#comment-15869047
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user godfreyhe commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869049#comment-15869049
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user godfreyhe commented on a diff i
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r101437939
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -122,6 +123,18 @@ class CodeGenerator(
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r101437890
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UDFContext.scala
---
@@ -0,0 +1,53 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15869029#comment-15869029
]
Jark Wu commented on FLINK-5792:
+1
The serialization way will be more flexible.
> Impro
[
https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15868981#comment-15868981
]
Patrick Lucas commented on FLINK-5751:
--
Opened a PR fixing as many broken links as I
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5739:
Labels: newbie starter (was: )
> NullPointerException in CliFrontend
>
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang reassigned FLINK-5739:
---
Assignee: Zhuoluo Yang
> NullPointerException in CliFrontend
> --
[
https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15868980#comment-15868980
]
ASF GitHub Bot commented on FLINK-5751:
---
GitHub user patricklucas opened a pull requ
GitHub user patricklucas opened a pull request:
https://github.com/apache/flink/pull/3329
[FLINK-5751] Fix some broken links in docs
I used a wget-based script to identify broken links then manually searched
and corrected as many as I found.
You can merge this pull request into a G
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5739:
Description:
I've run a simple program on a local cluster. It always fails with code
Version: 1.3-S
Github user liuyuzhong7 commented on the issue:
https://github.com/apache/flink/pull/3138
@zentol @StephanEwen Please help me to review this PR. Thanks.
---
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-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15868950#comment-15868950
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user godfreyhe commented on a diff i
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r101428511
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package org.apache.
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15868903#comment-15868903
]
Kurt Young commented on FLINK-5570:
---
Hi [~wheat9], thanks for the offering, i think we a
[
https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15868901#comment-15868901
]
Patrick Lucas commented on FLINK-5751:
--
Down to 15 now:
{noformat}
http://localhost/
[
https://issues.apache.org/jira/browse/FLINK-5771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5771.
Resolution: Fixed
Fix Version/s: 1.2.1
1.1.5
1.3.0
Fixe
[
https://issues.apache.org/jira/browse/FLINK-5567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5567.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented for 1.3.0 with ae0fbff76f327c008bdbf
[
https://issues.apache.org/jira/browse/FLINK-5567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15868760#comment-15868760
]
ASF GitHub Bot commented on FLINK-5567:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15868761#comment-15868761
]
ASF GitHub Bot commented on FLINK-5771:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3197
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3316
---
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 enab
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101394185
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/util/RexProgramExpressionExtractor.scala
---
@@ -0,0 +1,198 @@
+/
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101316851
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/util/RexProgramExpressionExtractor.scala
---
@@ -0,0 +1,198 @@
+/
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101302191
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/PushFilterIntoBatchTableSourceScanRule.scala
---
@@ -0,0 +1,7
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101306528
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/FilterableTableSource.scala
---
@@ -0,0 +1,38 @@
+/*
+ * License
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101319389
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/util/RexProgramExpressionExtractor.scala
---
@@ -0,0 +1,198 @@
+/
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101305739
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/PushFilterIntoStreamTableSourceScanRule.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101303197
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/PushFilterIntoBatchTableSourceScanRule.scala
---
@@ -0,0 +1,7
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101299952
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala
---
@@ -58,8 +58,16 @@ class S
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101397995
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/CommonTestData.scala
---
@@ -98,4 +106,134 @@ object CommonTestData {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101393867
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/util/RexProgramExpressionExtractor.scala
---
@@ -0,0 +1,198 @@
+/
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101302395
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/util/RexProgramExpressionExtractor.scala
---
@@ -0,0 +1,198 @@
+/
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3166#discussion_r101303533
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/PushFilterIntoBatchTableSourceScanRule.scala
---
@@ -0,0 +1,7
1 - 100 of 312 matches
Mail list logo
