Tzu-Li (Gordon) Tai created FLINK-4018:
--
Summary: Configurable idle time between getRecords requests to
Kinesis shards
Key: FLINK-4018
URL: https://issues.apache.org/jira/browse/FLINK-4018
Projec
Geoffrey Mon created FLINK-4017:
---
Summary: [py] Add Aggregation support to Python API
Key: FLINK-4017
URL: https://issues.apache.org/jira/browse/FLINK-4017
Project: Flink
Issue Type: Improvemen
Via YARN it's possible to set dynamically, but for standalone clusters
unfortunately not at the moment.
On Fri, Jun 3, 2016 at 3:46 PM, Vinay Patil wrote:
> Hi,
>
> I am unable to pass VM arguments to my jar, this is the way I am running it:
>
> *bin/flink run test.jar config.yaml*
>
> I cannot a
RWenden created FLINK-4016:
--
Summary: FoldApplyWindowFunction is not properly initialized
Key: FLINK-4016
URL: https://issues.apache.org/jira/browse/FLINK-4016
Project: Flink
Issue Type: Bug
Hi,
I am unable to pass VM arguments to my jar, this is the way I am running it:
*bin/flink run test.jar config.yaml*
I cannot add the VM arguments(app.name) in *env.java.opts * since there
will be multiple applications running which has this as the argument
Is there any way to pass the VM argu
Sebastian Klemke created FLINK-4015:
---
Summary: FlinkKafkaProducer08 fails when partition leader changes
Key: FLINK-4015
URL: https://issues.apache.org/jira/browse/FLINK-4015
Project: Flink
ZhengBowen created FLINK-4014:
-
Summary: Jobs hang， Maybe NetworkBufferPool and Local、
Key: FLINK-4014
URL: https://issues.apache.org/jira/browse/FLINK-4014
Project: Flink
Issue Type: Bug
Hi all,
+1 for shepherd
I would like to add me to shepherd for FlinkML.
Regards,
Chiwan Park
> On Jun 3, 2016, at 3:29 AM, Henry Saputra wrote:
>
> +1 for shepherd
>
> I would prefer using that term rather than maintainer. It is being used in
> Incubator PMC to help them keeping healthy devel
