[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15277514#comment-15277514
]
GaoLun commented on FLINK-3879:
---
Scatter-gather model divides original iteration into two pa
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276921#comment-15276921
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1947#issuecomment-217972596
I have updates this PR; it now contains a new feature: configurable system
scope. It essentially allows users to decide how Flink entities(Taskmanager,
jobs, tasks and op
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276811#comment-15276811
]
Martin Liesenberg commented on FLINK-2926:
--
the issue is FLINK-3888
> Add a Stro
Martin Liesenberg created FLINK-3888:
Summary: Custom Aggregator with Convergence can't be registered
directly with DeltaIteration
Key: FLINK-3888
URL: https://issues.apache.org/jira/browse/FLINK-3888
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276761#comment-15276761
]
Greg Hogan commented on FLINK-3879:
---
That is a very "meta" question :) Gelly currently c
[
https://issues.apache.org/jira/browse/FLINK-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright updated FLINK-3883:
Description:
I ran into some trouble in preparing a Homebrew formula to install Flink on Mac
([home
[
https://issues.apache.org/jira/browse/FLINK-3882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276590#comment-15276590
]
ASF GitHub Bot commented on FLINK-3882:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1971#issuecomment-217917157
Thanks for the fixes @markreddy.
+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
[
https://issues.apache.org/jira/browse/FLINK-3877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-3877.
---
Resolution: Fixed
Fixed with a27208da88390a1e5dd3ec4102064862c54eb7a0
> Create TranslateFunction inte
[
https://issues.apache.org/jira/browse/FLINK-3877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276545#comment-15276545
]
ASF GitHub Bot commented on FLINK-3877:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1968
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-3877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276536#comment-15276536
]
ASF GitHub Bot commented on FLINK-3877:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1968#issuecomment-217904645
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
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276496#comment-15276496
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r62518520
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java
---
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the
public.
> --
>
> Key: FLINK-3886
> URL: https://issues.apache.org/jira/browse/FLINK-3886
> Project: Flink
> Issue Type: Improvement
>Reporter: Niels Basjes
>Assignee: Niels Basjes
> Attachments:
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276469#comment-15276469
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user gallenvara commented on a diff
Maximilian Michels created FLINK-3887:
-
Summary: Improve dependency management for building docs
Key: FLINK-3887
URL: https://issues.apache.org/jira/browse/FLINK-3887
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276468#comment-15276468
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user gallenvara commented on a diff
Github user gallenvara commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r62514632
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java
---
@@ -0,0 +1,183 @@
+/*
+ * Licensed to th
Github user gallenvara commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r62514639
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java
---
@@ -0,0 +1,183 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276461#comment-15276461
]
ASF GitHub Bot commented on FLINK-3880:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276463#comment-15276463
]
Niels Basjes commented on FLINK-2597:
-
FYI: I see a close relationship between this is
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1976#issuecomment-217888511
Merging after tests pass.
---
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 mxm opened a pull request:
https://github.com/apache/flink/pull/1976
[FLINK-3880] remove mutex for user accumulators hash map
This has been reported as a performance impact. The synchronized lock is
not necessary because Flink doesn't perform concurrent updates on the pe
[
https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276460#comment-15276460
]
ASF GitHub Bot commented on FLINK-3880:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes updated FLINK-3886:
Attachment: FLINK-3886-20160509.patch
The proposed change.
Please verify if this works/is valid in
Niels Basjes created FLINK-3886:
---
Summary: Give a better error when the application Main class is
not public.
Key: FLINK-3886
URL: https://issues.apache.org/jira/browse/FLINK-3886
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276392#comment-15276392
]
Tzu-Li (Gordon) Tai commented on FLINK-3211:
On the other hand, if we're aimin
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276381#comment-15276381
]
Tzu-Li (Gordon) Tai commented on FLINK-3211:
[~rmetzger]
Hi Robert,
I'm halfwa
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276375#comment-15276375
]
ASF GitHub Bot commented on FLINK-3854:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1953#issuecomment-217869409
Ok, thats "normal" right now. @rmetzger if you don't have any more
objections I would merge it in a bit.
---
If your project is set up for it, you can reply to this em
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276370#comment-15276370
]
ASF GitHub Bot commented on FLINK-3772:
---
Github user greghogan closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-3772.
---
Resolution: Implemented
> Graph algorithms for vertex and edge degree
> --
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276369#comment-15276369
]
ASF GitHub Bot commented on FLINK-3772:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1901#issuecomment-217868088
Closed in 70181b28cf17e25b4b70f21f718ada2537cde2b6
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
Github user greghogan closed the pull request at:
https://github.com/apache/flink/pull/1901
---
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-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276356#comment-15276356
]
Aljoscha Krettek edited comment on FLINK-3758 at 5/9/16 1:29 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276356#comment-15276356
]
Aljoscha Krettek commented on FLINK-3758:
-
Please open a PR. The changes look good
[
https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276351#comment-15276351
]
Aljoscha Krettek commented on FLINK-3758:
-
I'm looking at it. :-)
> Add possibili
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1958#issuecomment-217862197
Yes, I will also take a look at it.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276348#comment-15276348
]
ASF GitHub Bot commented on FLINK-3754:
---
Github user twalthr commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276340#comment-15276340
]
ASF GitHub Bot commented on FLINK-3856:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1959#discussion_r62495413
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DateComparator.java
---
@@ -59,15 +55,37 @@ public boolean isNormalizedKeyPrefi
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276334#comment-15276334
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r62493996
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java
---
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276330#comment-15276330
]
ASF GitHub Bot commented on FLINK-3856:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1959#discussion_r62493248
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DateComparator.java
---
@@ -59,15 +55,37 @@ public boolean isNormalizedKeyPrefi
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r62493213
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java
---
@@ -0,0 +1,183 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276328#comment-15276328
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276313#comment-15276313
]
Greg Hogan commented on FLINK-3883:
---
+1 with a consideration for "start-scala-shell.sh"
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276306#comment-15276306
]
ASF GitHub Bot commented on FLINK-3772:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1901#issuecomment-217852205
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
[
https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276300#comment-15276300
]
ASF GitHub Bot commented on FLINK-3856:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1959#discussion_r62490034
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DateComparator.java
---
@@ -59,15 +55,37 @@ public boolean isNormalizedKeyPrefi
[
https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3880:
--
Summary: Improve performance of Accumulator map (was: Use
ConcurrentHashMap for Accumul
GitHub user gallenvara opened a pull request:
https://github.com/apache/flink/pull/1975
[FLINK-2184] Cannot get last element with maxBy/minBy.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276268#comment-15276268
]
ASF GitHub Bot commented on FLINK-2184:
---
GitHub user gallenvara opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276266#comment-15276266
]
Konstantin Knauf commented on FLINK-3758:
-
[~aljoscha] Ping. Going on vacation soo
[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276262#comment-15276262
]
GaoLun commented on FLINK-2184:
---
I will go on with this issue. :)
> Cannot get last element
[
https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276222#comment-15276222
]
ASF GitHub Bot commented on FLINK-3856:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1959#issuecomment-217836281
I will move it to `SqlTimeTypeInfo`.
---
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
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/1974
[FLINK-3842] [table] Fix handling null record/row in generated code
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideratio
[
https://issues.apache.org/jira/browse/FLINK-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276218#comment-15276218
]
ASF GitHub Bot commented on FLINK-3842:
---
GitHub user twalthr opened a pull request:
Till Rohrmann created FLINK-3885:
Summary: Revisit parallelism logic
Key: FLINK-3885
URL: https://issues.apache.org/jira/browse/FLINK-3885
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276181#comment-15276181
]
Timo Walther commented on FLINK-3842:
-
Thanks for testing. I will rebase it and open a
Ufuk Celebi created FLINK-3884:
--
Summary: Snapshot quickstart projects don't include snapshot
repository
Key: FLINK-3884
URL: https://issues.apache.org/jira/browse/FLINK-3884
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276130#comment-15276130
]
Aljoscha Krettek commented on FLINK-3883:
-
+1 The symlink thing should be fixed qu
[
https://issues.apache.org/jira/browse/FLINK-3881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276128#comment-15276128
]
ASF GitHub Bot commented on FLINK-3881:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1970
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-3881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3881.
--
Resolution: Fixed
Fixed via afd0f16b89683212104e7f41dbd3b557b1f02cc5
> Error in Java 8 Document
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276122#comment-15276122
]
ASF GitHub Bot commented on FLINK-3869:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1973
[FLINK-3869] Relax window fold generic parameters
Before, the WindowFunction in a fold/apply could not emit a type that
was different from the accumulator type of the fold. This restriction is
[
https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276119#comment-15276119
]
Ufuk Celebi commented on FLINK-3741:
I've asked INFRA to clear the caches
(https://is
[
https://issues.apache.org/jira/browse/FLINK-3881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276111#comment-15276111
]
ASF GitHub Bot commented on FLINK-3881:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1970#issuecomment-217807008
Thanks for your contribution @mans2singh. Changes look good. Will merge
this PR.
---
If your project is set up for it, you can reply to this email and have your
re
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276102#comment-15276102
]
Vasia Kalavri commented on FLINK-3879:
--
Hey [~greghogan], [~gallenvara_bg],
what's th
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1952#issuecomment-217804461
I'm running a last local test and then merging this. Thanks for the work!
ð
---
If your project is set up for it, you can reply to this email and have your
reply a
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276091#comment-15276091
]
Till Rohrmann commented on FLINK-1873:
--
I wouldn't like to bake in the dependency on
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276074#comment-15276074
]
ASF GitHub Bot commented on FLINK-3772:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1901#issuecomment-217799706
I've only left a minor comment @greghogan, otherwise I think it's good to
merge.
---
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-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276073#comment-15276073
]
ASF GitHub Bot commented on FLINK-3772:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1901#discussion_r62460922
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -2067,7 +2067,92 @@ configuration.
- TranslateGraphIds
+
degree.annotat
84 matches
Mail list logo