Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2618
Hi @mxm! Travis says ok, so please have another look
and let me know if you have any additional comments.
---
If your project is set up for it, you can reply to this email and have your
reply appea
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2673
[FLINK-4864] [table] Shade Calcite dependency in flink-table
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594176#comment-15594176
]
ASF GitHub Bot commented on FLINK-4864:
---
GitHub user wuchong opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594169#comment-15594169
]
ASF GitHub Bot commented on FLINK-4866:
---
GitHub user wuchong opened a pull request:
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2672
[FLINK-4866] [streaming] Make Trigger.clear() Abstract to Enforce
Implementation
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list int
[
https://issues.apache.org/jira/browse/FLINK-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4864:
--
Assignee: Jark Wu
> Shade Calcite dependency in flink-table
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-4866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4866:
--
Assignee: Jark Wu
> Make Trigger.clear() Abstract to Enforce Implementation
> -
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594036#comment-15594036
]
ASF GitHub Bot commented on FLINK-4862:
---
GitHub user manuzhang opened a pull request
GitHub user manuzhang opened a pull request:
https://github.com/apache/flink/pull/2671
[FLINK-4862] fix Timer register in ContinuousEventTimeTrigger
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manu Zhang closed FLINK-4863.
-
Resolution: Duplicate
> states of merging window and trigger are set to different TimeWindows on merge
> -
[
https://issues.apache.org/jira/browse/FLINK-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15593811#comment-15593811
]
Manu Zhang commented on FLINK-4863:
---
Found this is related to FLINK-4862. {{ContinuousEv
[
https://issues.apache.org/jira/browse/FLINK-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15593797#comment-15593797
]
ASF GitHub Bot commented on FLINK-4863:
---
Github user manuzhang closed the pull reque
Github user manuzhang closed the pull request at:
https://github.com/apache/flink/pull/2666
---
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
Krishna Prasad Anna Ramesh Kumar created FLINK-4874:
---
Summary: Enabling Flink web interface in local execution
Key: FLINK-4874
URL: https://issues.apache.org/jira/browse/FLINK-4874
Pr
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2617
I have started like to take a look at this...
The `FixLegthRecordSorter` and its interactions with the serializers /
comparators was not very well tested before, hence not activated. I am
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2618
Thanks for the comments @mxm ! I integrated them and waiting for Travis.
---
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-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15593069#comment-15593069
]
ASF GitHub Bot commented on FLINK-4204:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2670
[FLINK-4204] [gelly] Clean up gelly-examples
Moves drivers into separate package. Adds default main class to print usage
listing included classes. Includes documentation for running Gelly examples
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2506
+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 tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2669
[FLINK-4871] [mini cluster] Add memory calculation for TaskManagers to
MiniCluster
This PR is based on #2651, #2655 and #2657.
If the managed memory size for the task manager has not b
[
https://issues.apache.org/jira/browse/FLINK-4581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592877#comment-15592877
]
ASF GitHub Bot commented on FLINK-4581:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592866#comment-15592866
]
Stefan Richter commented on FLINK-4867:
---
I have already pushed my code into https://
[
https://issues.apache.org/jira/browse/FLINK-4705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592853#comment-15592853
]
ASF GitHub Bot commented on FLINK-4705:
---
Github user StephanEwen commented on the is
Gyula Fora created FLINK-4873:
-
Summary: Add config option to specify "home directory" for YARN
client resource sharing
Key: FLINK-4873
URL: https://issues.apache.org/jira/browse/FLINK-4873
Project: Flink
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2659
---
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 StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2570
Rebased version looks good to me.
---
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
ena
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2657
Sorry @mxm. The compilation problem were introduced due to an incomplete
rebasing. Should be fixed now.
---
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-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592479#comment-15592479
]
Eryn Dahlstedt commented on FLINK-2491:
---
We have been running into this problem as w
[
https://issues.apache.org/jira/browse/FLINK-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592476#comment-15592476
]
ASF GitHub Bot commented on FLINK-4857:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4857.
Resolution: Fixed
Fixed via 6f0faf9bb35e7cac3a38ed792cdabd6400fc4c79
> ZooKeeperUtils have a throws
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2659
Thanks for the review @mxm. Will merge this PR.
---
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
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/2628
> I transcribed Quicksort so as to remove considerations of Java
performance and inlining. It was not clear to me that if we encapsulated the
index, page number, and page offset into an object that Ja
[
https://issues.apache.org/jira/browse/FLINK-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592452#comment-15592452
]
ASF GitHub Bot commented on FLINK-4857:
---
Github user tillrohrmann commented on the i
Martin Junghanns created FLINK-4872:
---
Summary: Type erasure problem exclusively on cluster execution
Key: FLINK-4872
URL: https://issues.apache.org/jira/browse/FLINK-4872
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592447#comment-15592447
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592437#comment-15592437
]
ASF GitHub Bot commented on FLINK-4871:
---
GitHub user tillrohrmann opened a pull requ
Till Rohrmann created FLINK-4871:
Summary: Add memory calculation for TaskManagers and forward
MetricRegistry
Key: FLINK-4871
URL: https://issues.apache.org/jira/browse/FLINK-4871
Project: Flink
GitHub user tfournier314 opened a pull request:
https://github.com/apache/flink/pull/2668
Add EvaluateDataSetOperation for LabeledVector. This closes #4865
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into considera
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592359#comment-15592359
]
Gabor Gevay commented on FLINK-4867:
Hm, this sounds quite interesting. Could you plea
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-4867:
--
Assignee: Gabor Gevay
> Investigate code generation for improving sort performance
> --
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592367#comment-15592367
]
Gabor Gevay commented on FLINK-4867:
That's nice, thanks!
> Investigate code generati
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15592357#comment-15592357
]
Philipp von dem Bussche commented on FLINK-2821:
Thank you for all your ef
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
[
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
> --
[
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
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-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,
[
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-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=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-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
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-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-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
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
[
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
> ---
[
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
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-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
[
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-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-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:
-
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
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
[
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/2667#discussion_r84290827
--- 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_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 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 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 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_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_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_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_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_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_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_r84280372
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -199,44 +196,39 @@ public v
[
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 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
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 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
[
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
[
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
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
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 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 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 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:
[
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
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-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
[
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
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
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
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
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
1 - 100 of 142 matches
Mail list logo
