[
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
[
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 StreamTableS
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
[
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
[
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=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=16052154#comment-16052154
]
Fabian Hueske commented on FLINK-6886:
--
You are right. The problem is in {{translate
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
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
[
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 StreamTable
[
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 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-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 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
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: Sub-ta
[
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
[
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
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
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
[
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 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-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&focusedCommentId=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: Imp
[
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
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-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 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-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&focusedCommentId=16051627#comment-16051627
]
Fabian Hueske commented on FLINK-6568:
--
The documentation was updated and explains th
[
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-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-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&focusedCommentId=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 the
[
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 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-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&focusedCommentId=16051583#comment-16051583
]
ASF GitHub Bot commented on FLINK-6930:
---
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/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-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
[
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-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:
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=16051579#comment-16051579
]
ASF GitHub Bot commented on FLINK-6930:
---
Github user fhueske commented on a diff in
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
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
[
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
[
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
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
63 matches
Mail list logo
