Re: Exception when run flink-storm-example

Hi hanjing, *There may be both flink job and flink-storm in the my cluster, I don't know the influence about legacy mode.* > For storm-compatible jobs, because of technical limitations, you need to use a cluster that supports legacy mode. But for Jobs implemented using the Flink-related API, I

Re: Exception when run flink-storm-example

You can check these release notes https://flink.apache.org/news/2018/05/25/release-1.5.0.html for more information. Cheers, Till On Tue, Sep 11, 2018 at 12:02 PM jing wrote: > Hi Till， > legacy mode worked！ > Thanks a lot. And what's difference between legacy and new? Is there > any doc

Re: Exception when run flink-storm-example

Hi Till， legacy mode worked！ Thanks a lot. And what's difference between legacy and new? Is there any document and release note? There may be both flink job and flink-storm in the my cluster, I don't know the influence about legacy mode. | | Hanjing | | | 签名由网易邮箱大师定制 On 9/11/2018 14

Re: Exception when run flink-storm-example

Hi Hanjing, I think the problem is that the Storm compatibility layer only works with legacy mode at the moment. Please set `mode: legacy` in your flink-conf.yaml. I hope this will resolve the problems. Cheers, Till On Tue, Sep 11, 2018 at 7:10 AM jing wrote: > Hi vino, > Thank you very much.

Re: Exception when run flink-storm-example

Hi vino, Thank you very much. I'll try more tests. | | Hanjing | | | 签名由网易邮箱大师定制 On 9/11/2018 11:51，vino yang wrote： Hi Hanjing, Flink does not currently support TaskManager HA and only supports JobManager HA. In the Standalone environment, once the JobManager triggers a failover, it will al

Re: Exception when run flink-storm-example

Hi Hanjing, Flink does not currently support TaskManager HA and only supports JobManager HA. In the Standalone environment, once the JobManager triggers a failover, it will also cause cancel and restart for all jobs. Thanks, vino. jing 于2018年9月11日周二 上午11:12写道： > Hi vino, > Thanks a lot. > Besi

Re: Exception when run flink-storm-example

Hi vino, Thanks a lot. Besides, I'm also confused about taskmanager's HA. There're 2 taskmangaer in my cluster, only one job A worked on taskmanager A. If taskmangaer A crashed, what happend about my job. I tried, my job failed, taskmanger B does not take over job A. Is this right? | | Hanjing

Re: Exception when run flink-storm-example

Oh, I thought the flink job could not be submitted. I don't know why the storm's example could not be submitted. Because I have never used it. Maybe Till, Chesnay or Gary can help you. Ping them for you. Thanks, vino. jing 于2018年9月11日周二 上午10:26写道： > Hi vino， > My job mangaer log is as below. I

Re: Exception when run flink-storm-example

Hi vino， My job mangaer log is as below. I can submit regular flink job to this jobmanger, it worked. But the flink-storm example doesn's work. Thanks. Hanjing 2018-09-11 18:22:48,937 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - --

Re: Exception when run flink-storm-example

Hi Hanjing, Is your JobManager working properly? Can you share your JobManager log? Thanks, vino. jing 于2018年9月11日周二 上午10:06写道： > Hi vino， > >I tried change "localhost" to the real IP. But still throw > exception as below. JobManager configuration is as below. > > > > Thanks. > > Hanji

Re: Exception when run flink-storm-example

Hi vino， I tried change "localhost" to the real IP. But still throw exception as below. JobManager configuration is as below. Thanks. Hanjing flink-conf.yaml: jobmanager.rpc.address: 170.0.0.46 # The RPC port where the JobManager is reachabl

Re: Exception when run flink-storm-example

Hi Hanjing, OK, I mean you change the "localhost" to the real IP. Try it. Thanks, vino. jing 于2018年9月10日周一 下午8:07写道： > Hi vino, > jonmanager rpc address value is setted by localhost. > hadoop3@p-a36-72 is the node host the jobmanager jvm. > > Thanks. > Hanjing > > > > jing > 邮箱hanjingz...@163

Re: Exception when run flink-storm-example

Hi vino, jonmanager rpc address value is setted by localhost. hadoop3@p-a36-72 is the node host the jobmanager jvm. Thanks. Hanjing | | jing | | 邮箱hanjingz...@163.com | 签名由 网易邮箱大师 定制 On 09/10/2018 19:25, vino yang wrote: Hi Hanjing, I mean this configuration key.[1] What's more, Is the "

Re: Exception when run flink-storm-example

Hi Hanjing, I mean this configuration key.[1] What's more, Is the "hadoop3@p-a36-72" also the node which host JobManager's jvm process? Thanks, vino. [1]: https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/config.html#jobmanager-rpc-address jing 于2018年9月10日周一 下午6:57写道： > Hi vino

Re: Exception when run flink-storm-example

Hi vino, I commit the job on the jvm code with the command below. hadoop3@p-a36-72 flink-1.6.0]$ ./bin/flink run WordCount-StormTopology.jar input output And I'm a new user, which configuation name should be set. All the configuations are the default setting now. Thanks. Hanjing | | jing |