Manu Zhang created FLINK-4863:
-
Summary: states of merging window and trigger are set to different
TimeWindows on merge
Key: FLINK-4863
URL: https://issues.apache.org/jira/browse/FLINK-4863
Project: Flink
GitHub user manuzhang opened a pull request:
https://github.com/apache/flink/pull/2666
[FLINK-4863] fix trigger context window on merge
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your ch
[
https://issues.apache.org/jira/browse/FLINK-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591051#comment-15591051
]
ASF GitHub Bot commented on FLINK-4863:
---
GitHub user manuzhang opened a pull request
GitHub user sedgewickmm18 opened a pull request:
https://github.com/apache/flink/pull/2667
README.md -Description of the bluemix specifâ¦
Hi,
as per discussion with @mxm I'm proposing to include the following change
that makes use of container link
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591201#comment-15591201
]
ASF GitHub Bot commented on FLINK-3674:
---
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/2570#discussion_r84234419
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimelyFlatMapFunction.java
---
@@ -0,0 +1,78 @@
+/*
+ * Licensed t
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84237459
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591261#comment-15591261
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591262#comment-15591262
]
ASF GitHub Bot commented on FLINK-3674:
---
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/2570#discussion_r84236659
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591263#comment-15591263
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591264#comment-15591264
]
ASF GitHub Bot commented on FLINK-3674:
---
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/2570#discussion_r84237685
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/DefaultProcessingTimeService.java
---
@@ -35,10 +34,10 @@
import stat
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84235862
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -390,4 +425,141 @@ public void close()
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591260#comment-15591260
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591288#comment-15591288
]
ASF GitHub Bot commented on FLINK-4824:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591287#comment-15591287
]
ASF GitHub Bot commented on FLINK-4784:
---
Github user rmetzger commented on the issue
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2662
Thanks for the PR @greghogan! Having a custom exception for missing
arguments to a user program is a good approach. However, it requires the author
of the program to use the custom exception. At least, w
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84241679
--- Diff: flink-contrib/docker-flink/docker-entrypoint.sh ---
@@ -20,11 +20,19 @@
if [ "$1" = "jobmanager" ]; then
echo "Starting Job Manager"
[
https://issues.apache.org/jira/browse/FLINK-4784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591353#comment-15591353
]
ASF GitHub Bot commented on FLINK-4784:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2636
should be fixed now
---
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
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591419#comment-15591419
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591422#comment-15591422
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591424#comment-15591424
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591462#comment-15591462
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2570
Thanks for your comments @StefanRRichter and @kl0u. I incorporated most of
them by now.
---
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-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591460#comment-15591460
]
ASF GitHub Bot commented on FLINK-3674:
---
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/2570#discussion_r84251996
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591567#comment-15591567
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2652
+1 go ahead
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2642
@nssalian Thanks for understanding.
We as a community together have actually gone into that mode (more
conservative and stability focused) not too long ago. So it is still a bit of a
lea
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591577#comment-15591577
]
ASF GitHub Bot commented on FLINK-3999:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591587#comment-15591587
]
ASF GitHub Bot commented on FLINK-3030:
---
Github user StephanEwen commented on the is
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84236439
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ * Licens
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2448
Good to go from my side.
@rmetzger and @iampeter - since you are working on the web UI currently,
can you try and merge this?
---
If your project is set up for it, you can reply to this emai
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2636
I tested the change this morning, and its not working:
```
2016-10-20 11:08:28,216 WARN
org.apache.flink.runtime.metrics.MetricRegistry - Could not start
Metr
icDumpA
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591622#comment-15591622
]
Theodore Vasiloudis commented on FLINK-4850:
Just to note, the PR I opened onl
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591622#comment-15591622
]
Theodore Vasiloudis edited comment on FLINK-4850 at 10/20/16 11:57 AM:
-
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84251732
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ * Li
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84251918
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER updated FLINK-4850:
---
Description:
It seems that evaluate operation is defined for Vector and not LabeledVector.
It
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591644#comment-15591644
]
Thomas FOURNIER commented on FLINK-4850:
Ok I'm creating a specific JIRA issue rel
Fabian Hueske created FLINK-4864:
Summary: Shade Calcite dependency in flink-table
Key: FLINK-4864
URL: https://issues.apache.org/jira/browse/FLINK-4864
Project: Flink
Issue Type: Improvement
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84242416
--- Diff: flink-contrib/docker-flink/docker-compose.yml ---
@@ -20,16 +20,20 @@ version: "2"
services:
jobmanager:
image: flink
+conta
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84242735
--- Diff: flink-contrib/docker-flink/docker-compose.sh ---
@@ -0,0 +1,4 @@
+#!/bin/sh
--- End diff --
Could we name this file `bluemix-docker-comp
Thomas FOURNIER created FLINK-4865:
--
Summary: FlinkML - Add EvaluateDataSet operation for LabeledVector
Key: FLINK-4865
URL: https://issues.apache.org/jira/browse/FLINK-4865
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-4865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER updated FLINK-4865:
---
Description:
We can only call "evaluate" method on a DataSet[(Double,Vector)].
Eg: If our mod
[
https://issues.apache.org/jira/browse/FLINK-4865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER updated FLINK-4865:
---
Description:
We can only call "evaluate" method on a DataSet[(Vector,Double)].
Eg: If our mod
Aljoscha Krettek created FLINK-4866:
---
Summary: Make Trigger.clear() Abstract to Enforce Implementation
Key: FLINK-4866
URL: https://issues.apache.org/jira/browse/FLINK-4866
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591734#comment-15591734
]
ASF GitHub Bot commented on FLINK-3722:
---
Github user ggevay commented on a diff in t
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2657
This doesn't compile currently. Do you prefer if I review the PRs
individually or review the commits in this PR?
---
If your project is set up for it, you can reply to this email and have your
reply app
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591741#comment-15591741
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2618
Thanks for updating the description. Let take a look at the changes.
---
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 n
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2618
Thanks a lot @mxm !
---
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 i
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/2628#discussion_r84248344
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/QuickSort.java
---
@@ -49,20 +49,40 @@ protected static int getMaxDepth(int x) {
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84255151
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/DefaultProcessingTimeService.java
---
@@ -35,10 +34,10 @@
import
[
https://issues.apache.org/jira/browse/FLINK-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591808#comment-15591808
]
Jan Zajíc commented on FLINK-3902:
--
WE have same issue on Linux in docker, but *both* ! R
[
https://issues.apache.org/jira/browse/FLINK-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591808#comment-15591808
]
Jan Zajíc edited comment on FLINK-3902 at 10/20/16 1:24 PM:
WE
[
https://issues.apache.org/jira/browse/FLINK-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591808#comment-15591808
]
Jan Zajíc edited comment on FLINK-3902 at 10/20/16 1:24 PM:
We
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84242539
--- Diff: flink-contrib/docker-flink/docker-compose.yml ---
@@ -20,16 +20,20 @@ version: "2"
services:
jobmanager:
image: flink
+conta
Github user sedgewickmm18 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84286390
--- Diff: flink-contrib/docker-flink/docker-entrypoint.sh ---
@@ -20,11 +20,19 @@
if [ "$1" = "jobmanager" ]; then
echo "Starting Job
Github user sedgewickmm18 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84287069
--- Diff: flink-contrib/docker-flink/docker-compose.yml ---
@@ -20,16 +20,20 @@ version: "2"
services:
jobmanager:
image: flink
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591881#comment-15591881
]
ASF GitHub Bot commented on FLINK-3722:
---
Github user greghogan commented on the issu
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84285533
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ * Licens
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84288480
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ * Licens
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84280372
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -199,44 +196,39 @@ public v
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84285924
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ * Licens
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84288567
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ * Licens
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84288776
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ * Licens
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84284953
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/RichFileInputSplitTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84281147
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ * Licens
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84279968
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -189,7 +186,7 @@ public voi
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2628
Thanks @ggevay for reviewing. I added a commit with additional comments.
I transcribed `Quicksort` so as to remove considerations of Java
performance and inlining. It was not clear to me th
Github user sedgewickmm18 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84291047
--- Diff: flink-contrib/docker-flink/docker-compose.sh ---
@@ -0,0 +1,4 @@
+#!/bin/sh
--- End diff --
that's fine
---
If your project
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84290827
--- Diff: flink-contrib/docker-flink/docker-compose.yml ---
@@ -20,16 +20,20 @@ version: "2"
services:
jobmanager:
image: flink
+conta
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591955#comment-15591955
]
Anton Mushin commented on FLINK-4832:
-
Hello
I think that it needs to change
{{org.ap
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84288975
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -347,34 +328,17 @@ public v
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84276796
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -43,16 +41,18 @@
impor
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591955#comment-15591955
]
Anton Mushin edited comment on FLINK-4832 at 10/20/16 2:31 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592027#comment-15592027
]
ASF GitHub Bot commented on FLINK-4824:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592052#comment-15592052
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592051#comment-15592051
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user StefanRRichter closed the pull
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/2648
---
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
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2662
@mxm thanks for the review. I added a second commit which I think satisfies
your request. When no job is executed then the message is printed to stderr
without a stacktrace.
---
If your project i
[
https://issues.apache.org/jira/browse/FLINK-4842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-4842.
-
Resolution: Implemented
Fix Version/s: 1.2.0
> Introduce test to enforce order of operator
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-4844.
-
Resolution: Implemented
Fix Version/s: 1.2.0
> Partitionable Raw Keyed/Operator State
> ---
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2570
I updated this on top of the latest master with @StefanRRichter's state
changes.
Please take another look, @StefanRRichter.
---
If your project is set up for it, you can reply to this emai
Gabor Gevay created FLINK-4867:
--
Summary: Investigate code generation for improving sort performance
Key: FLINK-4867
URL: https://issues.apache.org/jira/browse/FLINK-4867
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592186#comment-15592186
]
ASF GitHub Bot commented on FLINK-3722:
---
Github user ggevay commented on the issue:
Gabor Gevay created FLINK-4868:
--
Summary: Insertion sort could avoid the swaps
Key: FLINK-4868
URL: https://issues.apache.org/jira/browse/FLINK-4868
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-4868:
---
Description:
This is about the fallback to insertion sort at the beginning of
{{QuickSort.sortInterna
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592239#comment-15592239
]
Greg Hogan commented on FLINK-4867:
---
It will be very interesting to see the results of t
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592246#comment-15592246
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592292#comment-15592292
]
Stefan Richter edited comment on FLINK-4867 at 10/20/16 4:32 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592292#comment-15592292
]
Stefan Richter commented on FLINK-4867:
---
If you sort performance is crucial to you,
Greg Hogan created FLINK-4869:
-
Summary: Store record pointer after record keys
Key: FLINK-4869
URL: https://issues.apache.org/jira/browse/FLINK-4869
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-4860:
---
Component/s: Local Runtime
> Sort performance
>
>
> Key: FLINK-4860
>
[
https://issues.apache.org/jira/browse/FLINK-4860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-4860:
---
Labels: performance (was: )
> Sort performance
>
>
> Key: FLINK-4860
[
https://issues.apache.org/jira/browse/FLINK-4869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-4869:
---
Labels: performance (was: )
> Store record pointer after record keys
> --
Chesnay Schepler created FLINK-4870:
---
Summary: ContinuousFileMonitoringFunction does not properly handle
absolut Windows paths
Key: FLINK-4870
URL: https://issues.apache.org/jira/browse/FLINK-4870
P
1 - 100 of 142 matches
Mail list logo
