Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1342#issuecomment-155719584
Thank you for the testing and the patch. I would like to merge this soon.
---
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-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000171#comment-15000171
]
Stephan Ewen commented on FLINK-2380:
-
Is this still interesting?
If yes, we should add this for 1.0,
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000170#comment-15000170
]
ASF GitHub Bot commented on FLINK-2977:
---
Github user mxm commented on the pull request:
Stephan Ewen created FLINK-3002:
---
Summary: Add an EitherType to the Java API
Key: FLINK-3002
URL: https://issues.apache.org/jira/browse/FLINK-3002
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000191#comment-15000191
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user sachingoel0101 commented on the pull request:
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-155726578
@rmetzger I have pushed a fix. Can you check this again? I apologize if
this takes one two more iterations to get right since I cannot check this
myself.
---
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000243#comment-15000243
]
ASF GitHub Bot commented on FLINK-7:
Github user ChengXiangLi commented on a diff in the pull request:
Github user ChengXiangLi commented on a diff in the pull request:
https://github.com/apache/flink/pull/1255#discussion_r44522180
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/RangePartitionRewriter.java
---
@@ -0,0 +1,194 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000245#comment-15000245
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user sachingoel0101 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000134#comment-15000134
]
Ufuk Celebi commented on FLINK-2993:
I agree that 100 seconds default is too high. Let's go for
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-155713026
Thank you. I've tested it on a YARN cluster, but the URL it is showing is
not correct.
It seems to me that you are just using the current hostname + ip of the web
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000153#comment-15000153
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user rmetzger commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1237#issuecomment-155719774
Why is it `AdaptiveTableSource` and `StaticTableSource`? Aren't static
sources a subset of adaptive sources that just don't adapt?
I don't think we need to
[
https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000172#comment-15000172
]
ASF GitHub Bot commented on FLINK-2828:
---
Github user aljoscha commented on the pull request:
Stephan Ewen created FLINK-3001:
---
Summary: Add Support for Java 8 Optional type
Key: FLINK-3001
URL: https://issues.apache.org/jira/browse/FLINK-3001
Project: Flink
Issue Type: New Feature
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-155740233
That's not a problem. You can test at your own convenience. There's no
hurry. :)
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000127#comment-15000127
]
ASF GitHub Bot commented on FLINK-2977:
---
Github user nielsbasjes commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000160#comment-15000160
]
ASF GitHub Bot commented on FLINK-2828:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000161#comment-15000161
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000211#comment-15000211
]
Maximilian Michels commented on FLINK-2380:
---
I think it makes sense to let the user replace the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1345#issuecomment-155735166
This looks like a bug you fixed. Do you have a case where this bug kicked
in that you could add as a test?
---
If your project is set up for it, you can reply to
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-155738270
Sure. :)
It's probably best you didn't. There was still a minor thing to hash out.
:')
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-3001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000208#comment-15000208
]
Stephan Ewen commented on FLINK-3001:
-
That is all up to us to define. I would say yes to both, and
Github user nielsbasjes commented on the pull request:
https://github.com/apache/flink/pull/1342#issuecomment-155708227
I created a test topology that puts the current time in an HBase cell
several times per second.
In the cluster I did this on HBase is configured to use Kerberos
Fabian Hueske created FLINK-2999:
Summary: Support connected keyed streams
Key: FLINK-2999
URL: https://issues.apache.org/jira/browse/FLINK-2999
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3003:
--
Summary: Add container allocation timeout to YARN CLI
Key: FLINK-3003
URL: https://issues.apache.org/jira/browse/FLINK-3003
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000248#comment-15000248
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user rmetzger commented on the pull request:
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1237#discussion_r44515720
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
---
@@ -64,15 +62,19 @@ import scala.reflect.ClassTag
*
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000218#comment-15000218
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-155732014
Thank you. Sadly, I've shut down the cluster a few minutes ago, because I
was finished with the release testing.
I'll try soon...
---
If your project is set up
Ufuk Celebi created FLINK-3000:
--
Summary: Add ShutdownHook to YARN CLI to prevent lingering sessions
Key: FLINK-3000
URL: https://issues.apache.org/jira/browse/FLINK-3000
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000181#comment-15000181
]
Fabian Hueske commented on FLINK-3001:
--
Do we want to support Option types as keys?
If yes, what will
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-155738690
I know. The problem is that MS Azure cloud needs 30 minutes to deploy a
small hortonworks cluster. Google handles that in a few minutes.
But I can use another
[
https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000282#comment-15000282
]
Piotr Godek commented on FLINK-2942:
OK will fix that soon.
> Dangling operators in web UI's program
[
https://issues.apache.org/jira/browse/FLINK-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000301#comment-15000301
]
ASF GitHub Bot commented on FLINK-2989:
---
Github user rmetzger commented on the pull request:
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1266#issuecomment-155764846
@fhueske 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 GitHub as well. If your project
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000307#comment-15000307
]
ASF GitHub Bot commented on FLINK-2977:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000310#comment-15000310
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1344#issuecomment-155764939
+1 for the integration test
---
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
[
https://issues.apache.org/jira/browse/FLINK-2692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000309#comment-15000309
]
ASF GitHub Bot commented on FLINK-2692:
---
Github user zentol commented on the pull request:
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-155764884
Okay. Figured it out. The Parallelism in the `ContextEnvironment` wasn't
being respected in `StreamContextEnvironment`. Passes on my local machine now;
waiting
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000323#comment-15000323
]
ASF GitHub Bot commented on FLINK-2977:
---
Github user rmetzger commented on the pull request:
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1341#discussion_r44529482
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
---
@@ -173,4 +174,12 @@ public void
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1341#discussion_r44530703
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000348#comment-15000348
]
ASF GitHub Bot commented on FLINK-2974:
---
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/1341#discussion_r44530755
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000347#comment-15000347
]
ASF GitHub Bot commented on FLINK-2974:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000365#comment-15000365
]
ASF GitHub Bot commented on FLINK-2974:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1337#issuecomment-155789414
BTW: You have pull request number 1337 ;-)
+1 also from my side. Take of colors is different for everyone,. If this is
Scala's default scheme, let's take it
[
https://issues.apache.org/jira/browse/FLINK-2947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000388#comment-15000388
]
ASF GitHub Bot commented on FLINK-2947:
---
Github user StephanEwen commented on the pull request:
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1325#issuecomment-155797348
+1 for 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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/976bacc65908cc35382ddbbcdc80249a700bc2d3#commitcomment-1496
In flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java:
In
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-155842188
There is a merge conflict. Looks good otherwise.
---
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-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000652#comment-15000652
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user mxm commented on the pull request:
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-155861149
@mxm , rebased.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000790#comment-15000790
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on the pull request:
Github user fangmu commented on the pull request:
https://github.com/apache/flink/pull/1345#issuecomment-155810945
I found this when learning codes
---
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
[
https://issues.apache.org/jira/browse/FLINK-2994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2994.
-
Resolution: Fixed
Client now prints the exception when program switched to FAILING.
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-2994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2994.
---
> Client sysout logging does not report exceptions
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000447#comment-15000447
]
ASF GitHub Bot commented on FLINK-2942:
---
Github user fhueske commented on the pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1339
---
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 aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1347#issuecomment-155826667
This does not touch the documentation yet. I would adapt it once we come to
the consensus that we want these refactorings.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2380:
--
Fix Version/s: (was: 0.10)
1.0
> Allow to configure default FS
[
https://issues.apache.org/jira/browse/FLINK-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000311#comment-15000311
]
ASF GitHub Bot commented on FLINK-2989:
---
Github user mxm commented on the pull request:
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1305#issuecomment-155765000
Should we do a final iteration over this and merge this to contrib?
The description got slightly out of date when I changed this back so that
it stores the state
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1342#discussion_r44527912
--- Diff: flink-yarn/pom.xml ---
@@ -63,6 +63,11 @@ under the License.
test
+
+
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1342#issuecomment-155768292
Thanks a lot for working on this issue! It doesn't happen everyday that
users identify issues, fix them and verify the fix so properly :)
I would really like
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1243#issuecomment-155783584
I would like to look over this in the next days and merge it if it looks
good.
@HilmiYildirim Do you know of any simple way to run an embedded RabbitMQ
[
https://issues.apache.org/jira/browse/FLINK-2996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000402#comment-15000402
]
Chiwan Park commented on FLINK-2996:
+1
This is really necessary.
> Add config entry to define
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1346#issuecomment-155800525
Thanks for the patch @iampeter!
I tried the fix on the broken plans and they look good!
![screen shot 2015-11-11 at 15 40
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1347
[refactor] Rename OperatorState to ValueState, add ListState
ValueState behaves exactly the same as OperatorState. ListState is a
stateful list to which elements can be added and for which the
Github user mxm commented on the pull request:
https://github.com/apache/flink/commit/976bacc65908cc35382ddbbcdc80249a700bc2d3#commitcomment-14333154
In flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java:
In
[
https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000528#comment-15000528
]
ASF GitHub Bot commented on FLINK-2826:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2826.
---
> transformed is modified in
> BroadcastVariableMaterialization#decrementReferenceInternal without
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/1243#issuecomment-155820098
Unfortunately, I do not know a simple way to run an embedded RabbitMQ broker
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000532#comment-15000532
]
ASF GitHub Bot commented on FLINK-2624:
---
Github user HilmiYildirim commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2826.
-
Resolution: Fixed
Fix Version/s: 1.0
Fixed via 6019f085f0d3dadc20a11f900784ce2796a89ce0
[
https://issues.apache.org/jira/browse/FLINK-3002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3002:
Assignee: Vasia Kalavri
> Add an EitherType to the Java API
>
Github user ChengXiangLi commented on a diff in the pull request:
https://github.com/apache/flink/pull/1255#discussion_r44521192
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java
---
@@ -121,6 +121,9 @@ public
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000257#comment-15000257
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user sachingoel0101 commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1342#issuecomment-155764769
The tests on travis are failing
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1342#issuecomment-155769960
Robert has a good point. Right now, if some one uses HBase, the HBase
dependency is part of the user program JAR. It would be nice to keep HBase out
of the core JAR
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000354#comment-15000354
]
ASF GitHub Bot commented on FLINK-2974:
---
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/1341#discussion_r44531013
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1341#issuecomment-155785654
I think this breaks the checkpoint atomicity. The fetcher (which emits the
data to the source context) will not lock on the checkpoint lock any more, but
on an
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000360#comment-15000360
]
ASF GitHub Bot commented on FLINK-2974:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000435#comment-15000435
]
Matthias J. Sax commented on FLINK-2671:
Occurred again:
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000355#comment-15000355
]
ASF GitHub Bot commented on FLINK-2974:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000372#comment-15000372
]
ASF GitHub Bot commented on FLINK-2974:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1341#issuecomment-155786742
Can you also move the periodic offset committer into the `run()` methods?
Saves another field that may have concurrent access. The run methods can make
sure it
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1342#issuecomment-155770210
I was thinking about something like a reflection-based mechanism. Not sure
though if this will work across different versions. Probably the API didn't
change much in this
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000326#comment-15000326
]
ASF GitHub Bot commented on FLINK-2977:
---
Github user mxm commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000325#comment-15000325
]
ASF GitHub Bot commented on FLINK-2977:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000331#comment-15000331
]
ASF GitHub Bot commented on FLINK-2974:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000351#comment-15000351
]
ASF GitHub Bot commented on FLINK-2974:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000350#comment-15000350
]
ASF GitHub Bot commented on FLINK-2974:
---
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/1341#discussion_r44530920
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1341#discussion_r44530770
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1341#discussion_r44532032
--- Diff:
flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000367#comment-15000367
]
ASF GitHub Bot commented on FLINK-2974:
---
Github user StephanEwen commented on a diff in the pull
1 - 100 of 126 matches
Mail list logo
