Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1957#issuecomment-216259593
The other possibility would be to store them in different column families.
Not sure about the performance there though
---
If your project is set up for it, you can repl
[
https://issues.apache.org/jira/browse/FLINK-3837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266735#comment-15266735
]
ASF GitHub Bot commented on FLINK-3837:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1943
---
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 aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1957#issuecomment-216258540
@gyfora I thought that was possible, yes, but I don't think so anymore. I
only found this document after I finished my implementation:
https://github.com/facebook/rocks
[
https://issues.apache.org/jira/browse/FLINK-3581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266731#comment-15266731
]
ASF GitHub Bot commented on FLINK-3581:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266720#comment-15266720
]
ASF GitHub Bot commented on FLINK-3581:
---
Github user gyfora commented on the pull re
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1943#issuecomment-216256600
Merging this.
---
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-3837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266718#comment-15266718
]
ASF GitHub Bot commented on FLINK-3837:
---
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=15266712#comment-15266712
]
Timo Walther commented on FLINK-3856:
-
I have created type information for all 3 types
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266693#comment-15266693
]
ASF GitHub Bot commented on FLINK-3854:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1953#issuecomment-216251703
Overall, the code looks good. I forgot that we have the avro dependency in
by default ;)
I had one minor commit regarding early input validation, other than that
th
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266691#comment-15266691
]
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-216251223
@vasia code modified and i add a extra iteration for getting the aggregated
value of previous iteration to normalize all vertex. :)
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266685#comment-15266685
]
ASF GitHub Bot commented on FLINK-3854:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1953#discussion_r61745567
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/AvroKeyValueSinkWriter.java
---
@@ -0
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1953#discussion_r61745619
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/AvroKeyValueSinkWriter.java
---
@@ -0
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266684#comment-15266684
]
ASF GitHub Bot commented on FLINK-3854:
---
Github user rmetzger commented on a diff in
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1953#issuecomment-216247252
@rmetzger this is good enough for me, since there are also tests. What do
you think?
---
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-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1523#comment-1523
]
ASF GitHub Bot commented on FLINK-3854:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266652#comment-15266652
]
ASF GitHub Bot commented on FLINK-3854:
---
Github user IgorBerman commented on the pul
Github user IgorBerman commented on the pull request:
https://github.com/apache/flink/pull/1953#issuecomment-216244636
@aljoscha , Hi, thanks for the review.
Not tested with real word data yet, only with simple avro objects(with
several fields inside).
Tested in local environ
[
https://issues.apache.org/jira/browse/FLINK-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266644#comment-15266644
]
ASF GitHub Bot commented on FLINK-3821:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1938#issuecomment-216243462
@greghogan Thanks for looking over it, I've addressed your comments.
---
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-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266638#comment-15266638
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user rawkintrevo commented on the pu
Github user rawkintrevo commented on the pull request:
https://github.com/apache/flink/pull/1898#issuecomment-216241912
This should be gtg
---
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
Timo Walther created FLINK-3858:
---
Summary: Date is wrongly serialized
Key: FLINK-3858
URL: https://issues.apache.org/jira/browse/FLINK-3858
Project: Flink
Issue Type: Bug
Components:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1941#issuecomment-216232502
Thanks for the PR @fpompermaier.
I think the new format is a bit too much tailored towards certain query
templates (`BETWEEN` predicate on integer column). Also modif
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r61736272
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -26,52 +26,69 @@
import jav
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r61735803
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/GenericRow.java
---
@@ -0,0 +1,123 @@
+package org.apache.flink.ap
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r61735690
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -352,6 +294,13 @@ public JDBCInputFor
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1941#discussion_r61735650
--- Diff:
flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
---
@@ -26,52 +26,69 @@
import java.sql
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266556#comment-15266556
]
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-216227985
I will have a try. If `iteration==1` or `iteration==maxIteration` maybe a
little difficult to deal.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266550#comment-15266550
]
ASF GitHub Bot commented on FLINK-3793:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1955#issuecomment-216227231
- Thanks for spotting the leftover menu. It's easy to remove.
- I'll add orderBy in the operators table
- I'll add a note to the SQL section regarding unsupported op
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266536#comment-15266536
]
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-216226071
There is no way to get the aggregated value of the current superstep, as
the aggregation happens at the superstep barrier. What you could do is
normalize the vertex value
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2099.
Resolution: Done
Fix Version/s: 1.1.0
Basic support for SQL was added.
Missing features are
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266530#comment-15266530
]
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-216225261
AFAIK the failing build is "normal" right now, we have some problem with
the travis caches.
The PR looks very good, @rmetzger what are you saying about copying
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266517#comment-15266517
]
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-216224456
@vasia i have noticed the `registerAggregator` can aggregate value in
distributed environment and i have used it at the very beginning of this issue.
But finally i fa
[
https://issues.apache.org/jira/browse/FLINK-3837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266516#comment-15266516
]
ASF GitHub Bot commented on FLINK-3837:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1943#issuecomment-216224308
Good to merge, IMO.
---
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 fe
[
https://issues.apache.org/jira/browse/FLINK-3581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266514#comment-15266514
]
ASF GitHub Bot commented on FLINK-3581:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1957#issuecomment-216223941
CC @tillrohrmann for review since you are also working on state
CC @StephanEwen for review as original requestor of this feature
---
If your project is set up for i
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1952#issuecomment-216223474
@cowtowncoder do you see a reason for not upgrading all the way to 2.7?
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266509#comment-15266509
]
Aljoscha Krettek commented on FLINK-3669:
-
Is the problem gone with changing this?
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266503#comment-15266503
]
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-216222300
Hi @gallenvara,
thank you for the PR! I only took a quick look, but I will go through the
changes in detail soon.
One thing I noticed is that you use static va
[
https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266498#comment-15266498
]
ASF GitHub Bot commented on FLINK-3793:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1955#issuecomment-216221749
Thanks for this PR @vasia.
I noticed a few things:
- The docs page (`./apis/table.html`) still has the menu of the DataSet API
on the left hand side. Is it
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266493#comment-15266493
]
Timo Walther commented on FLINK-2099:
-
Yes, I think we can close this issue. Basic sup
[
https://issues.apache.org/jira/browse/FLINK-3581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266475#comment-15266475
]
ASF GitHub Bot commented on FLINK-3581:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1957
[FLINK-3581] [FLINK-3582] State Iterator and Aligned Time Windows
This adds two things. A new call `getPartitionedStateForAllKeys` on
`AbstractStateBackend` that returns a `StateIterator` that can
[
https://issues.apache.org/jira/browse/FLINK-2099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266458#comment-15266458
]
Fabian Hueske commented on FLINK-2099:
--
The current master branch supports a subset o
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266344#comment-15266344
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user gallenvara commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266342#comment-15266342
]
ASF GitHub Bot commented on FLINK-2044:
---
GitHub user gallenvara opened a pull reques
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-216190461
@vasia Can you help with review work? :)
---
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 proje
GitHub user gallenvara opened a pull request:
https://github.com/apache/flink/pull/1956
[FLINK-2044] [gelly] Implementation of Gelly HITS Algorithm
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1952#issuecomment-216188894
Yes, I hope so.
---
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 featur
Fabian Hueske created FLINK-3857:
Summary: Add reconnect attempt to Elasticsearch host
Key: FLINK-3857
URL: https://issues.apache.org/jira/browse/FLINK-3857
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266308#comment-15266308
]
ASF GitHub Bot commented on FLINK-3793:
---
GitHub user vasia opened a pull request:
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1955
[FLINK-3793][docs] re-organize table API and SQL docs
- [X] General
- The pull request references the related JIRA issue ("[FLINK-XXX] Jira
title text")
- The pull request addresses only o
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3786.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in b3231ac
> Add BigDecimal and BigInteger as
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1952#issuecomment-216167122
@fhueske jackson-databind is only used in the Table API to render the
explain output. We should be good to update to latest there as well, right?
---
If your project i
[
https://issues.apache.org/jira/browse/FLINK-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266265#comment-15266265
]
Aljoscha Krettek commented on FLINK-3855:
-
Never mind, the link seems to be workin
[
https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-3856:
Description:
At the moment there is only the {{Date}} type which is not sufficient for most
use cas
Timo Walther created FLINK-3856:
---
Summary: Create types for java.sql.Date/Time/Timestamp
Key: FLINK-3856
URL: https://issues.apache.org/jira/browse/FLINK-3856
Project: Flink
Issue Type: New Fea
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266246#comment-15266246
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1928
---
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-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266234#comment-15266234
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1928#issuecomment-216151381
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
ena
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266206#comment-15266206
]
Vasia Kalavri commented on FLINK-2044:
--
Thanks, I'll assign it to you :)
> Implement
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2044:
-
Assignee: GaoLun
> Implementation of Gelly HITS Algorithm
> --
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15266205#comment-15266205
]
Vasia Kalavri commented on FLINK-2926:
--
Hi [~mliesenberg],
thank you for design docum
101 - 176 of 176 matches
Mail list logo
