[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently y
[
https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3753:
--
Description:
{code}
// this is harsh, but this watchdog is a last resort
if (toKill.isAlive()) {
t
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274657#comment-15274657
]
ASF GitHub Bot commented on FLINK-3772:
---
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/1901#discussion_r62384029
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -2067,7 +2067,92 @@ configuration.
- TranslateGraphIds
+
degree.ann
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274627#comment-15274627
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user sbcd90 commented on the pull re
Github user sbcd90 commented on the pull request:
https://github.com/apache/flink/pull/1962#issuecomment-217540405
Hello @rmetzger ,
I added a testcase now to the `ElasticsearchSinkITCase.java` list of tests.
Can you kindly have a look once?
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274561#comment-15274561
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user gallenvara commented on the pul
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-217527593
Hi, @vasia @greghogan ,
- code modified and support to return both hub and authority score as
`Tuple2` type now. The implementation will run extra one iteration to
[
https://issues.apache.org/jira/browse/FLINK-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-3618:
-
Assignee: Greg Hogan
> Rename abstract UDF classes in Scatter-Gather implementation
> ---
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274400#comment-15274400
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user ankitcha commented on the pull
Github user ankitcha commented on the pull request:
https://github.com/apache/flink/pull/1947#issuecomment-217507497
@rmetzger thanks for the response. I think I got what you explained and I
agree that using index in configuration keys won't be a nice experience.
But, can we
[
https://issues.apache.org/jira/browse/FLINK-3877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274331#comment-15274331
]
ASF GitHub Bot commented on FLINK-3877:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1968
[FLINK-3877] [gelly] Create TranslateFunction interface for Graph
translators
The TranslateFunction interface is similar to MapFunction but may be called
multiple times before serialization.
You
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274307#comment-15274307
]
Greg Hogan commented on FLINK-3879:
---
I think FLINK-2044 can test for convergence if the
[
https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274298#comment-15274298
]
Maximilian Michels commented on FLINK-3880:
---
You're right, the synchronized map
[
https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-3880:
-
Assignee: Maximilian Michels
> Use ConcurrentHashMap for Accumulators
> -
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274270#comment-15274270
]
Vasia Kalavri commented on FLINK-3879:
--
So, it provides the same functionality as FLI
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274265#comment-15274265
]
Simone Robutti commented on FLINK-1873:
---
Umh ok. I think that on block-partitioned m
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3879:
--
Description:
Hyperlink-Induced Topic Search (HITS, also "hubs and authorities") is presented
in [0] and
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274254#comment-15274254
]
Vasia Kalavri commented on FLINK-3879:
--
Hi [~greghogan],
Can you please extend the de
[
https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274225#comment-15274225
]
ASF GitHub Bot commented on FLINK-3879:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1967
[FLINK-3879] [gelly] Native implementation of HITS algorithm
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
3879_native_impl
Ken Krugler created FLINK-3880:
--
Summary: Use ConcurrentHashMap for Accumulators
Key: FLINK-3880
URL: https://issues.apache.org/jira/browse/FLINK-3880
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274229#comment-15274229
]
Till Rohrmann commented on FLINK-1873:
--
I think it's good to use Flink's matrix and v
GitHub user mbode opened a pull request:
https://github.com/apache/flink/pull/1966
[Flink-3836] Add LongHistogram accumulator
New accumulator `LongHistogram`; the `Histogram` accumulator now throws an
`IllegalArgumentException` instead of letting the int overflow.
- [x] Ge
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274177#comment-15274177
]
Simone Robutti commented on FLINK-1873:
---
I began working right away on this issue.
Greg Hogan created FLINK-3879:
-
Summary: Native implementation of HITS algorithm
Key: FLINK-3879
URL: https://issues.apache.org/jira/browse/FLINK-3879
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274119#comment-15274119
]
Robert Metzger commented on FLINK-3211:
---
[~tzulitai] Would you be okay of publishing
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15274018#comment-15274018
]
Robert Metzger commented on FLINK-3211:
---
I've spend quite some time with the Kinesis
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273993#comment-15273993
]
ASF GitHub Bot commented on FLINK-3772:
---
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/1901#discussion_r62325628
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -2067,7 +2067,92 @@ configuration.
- TranslateGraphIds
+
degree.ann
[
https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273989#comment-15273989
]
ASF GitHub Bot commented on FLINK-3754:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1958#issuecomment-217430461
I took a brief look at the PR. The overall structure of the validation
looks good to me. Will do a more in-depth review in the next days. @twalthr,
can you have another
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273983#comment-15273983
]
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-21742
@vasia I had looked at one of the failed tests and it wasn't due to bad
logic but rather to running out of some minimal number of memory buffers. This
results, I expec
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273945#comment-15273945
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r62320682
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java
---
@@ -72,8 +73,8 @@ public T reduce(T value1, T value2)
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273941#comment-15273941
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-217419465
Hi @gallenvara, @greghogan,
- If it's possible to return both the hub and the authority value, I'd
prefer that.
- GSA iterations allow setting the edge di
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273933#comment-15273933
]
Vasia Kalavri commented on FLINK-2926:
--
Hi [~mliesenberg],
delta iteration by default
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1901#issuecomment-217403403
@greghogan, after your last commit, there are several gelly test cases
failing on travis. Could you please take a look? Thanks!
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273868#comment-15273868
]
ASF GitHub Bot commented on FLINK-3772:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273867#comment-15273867
]
Fabian Hueske commented on FLINK-1873:
--
[~chobeat], I gave you contributor permission
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1873:
-
Assignee: Simone Robutti
> Distributed matrix implementation
> -
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r62310212
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java
---
@@ -72,8 +73,8 @@ public T reduce(T value1, T value2
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1873:
-
Assignee: (was: liaoyuxi)
> Distributed matrix implementation
> --
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1901#discussion_r62310380
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -2067,7 +2067,92 @@ configuration.
- TranslateGraphIds
+
degree.annotat
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r62309620
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java
---
@@ -72,8 +73,8 @@ public T reduce(T value1, T value2
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273854#comment-15273854
]
Simone Robutti commented on FLINK-1873:
---
Sure. I will have to study a bit to do it p
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273860#comment-15273860
]
ASF GitHub Bot commented on FLINK-3772:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273863#comment-15273863
]
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_r62310412
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -2067,7 +2067,92 @@ configuration.
- TranslateGraphIds
+
degree.annotat
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273862#comment-15273862
]
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_r62310388
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -2067,7 +2067,92 @@ configuration.
- TranslateGraphIds
+
degree.annotat
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273858#comment-15273858
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273852#comment-15273852
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273826#comment-15273826
]
Fabian Hueske commented on FLINK-1873:
--
I agree, looks like the issue is abandoned.
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1947#issuecomment-217389510
Okay. I think we need to support multiple instances of the same job on a
TaskManager.
---
If your project is set up for it, you can reply to this email and have your
r
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273812#comment-15273812
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1962#issuecomment-217373539
How did you test the code you've implemented in this pull request?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273771#comment-15273771
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273770#comment-15273770
]
Simone Robutti commented on FLINK-1873:
---
This is issue has been dead for one year. W
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1947#issuecomment-217368732
@rmetzger you are correct that you're job failed since the previous one
wasn't cleaned up yet. Should you try to run 2 identical jobs in parallel it
will fail, since 2 jo
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273740#comment-15273740
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user zentol commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273738#comment-15273738
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r62296025
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java
---
@@ -72,8 +73,8 @@ public T reduce(T value1, T value2)
66 matches
Mail list logo
