Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1949#issuecomment-215641753
I would add a test case to verify the fix here, too. Otherwise, +1 and
thanks!
---
If your project is set up for it, you can reply to this email and have your
reply
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1948#issuecomment-215641198
Thanks for the fix! Can you also add a test case that verifies that the bug
is fixed? You can simply extend `GraphMutationsITCase`. And +1 to merge.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-3846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263637#comment-15263637
]
ASF GitHub Bot commented on FLINK-3846:
---
Github user vasia commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263758#comment-15263758
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
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 :
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263777#comment-15263777
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263788#comment-15263788
]
Martin Liesenberg commented on FLINK-2926:
--
if there's still interest in having this algorithm as
[
https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263819#comment-15263819
]
Robert Metzger commented on FLINK-3852:
---
Yes, I think its a good idea to have a file for dataset and
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/939
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/1926
---
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-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263654#comment-15263654
]
ASF GitHub Bot commented on FLINK-2946:
---
Github user asfgit closed the pull request at:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1900#issuecomment-215663664
My intention was to simplify the API, not have different ways to do the
same thing. Anyway, if you think it's useful to have both the methods and the
algorithms, I won't
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263756#comment-15263756
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263806#comment-15263806
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
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=15263787#comment-15263787
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263812#comment-15263812
]
Ufuk Celebi commented on FLINK-3800:
We had to revert this in 0708dd0 for release-1.0 after a
[
https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263664#comment-15263664
]
Stefano Baghino commented on FLINK-3239:
Beware that in my prototype the {{krb.conf.path}} does
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263770#comment-15263770
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263772#comment-15263772
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263769#comment-15263769
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3790.
--
Fixed in d45cb69 (master), f1d34b1 (release-1.0)
> Rolling File sink does not pick up hadoop configuration
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263783#comment-15263783
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263641#comment-15263641
]
ASF GitHub Bot commented on FLINK-3845:
---
Github user vasia commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263780#comment-15263780
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
[
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:
[
https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263763#comment-15263763
]
Stefano Baghino commented on FLINK-3852:
I agree, but would it make sense to have a quickstart for
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-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263766#comment-15263766
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263768#comment-15263768
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263653#comment-15263653
]
ASF GitHub Bot commented on FLINK-2166:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2946.
Resolution: Implemented
Fix Version/s: 1.1.0
Implemented with
Robert Metzger created FLINK-3852:
-
Summary: Use a StreamExecutionEnvironment in the quickstart job
skeleton
Key: FLINK-3852
URL: https://issues.apache.org/jira/browse/FLINK-3852
Project: Flink
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263771#comment-15263771
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user vasia commented on a diff in the pull request:
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263946#comment-15263946
]
Aljoscha Krettek commented on FLINK-3844:
-
+1, we could have something similar to
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:
```
[
https://issues.apache.org/jira/browse/FLINK-3847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263947#comment-15263947
]
ASF GitHub Bot commented on FLINK-3847:
---
GitHub user fhueske opened a pull request:
[
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=15263834#comment-15263834
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263952#comment-15263952
]
Till Rohrmann commented on FLINK-3444:
--
The common nearest super type would be the intersection type
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
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263831#comment-15263831
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263841#comment-15263841
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user zentol commented on a diff in the pull request:
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
[
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-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263866#comment-15263866
]
Fabian Hueske commented on FLINK-2168:
--
Hi [~ram_krish],
this issue depends on FLINK-3848 and
[
https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263942#comment-15263942
]
Aljoscha Krettek commented on FLINK-3841:
-
I would do it next week... ;-)
> RocksDB statebackend
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 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
[
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
[
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=15263983#comment-15263983
]
Vasia Kalavri commented on FLINK-2926:
--
Hey [~mliesenberg],
thanks for pinging! I'll assign the issue
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
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264062#comment-15264062
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263992#comment-15263992
]
Martin Liesenberg commented on FLINK-2926:
--
Cool, I'll update the design doc then and start
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263974#comment-15263974
]
Aljoscha Krettek commented on FLINK-3669:
-
Ah, in the custom trigger the {{oldTimestamp}} field is
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
[
https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263977#comment-15263977
]
Martin Liesenberg commented on FLINK-3404:
--
I have been looking at this task recently and just
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
[
https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263993#comment-15263993
]
Greg Hogan commented on FLINK-3772:
---
There is am impedance mismatch between the algorithms and `Graph`
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:
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264091#comment-15264091
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user rawkintrevo commented on a diff in the pull
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
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 :
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264098#comment-15264098
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user greghogan commented on a diff in the pull
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264086#comment-15264086
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264127#comment-15264127
]
ASF GitHub Bot commented on FLINK-3771:
---
Github user greghogan commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264085#comment-15264085
]
Márton Balassi commented on FLINK-3090:
---
Thanks, [~cos]. Fortunately [~mxm] and [~rmetzger] has
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264132#comment-15264132
]
Konstantin Knauf commented on FLINK-3669:
-
Hmpf, of course...
> WindowOperator registers a lot of
[
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()) {
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264146#comment-15264146
]
Matthias J. Sax commented on FLINK-3404:
I think so. [~rmetzger] can you comment on this, as you
[
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-3853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264256#comment-15264256
]
Vijay Srinivasaraghavan commented on FLINK-3239:
My bad.. I overlooked the krb file to
[
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=15265115#comment-15265115
]
ASF GitHub Bot commented on FLINK-3855:
---
GitHub user cowtowncoder opened a pull request:
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
[
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
[
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-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1526#comment-1526
]
ASF GitHub Bot commented on FLINK-3821:
---
Github user greghogan commented on the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264410#comment-15264410
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user rawkintrevo commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264353#comment-15264353
]
ASF GitHub Bot commented on FLINK-3821:
---
Github user greghogan commented on a diff in the pull
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[]
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)
[
https://issues.apache.org/jira/browse/FLINK-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264363#comment-15264363
]
ASF GitHub Bot commented on FLINK-3821:
---
Github user greghogan commented on a diff in the pull
[
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)
>
1 - 100 of 102 matches
Mail list logo
