Re:Incorrect Rest URL

2018-03-06 Thread mingleizhang
I expect it response me like the following as the doc say. But does not. Sample Result: { "jobs":[ { "jid": "7684be6004e4e955c2a558a9bc463f65", "name": "Flink Java Job at Wed Sep 16 18:08:21 CEST 2015", "state": "FINISHED", "start-time": 1442419702857, "end

Incorrect Rest URL

2018-03-06 Thread mingleizhang
I am not sure about whether it is a incorrect rest url, but i think it is. https://ci.apache.org/projects/flink/flink-docs-master/monitoring/rest_api.html Overview of Jobs /jobs/overview And I access the url with : http://10.201.202.217:9081//jobs/overview It gives me : java.lang.RuntimeExc

Re: Proposal - Change shard discovery in Flink Kinesis Connector to use ListShards

2018-03-06 Thread Kailash Dayanand
Hello Bowen, Thank you very much for your feedback. I had a question with regard to your concern on compatibilities issues I notice that aws-java-sdk imported in the flink connector is shaded. So it is not likely to cause conflicts in classpath due to AWS EMR depending on a older version of the S

[jira] [Created] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

2018-03-06 Thread Kailash Hassan Dayanand (JIRA)
Kailash Hassan Dayanand created FLINK-: -- Summary: Upgrade AWS SDK in flink-connector-kinesis Key: FLINK- URL: https://issues.apache.org/jira/browse/FLINK- Project: Flink

[jira] [Created] (FLINK-8887) ClusterClient.getJobStatus can throw FencingTokenException

2018-03-06 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8887: --- Summary: ClusterClient.getJobStatus can throw FencingTokenException Key: FLINK-8887 URL: https://issues.apache.org/jira/browse/FLINK-8887 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-8886) Job isolation via scheduling in shared cluster

2018-03-06 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8886: - Summary: Job isolation via scheduling in shared cluster Key: FLINK-8886 URL: https://issues.apache.org/jira/browse/FLINK-8886 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-8885) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8885: --- Summary: The DispatcherThreadFactory should register uncaught exception handlers Key: FLINK-8885 URL: https://issues.apache.org/jira/browse/FLINK-8885 Project: Flink

[jira] [Created] (FLINK-8884) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8884: --- Summary: The DispatcherThreadFactory should register uncaught exception handlers Key: FLINK-8884 URL: https://issues.apache.org/jira/browse/FLINK-8884 Project: Flink

[jira] [Created] (FLINK-8883) ExceptionUtils.rethrowIfFatalError should tread ThreadDeath as fatal.

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8883: --- Summary: ExceptionUtils.rethrowIfFatalError should tread ThreadDeath as fatal. Key: FLINK-8883 URL: https://issues.apache.org/jira/browse/FLINK-8883 Project: Flink

[jira] [Created] (FLINK-8882) flink-tests fails with core dump

2018-03-06 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8882: --- Summary: flink-tests fails with core dump Key: FLINK-8882 URL: https://issues.apache.org/jira/browse/FLINK-8882 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8881) Accumulators not updated for running jobs

2018-03-06 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8881: --- Summary: Accumulators not updated for running jobs Key: FLINK-8881 URL: https://issues.apache.org/jira/browse/FLINK-8881 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8880) Validate configurations for SQL Client

2018-03-06 Thread Xingcan Cui (JIRA)
Xingcan Cui created FLINK-8880: -- Summary: Validate configurations for SQL Client Key: FLINK-8880 URL: https://issues.apache.org/jira/browse/FLINK-8880 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8879) Add concurrent access check to AvroSerializer

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8879: --- Summary: Add concurrent access check to AvroSerializer Key: FLINK-8879 URL: https://issues.apache.org/jira/browse/FLINK-8879 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-8878) Check for concurrent access to Kryo Serializer

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8878: --- Summary: Check for concurrent access to Kryo Serializer Key: FLINK-8878 URL: https://issues.apache.org/jira/browse/FLINK-8878 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-8877) Configure Kryo's log level based on Flink's log level

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8877: --- Summary: Configure Kryo's log level based on Flink's log level Key: FLINK-8877 URL: https://issues.apache.org/jira/browse/FLINK-8877 Project: Flink Issue Type:

[jira] [Created] (FLINK-8876) Improve concurrent access handling in stateful serializers

2018-03-06 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8876: --- Summary: Improve concurrent access handling in stateful serializers Key: FLINK-8876 URL: https://issues.apache.org/jira/browse/FLINK-8876 Project: Flink Issue

[jira] [Created] (FLINK-8875) Watermark tab on Web Interface should display low watermark in ISO8601

2018-03-06 Thread Daniel Harper (JIRA)
Daniel Harper created FLINK-8875: Summary: Watermark tab on Web Interface should display low watermark in ISO8601 Key: FLINK-8875 URL: https://issues.apache.org/jira/browse/FLINK-8875 Project: Flink