Re: Run apache flink from intellij or eclipse

When you run in the IDE, an embedded ("local") Flink environment is created. It doesn't make use of your Flink cluster as "flink run" would. I believe you can activate the Web UI by using the following API: StreamExecutionEnvironment::createLocalEnvironmentWithWebUI

Elasticsearch connector

Hi Team, Could you please let me know if the elasticsearch connector from Flink 1.3.2 support elasticsearch 5.5.1. I am not able to find the add method in RequestIndexer interface using this connector. Dependency used: org.apache.flink flink-connector-elasticsearch5_2.10 1.3.2 Tha

Re: [jira] [Commented] (FLINK-7606) CEP operator leaks state

Yes. In general, and for every keyed state, the amount of state you store is proportional to the number of active keys that you expect to have. On Sep 15, 2017 5:33 PM, "Paolo Rendano (JIRA)" wrote: > > [ https://issues.apache.org/jira/browse/FLINK-7606?page= > com.atlassian.jira.plugin.syst

[jira] [Created] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

Wei-Che Wei created FLINK-7630: -- Summary: Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() Key: FLINK-7630 URL: https://issues.apache.org/jira/browse/FLINK-7630 Project: Flink

[jira] [Created] (FLINK-7629) Scala stream aggregations should support nested field expressions

Gabor Gevay created FLINK-7629: -- Summary: Scala stream aggregations should support nested field expressions Key: FLINK-7629 URL: https://issues.apache.org/jira/browse/FLINK-7629 Project: Flink

Run apache flink from intellij or eclipse

Hello, I am running flink from intellij or eclipse, but i dont see my job on the flink dashboard localhost:8081 What should i do?

[jira] [Created] (FLINK-7628) Add cookbooks to the documentation

James Lafa created FLINK-7628: - Summary: Add cookbooks to the documentation Key: FLINK-7628 URL: https://issues.apache.org/jira/browse/FLINK-7628 Project: Flink Issue Type: Improvement