Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-219605318
@greghogan thanks for your advice and relevant codes have been modified. :)
---
If your project is set up for it, you can reply to this email and have your
reply
GitHub user rekhajoshm opened a pull request:
https://github.com/apache/flink/pull/1994
[FLINK-3900] Set nullCheck=true as default in TableConfig
[FLINK-3900] Settig nullCheck as true as default in TableConfig
You can merge this pull request into a Git repository by running:
$
[
https://issues.apache.org/jira/browse/FLINK-2829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15285315#comment-15285315
]
ASF GitHub Bot commented on FLINK-2829:
---
GitHub user rekhajoshm opened a pull request:
GitHub user rekhajoshm opened a pull request:
https://github.com/apache/flink/pull/1993
[FLINK-2829] Confusing error message when Flink cannot create enough task
threads
[FLINK-2829] Confusing error message when Flink cannot create enough task
threads
Clarifying the flink
[
https://issues.apache.org/jira/browse/FLINK-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-3768.
-
Resolution: Implemented
Implemented in c71675f7cbe7e538d62bf1491aff69b369eda9eb
> Clustering Coefficient
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1896
---
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
[
https://issues.apache.org/jira/browse/FLINK-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15285067#comment-15285067
]
ASF GitHub Bot commented on FLINK-3768:
---
Github user asfgit closed the pull request at:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1896#issuecomment-219454345
Hi @greghogan,
I haven't had time to review this PR. If this is blocking you or is urgent
for some reason, please go ahead. Otherwise, I could take a look later this
Github user gallenvara commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r63354507
--- Diff:
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/HITSData.java
---
@@ -0,0 +1,71 @@
+/*
+ *
Github user gallenvara commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r63354317
--- Diff:
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/library/HITSAlgorithmITCase.java
---
@@ -0,0 +1,133 @@
+/*
+
Github user gallenvara commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r63353881
--- Diff:
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/HITSData.java
---
@@ -0,0 +1,71 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284484#comment-15284484
]
Stavros Kontopoulos commented on FLINK-2147:
ok i will have a look as well to get familiar
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284479#comment-15284479
]
Gabor Gevay commented on FLINK-2147:
Yes. We should probably look in the direction of FoldFunction,
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284476#comment-15284476
]
Stavros Kontopoulos commented on FLINK-2147:
Ok i agree then we calculate statistics per
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2144:
---
Summary: Incremental count, average, and variance for windows (was:
Implement incremental count,
[
https://issues.apache.org/jira/browse/FLINK-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284474#comment-15284474
]
Gabor Gevay commented on FLINK-2142:
(I've also broken off FLINK-2144.)
> GSoC project: Exact and
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2144:
---
Summary: Implement incremental count, average, and variance for windows
(was: Implement count,
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2144:
---
Assignee: (was: Gabor Gevay)
> Implement incremental count, average, and variance for windows
>
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2144:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-2142)
> Implement count,
[
https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284473#comment-15284473
]
Gabor Gevay commented on FLINK-2144:
Originally, I wanted to make this calculation incremental both on
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284468#comment-15284468
]
Gabor Gevay commented on FLINK-2147:
(Note that the out-of-order problem that I mentioned for the
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284467#comment-15284467
]
Gabor Gevay commented on FLINK-2147:
In my opinion, the semantics would be to calculate the statistic
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284446#comment-15284446
]
Stavros Kontopoulos commented on FLINK-2147:
Ok so if there multiple windows evaluated at
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r63347071
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java
---
@@ -0,0 +1,276 @@
+/*
+ * Licensed to
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1896#issuecomment-219416157
If there are no further review comments I'll look at merging this today.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284440#comment-15284440
]
Stavros Kontopoulos commented on FLINK-2147:
For sure if you apply it per window then you need
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r63346546
--- Diff:
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/HITSData.java
---
@@ -0,0 +1,71 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284437#comment-15284437
]
Gabor Gevay commented on FLINK-2147:
I'm actually now closing the incremental median and similar
[
https://issues.apache.org/jira/browse/FLINK-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284435#comment-15284435
]
Gabor Gevay commented on FLINK-2142:
This proposal was based on the old (pre-0.10) windowing API. I'm
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r63346245
--- Diff:
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/data/HITSData.java
---
@@ -0,0 +1,71 @@
+/*
+ *
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1956#discussion_r63346119
--- Diff:
flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/library/HITSAlgorithmITCase.java
---
@@ -0,0 +1,133 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay resolved FLINK-2145.
Resolution: Won't Fix
I'm closing this, as it was based on assumptions of the old (pre-0.10)
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284431#comment-15284431
]
Stavros Kontopoulos commented on FLINK-2147:
Ok... btw I was looking your old PR for median
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284427#comment-15284427
]
Gabor Gevay commented on FLINK-2147:
OK, we can certainly think about it.
It would probably make
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2147:
---
Labels: approximate statistics (was: statistics)
> Approximate calculation of frequencies in data
[
https://issues.apache.org/jira/browse/FLINK-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2148:
---
Labels: approximate statistics (was: statistics)
> Approximately calculate the number of distinct
[
https://issues.apache.org/jira/browse/FLINK-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay resolved FLINK-2146.
Resolution: Not A Problem
I'm closing this, since with the redesigned windowing API (since 0.10)
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284410#comment-15284410
]
Stavros Kontopoulos commented on FLINK-2147:
Yes i agree the api is the hard part, but we
[
https://issues.apache.org/jira/browse/FLINK-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2148:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-2142)
> Approximately
Github user ggevay closed the pull request at:
https://github.com/apache/flink/pull/910
---
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
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/910#issuecomment-219407507
I'm closing this. It doesn't really make much sense to do this on an entire
stream; users would probably want to do this on large windows instead, so this
should probably
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2147:
---
Priority: Major (was: Minor)
> Approximate calculation of frequencies in data streams
>
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-2147:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-2142)
> Approximate
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284406#comment-15284406
]
Gabor Gevay commented on FLINK-2147:
Yes, I think it would be very good if you worked on this, and
[
https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284315#comment-15284315
]
Stefano Bortoli commented on FLINK-1827:
Hi Josh,
first of all, sorry for the troubles caused!
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284312#comment-15284312
]
Gabor Gevay commented on FLINK-2147:
Unfortunately, no.
> Approximate calculation of frequencies in
[
https://issues.apache.org/jira/browse/FLINK-3911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284296#comment-15284296
]
Patrice Freydiere commented on FLINK-3911:
--
hi fabian,
i'm currently working on using flink for
[
https://issues.apache.org/jira/browse/FLINK-3911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3911.
Resolution: Not A Bug
> Sort operation before a group reduce doesn't seem to be implemented on
[
https://issues.apache.org/jira/browse/FLINK-3911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284291#comment-15284291
]
Fabian Hueske commented on FLINK-3911:
--
Hi Patrice, that's a very good suggestion!
In fact, we have
[
https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284278#comment-15284278
]
Simone Robutti commented on FLINK-1873:
---
The tasks are not independent so I would go for sub-tasks
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1975#issuecomment-219362150
Hi @fhueske , can you help review this PR? Thanks! :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
51 matches
Mail list logo
