Flink buffer request blocking leads to low performance

Hi all, Flink buffer request blocking leads to low performance https://stackoverflow.com/q/48293248/6881117?sem=2 Thanks Best Regards. Alvin

Re: difference b/t filesystem and connector-filesystem

Hi, question on this page: "You need to point Flink to a valid Hadoop configuration..."https://ci.apache.org/projects/flink/flink-docs-release-1.4/ops/deployment/aws.html#s3-simple-storage-service How do you point Flink to the Hadoop config? On Saturday, January 13, 2018, 4:56:15 AM PST, Till

[jira] [Created] (FLINK-8441) serialize values and value separator directly to stream in RocksDBListState

Bowen Li created FLINK-8441: --- Summary: serialize values and value separator directly to stream in RocksDBListState Key: FLINK-8441 URL: https://issues.apache.org/jira/browse/FLINK-8441 Project: Flink

Re: difference b/t filesystem and connector-filesystem

Thanks, is there a sample project that outputs a Flink example app (ie WordCount) to S3? On Saturday, January 13, 2018, 4:56:15 AM PST, Till Rohrmann wrote: Hi, the flink-connector-filesystem contains the BucketingSink which is a connector with which you can write your data to a file

[jira] [Created] (FLINK-8440) Create Gitter Chanel for Flink users

Josh Lemer created FLINK-8440: - Summary: Create Gitter Chanel for Flink users Key: FLINK-8440 URL: https://issues.apache.org/jira/browse/FLINK-8440 Project: Flink Issue Type: Task Rep

Re: [DISCUSS] Releasing Flink 1.4.1

@Jincheng: Yes, I think we should include the two Table API PRs. Am 1/16/18 um 5:28 PM schrieb jincheng sun: Thanks for starting the discussion Gordon. I think it is better to add the commits of `https://issues.apache.org/jira/browse/FLINK-8355` and `https://issues.apache.org/jira/browse/FLIN

Re: [DISCUSS] Releasing Flink 1.4.1

Thanks for starting the discussion Gordon. I think it is better to add the commits of `https://issues.apache.org/jira/browse/FLINK-8355` and `https://issues.apache.org/jira/browse/FLINK-8325` for table API & SQL. Because these two issues fixed commonly used `count (*)` bug and improve of non-gro

Re: [DISCUSS] Releasing Flink 1.4.1

Please include these two bugs : https://issues.apache.org/jira/browse/FLINK-7756 https://issues.apache.org/jira/browse/FLINK-7760 Unable to restore from savepoint with CEP. -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[jira] [Created] (FLINK-8439) Document using a custom AWS Credentials Provider with flink-3s-fs-hadoop

Dyana Rose created FLINK-8439: - Summary: Document using a custom AWS Credentials Provider with flink-3s-fs-hadoop Key: FLINK-8439 URL: https://issues.apache.org/jira/browse/FLINK-8439 Project: Flink

[jira] [Created] (FLINK-8438) Ensure that implicit Scala TypeInformation works in Eclipse IDE

Timo Walther created FLINK-8438: --- Summary: Ensure that implicit Scala TypeInformation works in Eclipse IDE Key: FLINK-8438 URL: https://issues.apache.org/jira/browse/FLINK-8438 Project: Flink

Re: [DISCUSS] Releasing Flink 1.4.1

Taken from another ML thread some users would appreciate it if we included the savepoint trigger handler i implemented here

[jira] [Created] (FLINK-8437) SideOutput() API is ambiguous

Chesnay Schepler created FLINK-8437: --- Summary: SideOutput() API is ambiguous Key: FLINK-8437 URL: https://issues.apache.org/jira/browse/FLINK-8437 Project: Flink Issue Type: Bug C

Adding expire option to redis connector

Hi , We have a use that we need to collect some Meta data window it and group it by some rules. Each window can create different set of keys and value ,therefor the ability to set expire could be very helpful . i started to change the code , https://github.com/miko-code/bahir-flink/tree/master

[jira] [Created] (FLINK-8436) Allow implementing both RetractTableSink and BatchTableSink in one class

Timo Walther created FLINK-8436: --- Summary: Allow implementing both RetractTableSink and BatchTableSink in one class Key: FLINK-8436 URL: https://issues.apache.org/jira/browse/FLINK-8436 Project: Flink