[jira] [Created] (FLINK-12059) How to increase outputQueueLength/inputQueueLength

WuXiZao created FLINK-12059: --- Summary: How to increase outputQueueLength/inputQueueLength Key: FLINK-12059 URL: https://issues.apache.org/jira/browse/FLINK-12059 Project: Flink Issue Type:

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

Maybe to give some background about Dawid's latest email: Kurt raised some good points regarding the conversion of data types at the boundaries of the API and SPI. After that, Dawid and I had a long discussion of how users can define those boundaries in a nicer way. The outcome of this

[jira] [Created] (FLINK-12051) TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally.

Kostas Kloudas created FLINK-12051: -- Summary: TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally. Key: FLINK-12051 URL: https://issues.apache.org/jira/browse/FLINK-12051

[jira] [Created] (FLINK-12052) Redistributed unevenly sized result partitions

ryantaocer created FLINK-12052: -- Summary: Redistributed unevenly sized result partitions Key: FLINK-12052 URL: https://issues.apache.org/jira/browse/FLINK-12052 Project: Flink Issue Type:

[jira] [Created] (FLINK-12053) Calculation of parallelism based on metrics/signals

ryantaocer created FLINK-12053: -- Summary: Calculation of parallelism based on metrics/signals Key: FLINK-12053 URL: https://issues.apache.org/jira/browse/FLINK-12053 Project: Flink Issue Type:

[jira] [Created] (FLINK-12055) Remove legacy class ActorSystemLoader

TisonKun created FLINK-12055: Summary: Remove legacy class ActorSystemLoader Key: FLINK-12055 URL: https://issues.apache.org/jira/browse/FLINK-12055 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12056) Remove legacy methods in LeaderRetrievalUtils

TisonKun created FLINK-12056: Summary: Remove legacy methods in LeaderRetrievalUtils Key: FLINK-12056 URL: https://issues.apache.org/jira/browse/FLINK-12056 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12058) Cancel checkpoint operations belonging to a discarded/aborted checkpoint

Till Rohrmann created FLINK-12058: - Summary: Cancel checkpoint operations belonging to a discarded/aborted checkpoint Key: FLINK-12058 URL: https://issues.apache.org/jira/browse/FLINK-12058 Project:

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

Another big +1 from my side. Thank you Timo for preparing the document! I really look forward for this to have a standardized way of type handling. This should solve loads of problems. I really like the separation of logical type from its physical representation, I think we should aim to

[jira] [Created] (FLINK-12057) Refactor MemoryLogger to accept termination future instead of ActorSystem

Chesnay Schepler created FLINK-12057: Summary: Refactor MemoryLogger to accept termination future instead of ActorSystem Key: FLINK-12057 URL: https://issues.apache.org/jira/browse/FLINK-12057

[jira] [Created] (FLINK-12047) Savepoint connector to read / write / process savepoints

Tzu-Li (Gordon) Tai created FLINK-12047: --- Summary: Savepoint connector to read / write / process savepoints Key: FLINK-12047 URL: https://issues.apache.org/jira/browse/FLINK-12047 Project: Flink

[jira] [Created] (FLINK-12048) ZooKeeperHADispatcherTest failed on Travis

Chesnay Schepler created FLINK-12048: Summary: ZooKeeperHADispatcherTest failed on Travis Key: FLINK-12048 URL: https://issues.apache.org/jira/browse/FLINK-12048 Project: Flink Issue

[jira] [Created] (FLINK-12049) ClassLoaderUtilsTest fails on Java 9

Chesnay Schepler created FLINK-12049: Summary: ClassLoaderUtilsTest fails on Java 9 Key: FLINK-12049 URL: https://issues.apache.org/jira/browse/FLINK-12049 Project: Flink Issue Type:

[jira] [Created] (FLINK-12050) BlockingShutdownTest fails on Java 9

Chesnay Schepler created FLINK-12050: Summary: BlockingShutdownTest fails on Java 9 Key: FLINK-12050 URL: https://issues.apache.org/jira/browse/FLINK-12050 Project: Flink Issue Type: Bug

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

