[
https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14718110#comment-14718110
]
Huang Wei commented on FLINK-2480:
--
Sorry, didn`t see this before.
Yes, I plan to.
I will
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14718044#comment-14718044
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on the pul
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1030#issuecomment-135630392
The method notifyAll() maybe get a bug in my test file that sometimes it
will be called before the wait().
So the method wait() will get stuck.
Then I change t
[
https://issues.apache.org/jira/browse/FLINK-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717934#comment-14717934
]
ASF GitHub Bot commented on FLINK-2545:
---
Github user ChengXiangLi commented on the p
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/1067#issuecomment-135612599
Thanks for the remind, @zentol and @StephanEwen , I should be too hurry to
open this PR. I tried to fix the exception in bloom filter in this PR and
verify other po
[
https://issues.apache.org/jira/browse/FLINK-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2588:
---
Description:
In Storm, topologies run forever and need to be terminate via
`LocalCluster.kill
Matthias J. Sax created FLINK-2588:
--
Summary: Implement KillOptions
Key: FLINK-2588
URL: https://issues.apache.org/jira/browse/FLINK-2588
Project: Flink
Issue Type: Improvement
Com
Github user jamescao commented on a diff in the pull request:
https://github.com/apache/flink/pull/1064#discussion_r38163609
--- Diff: flink-staging/flink-hcatalog/pom.xml ---
@@ -34,17 +34,64 @@ under the License.
jar
+
+
+
Github user chenliang613 commented on the pull request:
https://github.com/apache/flink/pull/1068#issuecomment-135591554
@StephanEwen sure! actually i did the "verify operation" at local machine.
At my local machine's log msg showing: got reference jar(as below)from
central r
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717826#comment-14717826
]
ASF GitHub Bot commented on FLINK-2493:
---
Github user chenliang613 commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717741#comment-14717741
]
ASF GitHub Bot commented on FLINK-2493:
---
Github user chenliang613 commented on the p
Github user chenliang613 commented on the pull request:
https://github.com/apache/flink/pull/1068#issuecomment-135580675
@mbalassi OK, i will make changes for flink-streaming-examples and
flink-storm-compatibility-example modules too.
---
If your project is set up for it, you can re
[
https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-2499.
-
Resolution: Fixed
Fix Version/s: 0.10
Via 91069d1f73.
> start-cluster.sh can start multipl
[
https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-2499:
--
Component/s: Start-Stop Scripts
> start-cluster.sh can start multiple TaskManager on the same no
[
https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-2499:
--
Affects Version/s: (was: 0.8.1)
0.10
> start-cluster.sh can start mul
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1071
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717648#comment-14717648
]
ASF GitHub Bot commented on FLINK-2499:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2587.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fix Version/s: 0.10
Fixed via 74ed714534c
[
https://issues.apache.org/jira/browse/FLINK-2587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2587.
---
> FlinkKafkaConsumer may fail with a NPE
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2326.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via 8cf8736ad99c78aa419ee2d6be4b70ac1b29d0ec
>
[
https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2326.
---
> Mutitenancy on Yarn
> ---
>
> Key: FLINK-2326
> URL: htt
[
https://issues.apache.org/jira/browse/FLINK-2582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717593#comment-14717593
]
Stephan Ewen commented on FLINK-2582:
-
Added a description via bc63ef2c122a842bf2a98eb
[
https://issues.apache.org/jira/browse/FLINK-2582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717592#comment-14717592
]
Stephan Ewen commented on FLINK-2582:
-
Ah, sorry [~chiwanpark], saw your comment too l
[
https://issues.apache.org/jira/browse/FLINK-2556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2556.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via 1e38d6fad410c0a0ef82fa73617f6feda86cd0e0
>
[
https://issues.apache.org/jira/browse/FLINK-2556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2556.
---
> Fix/Refactor pre-flight Key validation
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2565.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed in 0807eec0cb1acf8052a77b6133387e25399fce08
>
[
https://issues.apache.org/jira/browse/FLINK-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2565.
---
> Support primitive arrays as keys
>
>
> Key: FLINK-2565
[
https://issues.apache.org/jira/browse/FLINK-2556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717579#comment-14717579
]
ASF GitHub Bot commented on FLINK-2556:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717578#comment-14717578
]
ASF GitHub Bot commented on FLINK-2582:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717580#comment-14717580
]
ASF GitHub Bot commented on FLINK-2565:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717577#comment-14717577
]
ASF GitHub Bot commented on FLINK-2326:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1043
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1070
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1044
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1062
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned FLINK-2586:
--
Assignee: Matthias J. Sax
> Unstable Storm Compatibility Tests
> --
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-2585.
---
Resolution: Not A Problem
> KafkaSource not working
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717398#comment-14717398
]
Robert Metzger edited comment on FLINK-2585 at 8/27/15 7:54 PM:
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717398#comment-14717398
]
Robert Metzger commented on FLINK-2585:
---
Very good!
The KafkaSource in Flink 0.10 is
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717397#comment-14717397
]
Boyang Jerry Peng commented on FLINK-2585:
--
Got it to work guys! I built 0.10 fro
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717397#comment-14717397
]
Boyang Jerry Peng edited comment on FLINK-2585 at 8/27/15 7:52 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717388#comment-14717388
]
Robert Metzger commented on FLINK-2585:
---
[~StephanEwen]: Kafka is only logging the e
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717306#comment-14717306
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-135523032
I just pushed three commits on top addressing your comment. The first two,
include reworking all test cases in a whole package each, to change the test
pattern from "catch
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717286#comment-14717286
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on a diff in th
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r38132263
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -411,6 +411,23 @@ class TaskManager(
log.d
[
https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717262#comment-14717262
]
ASF GitHub Bot commented on FLINK-2326:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1062#issuecomment-135518748
Confirming that with my local travis also work. +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 yo
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717245#comment-14717245
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717255#comment-14717255
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on a diff in th
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r38130678
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
---
@@ -363,7 +363,135 @@ protected void run() {
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r38129641
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerTest.java
---
@@ -218,4 +228,113 @@ public void testRequestPartitionState()
[
https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717222#comment-14717222
]
Stephan Ewen commented on FLINK-2586:
-
Okay, I see. Is there a way to check the status
[
https://issues.apache.org/jira/browse/FLINK-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717213#comment-14717213
]
ASF GitHub Bot commented on FLINK-2565:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1043#issuecomment-135512163
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 not have this
[
https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717198#comment-14717198
]
Matthias J. Sax commented on FLINK-2586:
You are right. It's not the kill thing. H
[
https://issues.apache.org/jira/browse/FLINK-2556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717190#comment-14717190
]
ASF GitHub Bot commented on FLINK-2556:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1044#issuecomment-135508810
Merging this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this fe
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717183#comment-14717183
]
Robert Metzger commented on FLINK-2585:
---
[~jerrypeng]: I think the problem is that t
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717169#comment-14717169
]
Stephan Ewen commented on FLINK-2585:
-
Seems that the exceptions do not propagate to t
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717162#comment-14717162
]
Boyang Jerry Peng commented on FLINK-2585:
--
I am getting this error in one of my
[
https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2584.
---
> ASM dependency is not shaded away
> -
>
> Key: FLINK-258
[
https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2584.
-
Resolution: Fixed
Assignee: Stephan Ewen (was: Robert Metzger)
Fix Version/s: 0.9.
[
https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717141#comment-14717141
]
ASF GitHub Bot commented on FLINK-2326:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1062#issuecomment-135503479
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 not have this
[
https://issues.apache.org/jira/browse/FLINK-2582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717126#comment-14717126
]
ASF GitHub Bot commented on FLINK-2582:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1070#issuecomment-135501709
Looks good, +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 featur
[
https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2571:
---
Component/s: (was: flink-contrib)
Storm Compatibility
> Add task hooks su
[
https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2525:
---
Component/s: (was: flink-contrib)
Storm Compatibility
> Add configuration
[
https://issues.apache.org/jira/browse/FLINK-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2338:
---
Component/s: (was: flink-contrib)
Storm Compatibility
> Shut down "Storm
[
https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717109#comment-14717109
]
Stephan Ewen commented on FLINK-2586:
-
That is not really the problem here.
The probl
Robert Metzger created FLINK-2587:
-
Summary: FlinkKafkaConsumer may fail with a NPE
Key: FLINK-2587
URL: https://issues.apache.org/jira/browse/FLINK-2587
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2566:
---
Component/s: (was: flink-contrib)
Storm Compatibility
> FlinkTopologyCont
[
https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717104#comment-14717104
]
Matthias J. Sax commented on FLINK-2586:
This is a know problem. The reasons why t
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717067#comment-14717067
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on a diff in th
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r38119693
--- Diff:
flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/StormWordCountLocal.
Stephan Ewen created FLINK-2586:
---
Summary: Unstable Storm Compatibility Tests
Key: FLINK-2586
URL: https://issues.apache.org/jira/browse/FLINK-2586
Project: Flink
Issue Type: Bug
Comp
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1071#issuecomment-135489719
This actually looks good.
Let's merge it and collect user feedback - whether anyone is bothered by
the warnings when they start multiple TaskManager on one m
[
https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717031#comment-14717031
]
ASF GitHub Bot commented on FLINK-2499:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14717027#comment-14717027
]
Robert Metzger commented on FLINK-2585:
---
if the log contains confidential informatio
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716997#comment-14716997
]
Aljoscha Krettek commented on FLINK-2585:
-
Could you please post the contents of t
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716966#comment-14716966
]
Boyang Jerry Peng commented on FLINK-2585:
--
Sounds good, but I am monitoring the
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716917#comment-14716917
]
Stephan Ewen commented on FLINK-2585:
-
The {{print()}} method in the batch API prints
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716916#comment-14716916
]
Boyang Jerry Peng commented on FLINK-2585:
--
I'm looking at the .out files, but I
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716910#comment-14716910
]
Aljoscha Krettek commented on FLINK-2585:
-
Sorry, this might be a stupid question
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716906#comment-14716906
]
Boyang Jerry Peng commented on FLINK-2585:
--
I have been monitoring the out logs o
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716900#comment-14716900
]
Aljoscha Krettek edited comment on FLINK-2585 at 8/27/15 3:49 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716900#comment-14716900
]
Aljoscha Krettek commented on FLINK-2585:
-
I see, I think the problem is that you
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716889#comment-14716889
]
Boyang Jerry Peng commented on FLINK-2585:
--
I running using 'bin/flink'. I have
[
https://issues.apache.org/jira/browse/FLINK-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716882#comment-14716882
]
ASF GitHub Bot commented on FLINK-2499:
---
GitHub user mbalassi opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Jerry Peng updated FLINK-2585:
-
Comment: was deleted
(was: Thank you for your help!)
> KafkaSource not working
>
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716877#comment-14716877
]
Boyang Jerry Peng commented on FLINK-2585:
--
Thank you for your help!
> KafkaSour
GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/1071
[FLINK-2499] [scripts] Warning message for hosts starting multiple daâ¦
â¦emons
As per the discussion on the relevant
[ticket](https://issues.apache.org/jira/browse/FLINK-2499) adds a wa
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716878#comment-14716878
]
Aljoscha Krettek commented on FLINK-2585:
-
Are you running the program from inside
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716876#comment-14716876
]
Boyang Jerry Peng commented on FLINK-2585:
--
Thank you for your help!
> KafkaSour
[
https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716872#comment-14716872
]
Robert Metzger commented on FLINK-2584:
---
The problem was that we upgraded the depend
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716865#comment-14716865
]
Boyang Jerry Peng commented on FLINK-2585:
--
The pom I am using to compile
http:
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716858#comment-14716858
]
Boyang Jerry Peng commented on FLINK-2585:
--
I am using flink (v0.9.0) binary that
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716854#comment-14716854
]
Boyang Jerry Peng commented on FLINK-2585:
--
Yes I am producing new data but Kafka
[
https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716860#comment-14716860
]
Boyang Jerry Peng commented on FLINK-2585:
--
And I am using Kafka 2.10-0.8.2.1
>
1 - 100 of 326 matches
Mail list logo
