[jira] [Created] (FLINK-9260) Introduce a friendly way to resume the job from externalized checkpoints automatically

2018-04-25 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9260: - Summary: Introduce a friendly way to resume the job from externalized checkpoints automatically Key: FLINK-9260 URL: https://issues.apache.org/jira/browse/FLINK-9260 Projec

[jira] [Created] (FLINK-9259) The implementation of the SourceFunction is not serializable.

2018-04-25 Thread Bob Lau (JIRA)
Bob Lau created FLINK-9259: -- Summary: The implementation of the SourceFunction is not serializable. Key: FLINK-9259 URL: https://issues.apache.org/jira/browse/FLINK-9259 Project: Flink Issue Type:

Re: Flink streaming job on yarn-cluster

2018-04-25 Thread Qi Yu
Can you provide more detail about this problem. e.g the version of flink,the corresponding configuration, hadoop, yarn version and so on. > 在 2018年4月24日，04:07，Qiong Wei 写道： > > This is Qiong Wei, from Microsoft. I’m trying to create a Flink streaming job > which consumer the data from Kafka a

CoProcessFunction doesn't support timer on keyed stream

2018-04-25 Thread Ken Krugler
Hi devs, I’m using Flink 1.5-SNAPSHOT, and I’ve got a connected stream that I’m using with a CoProcessFunction. One of the streams is keyed, and the other is broadcast. As per the documentation (https://ci.apache.org/projects/flink/flink-docs-release-1.4/api/java/org/apache/flink/streaming/api

[jira] [Created] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables

2018-04-25 Thread Narayanan Arunachalam (JIRA)
Narayanan Arunachalam created FLINK-9258: Summary: ConcurrentModificationException in ComponentMetricGroup.getAllVariables Key: FLINK-9258 URL: https://issues.apache.org/jira/browse/FLINK-9258

Flink streaming job on yarn-cluster

2018-04-25 Thread Qiong Wei
Hi, This is Qiong Wei, from Microsoft. I’m trying to create a Flink streaming job which consumer the data from Kafka and then write the data into Azure Blob Storage. I have a Hadoop cluster (yarn cluster), but it failed when I run the streaming job, I’m not sure if anybody can help me to solve

Re: [jira] [Created] (FLINK-9075) BucketingSink S3 does not work on local cluster

2018-04-25 Thread deanding
Hi, I have the similar issue when I was trying running on HDFS java.io.IOException: Error opening the Input Split hdfs://localhost:9000/user/yliu/test_big.csv [0,111513]: Provider for class javax.xml.parsers.DocumentBuilderFactory cannot be created at org.apache.flink.api.common.io.FileIn

[jira] [Created] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

2018-04-25 Thread Florian Schmidt (JIRA)
Florian Schmidt created FLINK-9257: -- Summary: End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code Key: FLINK-9257 URL: https://issues.apache.org/jira/browse/FLINK-92

[jira] [Created] (FLINK-9256) NPE in SingleInputGate#updateInputChannel() for non-credit based flow control

2018-04-25 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9256: -- Summary: NPE in SingleInputGate#updateInputChannel() for non-credit based flow control Key: FLINK-9256 URL: https://issues.apache.org/jira/browse/FLINK-9256 Project: Flin

[jira] [Created] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

2018-04-25 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-9255: --- Summary: Regression - Flink CLI -m,--jobmanager option not working Key: FLINK-9255 URL: https://issues.apache.org/jira/browse/FLINK-9255 Project: Flink Issue

[jira] [Created] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test

2018-04-25 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9254: -- Summary: Move NotSoMiniClusterIterations to be an end-to-end test Key: FLINK-9254 URL: https://issues.apache.org/jira/browse/FLINK-9254 Project: Flink Is

[jira] [Created] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

2018-04-25 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9253: -- Summary: Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers Key: FLINK-9253 URL: https://issues.apache.org/jira/browse/FLINK-9253 Proje

[jira] [Created] (FLINK-9252) OperatorChain.pushToOperators NullPointerException when ClassCastException

2018-04-25 Thread Stefano Bortoli (JIRA)
Stefano Bortoli created FLINK-9252: -- Summary: OperatorChain.pushToOperators NullPointerException when ClassCastException Key: FLINK-9252 URL: https://issues.apache.org/jira/browse/FLINK-9252 Project:

Re: [Discussion] Flink Pulsar Connector

2018-04-25 Thread Sijie Guo
Awesome! Thanks, Gordon! - Sijie On Wed, Apr 25, 2018 at 12:02 AM, Tzu-Li (Gordon) Tai wrote: > Hi Sijie, > > Thanks for initiating the discussion. > > Given that it seems promising that we will have good eyes on this > connector after it is merged, > +1 to proceed with the PR and reviewing it

Re: [Discussion] Flink Pulsar Connector

2018-04-25 Thread Tzu-Li (Gordon) Tai
Hi Sijie, Thanks for initiating the discussion. Given that it seems promising that we will have good eyes on this connector after it is merged, +1 to proceed with the PR and reviewing it as a connector contribution to Flink. Cheers, Gordon On 25 April 2018 at 4:07:48 AM, Sijie Guo (guosi...@gm