GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1365
[FLINK-3025] [kafka consumer] Bump transitive ZkClient dependency to 0.7
for bugfixes
Gives us a fix against deadlocks in the ZkClient which have caused the
Kafka Consumer to freeze.
You can
GitHub user thedrow opened a pull request:
https://github.com/apache/flink/pull/1366
Bumped the docker container to the latest version
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/thedrow/flink patch-1
Alternatively you can
Omer Katz created FLINK-3026:
Summary: Publish the flink docker container to the docker registry
Key: FLINK-3026
URL: https://issues.apache.org/jira/browse/FLINK-3026
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2508.
-
Resolution: Fixed
Assignee: (was: Márton Balassi)
Fix Version/s: (was:
[
https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2508.
---
> Confusing sharing of StreamExecutionEnvironment
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-3024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-3024.
---
Resolution: Fixed
Fix Version/s: 0.10.1
1.0.0
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008645#comment-15008645
]
ASF GitHub Bot commented on FLINK-2942:
---
Github user StephanEwen commented on the pull request:
Gyula Fora created FLINK-3025:
-
Summary: Flink Kafka consumer may get stuck due to Kafka/Zookeeper
client bug
Key: FLINK-3025
URL: https://issues.apache.org/jira/browse/FLINK-3025
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008491#comment-15008491
]
ASF GitHub Bot commented on FLINK-3025:
---
GitHub user StephanEwen opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2680.
---
> Create a dedicated aligned-event time window operator
>
[
https://issues.apache.org/jira/browse/FLINK-2680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2680.
-
Resolution: Won't Fix
Rather, we should unify the processing and event time windows and make only
[
https://issues.apache.org/jira/browse/FLINK-3021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008632#comment-15008632
]
ASF GitHub Bot commented on FLINK-3021:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2670.
-
Resolution: Fixed
Fix Version/s: (was: 1.0.0)
0.10.0
Fixed a while
[
https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2670.
---
> Unstable CombineTaskTest
>
>
> Key: FLINK-2670
>
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1368
[FLINK-3021] Fix class loading issue for streaming sources
Streaming sources were directly assigned their InputFormat in the
StreamingJobGraphGenerator. As a consequence, the input formats
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1361#discussion_r45052205
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java
---
@@ -180,7 +180,41 @@ public static InetAddress
[
https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008556#comment-15008556
]
ASF GitHub Bot commented on FLINK-2967:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008557#comment-15008557
]
ASF GitHub Bot commented on FLINK-2967:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1361#discussion_r45052228
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java
---
@@ -180,7 +180,41 @@ public static InetAddress
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1346#issuecomment-157373231
Will merge this for 1.0 and 0.10.0 ...
---
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-297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-297.
---
Resolution: Fixed
> Redesign GUI client-server model
>
>
>
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1362#issuecomment-157342698
Looks good, will merge 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
[
https://issues.apache.org/jira/browse/FLINK-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008568#comment-15008568
]
ASF GitHub Bot commented on FLINK-3025:
---
Github user gyfora commented on the pull request:
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1365#issuecomment-157354372
:+1:
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1353#issuecomment-157345512
How about using a try-with-resources statement here?
I would like to use this whenever we touch code that needs to ensure
closing a resource...
---
If your
[
https://issues.apache.org/jira/browse/FLINK-2913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008524#comment-15008524
]
ASF GitHub Bot commented on FLINK-2913:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1365#issuecomment-157362141
Tests pass, will merge 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
Krzysztof Zarzycki created FLINK-3027:
-
Summary: Cancel button in Flink job dashboard does not work
Key: FLINK-3027
URL: https://issues.apache.org/jira/browse/FLINK-3027
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008620#comment-15008620
]
Stephan Ewen commented on FLINK-2504:
-
I have over the days spent quite a bit of time with the code
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1359#issuecomment-157343610
Looks correct (and affects only logging).
Will merge this...
---
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-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008589#comment-15008589
]
Stephan Ewen commented on FLINK-2351:
-
Any news on this one? Would be great to include this with 1.0
[
https://issues.apache.org/jira/browse/FLINK-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008587#comment-15008587
]
ASF GitHub Bot commented on FLINK-3025:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2676.
-
Resolution: Won't Fix
> Add abstraction for keyed window state
>
[
https://issues.apache.org/jira/browse/FLINK-2676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008622#comment-15008622
]
Stephan Ewen commented on FLINK-2676:
-
Approach changed a bit. Will file a more detailed followup at
[
https://issues.apache.org/jira/browse/FLINK-2676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2676.
---
> Add abstraction for keyed window state
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-2750:
---
Assignee: Stephan Ewen
> FileStateHandleTest fails when building for Hadoop 2.6.0
>
Ufuk Celebi created FLINK-3028:
--
Summary: Cannot cancel restarting job via web frontend
Key: FLINK-3028
URL: https://issues.apache.org/jira/browse/FLINK-3028
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008883#comment-15008883
]
Vasia Kalavri commented on FLINK-3002:
--
Alright, specifically creating a {{Left}} means I can reuse
[
https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008516#comment-15008516
]
ASF GitHub Bot commented on FLINK-2914:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008531#comment-15008531
]
ASF GitHub Bot commented on FLINK-2879:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1348#issuecomment-157346537
Looks good, merging this!
BTW: It also affects the docs of the 0.10 release, so I will cherry pick it
into the 0.10.x branch as well.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008604#comment-15008604
]
Chesnay Schepler commented on FLINK-2351:
-
i planned on removing the stuff when the Record API is
[
https://issues.apache.org/jira/browse/FLINK-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008778#comment-15008778
]
Gyula Fora commented on FLINK-3018:
---
You are right but it is still confusing for jobs that fail
[
https://issues.apache.org/jira/browse/FLINK-3029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3029.
---
> JobGraph is not connected correctly in webfrontend for streaming job
>
[
https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2914.
---
> Missing break in
> ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent()
>
[
https://issues.apache.org/jira/browse/FLINK-3029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3029.
-
Resolution: Duplicate
Duplicate of FLINK-2942
> JobGraph is not connected correctly in
[
https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008835#comment-15008835
]
Chiwan Park commented on FLINK-3023:
+1 and I think that this improvement would be good for Flink
[
https://issues.apache.org/jira/browse/FLINK-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008834#comment-15008834
]
Stephan Ewen commented on FLINK-3018:
-
I would like to have an "accumulated num records" counter
[
https://issues.apache.org/jira/browse/FLINK-3009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008858#comment-15008858
]
ASF GitHub Bot commented on FLINK-3009:
---
Github user hsaputra commented on a diff in the pull
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/1363#discussion_r45075237
--- Diff: docs/docker/run.sh ---
@@ -0,0 +1,74 @@
+#!/bin/bash
+
+# Licensed to the Apache Software Foundation (ASF) under one or more
+#
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008768#comment-15008768
]
ASF GitHub Bot commented on FLINK-2972:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008743#comment-15008743
]
ASF GitHub Bot commented on FLINK-3013:
---
Github user vasia commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1331#issuecomment-157391821
What if a user registers a custom type in Kryo on the client side? That
type would receive a different ID, because fewer types have been registered at
the client
[
https://issues.apache.org/jira/browse/FLINK-2771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008777#comment-15008777
]
ASF GitHub Bot commented on FLINK-2771:
---
Github user mliesenberg commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-3018:
--
Priority: Minor (was: Critical)
> Job state discarded from web interface for restarting jobs
>
Github user mliesenberg commented on the pull request:
https://github.com/apache/flink/pull/1367#issuecomment-157394443
several travis builds failed:
oraclejdk8 & hadoop 2.7: https://issues.apache.org/jira/browse/FLINK-2771
oraclejdk8 & hadoop 2.5:
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008784#comment-15008784
]
Vasia Kalavri commented on FLINK-3002:
--
No, in fact, I didn't go with the abstract version :-)
I do
[
https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2967.
-
Resolution: Fixed
Fix Version/s: 0.10.1
1.0.0
Fixed in
- 0.10 via
[
https://issues.apache.org/jira/browse/FLINK-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3025.
---
> Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug
>
[
https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008814#comment-15008814
]
Stephan Ewen commented on FLINK-2942:
-
Fixed in 0.10 via 9895e3e43823be11f058a00b9c4eb0c049dd91a8
>
[
https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2914.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via 442fcb196f9bf9fada2278b78c8447e65f0c85e0
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008831#comment-15008831
]
Stephan Ewen commented on FLINK-3002:
-
The thing about {{Either}} is that you never create an
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008853#comment-15008853
]
Vasia Kalavri commented on FLINK-3002:
--
I agree [~StephanEwen], that was my reasoning as well. What
[
https://issues.apache.org/jira/browse/FLINK-3009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008862#comment-15008862
]
ASF GitHub Bot commented on FLINK-3009:
---
Github user hsaputra commented on the pull request:
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1363#issuecomment-157408961
Other than small nit on text, +1
Seems like Travis fails unrelated to this patch
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008861#comment-15008861
]
Stephan Ewen commented on FLINK-3002:
-
All object reuse is optional to be done where possible. If you
[
https://issues.apache.org/jira/browse/FLINK-2879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2879.
-
Resolution: Fixed
Fix Version/s: 0.10.1
1.0.0
Fixed in
- 0.10 via
[
https://issues.apache.org/jira/browse/FLINK-2879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2879.
---
> Links in documentation are broken
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2967.
---
> TM address detection might not always detect the right interface on slow
> networks / overloaded JMs
>
[
https://issues.apache.org/jira/browse/FLINK-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3025.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fix Version/s: 0.10.1
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008836#comment-15008836
]
Aljoscha Krettek commented on FLINK-3002:
-
Hi,
you can remove the {{isLeft}}/{{isRight}} fields,
[
https://issues.apache.org/jira/browse/FLINK-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008691#comment-15008691
]
ASF GitHub Bot commented on FLINK-2967:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1361#issuecomment-157378877
Will merge and address the 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
[
https://issues.apache.org/jira/browse/FLINK-3029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008699#comment-15008699
]
Stephan Ewen commented on FLINK-3029:
-
Duplicate of https://issues.apache.org/jira/browse/FLINK-2942 ?
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1369#issuecomment-157383381
I verified the intended behaviour on a cluster application, it works for
cancelling from both the command line and also from the web interface.
+1 from my side,
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1331#issuecomment-157383461
I can confirm that `chill-avro` was never used. I accidentally committed
the dependency while trying out different approaches for handling Avro POJOs
with Flink.
---
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008720#comment-15008720
]
ASF GitHub Bot commented on FLINK-2972:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008723#comment-15008723
]
ASF GitHub Bot commented on FLINK-2972:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1368#issuecomment-157384055
+1 to merge.
---
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-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008728#comment-15008728
]
Stephan Ewen commented on FLINK-3018:
-
There are multiple execution attempts in cases of failures,
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1348
---
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/1362
---
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/1359
---
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
Gyula Fora created FLINK-3029:
-
Summary: JobGraph is not connected correctly in webfrontend for
streaming job
Key: FLINK-3029
URL: https://issues.apache.org/jira/browse/FLINK-3029
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008709#comment-15008709
]
ASF GitHub Bot commented on FLINK-2972:
---
Github user fhueske commented on the pull request:
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1306#issuecomment-157382048
@fhueske I've addressed most of your concerns.
Things that still need work / clarification:
* PreviewPlanDumpTest was previously executed with 2 different
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1369
[FLINK-3011, 3019, 3028] Cancel jobs in RESTARTING state
This addresses issues with cancelling jobs, which are in the `RESTARTING`
state. A job enters this state after a failure as soon as all job
[
https://issues.apache.org/jira/browse/FLINK-3011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008719#comment-15008719
]
ASF GitHub Bot commented on FLINK-3011:
---
GitHub user uce opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008718#comment-15008718
]
ASF GitHub Bot commented on FLINK-2901:
---
Github user zentol commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1331#issuecomment-157381073
1. No, it seemed that `chill-avro` was not used.
2. Chill is required when Java programs are submitted to a cluster that
include collection data sets. The cluster
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1331#issuecomment-157382231
Why to we need chill for collection data sets?
Also, are you sure chill-avro was never used? No magic reflection loading
happening anywhere?
---
If your
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1331#issuecomment-157385199
I thought generic types within collections data sets are serialized with
Kryo when they are shipped to the JM, no? Or are they going through Java
serialization?
---
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008730#comment-15008730
]
ASF GitHub Bot commented on FLINK-2972:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008740#comment-15008740
]
Stephan Ewen commented on FLINK-3002:
-
You went with the abstract class version, that is good, IMHO.
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008746#comment-15008746
]
ASF GitHub Bot commented on FLINK-2972:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008689#comment-15008689
]
ASF GitHub Bot commented on FLINK-2972:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1331#issuecomment-157378685
Two questions:
1. The `chill-avro` dependency is added nowhere. Is it not necessary any
more?
2. It is necessary to add the chill dependency also to
[
https://issues.apache.org/jira/browse/FLINK-3029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15008713#comment-15008713
]
Gyula Fora commented on FLINK-3029:
---
Possibly, but this seems to be pretty deterministically not
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1356#issuecomment-157385739
Thanks a lot for the PR @smarthi! +1 to merge.
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1358
---
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
1 - 100 of 258 matches
Mail list logo
