[
https://issues.apache.org/jira/browse/FLINK-5077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov updated FLINK-5077:
Summary: testStreamTableSink fails unstable (was: testStreamTableSink
falls unstable)
> testStream
Boris Osipov created FLINK-5077:
---
Summary: testStreamTableSink falls unstable
Key: FLINK-5077
URL: https://issues.apache.org/jira/browse/FLINK-5077
Project: Flink
Issue Type: Bug
Comp
Biao Liu created FLINK-5076:
---
Summary: Shutting down TM when shutting down new mini cluster
Key: FLINK-5076
URL: https://issues.apache.org/jira/browse/FLINK-5076
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15669628#comment-15669628
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5013 at 11/16/16 6:55 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15669628#comment-15669628
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5013 at 11/16/16 6:53 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15669628#comment-15669628
]
Tzu-Li (Gordon) Tai commented on FLINK-5013:
Resolved for master with
http://
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15669623#comment-15669623
]
Craig Foster commented on FLINK-5013:
-
Is there a fix/issue pending for correctly shad
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-4727.
--
Resolution: Resolved
> Kafka 0.9 Consumer should also checkpoint auto retrieved offsets
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15669591#comment-15669591
]
ASF GitHub Bot commented on FLINK-5013:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2787
---
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 tzulitai commented on the issue:
https://github.com/apache/flink/pull/2787
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
enabled and wishes so, or if th
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15669582#comment-15669582
]
ASF GitHub Bot commented on FLINK-5013:
---
Github user tzulitai commented on the issue
Tzu-Li (Gordon) Tai created FLINK-5075:
--
Summary: Kinesis consumer incorrectly determines shards as newly
discovered when tested against Kinesalite
Key: FLINK-5075
URL: https://issues.apache.org/jira/browse/F
[
https://issues.apache.org/jira/browse/FLINK-5074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-5074:
---
Assignee: shuai.xu
> Implement a RunningJobRegistry based on Zookeeper
> ---
shuai.xu created FLINK-5074:
---
Summary: Implement a RunningJobRegistry based on Zookeeper
Key: FLINK-5074
URL: https://issues.apache.org/jira/browse/FLINK-5074
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-4164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LiuBiao closed FLINK-4164.
--
Resolution: Won't Fix
As the state backend has been reconstructed, this issue should be closed.
> Use only one
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15669039#comment-15669039
]
Yassine Marzougui commented on FLINK-3869:
--
[~aljoscha] would it be OK if I incor
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668845#comment-15668845
]
Robert Metzger commented on FLINK-5013:
---
We only strictly enforce the maven version
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668827#comment-15668827
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2797
Do we provide anything that allows the user to identify files that weren't
cleaned up but can be removed? Something like a list of "active" pending files?
---
If your project is set up for it, you ca
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585619#comment-15585619
]
Ted Yu edited comment on FLINK-4499 at 11/15/16 10:55 PM:
--
+1 on
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668574#comment-15668574
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668573#comment-15668573
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88124075
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88125887
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88127261
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkFaultTolerance2ITCase
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668572#comment-15668572
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668498#comment-15668498
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88122097
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668495#comment-15668495
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2797
Sorry I just amended my previous commit with the comment integration. :S
---
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 d
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668477#comment-15668477
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88120352
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -16
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668461#comment-15668461
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2797
That makes sense, thanks for the explanation.
---
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-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668371#comment-15668371
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2797
The subtask matters for files that were opened but they did not make it
into a checkpoint because
a failure occurred after they were opened but before a checkpoint barrier
arrived. These are the on
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668362#comment-15668362
]
sunjincheng commented on FLINK-4937:
I really want to separate incremental and non-inc
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668332#comment-15668332
]
sunjincheng commented on FLINK-4937:
done
> Add incremental group window aggregation
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88113221
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -34
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668331#comment-15668331
]
sunjincheng commented on FLINK-4937:
done
> Add incremental group window aggregation
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668327#comment-15668327
]
sunjincheng commented on FLINK-4937:
done
> Add incremental group window aggregation
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668324#comment-15668324
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668314#comment-15668314
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2797
No, it's not just that one method. The method is on a whole other level; it
is so easy to edit a commit there simply is no reason for such a thing to exist
in the *initial PR*.
So, let's go t
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668281#comment-15668281
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88110293
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -570,
[
https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668275#comment-15668275
]
ASF GitHub Bot commented on FLINK-4913:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2795
Thanks. +1 for reverting then!
---
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 wishe
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668195#comment-15668195
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88105517
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -341,
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mischa Krüger updated FLINK-4900:
-
Labels: release (was: release review)
> Implement Docker image support
>
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668128#comment-15668128
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mischa Krüger updated FLINK-4900:
-
Labels: release review (was: release)
> Implement Docker image support
>
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88101910
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -15
Till Rohrmann created FLINK-5073:
Summary: ZooKeeperCompleteCheckpointStore executes blocking delete
operation in ZooKeeper client thread
Key: FLINK-5073
URL: https://issues.apache.org/jira/browse/FLINK-5073
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mischa Krüger updated FLINK-4900:
-
Labels: release (was: )
> Implement Docker image support
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mischa Krüger reassigned FLINK-4900:
Assignee: Mischa Krüger (was: Eron Wright )
> Implement Docker image support
> ---
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667701#comment-15667701
]
ASF GitHub Bot commented on FLINK-5008:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/2764
I tried with several versions of Eclipse and Scala IDE, even with the one
claimed to work. Unfortunately, I got none of them to work.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667697#comment-15667697
]
Timo Walther commented on FLINK-4604:
-
I looked into the problem. If you take a look a
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2797
Thanks for the first review @zentol .
On the comment about the diff reduction, you are referring to the removal
of the method in the intermediate commits that was not used? If yes, then this
i
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2814
+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 t
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667681#comment-15667681
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667672#comment-15667672
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88063735
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -570,
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/2740
@greghogan Excuse my ignorance, I'm only now learning about Flink internals
:)
It seems like the issue here was that `partitionByRange` partitions keys in
ascending order but we want the end res
[
https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667671#comment-15667671
]
ASF GitHub Bot commented on FLINK-4964:
---
Github user thvasilo commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667664#comment-15667664
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88063330
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -150,
GitHub user bitchelov opened a pull request:
https://github.com/apache/flink/pull/2814
Corrected log4j files.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the item
Github user bitchelov closed the pull request at:
https://github.com/apache/flink/pull/2802
---
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 e
Github user bitchelov closed the pull request at:
https://github.com/apache/flink/pull/2800
---
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 e
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667527#comment-15667527
]
Nikolay Vasilishin commented on FLINK-4565:
---
Thanks, guys.
I've implemented firs
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667497#comment-15667497
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2797
I also haven't checked the tests 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
enabled
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88044100
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -57
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667493#comment-15667493
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667489#comment-15667489
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667490#comment-15667490
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88044225
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -57
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667492#comment-15667492
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667491#comment-15667491
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88043878
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -57
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88044327
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -57
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2797#discussion_r88032585
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
---
@@ -57
[
https://issues.apache.org/jira/browse/FLINK-4369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4369.
---
Resolution: Fixed
Fix Version/s: 1.2.0
> EvictingWindowOperator Must Actually Evict Ele
[
https://issues.apache.org/jira/browse/FLINK-4369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-4369:
-
Reopen to set fix version.
> EvictingWindowOperator Must Actually Evict Elements
> --
[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667457#comment-15667457
]
ASF GitHub Bot commented on FLINK-4174:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2736
I reopened and then closed with the correct fix version. I think no-one can
change closed issues.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Git
[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4174.
---
Resolution: Fixed
Fix Version/s: 1.2.0
> Enhance Window Evictor
> -
[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-4174:
-
Reopen to set fix version.
> Enhance Window Evictor
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667421#comment-15667421
]
Chesnay Schepler commented on FLINK-5072:
-
hmm. Well it isn't something critical i
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2740
`zipWithIndex` preserves the order between partitions
(DataSetUtils.java:121). @tfournier314, I don't think it's a problem pushing
your current code since we're still discussing the PR.
---
If yo
[
https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667423#comment-15667423
]
ASF GitHub Bot commented on FLINK-4964:
---
Github user greghogan commented on the issu
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2736
I don't think I can edit a closed issue, could you please make the edit.
---
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 pr
[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667391#comment-15667391
]
ASF GitHub Bot commented on FLINK-4174:
---
Github user soniclavier commented on the is
Ufuk Celebi created FLINK-5072:
--
Summary: MetricFetcher Ask Timeout
Key: FLINK-5072
URL: https://issues.apache.org/jira/browse/FLINK-5072
Project: Flink
Issue Type: Improvement
Repor
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667325#comment-15667325
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15667353#comment-15667353
]
ASF GitHub Bot commented on FLINK-4174:
---
Github user aljoscha commented on the issue
1 - 100 of 212 matches
Mail list logo
