[
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
>
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
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
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16052304#comment-16052304
]
ASF GitHub Bot commented on FLINK-6886:
---
Github user sunjincheng121 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16052246#comment-16052246
]
sunjincheng commented on FLINK-6886:
Thanks [~fhueske] your code is nicer. I'll update the PR. :)
>
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16052154#comment-16052154
]
Fabian Hueske edited comment on FLINK-6886 at 6/16/17 5:29 PM:
---
You are
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16052154#comment-16052154
]
Fabian Hueske commented on FLINK-6886:
--
You are right. The problem is in {{translate(dataStreamPlan,
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
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
[
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
>
[
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
>
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
[
https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16052025#comment-16052025
]
Zhe Li commented on FLINK-6602:
---
It's my pleasure:)
I have opened a pull request just now.
Thank you.
>
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
[
https://issues.apache.org/jira/browse/FLINK-6933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16052019#comment-16052019
]
ASF GitHub Bot commented on FLINK-6933:
---
Github user kl0u commented on the issue:
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
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
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:
[
https://issues.apache.org/jira/browse/FLINK-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051962#comment-16051962
]
ASF GitHub Bot commented on FLINK-6888:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051961#comment-16051961
]
ASF GitHub Bot commented on FLINK-6888:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051960#comment-16051960
]
ASF GitHub Bot commented on FLINK-6888:
---
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/4105#discussion_r122448432
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -358,20 +358,27 @@ abstract class
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
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
[
https://issues.apache.org/jira/browse/FLINK-6652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051959#comment-16051959
]
ASF GitHub Bot commented on FLINK-6652:
---
Github user alpinegizmo commented on the issue:
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
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-6937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051774#comment-16051774
]
ASF GitHub Bot commented on FLINK-6937:
---
GitHub user juanpaulo opened a pull request:
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
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
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:
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051710#comment-16051710
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user sunjincheng121 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,
[
https://issues.apache.org/jira/browse/FLINK-6933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051698#comment-16051698
]
ASF GitHub Bot commented on FLINK-6933:
---
Github user aljoscha commented on the issue:
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
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051627#comment-16051627
]
Fabian Hueske commented on FLINK-6568:
--
The documentation was updated and explains that `flink-scala`
[
https://issues.apache.org/jira/browse/FLINK-6433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051620#comment-16051620
]
Fabian Hueske commented on FLINK-6433:
--
We will remove this class once we upgrade our Calcite
[
https://issues.apache.org/jira/browse/FLINK-6887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051610#comment-16051610
]
Fabian Hueske commented on FLINK-6887:
--
I think that's a good idea. What do you think [~twalthr]?
>
[
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-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051601#comment-16051601
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user fhueske 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
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051588#comment-16051588
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user wuchong commented on the issue:
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
[
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
>
[
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-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-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-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051583#comment-16051583
]
ASF GitHub Bot commented on FLINK-6930:
---
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/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
[
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
[
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:
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051581#comment-16051581
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user fhueske commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051579#comment-16051579
]
ASF GitHub Bot commented on FLINK-6930:
---
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/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
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:
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051513#comment-16051513
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user sunjincheng121 commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051514#comment-16051514
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user sunjincheng121 commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051466#comment-16051466
]
sunjincheng commented on FLINK-6886:
So, We have two chances to deal with the problem，one is the PR.
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051451#comment-16051451
]
sunjincheng edited comment on FLINK-6886 at 6/16/17 6:27 AM:
-
But, I think not
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051451#comment-16051451
]
sunjincheng commented on FLINK-6886:
But, I think not the optimization issue, because,
[
https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051442#comment-16051442
]
ASF GitHub Bot commented on FLINK-6904:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4121
Hi @dawidwys thanks a lot for the review, what's your thought for the
updated patch?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051425#comment-16051425
]
sunjincheng commented on FLINK-6886:
Hi, [~fhueske] Thanks for check this issue. Calcite can not
67 matches
Mail list logo
