[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6228:
---
Description:
Syntax:
{code}
table
.overWindows(
(Rows|Range [ partitionBy value_expression ,
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6228:
---
Description:
Syntax:
{code}
table
.overWindows(
(Rows|Range [ partitionBy value_expression ,
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6228:
---
Description:
Syntax:
{code}
table
.overWindows(
(Rows|Range [ partitionBy value_expression ,
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6228:
---
Description:
Syntax:
{code}
table
.overWindows(
(Rows|Range [ partitionBy value_expression ,
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6228:
---
Description:
Syntax:
{code}
table
.overWindows(
(Rows|Range [ partitionBy value_expression ,
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6228:
---
Description:
Syntax:
{code}
table
.overWindows(
(Rows|Range [ partitionBy value_expression ,
[
https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956221#comment-15956221
]
sunjincheng commented on FLINK-6257:
Hi [~fhueske] I like this proposal very much. We really need to
[
https://issues.apache.org/jira/browse/FLINK-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956216#comment-15956216
]
ASF GitHub Bot commented on FLINK-4953:
---
Github user manuzhang commented on a diff in the pull
Github user manuzhang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3661#discussion_r109821341
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java
---
@@ -2560,7 +2560,7 @@
[
https://issues.apache.org/jira/browse/FLINK-6259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-6259.
--
Resolution: Fixed
Fix Version/s: 1.3.0
fixed in cae4976a4b9d4fa67f207dd08b8c9480c6f8989b
> Fix a small
[
https://issues.apache.org/jira/browse/FLINK-6259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956183#comment-15956183
]
ASF GitHub Bot commented on FLINK-6259:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3667
---
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
[
https://issues.apache.org/jira/browse/FLINK-6231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956181#comment-15956181
]
Chao Zhao commented on FLINK-6231:
--
I tried to set checkPoint interval to 5 min instead of 5 sec, and
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3667
+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
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3665#discussion_r109810006
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/LogicalWindowAggregateRule.scala
---
@@ -117,46 +119,86 @@
[
https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956126#comment-15956126
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user haohui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956108#comment-15956108
]
Haohui Mai commented on FLINK-6261:
---
[~fhueske], I am interested in contributing this feature. If you
[
https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955419#comment-15955419
]
radu commented on FLINK-6249:
-
[~fhueske] [~twalthr]
It seems that the aggregates that are passed in the
Kostas Kloudas created FLINK-6265:
-
Summary: Fix consecutive() for times() pattern.
Key: FLINK-6265
URL: https://issues.apache.org/jira/browse/FLINK-6265
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5541:
--
Description:
{code}
if (localJar == null) {
try {
for (final URL url :
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5855:
--
Description:
{code}
handlePendingFilesForPreviousCheckpoints(restoredState.pendingFilesPerCheckpoint);
[
https://issues.apache.org/jira/browse/FLINK-5629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15854366#comment-15854366
]
Ted Yu edited comment on FLINK-5629 at 4/4/17 3:18 PM:
---
RandomAccessFile#length()
[
https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5943:
--
Description:
{code}
protected void shutdown(ApplicationStatus status, String msg) {
// Need to clear the
[
https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942518#comment-15942518
]
Ted Yu edited comment on FLINK-5987 at 4/4/17 3:17 PM:
---
We can upgrade to 3.4.10 .
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955200#comment-15955200
]
Stefano Bortoli commented on FLINK-6250:
I am also fine implementing it extending the existing
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3656
Thanks @fhueske , I had moved the PR to FLINK-6247, and think about how to
deal with this JIRA.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955189#comment-15955189
]
ASF GitHub Bot commented on FLINK-5994:
---
Github user sunjincheng121 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955164#comment-15955164
]
Stavros Kontopoulos edited comment on FLINK-2147 at 4/4/17 2:04 PM:
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955166#comment-15955166
]
Gabor Gevay commented on FLINK-2147:
Maybe we could over-partition the sketch into maxParallelism
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955164#comment-15955164
]
Stavros Kontopoulos commented on FLINK-2147:
You just pick one of the sketches merge it with
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955164#comment-15955164
]
Stavros Kontopoulos edited comment on FLINK-2147 at 4/4/17 2:01 PM:
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955147#comment-15955147
]
Aljoscha Krettek commented on FLINK-2147:
-
Yes, but what I'm saying is that it is not easy to deal
Gyula Fora created FLINK-6264:
-
Summary: Kafka consumer fails if can't find leader for partition
Key: FLINK-6264
URL: https://issues.apache.org/jira/browse/FLINK-6264
Project: Flink
Issue Type:
Gyula Fora created FLINK-6263:
-
Summary: Leader error in Kafka producer on leader change (broker
restart/failrue)
Key: FLINK-6263
URL: https://issues.apache.org/jira/browse/FLINK-6263
Project: Flink
Gyula Fora created FLINK-6262:
-
Summary: UnknownTopicOrPartitionException Kafka consumer error on
broker restart/failure
Key: FLINK-6262
URL: https://issues.apache.org/jira/browse/FLINK-6262
Project:
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955117#comment-15955117
]
Fabian Hueske commented on FLINK-6250:
--
I'm not sure about implementing this as a separate
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955103#comment-15955103
]
Stavros Kontopoulos edited comment on FLINK-2147 at 4/4/17 1:02 PM:
I
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955103#comment-15955103
]
Stavros Kontopoulos edited comment on FLINK-2147 at 4/4/17 1:01 PM:
I
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955103#comment-15955103
]
Stavros Kontopoulos commented on FLINK-2147:
I think Count-min sketch can be implemented in
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955100#comment-15955100
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user tzulitai commented on the issue:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/3670
[FLINK-5808] Revert changes
This reverts the changes around FLINK-5808 because they introduced
follow-up issues.
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955050#comment-15955050
]
ASF GitHub Bot commented on FLINK-5808:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955041#comment-15955041
]
Stefano Bortoli commented on FLINK-6250:
I will approach this implementing a processing function
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955036#comment-15955036
]
Aljoscha Krettek commented on FLINK-2147:
-
If I'm not mistaken, a count-min sketch or similar
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955026#comment-15955026
]
ASF GitHub Bot commented on FLINK-5808:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955027#comment-15955027
]
ASF GitHub Bot commented on FLINK-5808:
---
Github user aljoscha closed the pull request at:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3664
Thanks for reviewing! I'm 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 this feature
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/3664
---
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
[
https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955020#comment-15955020
]
ASF GitHub Bot commented on FLINK-6183:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3611
---
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
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954976#comment-15954976
]
ASF GitHub Bot commented on FLINK-5090:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/3348
ok, sorry, these slipped through...
please note however, that the not-null checks in #3610 become obsolete with
this PR
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954938#comment-15954938
]
Chesnay Schepler commented on FLINK-4840:
-
I may have found a suitable implementation alternative:
[
https://issues.apache.org/jira/browse/FLINK-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954925#comment-15954925
]
ASF GitHub Bot commented on FLINK-6215:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3669
[FLINK-6215] Make the StatefulSequenceSource scalable.
So far this source was computing all the elements to
be emitted and stored them in memory. This could lead
to out-of-memory problems for
[
https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954914#comment-15954914
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954915#comment-15954915
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3665#discussion_r109615593
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/validate/FunctionCatalog.scala
---
@@ -350,7 +350,16 @@ class
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3665#discussion_r109616209
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/LogicalWindowAggregateRule.scala
---
@@ -117,46 +119,86
[
https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas resolved FLINK-6254.
---
Resolution: Fixed
> Consolidate late data methods on PatternStream and WindowedStream
>
[
https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954906#comment-15954906
]
ASF GitHub Bot commented on FLINK-6254:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954907#comment-15954907
]
ASF GitHub Bot commented on FLINK-6254:
---
Github user kl0u closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954908#comment-15954908
]
Kostas Kloudas commented on FLINK-6254:
---
Merged at 1b6baddca07bfba6093951e82ac9108cf4728f2a
>
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/3668
---
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
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3668
Thanks @aljoscha ! 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
enabled and
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954901#comment-15954901
]
Aljoscha Krettek commented on FLINK-3089:
-
Yes, I admit that it is a bit of a shortcoming. This
[
https://issues.apache.org/jira/browse/FLINK-6258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6258:
Component/s: DataStream API
> Deprecate ListCheckpointed interface for managed operator
[
https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954888#comment-15954888
]
ASF GitHub Bot commented on FLINK-6254:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3668
LGTM! ð
---
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-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-6261:
Assignee: Fabian Hueske
> Add support for TUMBLE, HOP, SESSION to batch SQL
>
Fabian Hueske created FLINK-6261:
Summary: Add support for TUMBLE, HOP, SESSION to batch SQL
Key: FLINK-6261
URL: https://issues.apache.org/jira/browse/FLINK-6261
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954881#comment-15954881
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3508
Very good work and thanks for improving the documentation. I like the
update. From what I have seen in the past, some user have mistaken the
list-nature of the operator state and simply
[
https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954865#comment-15954865
]
ASF GitHub Bot commented on FLINK-6246:
---
Github user dawidwys commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954866#comment-15954866
]
ASF GitHub Bot commented on FLINK-4953:
---
Github user aljoscha commented on the issue:
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/3662
Now, I think it is good 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
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3661
I'd like to keep it for now, since it might help catch some bugs and
doesn't take long to run.
What was the bug in the comparator?
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954860#comment-15954860
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3508
Nice update to the docs! And yeah, a separate issue for deprecation is very
good. ð
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954859#comment-15954859
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3508#discussion_r109610444
--- Diff: docs/dev/stream/state.md ---
@@ -233,45 +229,44 @@ val counts: DataStream[(String, Int)] = stream
## Using Managed Operator State
[
https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954851#comment-15954851
]
ASF GitHub Bot commented on FLINK-6246:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3662
@dawidwys thanks for reviewing so quickly. I pushed a commit to address
your comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954849#comment-15954849
]
ASF GitHub Bot commented on FLINK-6246:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3662#discussion_r109608264
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/iteration/IterateExample.java
---
@@ -107,7 +107,8 @@
[
https://issues.apache.org/jira/browse/FLINK-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6209:
Fix Version/s: 1.2.2
> StreamPlanEnvironment always has a parallelism of 1
>
[
https://issues.apache.org/jira/browse/FLINK-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6209:
Fix Version/s: 1.3.0
> StreamPlanEnvironment always has a parallelism of 1
>
[
https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954840#comment-15954840
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user shaoxuan-wang commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6188:
Fix Version/s: (was: 1.2.1)
1.3.0
1.2.2
> Some
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3665
So we finally got those supported by Calcite 1.12ï¼Really excited to see
those features supported in flinkSQL. Thanks @haohui.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954799#comment-15954799
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3665
Thanks for the PR @haohui!
+1 to merge.
I've been waiting for this feature :-)
---
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-6241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954746#comment-15954746
]
radu commented on FLINK-6241:
-
[~shaoxuan] i realized i did not notify you :)
> codeGen dataStream aggregates
[
https://issues.apache.org/jira/browse/FLINK-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954739#comment-15954739
]
radu commented on FLINK-6260:
-
[~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalthr]
radu created FLINK-6260:
---
Summary: Distinct Aggregates for Group By Windows
Key: FLINK-6260
URL: https://issues.apache.org/jira/browse/FLINK-6260
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953646#comment-15953646
]
radu edited comment on FLINK-6249 at 4/4/17 7:48 AM:
-
[~fhueske] [~shijinkui]
[
https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15954717#comment-15954717
]
radu commented on FLINK-6249:
-
[~fhueske] Thanks for the feedback!
I cleaned the JIRA as you suggested. I will
[
https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radu updated FLINK-6249:
Description:
Time target: ProcTime/EventTime
SQL targeted query examples:
Q1.
[
https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radu updated FLINK-6249:
Description:
Time target: ProcTime/EventTime
SQL targeted query examples:
Q1.
[
https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radu updated FLINK-6249:
Description:
Time target: ProcTime/EventTime
SQL targeted query examples:
Q1.
1 - 100 of 104 matches
Mail list logo
