Github user fhueske 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 the
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3668
[FLINK-6254] [cep] Same method name for late data outputs on PatternStream
and windowing.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/fli
[
https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954706#comment-15954706
]
ASF GitHub Bot commented on FLINK-6254:
---
GitHub user kl0u opened a pull request:
[
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. Boundar
[
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. Boundar
[
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. Boundar
[
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. Boundar
[
https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954717#comment-15954717
]
radu commented on FLINK-6249:
-
[~fhueske] Thanks for the feedback!
I cleaned the JIRA as you s
[
https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953646#comment-15953646
]
radu edited comment on FLINK-6249 at 4/4/17 7:48 AM:
-
[~fhueske] [~shi
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
Compon
[
https://issues.apache.org/jira/browse/FLINK-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954739#comment-15954739
]
radu commented on FLINK-6260:
-
[~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt
[
https://issues.apache.org/jira/browse/FLINK-6241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954746#comment-15954746
]
radu commented on FLINK-6241:
-
[~shaoxuan] i realized i did not notify you :)
> codeGen dataS
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-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954799#comment-15954799
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user fhueske commented on the issue:
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 ema
[
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 set
[
https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954840#comment-15954840
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user shaoxuan-wang commented on the
[
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
> ---
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 @@ p
[
https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954849#comment-15954849
]
ASF GitHub Bot commented on FLINK-6246:
---
Github user aljoscha commented on a diff in
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 well
[
https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954851#comment-15954851
]
ASF GitHub Bot commented on FLINK-6246:
---
Github user aljoscha commented on the issue
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-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954859#comment-15954859
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user aljoscha commented on a diff in
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 wel
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954860#comment-15954860
]
ASF GitHub Bot commented on FLINK-5991:
---
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
enabled
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 th
[
https://issues.apache.org/jira/browse/FLINK-6246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15954866#comment-15954866
]
ASF GitHub Bot commented on FLINK-4953:
---
Github user aljoscha 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 dumped
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954881#comment-15954881
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user StefanRRichter commented on the
[
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: S
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 th
[
https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954888#comment-15954888
]
ASF GitHub Bot commented on FLINK-6254:
---
Github user aljoscha commented on the issue
[
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 stat
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954901#comment-15954901
]
Aljoscha Krettek commented on FLINK-3089:
-
Yes, I admit that it is a bit of a shor
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 wi
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 enable
[
https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15954908#comment-15954908
]
Kostas Kloudas commented on FLINK-6254:
---
Merged at 1b6baddca07bfba6093951e82ac9108cf
[
https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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:all-tabpanel
]
Kostas Kloudas resolved FLINK-6254.
---
Resolution: Fixed
> Consolidate late data methods on PatternStream and WindowedStream
> --
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 @@
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 BasicOperatorTable
[
https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954915#comment-15954915
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954914#comment-15954914
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user twalthr commented on a diff in
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 la
[
https://issues.apache.org/jira/browse/FLINK-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954925#comment-15954925
]
ASF GitHub Bot commented on FLINK-6215:
---
GitHub user kl0u opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954938#comment-15954938
]
Chesnay Schepler commented on FLINK-4840:
-
I may have found a suitable implementat
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 h
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954976#comment-15954976
]
ASF GitHub Bot commented on FLINK-5090:
---
Github user NicoK commented on the issue:
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 enab
[
https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955020#comment-15955020
]
ASF GitHub Bot commented on FLINK-6183:
---
Github user asfgit closed the pull request
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 en
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955027#comment-15955027
]
ASF GitHub Bot commented on FLINK-5808:
---
Github user aljoscha closed the pull reques
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
enable
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955026#comment-15955026
]
ASF GitHub Bot commented on FLINK-5808:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955036#comment-15955036
]
Aljoscha Krettek commented on FLINK-2147:
-
If I'm not mistaken, a count-min sketch
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955041#comment-15955041
]
Stefano Bortoli commented on FLINK-6250:
I will approach this implementing a proce
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955050#comment-15955050
]
ASF GitHub Bot commented on FLINK-5808:
---
GitHub user aljoscha opened a pull request:
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 h
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955100#comment-15955100
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955103#comment-15955103
]
Stavros Kontopoulos commented on FLINK-2147:
I think Count-min sketch can be i
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955103#comment-15955103
]
Stavros Kontopoulos edited comment on FLINK-2147 at 4/4/17 1:01 PM:
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955103#comment-15955103
]
Stavros Kontopoulos edited comment on FLINK-2147 at 4/4/17 1:02 PM:
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955117#comment-15955117
]
Fabian Hueske commented on FLINK-6250:
--
I'm not sure about implementing this as a sep
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: Flin
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-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: B
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955147#comment-15955147
]
Aljoscha Krettek commented on FLINK-2147:
-
Yes, but what I'm saying is that it is
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15955164#comment-15955164
]
Stavros Kontopoulos commented on FLINK-2147:
You just pick one of the sketches
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955166#comment-15955166
]
Gabor Gevay commented on FLINK-2147:
Maybe we could over-partition the sketch into max
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955164#comment-15955164
]
Stavros Kontopoulos edited comment on FLINK-2147 at 4/4/17 2:04 PM:
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955189#comment-15955189
]
ASF GitHub Bot commented on FLINK-5994:
---
Github user sunjincheng121 commented on the
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 o
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955200#comment-15955200
]
Stefano Bortoli commented on FLINK-6250:
I am also fine implementing it extending
[
https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942518#comment-15942518
]
Ted Yu edited comment on FLINK-5987 at 4/4/17 3:17 PM:
---
We can upgra
[
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 j
[
https://issues.apache.org/jira/browse/FLINK-5629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854366#comment-15854366
]
Ted Yu edited comment on FLINK-5629 at 4/4/17 3:18 PM:
---
RandomAccess
[
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-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 : ((ContextEnvironm
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-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955419#comment-15955419
]
radu commented on FLINK-6249:
-
[~fhueske] [~twalthr]
It seems that the aggregates that are pa
[
https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956108#comment-15956108
]
Haohui Mai commented on FLINK-6261:
---
[~fhueske], I am interested in contributing this fe
[
https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956126#comment-15956126
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user haohui commented on a diff in t
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 @@
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 the
[
https://issues.apache.org/jira/browse/FLINK-6231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956181#comment-15956181
]
Chao Zhao commented on FLINK-6231:
--
I tried to set checkPoint interval to 5 min instead o
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 enab
[
https://issues.apache.org/jira/browse/FLINK-6259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956183#comment-15956183
]
ASF GitHub Bot commented on FLINK-6259:
---
Github user asfgit closed the pull request
[
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 s
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 @@ publ
[
https://issues.apache.org/jira/browse/FLINK-4953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956216#comment-15956216
]
ASF GitHub Bot commented on FLINK-4953:
---
Github user manuzhang commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956221#comment-15956221
]
sunjincheng commented on FLINK-6257:
Hi [~fhueske] I like this proposal very much. We
[
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 , .
1 - 100 of 105 matches
Mail list logo
