[jira] [Created] (FLINK-12042) RocksDBStateBackend mistakenly uses default filesystem

Paul Lin created FLINK-12042: Summary: RocksDBStateBackend mistakenly uses default filesystem Key: FLINK-12042 URL: https://issues.apache.org/jira/browse/FLINK-12042 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-27: Refactor Source Interface

This proposal mentioned that SplitEnumerator might run on the JobManager or in a single task on a TaskManager. if enumerator is a single task on a taskmanager, then the job DAG can never been embarrassingly parallel anymore. That will nullify the leverage of fine-grained recovery for

Re: [DISCUSS] Python (and Non-JVM) Language Support in Flink

Hi everyone, Sorry to join in this discussion late. Thanks to Xianda Ke for initiating this discussion. I also enjoy the discussions by Max, Austin, Thomas, Shaoxuan and others. Recently, I did feel the desire of the community and Flink users for Python support. Stephan also pointed out in the

[jira] [Created] (FLINK-12041) Introduce ResettableExternalBuffer to blink batch

Jingsong Lee created FLINK-12041: Summary: Introduce ResettableExternalBuffer to blink batch Key: FLINK-12041 URL: https://issues.apache.org/jira/browse/FLINK-12041 Project: Flink Issue

Re: [VOTE] Release 1.8.0, release candidate #4

By now, I'm reasonably sure that the test instabilities on the end-to-end test are only instabilities. I pushed changes to increase timeouts to make the tests more stable. As in any project, there will always be bugs but I think we could release this RC4 and be reasonably sure that it works

[jira] [Created] (FLINK-12040) Remove unused akka dependencies in pom.xml

TisonKun created FLINK-12040: Summary: Remove unused akka dependencies in pom.xml Key: FLINK-12040 URL: https://issues.apache.org/jira/browse/FLINK-12040 Project: Flink Issue Type: Improvement

[DISCUSS] FLIP-37: Rework of the Table API Type System (Part 1)

Hi everyone, some of you might have already read FLIP-32 [1] where we've described an approximate roadmap of how to handle the big Blink SQL contribution and how we can make the Table & SQL API equally important to the existing DataStream API. As mentioned there (Advance the API and Unblock

Re: [DISCUSS] Introduction of a Table API Java Expression DSL

Hi all, thanks for the great feedback! I see a clear majority for a new Java DSL. I agree with Dawid that we should aim for 1.9. Compared to other efforts, this is a relatively small change ;-) I will further develop my protoype and come back to you once I have a production-ready solution.

[jira] [Created] (FLINK-12039) Remove ASSIGNED_SLOT_UPDATER in Execution.tryAssignResource

Andrey Zagrebin created FLINK-12039: --- Summary: Remove ASSIGNED_SLOT_UPDATER in Execution.tryAssignResource Key: FLINK-12039 URL: https://issues.apache.org/jira/browse/FLINK-12039 Project: Flink

[jira] [Created] (FLINK-12038) YARNITCase stalls on travis

Chesnay Schepler created FLINK-12038: Summary: YARNITCase stalls on travis Key: FLINK-12038 URL: https://issues.apache.org/jira/browse/FLINK-12038 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12037) High parallelism E2E test failed on Travis

Chesnay Schepler created FLINK-12037: Summary: High parallelism E2E test failed on Travis Key: FLINK-12037 URL: https://issues.apache.org/jira/browse/FLINK-12037 Project: Flink Issue

[jira] [Created] (FLINK-12036) Simplify ExecutionGraph by removing legacy concurrency code

Till Rohrmann created FLINK-12036: - Summary: Simplify ExecutionGraph by removing legacy concurrency code Key: FLINK-12036 URL: https://issues.apache.org/jira/browse/FLINK-12036 Project: Flink

[jira] [Created] (FLINK-12035) StreamingFileSink E2E failed on Travis

Chesnay Schepler created FLINK-12035: Summary: StreamingFileSink E2E failed on Travis Key: FLINK-12035 URL: https://issues.apache.org/jira/browse/FLINK-12035 Project: Flink Issue Type:

[jira] [Created] (FLINK-12034) KafkaITCase.testAllDeletes failed on Travis

Till Rohrmann created FLINK-12034: - Summary: KafkaITCase.testAllDeletes failed on Travis Key: FLINK-12034 URL: https://issues.apache.org/jira/browse/FLINK-12034 Project: Flink Issue Type:

[jira] [Created] (FLINK-12033) KafkaITCase.testCancelingFullTopic failed on Travis

Till Rohrmann created FLINK-12033: - Summary: KafkaITCase.testCancelingFullTopic failed on Travis Key: FLINK-12033 URL: https://issues.apache.org/jira/browse/FLINK-12033 Project: Flink Issue

[jira] [Created] (FLINK-12032) KafkaProducerAtLeastOnceITCase failed to bind to address

Till Rohrmann created FLINK-12032: - Summary: KafkaProducerAtLeastOnceITCase failed to bind to address Key: FLINK-12032 URL: https://issues.apache.org/jira/browse/FLINK-12032 Project: Flink

[jira] [Created] (FLINK-12031) the registerFactory method of TypeExtractor Should not be private

frank wang created FLINK-12031: -- Summary: the registerFactory method of TypeExtractor Should not be private Key: FLINK-12031 URL: https://issues.apache.org/jira/browse/FLINK-12031 Project: Flink

[jira] [Created] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable

Aljoscha Krettek created FLINK-12030: Summary: KafkaITCase.testMultipleSourcesOnePartition is unstable Key: FLINK-12030 URL: https://issues.apache.org/jira/browse/FLINK-12030 Project: Flink

Re: [VOTE] Release 1.8.0, release candidate #4

+1 （non-binding) • checked signature and checksum  ok • mvn clean package -DskipTests ok • Run job on yarn ok • Test state migration with POJO type (both heap and rocksdb) ok • - 1.6 -> 1.8 • - 1.7 -> 1.8 • - 1.8 -> 1.8 Best, Congxian On Mar 27, 2019, 10:26 +0800, vino yang , wrote: > +1