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

If ListShards() gives all the info that Flink needs, +1 on switching. DescribeStreams() has a limitation of 5 requests/sec, which is pretty bad But, I believe the goal of switching APIs should be *making Flink jobs that read from Kinesis more stable*, rather than having faster shard discovery

Re: StreamSQL queriable state

Hi, Timo: I've read your QueryableStateTableSink implementation and that basically implementes what I want to do. I also want to extend SQL client so that user can do point query against the table sink. Do we still need a design doc for that? It seems that I just need to finish the left part and do

[jira] [Created] (FLINK-8856) Move all interrupt() calls to TaskCanceler

Stephan Ewen created FLINK-8856: --- Summary: Move all interrupt() calls to TaskCanceler Key: FLINK-8856 URL: https://issues.apache.org/jira/browse/FLINK-8856 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8855) SQL client result serving gets stuck in result-mode=table

Fabian Hueske created FLINK-8855: Summary: SQL client result serving gets stuck in result-mode=table Key: FLINK-8855 URL: https://issues.apache.org/jira/browse/FLINK-8855 Project: Flink Issue

[jira] [Created] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

Fabian Hueske created FLINK-8854: Summary: Mapping of SchemaValidator.deriveFieldMapping() is incorrect. Key: FLINK-8854 URL: https://issues.apache.org/jira/browse/FLINK-8854 Project: Flink

[jira] [Created] (FLINK-8853) SQL Client cannot emit query results that contain a rowtime attribute

Fabian Hueske created FLINK-8853: Summary: SQL Client cannot emit query results that contain a rowtime attribute Key: FLINK-8853 URL: https://issues.apache.org/jira/browse/FLINK-8853 Project: Flink

[jira] [Created] (FLINK-8852) SQL Client does not work with new FLIP-6 mode

Fabian Hueske created FLINK-8852: Summary: SQL Client does not work with new FLIP-6 mode Key: FLINK-8852 URL: https://issues.apache.org/jira/browse/FLINK-8852 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8851) SQL Client fails if same file is used as default and env configuration

Fabian Hueske created FLINK-8851: Summary: SQL Client fails if same file is used as default and env configuration Key: FLINK-8851 URL: https://issues.apache.org/jira/browse/FLINK-8851 Project: Flink

[jira] [Created] (FLINK-8850) SQL Client does not support Event-time

Fabian Hueske created FLINK-8850: Summary: SQL Client does not support Event-time Key: FLINK-8850 URL: https://issues.apache.org/jira/browse/FLINK-8850 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8849) Wrong link from concepts/runtime to doc on chaining

Ken Krugler created FLINK-8849: -- Summary: Wrong link from concepts/runtime to doc on chaining Key: FLINK-8849 URL: https://issues.apache.org/jira/browse/FLINK-8849 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8848) bin/start-cluster.sh won't start jobmanager on master machine.

Yesheng Ma created FLINK-8848: - Summary: bin/start-cluster.sh won't start jobmanager on master machine. Key: FLINK-8848 URL: https://issues.apache.org/jira/browse/FLINK-8848 Project: Flink Issue