[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956393#comment-15956393
]
sunjincheng commented on FLINK-6228:
Hi, [~fhueske] about {{orderBy}} clause the time
[
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&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-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
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-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
[
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
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-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 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
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&focusedCommentId=15956126#comment-15956126
]
ASF GitHub Bot commented on FLINK-6011:
---
Github user haohui commented on a diff in t
[
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-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
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 : ((ContextEnvironm
[
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&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-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-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-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
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-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
[
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-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 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=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=15955147#comment-15955147
]
Aljoscha Krettek commented on FLINK-2147:
-
Yes, but what I'm saying is that it is
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
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: Flin
[
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
[
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-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 commented on FLINK-2147:
I think Count-min sketch can be i
[
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
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-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:
[
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-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-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-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
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-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 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-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 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-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
[
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:
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-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
[
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
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
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&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:
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
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
[
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
[
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-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
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-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
[
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
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-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 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-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 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=15954859#comment-15954859
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user aljoscha commented on a diff in
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&focusedCommentId=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 well
[
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 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-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&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-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
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-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 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&focusedCommentId=15954746#comment-15954746
]
radu commented on FLINK-6241:
-
[~shaoxuan] i realized i did not notify you :)
> codeGen dataS
[
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-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-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: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
1 - 100 of 105 matches
Mail list logo
