[
https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196560#comment-16196560
]
Yun Tang commented on FLINK-5510:
-
According to [FLINK-725 (Remove Flink Futures or back t
[
https://issues.apache.org/jira/browse/FLINK-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6684:
---
Assignee: Bowen Li
> Remove AsyncCheckpointRunnable from StreamTask
> ---
[
https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6505:
---
Assignee: Bowen Li
> Proactively cleanup local FS for RocksDBKeyedStateBackend on startup
> -
[
https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196523#comment-16196523
]
Bowen Li commented on FLINK-7167:
-
Hi [~aljoscha], I feel this is partly related to discus
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou UTC+8 reassigned FLINK-:
-
Assignee: Hai Zhou UTC+8
> Upgrade maven plugin japicmp version to 0.10.0
> -
[
https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196502#comment-16196502
]
ASF GitHub Bot commented on FLINK-6615:
---
GitHub user bowenli86 opened a pull request
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4787
[FLINK-6615] simplify FileUtils
## What is the purpose of the change
simplify FileUtils
## Brief change log
simplify FileUtils
## Verifying this change
[
https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6615:
---
Assignee: Bowen Li
> tmp directory not cleaned up on shutdown
> -
[
https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196456#comment-16196456
]
Bowen Li commented on FLINK-7167:
-
I've been looking forward to such an improvement too. N
[
https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-7167:
---
Assignee: Bowen Li
> Job can't set checkpoint meta directory to cover the system setting
> state.che
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li resolved FLINK-6219.
-
Resolution: Won't Fix
> Add a state backend which supports sorting
> -
Hai Zhou UTC+8 created FLINK-:
-
Summary: Upgrade maven plugin japicmp version to 0.10.0
Key: FLINK-
URL: https://issues.apache.org/jira/browse/FLINK-
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196399#comment-16196399
]
Bowen Li commented on FLINK-7388:
-
[~xccui] [~fhueske] Thank you for pointing it out!
> P
[
https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196370#comment-16196370
]
ASF GitHub Bot commented on FLINK-7388:
---
GitHub user bowenli86 opened a pull request
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4786
[FLINK-7388][DataStream API] ProcessFunction.onTimer() sets processing time
as timestamp
## What is the purpose of the change
Before Flink 1.4.0, when called from a processing-time timer,
[
https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7388:
Fix Version/s: 1.4.0
> ProcessFunction.onTimer() sets processing time as timestamp
> ---
[
https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-7648:
---
Assignee: (was: Bowen Li)
> Port TaskManagersHandler to new REST endpoint
> -
[
https://issues.apache.org/jira/browse/FLINK-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196339#comment-16196339
]
ASF GitHub Bot commented on FLINK-7660:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4740
@aljoscha @chenqin Hi guys, can you please take a look?
---
[
https://issues.apache.org/jira/browse/FLINK-7772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-7772.
---
> Test instability in BlobCacheDeleteTest
> ---
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196309#comment-16196309
]
ASF GitHub Bot commented on FLINK-7739:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-7772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-7772.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Release Note: Fixed via a8443a52e33e5cf1f85b3be7
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4749
I think this looks good.
Since it rename the mini cluster methods (meaning it does actually change
user facing pre-production code which should also be stable), I would only
merge this
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196308#comment-16196308
]
Chesnay Schepler commented on FLINK-7608:
-
Hold on, isn't this issue only about re
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196308#comment-16196308
]
Chesnay Schepler edited comment on FLINK-7608 at 10/8/17 7:52 PM:
--
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4751
@pnowojski I am wondering whether this is really necessary. This is not
quite a busy loop after all, because the `collect()` call emits to the Kafka
Producer and goes through buffering and I/O.
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196307#comment-16196307
]
ASF GitHub Bot commented on FLINK-7739:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-7742:
Release Note:
Fixed in
- 1.3.3 via c845ba09a25f577356e5b74c279c3e7653c4885a
- 1.4.0 via edc53a74
[
https://issues.apache.org/jira/browse/FLINK-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-7742.
---
> Fix array access might be out of bounds
> ---
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-7742.
-
Resolution: Fixed
Fix Version/s: 1.3.3
Release Note:
Fixed in
- 1.3.2 via c845ba09a2
[
https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-7312.
---
> activate checkstyle for flink/core/memory/*
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-7312.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Release Note: Fixed in c3235c395f7bb69b482b85c68
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4754
---
[
https://issues.apache.org/jira/browse/FLINK-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-7310.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Release Note: Implemented in e14caef3794d0acde4b
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196303#comment-16196303
]
ASF GitHub Bot commented on FLINK-7739:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-7310.
---
> always use HybridMemorySegment
> --
>
> Key: FLINK-7310
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4755
---
[
https://issues.apache.org/jira/browse/FLINK-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196305#comment-16196305
]
ASF GitHub Bot commented on FLINK-7310:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196302#comment-16196302
]
ASF GitHub Bot commented on FLINK-7772:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196304#comment-16196304
]
ASF GitHub Bot commented on FLINK-7742:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4782
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4775
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4445
---
[
https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196296#comment-16196296
]
ASF GitHub Bot commented on FLINK-7736:
---
Github user haohui commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196295#comment-16196295
]
ASF GitHub Bot commented on FLINK-7736:
---
Github user haohui commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196297#comment-16196297
]
ASF GitHub Bot commented on FLINK-7736:
---
Github user haohui commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196298#comment-16196298
]
ASF GitHub Bot commented on FLINK-7736:
---
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/4784#discussion_r143363777
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java
---
@@ -448,7 +448,7 @@ public boolean addTask(Task task)
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4784#discussion_r143363797
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/ArchivedJson.java
---
@@ -55,6 +57,13 @@ public boolean equals(Object obj)
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4784#discussion_r143363755
--- Diff: flink-java/src/main/java/org/apache/flink/api/java/Utils.java ---
@@ -53,7 +53,7 @@ public static String getCallLocationName() {
public stati
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4784#discussion_r143363766
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/GroupReduceNode.java
---
@@ -97,7 +97,7 @@ else if
(Optimizer.HINT_LOCAL_STRATEGY_COM
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196168#comment-16196168
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in th
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r143357544
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/JoinITCase.scala
---
@@ -102,5 +117,154 @@ class JoinITCase ext
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7776:
--
Description:
the current group aggregation will compare the last {{Row}} and current {{Row}}
when {{gen
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7776:
--
Summary: do not emit duplicated records in group aggregation (was: remove
duplicated records collecting
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196117#comment-16196117
]
ASF GitHub Bot commented on FLINK-7776:
---
GitHub user Xpray opened a pull request:
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/4785
[FLINK-7776][TableAPI & SQL] remove duplicated records collecting in gâ¦
â¦roup aggregation
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help u
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7776:
--
Summary: remove duplicated records collecting in group aggregation (was:
remove duplicate records colle
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-7776:
--
Summary: remove duplicate records collecting in group aggregation (was:
remove duplicate records in gro
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196096#comment-16196096
]
Hai Zhou UTC+8 edited comment on FLINK-7608 at 10/8/17 12:45 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196096#comment-16196096
]
Hai Zhou UTC+8 edited comment on FLINK-7608 at 10/8/17 12:44 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196096#comment-16196096
]
Hai Zhou UTC+8 edited comment on FLINK-7608 at 10/8/17 12:43 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196096#comment-16196096
]
Hai Zhou UTC+8 commented on FLINK-7608:
---
Thanks [~rmetzger], [~StephanEwen] for the
Ruidong Li created FLINK-7776:
-
Summary: remove duplicate records in group aggregation
Key: FLINK-7776
URL: https://issues.apache.org/jira/browse/FLINK-7776
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196030#comment-16196030
]
Fabian Hueske commented on FLINK-3655:
--
I don't think there's a particular reason why
[
https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196004#comment-16196004
]
ASF GitHub Bot commented on FLINK-7736:
---
GitHub user 1m2c3t4 opened a pull request:
GitHub user 1m2c3t4 opened a pull request:
https://github.com/apache/flink/pull/4784
FLINK-7736: fix some lgtm.com alerts
## What is the purpose of the change
lgtm.com performs deep analysis on more than 50,000 open source projects
including many of the apache projects
67 matches
Mail list logo
