[jira] [Created] (FLINK-11343) TaskExecutorTest is unstable on travis

2019-01-15 Thread TisonKun (JIRA)
TisonKun created FLINK-11343: Summary: TaskExecutorTest is unstable on travis Key: FLINK-11343 URL: https://issues.apache.org/jira/browse/FLINK-11343 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-11342) Add example for every built-In TableAPI&SQL Function

2019-01-15 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-11342: --- Summary: Add example for every built-In TableAPI&SQL Function Key: FLINK-11342 URL: https://issues.apache.org/jira/browse/FLINK-11342 Project: Flink Issue Typ

[jira] [Created] (FLINK-11341) Javadoc description does not match the parameter name

2019-01-15 Thread Gongwenzhou (JIRA)
Gongwenzhou created FLINK-11341: --- Summary: Javadoc description does not match the parameter name Key: FLINK-11341 URL: https://issues.apache.org/jira/browse/FLINK-11341 Project: Flink Issue Typ

[jira] [Created] (FLINK-11340) Bump commons-configuration from 1.7 to 1.10

2019-01-15 Thread Fokko Driesprong (JIRA)
Fokko Driesprong created FLINK-11340: Summary: Bump commons-configuration from 1.7 to 1.10 Key: FLINK-11340 URL: https://issues.apache.org/jira/browse/FLINK-11340 Project: Flink Issue Typ

[jira] [Created] (FLINK-11339) Bump exec-maven-plugin from 1.5.0 to 1.6.0

2019-01-15 Thread Fokko Driesprong (JIRA)
Fokko Driesprong created FLINK-11339: Summary: Bump exec-maven-plugin from 1.5.0 to 1.6.0 Key: FLINK-11339 URL: https://issues.apache.org/jira/browse/FLINK-11339 Project: Flink Issue Typ

[jira] [Created] (FLINK-11338) Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2

2019-01-15 Thread Fokko Driesprong (JIRA)
Fokko Driesprong created FLINK-11338: Summary: Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2 Key: FLINK-11338 URL: https://issues.apache.org/jira/browse/FLINK-11338 Project: Flink

[ANNOUNCE] Apache Roadshow Chicago, Call for Presentations

2019-01-15 Thread Trevor Grant
Hello Devs! You're receiving this email because you are subscribed to one or more Apache developer email lists. I’m writing to let you know about an exciting event coming to the Chicago area: The Apache Roadshow Chicago. It will be held May 13th and 14th at three bars in the Logan Square neighb

Issues regarding Table-API

2019-01-15 Thread Elias Saalmann
Hi there, I'm working on the Gradoop project at the University of Leipzig (https://github.com/dbs-leipzig/gradoop). Currently we're using the Batch-API - now we're investigating Table-API as an abstraction for Batch-API. I found 2 issues I want to discuss: 1. I get an error (Error while appl

[jira] [Created] (FLINK-11337) Incorrect watermark in StreaminFileSink BucketAssigner.Context when used in connected stream

2019-01-15 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-11337: Summary: Incorrect watermark in StreaminFileSink BucketAssigner.Context when used in connected stream Key: FLINK-11337 URL: https://issues.apache.org/jira/browse/FLINK-11337

Re: [DISCUSS] Checkpoint Failure process improvement

2019-01-15 Thread vino yang
Hi all, I will try to start coding based on the design document. Any feedback is welcome throughout the process. Best, Vino vino yang 于2019年1月9日周三 上午12:29写道: > Hi all, > > > Currently, the checkpoint's failure handling logic is somewhat confusing > (not focused), which makes some functions on

[SURVEY] Custom RocksDB branch

2019-01-15 Thread Andrey Zagrebin
Dear Flink users and developers! I start this discussion to collect feedback about maintaining a custom RocksDB branch for Flink, if anyone sees any problems with this approach. Are there people who already uses a custom RocksDB client build with RocksDB state backend? As you might already know,

[jira] [Created] (FLINK-11336) Flink HA didn't remove ZK metadata

