Tatu Saloranta created FLINK-3855:
-
Summary: Upgrade Jackson version
Key: FLINK-3855
URL: https://issues.apache.org/jira/browse/FLINK-3855
Project: Flink
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/FLINK-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tatu Saloranta updated FLINK-3855:
--
Component/s: (was: Streaming Connectors)
Core
> Upgrade Jackson version
> -
[
https://issues.apache.org/jira/browse/FLINK-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15265115#comment-15265115
]
ASF GitHub Bot commented on FLINK-3855:
---
GitHub user cowtowncoder opened a pull requ
GitHub user cowtowncoder opened a pull request:
https://github.com/apache/flink/pull/1952
Jackson version upgrade: default from 2.4.2 to 2.5.5, ES client to latest
2.7
Fix for [FLINK-3855] -- upgrade default Jackson version from 2.4.2 to 2.5.5
(last 2.5 patch); remove unnecessary e
[
https://issues.apache.org/jira/browse/FLINK-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tatu Saloranta updated FLINK-3855:
--
Description:
Jackson version in use (2.4.2) is rather old (and not even the latest patch
from m
[
https://issues.apache.org/jira/browse/FLINK-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tatu Saloranta updated FLINK-3855:
--
Priority: Minor (was: Major)
> Upgrade Jackson version
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Berman updated FLINK-3854:
---
Summary: Support Avro key-value rolling sink writer (was: Support Avro
key-value rolling sink)
> Sup
Igor Berman created FLINK-3854:
--
Summary: Support Avro key-value rolling sink
Key: FLINK-3854
URL: https://issues.apache.org/jira/browse/FLINK-3854
Project: Flink
Issue Type: Improvement
Github user gna-phetsarath commented on the pull request:
https://github.com/apache/flink/pull/1920#issuecomment-215887300
Many contributions to Flink is a great problem to heave. :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1938#issuecomment-215830882
+1 with two comments.
---
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 thi
[
https://issues.apache.org/jira/browse/FLINK-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1526#comment-1526
]
ASF GitHub Bot commented on FLINK-3821:
---
Github user greghogan commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264410#comment-15264410
]
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-215826478
Hey @tillrohrmann, thanks for the review. I've addressed your commments in
the code. I am in the middle of documentation had to commit. Should finish up
docs this a
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1938#discussion_r61614176
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java ---
@@ -104,7 +104,10 @@ public void open(Configuration parameters) thr
[
https://issues.apache.org/jira/browse/FLINK-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264363#comment-15264363
]
ASF GitHub Bot commented on FLINK-3821:
---
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/1938#discussion_r61613247
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -133,13 +132,17 @@ public OUT readRecord(OUT reuse, byte[] bytes,
[
https://issues.apache.org/jira/browse/FLINK-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264353#comment-15264353
]
ASF GitHub Bot commented on FLINK-3821:
---
Github user greghogan commented on a diff i
[
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-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
[
https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264256#comment-15264256
]
Vijay Srinivasaraghavan commented on FLINK-3239:
My bad.. I overlooked the
[
https://issues.apache.org/jira/browse/FLINK-3853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264217#comment-15264217
]
ASF GitHub Bot commented on FLINK-3853:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1951
[FLINK-3853] [gelly] Reduce object creation in Gelly utility mappers
Gelly contains a set of MapFunction between Vertex and Tuple2 and between
Edge and Tuple3. A Vertex is a Tuple2 and an Edge is
[
https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264146#comment-15264146
]
Matthias J. Sax commented on FLINK-3404:
I think so. [~rmetzger] can you comment o
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264132#comment-15264132
]
Konstantin Knauf commented on FLINK-3669:
-
Hmpf, of course...
> WindowOperator re
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264127#comment-15264127
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1900#issuecomment-215738750
I pushed the most recent changes. In order of things I care more about to
things I care less about:
The indentation is as intended. I find method chaining on a
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264098#comment-15264098
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61583101
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/LongValueAddOffset.java
---
@@ -0,0 +1,50 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264091#comment-15264091
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user rawkintrevo commented on a diff
Github user rawkintrevo commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r61582494
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264086#comment-15264086
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61582214
--- Diff:
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala
---
@@ -407,6 +407,36 @@ TypeInformation : ClassTag](jg
[
https://issues.apache.org/jira/browse/FLINK-3090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264085#comment-15264085
]
Márton Balassi commented on FLINK-3090:
---
Thanks, [~cos]. Fortunately [~mxm] and [~rm
[
https://issues.apache.org/jira/browse/FLINK-3090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-3090:
-
Assignee: Márton Balassi
> Create a Parcel Distribution for Cloudera Manager
> --
Github user gna-phetsarath commented on the pull request:
https://github.com/apache/flink/pull/1920#issuecomment-215716418
@greghogan - What are next steps?
---
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
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15264062#comment-15264062
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user greghogan commented on a diff i
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1920#issuecomment-215717429
Sorry for the delay. The Flink community is receiving many contributions,
that causes sometimes long review times.
I think we can merge the change once @greghogan ha
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61579289
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/Translate.java
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-3853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3853:
--
Description:
Gelly contains a set of {{MapFunction}} between {{Vertex}} and {{Tuple2}} and
between {{Ed
Greg Hogan created FLINK-3853:
-
Summary: Reduce object creation in Gelly utility mappers
Key: FLINK-3853
URL: https://issues.apache.org/jira/browse/FLINK-3853
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263993#comment-15263993
]
Greg Hogan commented on FLINK-3772:
---
There is am impedance mismatch between the algorith
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263992#comment-15263992
]
Martin Liesenberg commented on FLINK-2926:
--
Cool, I'll update the design doc then
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-2926:
-
Assignee: Martin Liesenberg
> Add a Strongly Connected Components Library Method
> ---
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263983#comment-15263983
]
Vasia Kalavri commented on FLINK-2926:
--
Hey [~mliesenberg],
thanks for pinging! I'll
[
https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263977#comment-15263977
]
Martin Liesenberg commented on FLINK-3404:
--
I have been looking at this task rece
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263974#comment-15263974
]
Aljoscha Krettek commented on FLINK-3669:
-
Ah, in the custom trigger the {{oldTime
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1944#discussion_r61567670
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -542,14 +561,24 @@ public voi
[
https://issues.apache.org/jira/browse/FLINK-3444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263952#comment-15263952
]
Till Rohrmann commented on FLINK-3444:
--
The common nearest super type would be the in
[
https://issues.apache.org/jira/browse/FLINK-3847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263947#comment-15263947
]
ASF GitHub Bot commented on FLINK-3847:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/1950
[FLINK-3847] Restructure flink-table test packages.
This PR refactors the tests of the flink-table module.
The new package structure is as follows:
```
src/test/java/o/a/f/api/java/b
[
https://issues.apache.org/jira/browse/FLINK-3844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263946#comment-15263946
]
Aljoscha Krettek commented on FLINK-3844:
-
+1, we could have something similar to
[
https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263942#comment-15263942
]
Aljoscha Krettek commented on FLINK-3841:
-
I would do it next week... ;-)
> Rocks
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263866#comment-15263866
]
Fabian Hueske commented on FLINK-2168:
--
Hi [~ram_krish],
this issue depends on FLINK
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-3848:
Assignee: Fabian Hueske
> Add ProjectableTableSource interface and translation rule
> -
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-3849:
Assignee: Fabian Hueske
> Add FilterableTableSource interface and translation rule
> --
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263841#comment-15263841
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1947#discussion_r61556020
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -152,6 +154,9 @@ class TaskManager(
/** Registry o
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263834#comment-15263834
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1947#discussion_r61555221
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -924,6 +936,15 @@ class TaskManager(
else {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1947#discussion_r61555065
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -152,6 +154,9 @@ class TaskManager(
/** Registry of m
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263831#comment-15263831
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263819#comment-15263819
]
Robert Metzger commented on FLINK-3852:
---
Yes, I think its a good idea to have a file
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263812#comment-15263812
]
Ufuk Celebi commented on FLINK-3800:
We had to revert this in 0708dd0 for release-1.0
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263806#comment-15263806
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reopened FLINK-3800:
> ExecutionGraphs can become orphans
> --
>
> Key: FLINK
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263805#comment-15263805
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61552674
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/TranslateEdgeValues.java
---
@@ -0,0 +1,81 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263804#comment-15263804
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61552700
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/TranslateEdgeValues.java
---
@@ -0,0 +1,81 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61552592
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/TranslateEdgeValues.java
---
@@ -0,0 +1,81 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263795#comment-15263795
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263798#comment-15263798
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263796#comment-15263796
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61552498
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/Translate.java
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the A
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61552416
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/Translate.java
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the A
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61552437
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/Translate.java
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263788#comment-15263788
]
Martin Liesenberg commented on FLINK-2926:
--
if there's still interest in having t
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61551910
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/Translate.java
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263787#comment-15263787
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263783#comment-15263783
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263780#comment-15263780
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61551647
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/Translate.java
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the A
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61551561
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/Translate.java
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263777#comment-15263777
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61551440
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/Translate.java
---
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263770#comment-15263770
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263772#comment-15263772
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263769#comment-15263769
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263771#comment-15263771
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61551292
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/LongValueAddOffset.java
---
@@ -0,0 +1,50 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61551265
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/LongValueToStringValue.java
---
@@ -0,0 +1,39 @@
+/*
+ * Licen
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61551238
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/LongValueToIntValue.java
---
@@ -0,0 +1,47 @@
+/*
+ * Licensed
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61551225
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/LongValueToIntValue.java
---
@@ -0,0 +1,47 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263766#comment-15263766
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263768#comment-15263768
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61551172
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/LongValueAddOffset.java
---
@@ -0,0 +1,50 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263763#comment-15263763
]
Stefano Baghino commented on FLINK-3852:
I agree, but would it make sense to have
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1900#discussion_r61551105
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/translate/LongValueAddOffset.java
---
@@ -0,0 +1,50 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263758#comment-15263758
]
ASF GitHub Bot commented on FLINK-3771:
---
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/1900#discussion_r61550681
--- Diff:
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala
---
@@ -407,6 +407,36 @@ TypeInformation : ClassTag](jgraph
1 - 100 of 110 matches
Mail list logo
