Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4133#discussion_r122378757
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
---
@@ -652,6 +653,21 @@ case class WindowAg
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051514#comment-16051514
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051513#comment-16051513
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4133#discussion_r122378782
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
---
@@ -652,6 +653,21 @@ case class WindowAg
Jark Wu created FLINK-6935:
--
Summary: Integration of SQL and CEP
Key: FLINK-6935
URL: https://issues.apache.org/jira/browse/FLINK-6935
Project: Flink
Issue Type: New Feature
Components: CE
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4133#discussion_r122388804
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
---
@@ -652,6 +653,21 @@ case class WindowAggregate
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051579#comment-16051579
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user fhueske commented on a diff in
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4133
Thanks for the fix @wuchong!
I would adjust the error message as proposed but otherwise it's good to
merge.
Thanks, Fabian
---
If your project is set up for it, you can reply to this e
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051581#comment-16051581
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-6935:
--
Assignee: Dian Fu
> Integration of SQL and CEP
> --
>
> Key: FL
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-6904:
---
Issue Type: Sub-task (was: Bug)
Parent: FLINK-6935
> Support for quantifier range to CEP's pattern AP
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4133#discussion_r122389818
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
---
@@ -652,6 +653,21 @@ case class WindowAggregate
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051583#comment-16051583
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-6927:
---
Issue Type: Sub-task (was: Bug)
Parent: FLINK-6935
> Support pattern group in CEP
> -
[
https://issues.apache.org/jira/browse/FLINK-6933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-6933:
---
Issue Type: Sub-task (was: Bug)
Parent: FLINK-6935
> Refactor NFACompiler to reduce code duplication
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-4641:
--
Assignee: Dian Fu (was: Alexander Chermenin)
> Support branching CEP patterns
> -
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-4641:
---
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-6935
> Support branching CEP patterns
> --
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/4133
Updated
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051588#comment-16051588
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user wuchong commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4133
+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 feature
enabled and wishes so, or if the
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051601#comment-16051601
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6887:
-
Issue Type: Task (was: Bug)
> Split up CodeGenerator into several specific CodeGenerator
> --
[
https://issues.apache.org/jira/browse/FLINK-6887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051610#comment-16051610
]
Fabian Hueske commented on FLINK-6887:
--
I think that's a good idea. What do you think
[
https://issues.apache.org/jira/browse/FLINK-6433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051620#comment-16051620
]
Fabian Hueske commented on FLINK-6433:
--
We will remove this class once we upgrade our
[
https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051627#comment-16051627
]
Fabian Hueske commented on FLINK-6568:
--
The documentation was updated and explains th
[
https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai closed FLINK-6568.
-
Resolution: Duplicate
> flink-table doesn't work without flink-streaming-scala dependency
> --
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4132
R: @kl0u or @dawidwys for review, please ð
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-6933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051698#comment-16051698
]
ASF GitHub Bot commented on FLINK-6933:
---
Github user aljoscha commented on the issue
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4133
+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 feature
enabled and wishes so, or
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051710#comment-16051710
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user sunjincheng121 commented on the
Xingcan Cui created FLINK-6936:
--
Summary: Add multiple targets support for custom partitioner
Key: FLINK-6936
URL: https://issues.apache.org/jira/browse/FLINK-6936
Project: Flink
Issue Type: Imp
Juan Paulo Gutierrez created FLINK-6937:
---
Summary: Fix link markdown in Production Readiness Checklist doc
Key: FLINK-6937
URL: https://issues.apache.org/jira/browse/FLINK-6937
Project: Flink
GitHub user juanpaulo opened a pull request:
https://github.com/apache/flink/pull/4134
[FLINK-6937] Fix link markdown in Production Readiness Checklist doc
[FLINK-6937] Fix link markdown in Production Readiness Checklist doc
- [x] General
- The pull request references
[
https://issues.apache.org/jira/browse/FLINK-6937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051774#comment-16051774
]
ASF GitHub Bot commented on FLINK-6937:
---
GitHub user juanpaulo opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-6929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6929:
--
Assignee: sunjincheng
> Add documentation for Table API OVER windows
>
Github user alpinegizmo commented on the issue:
https://github.com/apache/flink/pull/4088
FYI, the reference solutions to the batch training exercises are failing,
and it looks to me like it's because of this issue.
---
If your project is set up for it, you can reply to this email an
[
https://issues.apache.org/jira/browse/FLINK-6652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051959#comment-16051959
]
ASF GitHub Bot commented on FLINK-6652:
---
Github user alpinegizmo commented on the is
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4105#discussion_r122447580
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -192,10 +193,14 @@ class BatchTableE
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4105#discussion_r122448432
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -358,20 +358,27 @@ abstract class TableEnviron
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4105#discussion_r122447088
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -307,9 +315,29 @@ object U
[
https://issues.apache.org/jira/browse/FLINK-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051961#comment-16051961
]
ASF GitHub Bot commented on FLINK-6888:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051960#comment-16051960
]
ASF GitHub Bot commented on FLINK-6888:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051962#comment-16051962
]
ASF GitHub Bot commented on FLINK-6888:
---
Github user fhueske commented on a diff in
Jark Wu created FLINK-6938:
--
Summary: IterativeCondition should support RichFunction interface
Key: FLINK-6938
URL: https://issues.apache.org/jira/browse/FLINK-6938
Project: Flink
Issue Type: Sub-ta
Jark Wu created FLINK-6939:
--
Summary: Not store IterativeCondition with NFA state
Key: FLINK-6939
URL: https://issues.apache.org/jira/browse/FLINK-6939
Project: Flink
Issue Type: Sub-task
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4132
After an offline discussion with @dianfu , we decided to close this PR and
merge this change with https://github.com/apache/flink/pull/4121/ as it is more
relevant there.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-6933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052019#comment-16052019
]
ASF GitHub Bot commented on FLINK-6933:
---
Github user kl0u commented on the issue:
GitHub user lmalds opened a pull request:
https://github.com/apache/flink/pull/4135
Flink 6602 -- bug fix
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the items in
[
https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052025#comment-16052025
]
Zhe Li commented on FLINK-6602:
---
It's my pleasure:)
I have opened a pull request just now.
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4135#discussion_r122469825
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/StreamTableSourceTable.scala
---
@@ -39,6 +39,8 @@ class StreamTable
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-6938:
---
Component/s: (was: Table API & SQL)
> IterativeCondition should support RichFunction interface
> -
[
https://issues.apache.org/jira/browse/FLINK-6939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-6939:
---
Component/s: (was: Table API & SQL)
> Not store IterativeCondition with NFA state
> --
Github user lmalds commented on a diff in the pull request:
https://github.com/apache/flink/pull/4135#discussion_r122484136
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/StreamTableSourceTable.scala
---
@@ -39,6 +39,8 @@ class StreamTableS
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4135#discussion_r122487052
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/StreamTableSourceTable.scala
---
@@ -39,6 +39,9 @@ class StreamTable
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052154#comment-16052154
]
Fabian Hueske commented on FLINK-6886:
--
You are right. The problem is in {{translate
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052154#comment-16052154
]
Fabian Hueske edited comment on FLINK-6886 at 6/16/17 5:29 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052246#comment-16052246
]
sunjincheng commented on FLINK-6886:
Thanks [~fhueske] your code is nicer. I'll update
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052304#comment-16052304
]
ASF GitHub Bot commented on FLINK-6886:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4102
Hi @fhueske I have update the PR. according your suggestion. Please have a
look at the changes.
Best,
SunJincheng
---
If your project is set up for it, you can reply to this emai
Github user lmalds commented on a diff in the pull request:
https://github.com/apache/flink/pull/4135#discussion_r122525124
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/StreamTableSourceTable.scala
---
@@ -39,6 +39,9 @@ class StreamTableS
[
https://issues.apache.org/jira/browse/FLINK-6937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6937:
--
Component/s: Documentation
> Fix link markdown in Production Readiness Checklist doc
> -
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052711#comment-16052711
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user ch33hau commented on the issue:
Github user ch33hau commented on the issue:
https://github.com/apache/flink/pull/2761
Hi @fhueske this is ready for review.
I have moved Java's IT cases to
`org.apache.flink.streaming.test.StreamingExamplesITCase` and Scala's IT cases
to `org.apache.flink.streaming.scala.exam
63 matches
Mail list logo
