Docker images

2017-12-19 Thread Felix Cheung
Hi! Is there a reason the official docker images https://hub.docker.com/r/_/flink/ Has sources in a different repo https://github.com/docker-flink/docker-flink ?

Re: Storing large lists into state per key

2017-12-19 Thread Jan Lukavský
Hi, I filled a JIRA issue and pushed a PR for this. https://issues.apache.org/jira/browse/FLINK-8297 Best,  Jan On 12/14/2017 11:13 AM, Stephan Ewen wrote: Hi Jan! One could implement the RocksDB ListState like you suggested. We did it the current way because that pattern is actually

[jira] [Created] (FLINK-8297) RocksDBListState stores whole list in single byte[]

2017-12-19 Thread JIRA
Jan Lukavský created FLINK-8297: --- Summary: RocksDBListState stores whole list in single byte[] Key: FLINK-8297 URL: https://issues.apache.org/jira/browse/FLINK-8297 Project: Flink Issue Type:

[jira] [Created] (FLINK-8296) Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection

2017-12-19 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8296: -- Summary: Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection Key: FLINK-8296 URL: https://issues.apache.org/jira/browse/FLINK-8296

Using SQL with dynamic tables where rows are updated

2017-12-19 Thread Ghassan Yammine
Hello, I’m knew to Flink and I need some help. I’d like to use the SQL API for processing an incoming stream that has the following characteristics: * Each stream record has a key * The record can be updated * The record is of the form: reviewId -> (productId, rating) For the

Re: [DISCUSS] Service Authorization (SSL client authentication)

2017-12-19 Thread Eron Wright
Folks, what is the next step to formally submit a FLIP?i.e. assign a number, drive to 'accepted' state? Given the introduction of new RPC and REST endpoints with FLIP-6, now is a good time to agree on the approach to securing Flink. Thanks! Eron On Mon, Nov 27, 2017 at 11:52 AM, Eron Wright

[DISCUSS] FLIP-24 - SQL Client

2017-12-19 Thread Timo Walther
Hey everyone, in the past, the community already asked about having a way to write Flink jobs without extensive programming skills. During the last year we have put a lot of effort in the core of our Table & SQL API. Now it is time to improve the tooling around it as well and make Flink more

[jira] [Created] (FLINK-8295) Netty shading does not work properly

2017-12-19 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8295: --- Summary: Netty shading does not work properly Key: FLINK-8295 URL: https://issues.apache.org/jira/browse/FLINK-8295 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8294) Missing examples/links in Data Sink docs

2017-12-19 Thread Julio Biason (JIRA)
Julio Biason created FLINK-8294: --- Summary: Missing examples/links in Data Sink docs Key: FLINK-8294 URL: https://issues.apache.org/jira/browse/FLINK-8294 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8293) Rework Flink's type and serialization docs

2017-12-19 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8293: --- Summary: Rework Flink's type and serialization docs Key: FLINK-8293 URL: https://issues.apache.org/jira/browse/FLINK-8293 Project: Flink Issue Type:

[jira] [Created] (FLINK-8292) Remove unnecessary force cast in DataStreamSource

2017-12-19 Thread Matrix42 (JIRA)
Matrix42 created FLINK-8292: --- Summary: Remove unnecessary force cast in DataStreamSource Key: FLINK-8292 URL: https://issues.apache.org/jira/browse/FLINK-8292 Project: Flink Issue Type:

[jira] [Created] (FLINK-8291) For security, Job Manager web UI should be accessed with username/password

2017-12-19 Thread Lynch Lee (JIRA)
Lynch Lee created FLINK-8291: Summary: For security, Job Manager web UI should be accessed with username/password Key: FLINK-8291 URL: https://issues.apache.org/jira/browse/FLINK-8291 Project: Flink