2019-01-15 Thread shengjk1 (JIRA)
shengjk1 created FLINK-11336: Summary: Flink HA didn't remove ZK metadata Key: FLINK-11336 URL: https://issues.apache.org/jira/browse/FLINK-11336 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-11335) Kafka consumer can not commit offset at checkpoint

2019-01-15 Thread andy hoang (JIRA)
andy hoang created FLINK-11335: -- Summary: Kafka consumer can not commit offset at checkpoint Key: FLINK-11335 URL: https://issues.apache.org/jira/browse/FLINK-11335 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-11333) First-class support for Protobuf types with evolvable schema

2019-01-15 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11333: --- Summary: First-class support for Protobuf types with evolvable schema Key: FLINK-11333 URL: https://issues.apache.org/jira/browse/FLINK-11333 Project: F

[jira] [Created] (FLINK-11334) Migrate enum serializers to use new serialization compatibility abstractions

2019-01-15 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11334: --- Summary: Migrate enum serializers to use new serialization compatibility abstractions Key: FLINK-11334 URL: https://issues.apache.org/jira/browse/FLINK-11334

[jira] [Created] (FLINK-11332) Migrate Kryo-related serializers to use new serialization compatibility abstractions

2019-01-15 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11332: --- Summary: Migrate Kryo-related serializers to use new serialization compatibility abstractions Key: FLINK-11332 URL: https://issues.apache.org/jira/browse/FLINK-11332

[jira] [Created] (FLINK-11331) Fix errors in tableApi.md and functions.md

2019-01-15 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-11331: --- Summary: Fix errors in tableApi.md and functions.md Key: FLINK-11331 URL: https://issues.apache.org/jira/browse/FLINK-11331 Project: Flink Issue Type: Improvem

Re: [DISCUSS] Proposal of external shuffle service

2019-01-15 Thread zhijiang
Hi all, After continuous discussion with Andrey offline, we already reach an agreement for this proposal and co-author the latest google doc under [1]. We plan to create FLIP and sub-tasks by the end of this week, and the first MVP wishes to be covered in FLINK 1.8. Welcome any feedbacks and s

[jira] [Created] (FLINK-11330) Migrate Scala-macro generated serializers to use new serialization compatibility abstractions

2019-01-15 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11330: --- Summary: Migrate Scala-macro generated serializers to use new serialization compatibility abstractions Key: FLINK-11330 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-11329) Migrate all remaining composite serializers to use new serializer snapshot abstraction

2019-01-15 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11329: --- Summary: Migrate all remaining composite serializers to use new serializer snapshot abstraction Key: FLINK-11329 URL: https://issues.apache.org/jira/browse/FLINK-113

[jira] [Created] (FLINK-11328) Migrate all parameterless serializers / TypeSerializerSingleton's to use new serializer snapshot abstractions

2019-01-15 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11328: --- Summary: Migrate all parameterless serializers / TypeSerializerSingleton's to use new serializer snapshot abstractions Key: FLINK-11328 URL: https://issues.apache.or

[jira] [Created] (FLINK-11327) Migrate all remaining Flink serializers' snapshot classes to the new TypeSerializerSnapshot / TypeSerializerSchemaCompatibility abstractions

2019-01-15 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11327: --- Summary: Migrate all remaining Flink serializers' snapshot classes to the new TypeSerializerSnapshot / TypeSerializerSchemaCompatibility abstractions Key: FLINK-11327

Re: [DISCUSS] Bot for stale PRs on GitHub

2019-01-15 Thread Aljoscha Krettek
@Chesnay I agree that we did not handle PRs well at all in the past and we need to change more things than adding a stale bot to address them. I think, however, that a state bot is one piece of the solution for this because it makes the staleness of PRs more apparent. Plus, it will clean up thos

[jira] [Created] (FLINK-11326) Using offsets to adjust windows to timezones UTC-8 throws IllegalArgumentException

2019-01-15 Thread TANG Wen-hui (JIRA)
TANG Wen-hui created FLINK-11326: Summary: Using offsets to adjust windows to timezones UTC-8 throws IllegalArgumentException Key: FLINK-11326 URL: https://issues.apache.org/jira/browse/FLINK-11326 Pr