According to the logs the job was submitted successfully and is running.
Please verify that the server you're connecting to is actually sending data.
On 04.05.2018 22:44, Alex Chen (JIRA) wrote:
Alex Chen created FLINK-9298:
Summary: setup_quickst
> On May 3, 2018, at 9:06 PM, Rong Rong wrote:
>
> Agree it is definitely not intuitive trying to figure out what to do based
> on this message.
> I think the message should be changed to "please consider increasing
> maximum permitted memory size, increase task manager parallelism, or using
> a
Ken Krugler created FLINK-9300:
--
Summary: Improve error message when in-memory state is too large
Key: FLINK-9300
URL: https://issues.apache.org/jira/browse/FLINK-9300
Project: Flink
Issue Type:
Ken Krugler created FLINK-9299:
--
Summary: ProcessWindowFunction documentation Java examples have
errors
Key: FLINK-9299
URL: https://issues.apache.org/jira/browse/FLINK-9299
Project: Flink
Issu
Alex Chen created FLINK-9298:
Summary: setup_quickstart hanging
Key: FLINK-9298
URL: https://issues.apache.org/jira/browse/FLINK-9298
Project: Flink
Issue Type: Bug
Reporter: Alex Che
Hi,
We have been looking into more intelligent UDF supports such as creating a
better type inference module to infer automatically composite data
types[1].
One most comment pain point we have are some use cases where users would
like to re-use a rather generic UDF, for example:
public List eval(
Jelmer Kuperus created FLINK-9297:
-
Summary: Make size of JobManager's ioExecutor configurable
Key: FLINK-9297
URL: https://issues.apache.org/jira/browse/FLINK-9297
Project: Flink
Issue Type:
Fabian Hueske created FLINK-9296:
Summary: Support distinct aggregation on non-windowed grouped
streaming tables
Key: FLINK-9296
URL: https://issues.apache.org/jira/browse/FLINK-9296
Project: Flink
Hi,
There are a few JIRA tickets that address this problem [1] [2].
Summary: The best execution strategy depends on the amount of data / window
configuration.
Best, Fabian
[1] https://issues.apache.org/jira/browse/FLINK-7001
[2] https://issues.apache.org/jira/browse/FLINK-5387
2018-05-04 7:22
