[jira] [Created] (FLINK-7833) Flink's Literal(value, SqlTimeTypeInfo) fails to convert Calctie's RexNode

2017-10-12 Thread John Fang (JIRA)
John Fang created FLINK-7833: Summary: Flink's Literal(value, SqlTimeTypeInfo) fails to convert Calctie's RexNode Key: FLINK-7833 URL: https://issues.apache.org/jira/browse/FLINK-7833 Project: Flink

[jira] [Created] (FLINK-7832) SlotManager should return number of registered slots

2017-10-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7832: Summary: SlotManager should return number of registered slots Key: FLINK-7832 URL: https://issues.apache.org/jira/browse/FLINK-7832 Project: Flink Issue Type

[jira] [Created] (FLINK-7831) Retrieve last received heartbeat from HeartbeatManager

2017-10-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7831: Summary: Retrieve last received heartbeat from HeartbeatManager Key: FLINK-7831 URL: https://issues.apache.org/jira/browse/FLINK-7831 Project: Flink Issue Ty

[jira] [Created] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots

2017-10-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7830: --- Summary: Problematic interaction of CEP and asynchronous snapshots Key: FLINK-7830 URL: https://issues.apache.org/jira/browse/FLINK-7830 Project: Flink

running flink 1.4 in eclipse

2017-10-12 Thread Radu Tudoran
Hi, Any thoughts of why would I get such an error when trying to run within eclipse a simple (i.e., any) flink program. ...I did start the local cluster before - where I was able to run the job...but after that it did not work anymore to run flink from eclipse. Exception in thread "main" java.

Re: Unable to write snapshots to S3 on EMR

2017-10-12 Thread Andy M.
Hi Ajoscha, That didn't seem to do the trick either. Do the following look correct? I see 5.9.0 is released with Flink 1.3.2, so I tried that, and got the same problem, all I did was upload my Scala .jar to the master, updated my flink-conf.yaml, set my env variables, and ran it with the followi

[jira] [Created] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

2017-10-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7829: --- Summary: Remove (or at least deprecate) DataStream.writeToFile/Csv Key: FLINK-7829 URL: https://issues.apache.org/jira/browse/FLINK-7829 Project: Flink

[jira] [Created] (FLINK-7828) Improve object copying/reuse mode for streaming runtime

2017-10-12 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7828: --- Summary: Improve object copying/reuse mode for streaming runtime Key: FLINK-7828 URL: https://issues.apache.org/jira/browse/FLINK-7828 Project: Flink I

[jira] [Created] (FLINK-7827) creating and starting a NetCat in test cases programmatically

2017-10-12 Thread bluejoe (JIRA)
bluejoe created FLINK-7827: -- Summary: creating and starting a NetCat in test cases programmatically Key: FLINK-7827 URL: https://issues.apache.org/jira/browse/FLINK-7827 Project: Flink Issue Type:

Re: the Table API `limit` is confused

2017-10-12 Thread John Fang
Hi Fabian, Thank you for your replay. On Thu, Oct 12, 2017 at 4:18 PM, Fabian Hueske wrote: > Hi John, > > I agree that the Table.limit(offset) method is confusing and that the > semantics should rather be to specify the fetch parameter than the offset > parameter. > However, we can not easil

[jira] [Created] (FLINK-7826) Add support for all types of state to the QueryableStateClient.

2017-10-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-7826: - Summary: Add support for all types of state to the QueryableStateClient. Key: FLINK-7826 URL: https://issues.apache.org/jira/browse/FLINK-7826 Project: Flink

[jira] [Created] (FLINK-7825) Change the `QueryableStateClient` to use a builder pattern.

2017-10-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-7825: - Summary: Change the `QueryableStateClient` to use a builder pattern. Key: FLINK-7825 URL: https://issues.apache.org/jira/browse/FLINK-7825 Project: Flink

[jira] [Created] (FLINK-7824) Put the queryable state jars in the opt folder.

2017-10-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-7824: - Summary: Put the queryable state jars in the opt folder. Key: FLINK-7824 URL: https://issues.apache.org/jira/browse/FLINK-7824 Project: Flink Issue Type: S

[jira] [Created] (FLINK-7823) Adjust queryable state configuration parameters

2017-10-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-7823: - Summary: Adjust queryable state configuration parameters Key: FLINK-7823 URL: https://issues.apache.org/jira/browse/FLINK-7823 Project: Flink Issue Type: S

[jira] [Created] (FLINK-7822) Add documentation for the new queryable state client.

2017-10-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-7822: - Summary: Add documentation for the new queryable state client. Key: FLINK-7822 URL: https://issues.apache.org/jira/browse/FLINK-7822 Project: Flink Issue T

Re: the Table API `limit` is confused

2017-10-12 Thread Fabian Hueske
Hi John, I agree that the Table.limit(offset) method is confusing and that the semantics should rather be to specify the fetch parameter than the offset parameter. However, we can not easily change the behavior of an existing function. The only way to evolve the functionality is to add new methods

[jira] [Created] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-12 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7821: Summary: Replace Table.limit() by Table.fetch() and Table.offset() Key: FLINK-7821 URL: https://issues.apache.org/jira/browse/FLINK-7821 Project: Flink Issue