Big +1 to this! I left some comments in google doc. Best, Kurt On Wed, Mar 27, 2019 at 11:32 PM Timo Walther wrote: > 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

[jira] [Created] (FLINK-12044) Flink CEP discards events as late if they have timestamps <= 0

Arseniy Tashoyan created FLINK-12044: Summary: Flink CEP discards events as late if they have timestamps <= 0 Key: FLINK-12044 URL: https://issues.apache.org/jira/browse/FLINK-12044 Project:

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

Hi Steven, Thank you for the feedback. Please take a look at the document FLIP-27 which is updated recently. A lot of details of enumerator were added in this document. I think it would help. Steven Wu

[jira] [Created] (FLINK-12045) Support force migration between incompatible state schemas/serializers

Yu Li created FLINK-12045: - Summary: Support force migration between incompatible state schemas/serializers Key: FLINK-12045 URL: https://issues.apache.org/jira/browse/FLINK-12045 Project: Flink

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

@Shaoxuan The drop in the serializerAvro benchmark, as explained earlier in previous voting threads of earlier RCs, was due to a slower job initialization phase caused by slower deserialization of the AvroSerializer. Piotr also pointed out that after the number of records was increased in the

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

+1 (binding) Functional checks: - Built Flink from source (`mvn clean verify`) locally, with success - Ran end-to-end tests locally for 5 times in a loop, no attempts failed (Hadoop 2.8.4, Scala 2.12) - Manually tested state schema evolution for POJO. Besides the tests that @Congxian already

[jira] [Created] (FLINK-12046) Increase records per invocation for serializerAvro benchmark to stabilize it

Yu Li created FLINK-12046: - Summary: Increase records per invocation for serializerAvro benchmark to stabilize it Key: FLINK-12046 URL: https://issues.apache.org/jira/browse/FLINK-12046 Project: Flink

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

Hi Shaoxuan & Jincheng, Thanks for driving this initiative. Python would be a very big add-on for flink adoption in data science world. One additional suggestion is you may need to think about how to transfer flink Table to pandas dataframe which is a very popular library in python. And you may

Bump up the shaded dependency version

Hi, all Is there some way to bump up the version of shaded jars like flink-shaded-jackson? Or is there someone can deal with this Best, Zhang

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

Thanks @Timo for starting this effort and preparing the document :-) I took a pass and left some comments. I also very much like the idea of the DataType and LogicalType separation. As explained in the doc, we've also been looking into ways to improve the type system so a huge +1 on our side.

[jira] [Created] (FLINK-12060) Unify change pom version scripts

Ufuk Celebi created FLINK-12060: --- Summary: Unify change pom version scripts Key: FLINK-12060 URL: https://issues.apache.org/jira/browse/FLINK-12060 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12054) HBaseConnectorITCase fails on Java 9

Chesnay Schepler created FLINK-12054: Summary: HBaseConnectorITCase fails on Java 9 Key: FLINK-12054 URL: https://issues.apache.org/jira/browse/FLINK-12054 Project: Flink Issue Type:

[jira] [Created] (FLINK-12061) Add more window operator contract tests to table runtime

Kurt Young created FLINK-12061: -- Summary: Add more window operator contract tests to table runtime Key: FLINK-12061 URL: https://issues.apache.org/jira/browse/FLINK-12061 Project: Flink Issue

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

-1 (non-binding) - Ran integration tests locally (1000+) of our flink job, all succeeded. - Attempted to run job on hadoop, failed. It failed because we have a firewall in place and we cannot set the rest port to a specific port/port range. Unless I am mistaken, it seems like FLINK-11081 broke

[jira] [Created] (FLINK-12043) Null value check in array serializers classes

Quan Shi created FLINK-12043: Summary: Null value check in array serializers classes Key: FLINK-12043 URL: https://issues.apache.org/jira/browse/FLINK-12043 Project: Flink Issue Type: Bug

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

Hi jincheng, Thanks for activating this discussion again. I personally look forward to your design draft. Best, Vino jincheng sun 于2019年3月28日周四 下午12:16写道： > Hi everyone, > Sorry to join in this discussion late. > > Thanks to Xianda Ke for initiating this discussion. I also enjoy the >