[
https://issues.apache.org/jira/browse/FLINK-7093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7093:
-
Priority: Minor (was: Major)
> Send SlotReport as part of the heartbeat payload to the RM
> -
[
https://issues.apache.org/jira/browse/FLINK-7093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7093:
Assignee: Till Rohrmann
> Send SlotReport as part of the heartbeat payload to the RM
>
[
https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073205#comment-16073205
]
ASF GitHub Bot commented on FLINK-4286:
---
GitHub user mylog00 opened a pull request:
GitHub user mylog00 opened a pull request:
https://github.com/apache/flink/pull/4250
[FLINK-4286] Have Kafka examples that use the Kafka 0.9 connector
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-7082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7082:
-
Description:
Implement a generic entry point for Flink sessions. This {{ClusterEntryPoint}}
has t
[
https://issues.apache.org/jira/browse/FLINK-7083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7083:
-
Description: In order to handle the Flink session mode with Flip-6, we have
to adapt the {{WebRunt
Till Rohrmann created FLINK-7093:
Summary: Send SlotReport as part of the heartbeat payload to the RM
Key: FLINK-7093
URL: https://issues.apache.org/jira/browse/FLINK-7093
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-7089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7089:
-
Priority: Minor (was: Major)
> Rework LaunchCoordinator to not depend on Akka
> -
[
https://issues.apache.org/jira/browse/FLINK-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7091:
-
Priority: Minor (was: Major)
> Rework ReconciliationCoordinator to not depend on Akka
> -
Till Rohrmann created FLINK-7092:
Summary: Shutdown ResourceManager components properly
Key: FLINK-7092
URL: https://issues.apache.org/jira/browse/FLINK-7092
Project: Flink
Issue Type: Sub-ta
[
https://issues.apache.org/jira/browse/FLINK-7090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7090:
-
Priority: Minor (was: Major)
> Rework ConnectionMonitor to not depend on Akka
> -
[
https://issues.apache.org/jira/browse/FLINK-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7088:
-
Priority: Minor (was: Major)
> Rework TaskMonitor to not depend on Akka
> ---
Till Rohrmann created FLINK-7091:
Summary: Rework ReconciliationCoordinator to not depend on Akka
Key: FLINK-7091
URL: https://issues.apache.org/jira/browse/FLINK-7091
Project: Flink
Issue Ty
Till Rohrmann created FLINK-7089:
Summary: Rework LaunchCoordinator to not depend on Akka
Key: FLINK-7089
URL: https://issues.apache.org/jira/browse/FLINK-7089
Project: Flink
Issue Type: Sub-
Till Rohrmann created FLINK-7090:
Summary: Rework ConnectionMonitor to not depend on Akka
Key: FLINK-7090
URL: https://issues.apache.org/jira/browse/FLINK-7090
Project: Flink
Issue Type: Sub-
Till Rohrmann created FLINK-7088:
Summary: Rework TaskMonitor to not depend on Akka
Key: FLINK-7088
URL: https://issues.apache.org/jira/browse/FLINK-7088
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-7087:
Summary: Implement Flip-6 container entry point
Key: FLINK-7087
URL: https://issues.apache.org/jira/browse/FLINK-7087
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-7086:
Summary: Create entry point for standalone session mode
Key: FLINK-7086
URL: https://issues.apache.org/jira/browse/FLINK-7086
Project: Flink
Issue Type: Sub-
Till Rohrmann created FLINK-7085:
Summary: Test slot allocation protocol
Key: FLINK-7085
URL: https://issues.apache.org/jira/browse/FLINK-7085
Project: Flink
Issue Type: Sub-task
Co
Till Rohrmann created FLINK-7084:
Summary: Flip-6 testing
Key: FLINK-7084
URL: https://issues.apache.org/jira/browse/FLINK-7084
Project: Flink
Issue Type: Test
Components: Tests
[
https://issues.apache.org/jira/browse/FLINK-7073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073170#comment-16073170
]
Till Rohrmann commented on FLINK-7073:
--
It might also be possible to merge the {{JobM
[
https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073081#comment-16073081
]
shuai.xu commented on FLINK-6434:
-
[~till.rohrmann] Sorry, I have not start working on it
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/3539
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073076#comment-16073076
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4153
@dawidwys Thanks a lot for the review. Updated the doc.
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073075#comment-16073075
]
ASF GitHub Bot commented on FLINK-6617:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3943
Thanks @twalthr ! I have rebased the code and updated the PR.
Thanks,
SunJincheng
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073006#comment-16073006
]
mingleizhang commented on FLINK-6995:
-
Icy! Let me try it.
> Add a warning to outdate
Till Rohrmann created FLINK-7083:
Summary: Adapt WebRuntimeMonitor to work with Flip-6 architecture
Key: FLINK-7083
URL: https://issues.apache.org/jira/browse/FLINK-7083
Project: Flink
Issue
Till Rohrmann created FLINK-7082:
Summary: Flip-6: Generic entry point for Flink sessions
Key: FLINK-7082
URL: https://issues.apache.org/jira/browse/FLINK-7082
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-7081:
Summary: Deploy Mesos framework with job
Key: FLINK-7081
URL: https://issues.apache.org/jira/browse/FLINK-7081
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-7080:
Summary: Deploy Yarn cluster with job
Key: FLINK-7080
URL: https://issues.apache.org/jira/browse/FLINK-7080
Project: Flink
Issue Type: Sub-task
Com
[
https://issues.apache.org/jira/browse/FLINK-7079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7079:
-
Labels: flip-6 (was: )
> Refactor ClusterDescriptor to support cluster deployment with job
>
Till Rohrmann created FLINK-7079:
Summary: Refactor ClusterDescriptor to support cluster deployment
with job
Key: FLINK-7079
URL: https://issues.apache.org/jira/browse/FLINK-7079
Project: Flink
Till Rohrmann created FLINK-7078:
Summary: Support fencing tokens to filter out outdated messages
Key: FLINK-7078
URL: https://issues.apache.org/jira/browse/FLINK-7078
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4346:
-
Labels: flip-6 (was: )
> Implement basic RPC abstraction
> ---
>
>
Till Rohrmann created FLINK-7077:
Summary: Implement task release to support dynamic scaling
Key: FLINK-7077
URL: https://issues.apache.org/jira/browse/FLINK-7077
Project: Flink
Issue Type: S
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7076:
-
Description: In order to support dynamic scaling, the
{{YarnResourceManager}} has to be able to dy
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7076:
-
Summary: Implement container release to support dynamic scaling (was: Add
support for dynamic con
Till Rohrmann created FLINK-7076:
Summary: Add support for dynamic container allocation to
ResourceManager
Key: FLINK-7076
URL: https://issues.apache.org/jira/browse/FLINK-7076
Project: Flink
Till Rohrmann created FLINK-7075:
Summary: Implement Flip-6 standalone mode
Key: FLINK-7075
URL: https://issues.apache.org/jira/browse/FLINK-7075
Project: Flink
Issue Type: New Feature
Till Rohrmann created FLINK-7074:
Summary: Add entry point for TaskManagerRunner
Key: FLINK-7074
URL: https://issues.apache.org/jira/browse/FLINK-7074
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-6631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072933#comment-16072933
]
Till Rohrmann commented on FLINK-6631:
--
Most likely, we can use the {{TaskManagerRunn
[
https://issues.apache.org/jira/browse/FLINK-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4897:
-
Description:
This task is to implement the dispatcher component which reacts to calls from
the cl
[
https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4352:
-
Description:
We have to refactor the Flink's CLI in order to be able to use the RESTful
client to
[
https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4352:
-
Summary: Refactor CLI to use RESTful client for cluster communication
(was: Refactor CLI to use R
[
https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4352:
-
Component/s: Client
> Refactor CLI to use RESTful client
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4352:
-
Summary: Refactor CLI to use RESTful client (was: Refactor Client to work
together with Flip-6 co
[
https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7040:
-
Description:
With the new Flip-6 architecture, the client will communicate with the cluster
in a
Till Rohrmann created FLINK-7073:
Summary: Create RESTful JobManager endpoint
Key: FLINK-7073
URL: https://issues.apache.org/jira/browse/FLINK-7073
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-7072:
Summary: Create RESTful cluster endpoint
Key: FLINK-7072
URL: https://issues.apache.org/jira/browse/FLINK-7072
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7040:
-
Description:
With the new Flip-6 architecture, the client will communicate with the cluster
in a
[
https://issues.apache.org/jira/browse/FLINK-7071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7071:
-
Labels: flip-6 (was: )
> Create RESTful client
> -
>
> Key: F
Till Rohrmann created FLINK-7071:
Summary: Create RESTful client
Key: FLINK-7071
URL: https://issues.apache.org/jira/browse/FLINK-7071
Project: Flink
Issue Type: Sub-task
Components
[
https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7040:
-
Description:
With the new Flip-6 architecture, the client will communicate with the cluster
in a
[
https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7040:
-
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-4897)
> Flip-6 client-clu
[
https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-7040:
-
Labels: flip-6 (was: )
> Flip-6 client-cluster communication
> --
[
https://issues.apache.org/jira/browse/FLINK-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072911#comment-16072911
]
ASF GitHub Bot commented on FLINK-7037:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4221
@greghogan fixed
---
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-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072869#comment-16072869
]
ASF GitHub Bot commented on FLINK-7037:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4221#discussion_r125350366
--- Diff: flink-examples/flink-examples-table/pom.xml ---
@@ -24,7 +24,7 @@ under the License.
org.apache.flink
-
[
https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072845#comment-16072845
]
ASF GitHub Bot commented on FLINK-6301:
---
Github user vidhu5269 commented on the issu
Github user vidhu5269 commented on the issue:
https://github.com/apache/flink/pull/4015
I also see that a few of the continuous-integration builds have failed. Is
there something I should do in that regard?
---
If your project is set up for it, you can reply to this email and have yo
[
https://issues.apache.org/jira/browse/FLINK-6301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072843#comment-16072843
]
ASF GitHub Bot commented on FLINK-6301:
---
Github user vidhu5269 commented on the issu
Github user vidhu5269 commented on the issue:
https://github.com/apache/flink/pull/4015
Hi @tzulitai
Apologies for such a long delay. It took me quite a while to come back to
this.
I ran the updated connector on the cluster and didn't see any dependency
conflicts. T
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072813#comment-16072813
]
ASF GitHub Bot commented on FLINK-7047:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4233
I've moved a few more modules into the misc. group:
* flink-metrics
* flink-java8
* flink-streaming-contrib
* flink-scala-shell
For the core group we now only compile modules th
[
https://issues.apache.org/jira/browse/FLINK-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072773#comment-16072773
]
ASF GitHub Bot commented on FLINK-7015:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4241
In general, it is a good idea to clean that up a bit. That code needed some
refactoring.
As @aljoscha pointed out, that is an intricate part, so we need to review
that carefully. To be a
[
https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072759#comment-16072759
]
ASF GitHub Bot commented on FLINK-4286:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3270
Thank you!
---
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
Github user mylog00 closed the pull request at:
https://github.com/apache/flink/pull/3270
---
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 ena
[
https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072733#comment-16072733
]
ASF GitHub Bot commented on FLINK-4286:
---
Github user mylog00 closed the pull request
Github user mylog00 commented on the issue:
https://github.com/apache/flink/pull/3270
Many merge conflicts.
---
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-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072731#comment-16072731
]
ASF GitHub Bot commented on FLINK-4286:
---
Github user mylog00 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072732#comment-16072732
]
ASF GitHub Bot commented on FLINK-4286:
---
Github user mylog00 commented on the issue:
Github user mylog00 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3270#discussion_r125331370
--- Diff: flink-examples/flink-examples-streaming/pom.xml ---
@@ -360,6 +360,26 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-7032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072728#comment-16072728
]
ASF GitHub Bot commented on FLINK-7032:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4213
@aljoscha you merge since you asked first.
---
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
en
[
https://issues.apache.org/jira/browse/FLINK-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072724#comment-16072724
]
ASF GitHub Bot commented on FLINK-6388:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3783
Not yet, but AFAIK is @twalthr working on that.
---
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-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072697#comment-16072697
]
ASF GitHub Bot commented on FLINK-6649:
---
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/4157#discussion_r125304367
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala
---
@@ -0,0 +1
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4157#discussion_r125284189
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala
---
@@ -0,0 +1
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4157#discussion_r125281365
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala
---
@@ -37,6 +37,13 @@ class BatchQueryConfig private[tabl
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072690#comment-16072690
]
ASF GitHub Bot commented on FLINK-6649:
---
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/4157#discussion_r125300423
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072694#comment-16072694
]
ASF GitHub Bot commented on FLINK-6649:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072693#comment-16072693
]
ASF GitHub Bot commented on FLINK-6649:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072689#comment-16072689
]
ASF GitHub Bot commented on FLINK-6649:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072695#comment-16072695
]
ASF GitHub Bot commented on FLINK-6649:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072698#comment-16072698
]
ASF GitHub Bot commented on FLINK-6649:
---
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/4157#discussion_r125289222
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala
---
@@ -0,0 +1
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4157#discussion_r125316505
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala
---
@@ -80,18 +80,79 @@ class NonWind
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4157#discussion_r125325560
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala
---
@@ -80,18 +80,79 @@ class NonWind
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072699#comment-16072699
]
ASF GitHub Bot commented on FLINK-6649:
---
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/4157#discussion_r125299675
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072692#comment-16072692
]
ASF GitHub Bot commented on FLINK-6649:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16072696#comment-16072696
]
ASF GitHub Bot commented on FLINK-6649:
---
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/4157#discussion_r125316569
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala
---
@@ -80,18 +80,79 @@ class NonWind
1 - 100 of 228 matches
Mail list logo
