{"action":"opened","issue":{"url":"https://api.github.com/repos/lmco/streamflow/issues/42","labels_url":"https://api.github.com/repos/lmco/streamflow/issues/42/labels{/name}","comments_url":"https://api.github.com/repos/lmco/streamflow/issues/42/comments","events_url":"https://api.github.com/repos/lmco/streamflow/issues/42/events","html_url":"https://github.com/lmco/streamflow/issues/42","id":117271489,"number":42,"title":"Flink","user":{"login":"jloveland","id":3456708,"avatar_url":"https://avatars.githubusercontent.com/u/3456708?v=3","gravatar_id":"","url":"https://api.github.com/users/jloveland","html_url":"https://github.com/jloveland","followers_url":"https://api.github.com/users/jloveland/followers","following_url":"https://api.github.com/users/jloveland/following{/other_user}","gists_url":"https://api.github.com/users/jloveland/gists{/gist_id}","starred_url":"https://api.github.com/users/jloveland/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/jloveland/subscriptions","organizations_url":"https://api.github.com/users/jloveland/orgs","repos_url":"https://api.github.com/users/jloveland/repos","events_url":"https://api.github.com/users/jloveland/events{/privacy}","received_events_url":"https://api.github.com/users/jloveland/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":0,"created_at":"2015-11-17T02:53:10Z","updated_at":"2015-11-17T02:53:10Z","closed_at":null,"body":"Apache Flink is quickly gaining momentum as an alternative to Spark Streaming, Storm, etc.\r\n> Apache Flink is an open source platform for distributed stream and batch data processing. Flink’s core is a streaming dataflow engine that provides data distribution, communication, and fault tolerance for distributed computations over data streams.\r\n\r\nWhat are your thoughts on developing a plugin for [Flink Streaming](https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming_guide.html) in StreamFlow? The rationale is that Flink provides a Storm compatible API:\r\n> Flink provides a Storm compatible API (org.apache.flink.storm.api) that offers replacements for the following classes:\r\n>\r\n    TopologyBuilder replaced by FlinkTopologyBuilder\r\n    StormSubmitter replaced by FlinkSubmitter\r\n    NimbusClient and Client replaced by FlinkClient\r\n    LocalCluster replaced by FlinkLocalCluster\r\n\r\n> In order to submit a Storm topology to Flink, it is sufficient to replace the used Storm classes with their Flink replacements in the Storm client code that assembles the topology. The actual runtime code, ie, Spouts and Bolts, can be uses unmodified. If a topology is executed in a remote cluster, parameters nimbus.host and nimbus.thrift.port are used as jobmanger.rpc.address and jobmanger.rpc.port, respectively. If a parameter is not specified, the value is taken from flink-conf.yaml.\r\n\r\nhttps://ci.apache.org/projects/flink/flink-docs-master/apis/storm_compatibility.html"}}