Kurt Young created FLINK-6154:
-
Summary: Refine code reusing between logical and physical operators
Key: FLINK-6154
URL: https://issues.apache.org/jira/browse/FLINK-6154
Project: Flink
Issue Type
Tao Meng created FLINK-6153:
---
Summary: Fix documentation about which version to download if
don't care hadoop version
Key: FLINK-6153
URL: https://issues.apache.org/jira/browse/FLINK-6153
Project: Flink
Yelei Feng created FLINK-6152:
-
Summary: Yarn session CLI tries to shut cluster down too
agressively in interative mode
Key: FLINK-6152
URL: https://issues.apache.org/jira/browse/FLINK-6152
Project: Flink
zhangrucong1982 created FLINK-6151:
--
Summary: The zookeeper occur a warning when one node of zookeeper
server is down
Key: FLINK-6151
URL: https://issues.apache.org/jira/browse/FLINK-6151
Project: Fl
Kurt Young created FLINK-6150:
-
Summary: change DataSetCost to FlinkRelOptCost
Key: FLINK-6150
URL: https://issues.apache.org/jira/browse/FLINK-6150
Project: Flink
Issue Type: Sub-task
Kurt Young created FLINK-6149:
-
Summary: add additional flink logical relation nodes
Key: FLINK-6149
URL: https://issues.apache.org/jira/browse/FLINK-6149
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935767#comment-15935767
]
ASF GitHub Bot commented on FLINK-5990:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3585
Hi, @fhueske Thanks for your attention to the PR. Today I'll proposal the
design doc and link here.
Best,
SunJIncheng
---
If your project is set up for it, you can reply to this
zhangrucong1982 created FLINK-6148:
--
Summary: The Zookeeper client occur SASL error when the sasl is
disable
Key: FLINK-6148
URL: https://issues.apache.org/jira/browse/FLINK-6148
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yelei Feng updated FLINK-6147:
--
Description:
I tested in yarn mode, reproduce step:
1. flink run xx.jar
2. kill yarn application
CLI han
Yelei Feng created FLINK-6147:
-
Summary: flink client can't detect cluster is down
Key: FLINK-6147
URL: https://issues.apache.org/jira/browse/FLINK-6147
Project: Flink
Issue Type: Bug
C
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935703#comment-15935703
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user hongyuhong commented on the iss
Github user hongyuhong commented on the issue:
https://github.com/apache/flink/pull/3386
Hi @fhueske , @shijinkui & @sunjincheng121 , i have updated the pr
according to your advices. Thanks very much.
---
If your project is set up for it, you can reply to this email and have your
rep
[
https://issues.apache.org/jira/browse/FLINK-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935658#comment-15935658
]
ASF GitHub Bot commented on FLINK-6124:
---
Github user shaoxuan-wang commented on the
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3579
@twalthr, I saw you have removed the CHAR type when you merge this. Just
want to clarify. In FLINK-3916, in method typeInfoToSqlTypeName, you have added
```
case CHAR_TYPE_INFO |
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582930#comment-15582930
]
Ted Yu edited comment on FLINK-4848 at 3/22/17 1:54 AM:
There is s
[
https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zohar Mizrahi updated FLINK-5886:
-
Description:
A work in progress to provide python interface for Flink streaming APIs. The
core te
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935589#comment-15935589
]
Luke Hutchison edited comment on FLINK-6114 at 3/22/17 1:05 AM:
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935576#comment-15935576
]
Luke Hutchison edited comment on FLINK-6114 at 3/22/17 12:45 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935589#comment-15935589
]
Luke Hutchison commented on FLINK-6114:
---
I figured maybe I was using distinct() wron
[
https://issues.apache.org/jira/browse/FLINK-6146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6146:
--
Description:
In the following code, this exception is thrown at the line marked {{// (1)}}:
{no
[
https://issues.apache.org/jira/browse/FLINK-6146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Hutchison updated FLINK-6146:
--
Description:
In the following code, this exception is thrown at the line marked {{// (1)}}:
{no
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935576#comment-15935576
]
Luke Hutchison edited comment on FLINK-6114 at 3/22/17 12:25 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935576#comment-15935576
]
Luke Hutchison commented on FLINK-6114:
---
[~greghogan] I partially reconstructed exac
Luke Hutchison created FLINK-6146:
-
Summary: Incorrect function name given in exception thrown by
DataSet.getType()
Key: FLINK-6146
URL: https://issues.apache.org/jira/browse/FLINK-6146
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935421#comment-15935421
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3590
@fhueske @shijinkui @hongyuhong @twalthr @stefanobortoli
I have reimplemented the OVER logic with time bounds over processfunction.
PLease take a look
I also addressed in principle the other
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935414#comment-15935414
]
ASF GitHub Bot commented on FLINK-5654:
---
GitHub user rtudoran opened a pull request:
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/3590
[FLINK-5654] - Add processing time OVER RANGE BETWEEN x PRECEDING
aggregation to SQL
function
Added corresponding tests
Thanks for contributing to Apache Flink. Before you open your pu
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107274117
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935335#comment-15935335
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935329#comment-15935329
]
ASF GitHub Bot commented on FLINK-1579:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3460
Yeah, true.
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935326#comment-15935326
]
ASF GitHub Bot commented on FLINK-1579:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3460
According to GitHub this wasnt merged yet.
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3540
---
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 rmetzger commented on the issue:
https://github.com/apache/flink/pull/3582
+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 th
[
https://issues.apache.org/jira/browse/FLINK-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6144.
-
Resolution: Fixed
Fixed in 1.3.0 via e2ca12957435e9ac3d811ebec611c4465525dea9
> Port job manager
[
https://issues.apache.org/jira/browse/FLINK-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6144.
---
> Port job manager related configuration options to ConfigOption
> ---
[
https://issues.apache.org/jira/browse/FLINK-6056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6056.
---
> apache-rat exclude flink directory in tools
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-6056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6056.
-
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed in 1.3.0 via 96ec65592ca0c1f4da144a2fd8f418a05
[
https://issues.apache.org/jira/browse/FLINK-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-6000.
-
Resolution: Fixed
Fix Version/s: 1.2.1
1.3.0
Fixed in
- 1.2.1 via d398
[
https://issues.apache.org/jira/browse/FLINK-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935290#comment-15935290
]
ASF GitHub Bot commented on FLINK-6000:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935291#comment-15935291
]
ASF GitHub Bot commented on FLINK-6056:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-6000.
---
> Can not start HA cluster with start-cluster.sh
> --
>
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3506
---
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
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935284#comment-15935284
]
ASF GitHub Bot commented on FLINK-1579:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-6139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935283#comment-15935283
]
ASF GitHub Bot commented on FLINK-6139:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3460
Looks like the PR wasn't closed as part of the merging?
---
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
[
https://issues.apache.org/jira/browse/FLINK-6084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935280#comment-15935280
]
ASF GitHub Bot commented on FLINK-6084:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-6084.
---
Resolution: Fixed
Fix Version/s: 1.2.1
1.3.0
Resolved for 1.3 in htt
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3556
---
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 rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107264081
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935239#comment-15935239
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on a diff in
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3588
Good change, +1
merging this...
---
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
[
https://issues.apache.org/jira/browse/FLINK-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935088#comment-15935088
]
ASF GitHub Bot commented on FLINK-6144:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-6132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935086#comment-15935086
]
ASF GitHub Bot commented on FLINK-6132:
---
Github user hadronzoo commented on the issu
Github user hadronzoo commented on the issue:
https://github.com/apache/flink/pull/3576
LGTM @zhengcanbin
---
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-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6143:
--
Component/s: Client
> Unprotected access to this.flink in LocalExecutor#endSession()
> -
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3574
Hi @huawei-flink, all of the current aggregation functions (including avg)
should support retraction.
Have a look at
https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/ma
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934898#comment-15934898
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3479
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 not have this feature
enabled and wishes so, or if the fe
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934894#comment-15934894
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user aljoscha commented on the issue
Github user huawei-flink commented on the issue:
https://github.com/apache/flink/pull/3574
I have a first implementation of the processFunction, using a Queue as a
state. However, I need to implement the retractableAggregation, as AVG for
example is not supported.
---
If your projec
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934890#comment-15934890
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user huawei-flink commented on the i
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934879#comment-15934879
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user sjwiesman commented on the issu
Github user sjwiesman commented on the issue:
https://github.com/apache/flink/pull/3479
Pushed the fix, I had to update SideOutputsITCase so the
ProcessAllWindowFunctions had a noop clear method. All tests passed locally,
take a look
---
If your project is set up for it, you can rep
[
https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934866#comment-15934866
]
Stephan Ewen commented on FLINK-6103:
-
+1 to go with {{Files.move(source, target, REPL
[
https://issues.apache.org/jira/browse/FLINK-6132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-6132:
Assignee: zhengcanbin
> Remove redundant code in CliFrontend.java
> ---
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-6117:
Assignee: zhengcanbin
> 'zookeeper.sasl.disable' not takes effet when starting CuratorFram
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934850#comment-15934850
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3574
Hi @sunjincheng121, I think processing `OVER ROW PRECEDING` windows are a
much simpler case than the event-time variant. Not sure how much code could be
shared.
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934844#comment-15934844
]
ASF GitHub Bot commented on FLINK-5990:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3585
Hi @sunjincheng121, thanks for this PR.
To be honest, I don't completely understand the implementation of the
`RowsClauseBoundedOverProcessFunction`.
I thought about another design,
[
https://issues.apache.org/jira/browse/FLINK-5972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5972:
Fix Version/s: 1.2.1
> Don't allow shrinking merging windows
> -
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5990:
---
Description:
The goal of this issue is to add support for OVER ROWS aggregations on event
time stream
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934819#comment-15934819
]
ASF GitHub Bot commented on FLINK-5047:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/3589
[FLINK-5047] [table] Add count sliding group-windows for batch tables
This PR adds the missing sliding group-windows for row intervals. I also
added an additional table to the documentation to make
[
https://issues.apache.org/jira/browse/FLINK-6084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934809#comment-15934809
]
ASF GitHub Bot commented on FLINK-6084:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3556
I'll merge it later today.
---
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 wish
sunjincheng created FLINK-6145:
--
Summary: Add [non-partitioned] event time OVER ROWS BETWEEN x
PRECEDING aggregation to SQL
Key: FLINK-6145
URL: https://issues.apache.org/jira/browse/FLINK-6145
Project:
[
https://issues.apache.org/jira/browse/FLINK-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934807#comment-15934807
]
ASF GitHub Bot commented on FLINK-6144:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3588
[FLINK-6144] [config] Port JobManager configuration options to ConfigOption
This PR ports the existing JobManager configuration options to the
JobManagerOptions class
using the ConfigOption
[
https://issues.apache.org/jira/browse/FLINK-6084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934803#comment-15934803
]
ASF GitHub Bot commented on FLINK-6084:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3556
Thanks for the fix, LGTM.
@rmetzger could you proceed to merge this?
---
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 proje
Till Rohrmann created FLINK-6144:
Summary: Port job manager related configuration options to
ConfigOption
Key: FLINK-6144
URL: https://issues.apache.org/jira/browse/FLINK-6144
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5990:
---
Description:
The goal of this issue is to add support for OVER ROWS aggregations on event
time stream
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5990:
---
Summary: Add [partitioned] event time OVER ROWS BETWEEN x PRECEDING
aggregation to SQL (was: Add even
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934791#comment-15934791
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3567
AFAIK it's not possible to make IntelliJ pick up the checkstyle config by
itself. On my machine the setting is in the "*.iml" project file and I think we
have so far not included IDE specific projec
Ted Yu created FLINK-6143:
-
Summary: Unprotected access to this.flink in
LocalExecutor#endSession()
Key: FLINK-6143
URL: https://issues.apache.org/jira/browse/FLINK-6143
Project: Flink
Issue Type: B
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107186780
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934768#comment-15934768
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934764#comment-15934764
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on a diff in
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107184664
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934762#comment-15934762
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107184192
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3574
Hi, @huawei-flink @fhueske I have used `ProcessFunction` and implemented
bounded event-time OVER window. Since I think both bounded proc-time can share
the same infra. So I have completed the
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934728#comment-15934728
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on the
[
https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934726#comment-15934726
]
ASF GitHub Bot commented on FLINK-5929:
---
Github user aljoscha commented on the issue
1 - 100 of 137 matches
Mail list logo
