You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [RESULT][VOTE] Clean up and reorganize the JIRA components - posted by Kurt Young <yk...@gmail.com> on 2019/03/01 01:15:06 UTC, 1 replies.
- Re: Recommended module for connector ratelimiting? - posted by Lakshmi Gururaja Rao <lr...@lyft.com.INVALID> on 2019/03/01 01:29:04 UTC, 1 replies.
- Re: [DISCUSS] Flink framework and user log separation - posted by vino yang <ya...@gmail.com> on 2019/03/01 02:44:22 UTC, 0 replies.
- Permission to apply for contributor - posted by yelun <98...@qq.com> on 2019/03/01 07:43:29 UTC, 1 replies.
- Flink Custom SourceFunction and SinkFunction - posted by Siew Wai Yow <wa...@hotmail.com> on 2019/03/01 08:39:56 UTC, 1 replies.
- Some dev questions - posted by Flavio Pompermaier <po...@okkam.it> on 2019/03/01 10:13:14 UTC, 2 replies.
- [jira] [Created] (FLINK-11789) Checkpoint directories are not cleaned up after job termination - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/01 13:09:00 UTC, 0 replies.
- Refactoring of FlinkKafkaProducer - posted by Александр <sa...@gmail.com> on 2019/03/01 13:14:53 UTC, 0 replies.
- [jira] [Created] (FLINK-11790) Introduce basic Flink RelNode interface - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/01 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11791) Describe how to build Flink with Hadoop in build guide - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/03/01 15:04:00 UTC, 0 replies.
- [ANNOUNCE] Update on Flink 1.8 Release Progress - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/01 15:43:48 UTC, 2 replies.
- Re: [DISCUSS] Improve the flinkbot - posted by Robert Metzger <rm...@apache.org> on 2019/03/01 16:37:53 UTC, 15 replies.
- [jira] [Created] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/03/01 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/03/01 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11794) Allow compression of row format files created by StreamingFileSink - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2019/03/02 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11795) Introduce DataStream nodes and rules for batch and stream - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/02 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11796) Remove Snapshotable interface - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/02 19:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11797) Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/03/03 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11798) Incorrect Kubernetes Documentation - posted by "Pritesh Patel (JIRA)" <ji...@apache.org> on 2019/03/03 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11799) KryoSerializer/OperatorChain ignores copy failure resulting in NullPointerException - posted by "Jason Kania (JIRA)" <ji...@apache.org> on 2019/03/03 22:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11800) Move table-planner-blink type to table-runtime-blink - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/04 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11801) Port SqlParserException to flink-table-common - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/04 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11802) Create TypeInfo and TypeSerializer for blink data format - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/04 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11803) Create FlinkTypeFactory for Blink - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/04 02:50:00 UTC, 0 replies.
- [DISCUSS] Introducing Builder in FlinkKafkaProducer - posted by Александр <sa...@gmail.com> on 2019/03/04 07:49:39 UTC, 3 replies.
- [jira] [Created] (FLINK-11804) Make sure the CloseableRegistry used in backend builder is registered with task - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/04 09:23:00 UTC, 0 replies.
- Contributor permission application - posted by zenppl liu <ze...@gmail.com> on 2019/03/04 09:29:08 UTC, 9 replies.
- Contributor permission - posted by 张大伟 <lo...@gmail.com> on 2019/03/04 11:30:59 UTC, 1 replies.
- [jira] [Created] (FLINK-11805) A Common External Shuffle Service Framework - posted by "MalcolmSanders (JIRA)" <ji...@apache.org> on 2019/03/04 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11806) Import shaded jetcd - posted by "MalcolmSanders (JIRA)" <ji...@apache.org> on 2019/03/04 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11807) Implement etcd based LeaderElectionService and LeaderRetrievalService - posted by "MalcolmSanders (JIRA)" <ji...@apache.org> on 2019/03/04 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11808) etcd based SharedCount or sequencer - posted by "MalcolmSanders (JIRA)" <ji...@apache.org> on 2019/03/04 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11809) Implement etcd based StateHandleStore - posted by "MalcolmSanders (JIRA)" <ji...@apache.org> on 2019/03/04 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory - posted by "MalcolmSanders (JIRA)" <ji...@apache.org> on 2019/03/04 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore - posted by "MalcolmSanders (JIRA)" <ji...@apache.org> on 2019/03/04 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11812) Composite etcd based HighAvailability components - posted by "MalcolmSanders (JIRA)" <ji...@apache.org> on 2019/03/04 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11813) Standby per job mode Dispatchers don't know job's JobSchedulingStatus - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/04 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11815) Support execution with static resources (Flip-6): E.g. spreading tasks across available set of TMs - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/03/04 15:46:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11814) Changes of FLINK-11516 causes compilation failure - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/04 15:46:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11816) Changes of FLINK-11516 causes compilation failure - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/04 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11817) DataStream API Tutorial uses deprecated fold function - posted by "Michael Holler (JIRA)" <ji...@apache.org> on 2019/03/04 21:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11818) Provide pipe transformation function for DataSet API - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/03/05 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11819) Additional attribute for order by not support by flink sql, but told supported in doc - posted by "Lifei Chen (JIRA)" <ji...@apache.org> on 2019/03/05 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11820) KafkaDeserializationSchemaWrapper should filter record which value is null - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2019/03/05 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11821) fix the error package location of KafkaDeserializationSchemaWrapper.java file - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2019/03/05 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11822) Introduce Flink metadata handler - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/05 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11823) TrySerializer#duplicate does not create a proper duplication - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/03/05 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11824) Event-time attribute cannot have same name as in original format - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2019/03/05 10:48:00 UTC, 0 replies.
- Re: [DISCUSS] -- Need to be able to access multiple s3 buckets with different authentication from within a single job - posted by Stephan Ewen <se...@apache.org> on 2019/03/05 10:50:07 UTC, 0 replies.
- [jira] [Created] (FLINK-11825) Resolve name clash of StateTTL TimeCharacteristic class - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2019/03/05 10:58:00 UTC, 0 replies.
- [DISCUSS] Create a Flink ecosystem website - posted by Becket Qin <be...@gmail.com> on 2019/03/05 11:03:19 UTC, 24 replies.
- [jira] [Created] (FLINK-11826) Kafka09ITCase.testRateLimitedConsumer fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/05 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11827) Introduce DataFormatConverters to convert internal data format and java format - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/05 13:27:00 UTC, 0 replies.
- re:WELCOME to dev@flink.apache.org - posted by 107565445 <10...@qq.com> on 2019/03/05 13:30:40 UTC, 1 replies.
- Error on importing flink source code into Intellij - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/03/05 15:15:50 UTC, 3 replies.
- [jira] [Created] (FLINK-11828) [HA] Test instability: ZooKeeperHADispatcherTest.testStandbyDispatcherJobRecovery - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/03/05 16:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11829) [checkpoint] FsCheckpointStateOutputStream might store state in files even state size below fileStateThreshold - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/03/05 17:36:04 UTC, 0 replies.
- Re: [DISCUSS] FLIP-33: Terminate/Suspend Job with Savepoint - posted by Elias Levy <fe...@gmail.com> on 2019/03/05 23:26:55 UTC, 4 replies.
- [jira] [Created] (FLINK-11830) Introduce CodeGeneratorContext to maintain reusable statements for code generation - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/06 03:16:02 UTC, 0 replies.
- [jira] [Created] (FLINK-11831) Separate CodeGeneratorContext for different generation targets - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/06 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11832) Convert some InternalType property related functions to InternalType's method - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/06 04:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11833) Cleanup unnecessary createKeyedStateBackend methods in StateBackend - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/06 06:53:02 UTC, 0 replies.
- [jira] [Created] (FLINK-11834) Introduce flink logical relational nodes - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/06 07:55:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/03/06 08:23:00 UTC, 0 replies.
- Apply for rights of contributor - posted by zoudan <zo...@163.com> on 2019/03/06 08:42:53 UTC, 1 replies.
- Apply for rights for contributor - posted by zoudan <zo...@163.com> on 2019/03/06 08:49:19 UTC, 3 replies.
- Re: [DISCUSS] A more restrictive JIRA workflow - posted by ZiLi Chen <wa...@gmail.com> on 2019/03/06 10:02:17 UTC, 4 replies.
- [jira] [Created] (FLINK-11836) Update NOTICE-binary and licenses-binary for Flink 1.8.0 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/03/06 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11837) Improve blink internal data foramt - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/06 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11838) Create RecoverableWriter for GCS - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/03/06 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11839) Introduce the rest flink logical relational nodes - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/06 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11840) Introduce FlinkLogicalSnapshot - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/06 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11841) Introduce FlinkLogicalSemiJoin - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/06 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11842) Introduce FlinkLogicalMatch - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/06 13:41:00 UTC, 0 replies.
- 4 Apache Events in 2019: DC Roadshow soon; next up Chicago, Las Vegas, and Berlin! - posted by Rich Bowen <rb...@apache.org> on 2019/03/06 14:00:23 UTC, 0 replies.
- [DISCUSS] Using Guava in Flink "core" packages - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/06 14:10:31 UTC, 9 replies.
- JobManager scale limitation - Slow S3 checkpoint deletes - posted by Jamie Grier <jg...@lyft.com.INVALID> on 2019/03/06 14:40:09 UTC, 6 replies.
- [jira] [Created] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/06 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11844) Simplify OVER window Table API classes - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/03/06 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11845) Drop unused InfoMessage - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/03/06 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11846) Duplicate job submission delete HA files - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/06 17:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11847) Docker job-specific image creation instruction make reference to --job-jar parameter that does not actually exist in the script - posted by "Frank Wilson (JIRA)" <ji...@apache.org> on 2019/03/06 17:35:00 UTC, 0 replies.
- Re: [ANNOUNCEMENT] March 2019 Bay Area Apache Flink Meetup - posted by Xuefu Zhang <xu...@apache.org> on 2019/03/06 22:09:58 UTC, 2 replies.
- Fwd: DataStream EventTime last data cannot be output? - posted by 刘 文 <th...@yahoo.com.INVALID> on 2019/03/07 00:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-11848) Delete outdated kafka topics caused UNKNOWN_TOPIC_EXCEPTIION - posted by "Shengnan YU (JIRA)" <ji...@apache.org> on 2019/03/07 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11849) The flink document about checkpoint and savepoint may be wrong - posted by "xulongfetion (JIRA)" <ji...@apache.org> on 2019/03/07 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11850) ZooKeeperHaServicesTest#testSimpleCloseAndCleanupAllData fails on Travis - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/03/07 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11851) ClusterEntrypoint provides wrong executor to HaServices - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/07 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11852) Improve Processing function example - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2019/03/07 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11853) Allow /jars/:jarid/plan as a POST request too - posted by "Stephen Connolly (JIRA)" <ji...@apache.org> on 2019/03/07 12:34:00 UTC, 0 replies.
- 回复:Fwd: DataStream EventTime last data cannot be output? - posted by 何春平 <24...@qq.com> on 2019/03/07 12:42:22 UTC, 0 replies.
- [jira] [Created] (FLINK-11854) Introduce batch physical nodes - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/07 13:35:00 UTC, 0 replies.
- Re: Sharing state between subtasks - posted by Gerard Garcia <ge...@talaia.io> on 2019/03/07 14:52:47 UTC, 1 replies.
- [jira] [Created] (FLINK-11855) Race condition in EmbeddedLeaderService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/07 15:36:00 UTC, 0 replies.
- I want to be contributor - posted by leocook <le...@163.com> on 2019/03/08 01:56:29 UTC, 1 replies.
- [jira] [Created] (FLINK-11856) Introduce BinaryHashTable and LongHashTable to batch table runtime - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/08 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11857) Introduce BinaryExternalSorter to batch table runtime - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/08 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11858) Introduce block compressor/decompressor for batch table runtime - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/08 04:06:00 UTC, 0 replies.
- apply for contributor permission - posted by 何春平 <ch...@gmail.com> on 2019/03/08 06:28:59 UTC, 5 replies.
- [jira] [Created] (FLINK-11859) Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly - posted by "Yingjie Cao (JIRA)" <ji...@apache.org> on 2019/03/08 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11860) Remove all the usage of deprecated unit-provided memory options in docs and scripts - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/03/08 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11861) JobMasterTriggerSavepointIT case is not executed - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2019/03/08 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11862) 在同一条流上进行多次不同的sql,第二个sql的where条件不可用 - posted by "zhengbm (JIRA)" <ji...@apache.org> on 2019/03/08 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11863) Introduce channel to read and write compressed data - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/08 14:42:00 UTC, 0 replies.
- applay for jira of flink - posted by "sunxiongkun2018@163.com" <su...@163.com> on 2019/03/09 03:32:11 UTC, 1 replies.
- [jira] [Created] (FLINK-11864) Let compressed channel reader/writer reuse the logic of AsynchronousFileIOChannel - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/09 05:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/03/09 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11866) [py] Pathon API Data Types section documentation outdated - posted by "romano vacca (JIRA)" <ji...@apache.org> on 2019/03/09 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11867) mistaking in checking filePath's value - posted by "Tom Goong (JIRA)" <ji...@apache.org> on 2019/03/09 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/03/09 18:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11869) [checkpoint] Make buffer size in checkpoint stream factory configurable - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/03/09 18:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11870) Code refactor for some details - posted by "shiwuliang (JIRA)" <ji...@apache.org> on 2019/03/10 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11871) Introduce LongHashTable to improve performance when join key fits in long - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/11 02:03:00 UTC, 0 replies.
- [DISCUSS] Add column operations in Table API - posted by jincheng sun <su...@gmail.com> on 2019/03/11 04:05:07 UTC, 4 replies.
- [jira] [Created] (FLINK-11872) update lz4 license file - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/11 11:47:00 UTC, 0 replies.
- [VOTE] Release 1.8.0, release candidate #1 - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/11 13:07:31 UTC, 8 replies.
- [jira] [Created] (FLINK-11873) Flink Document has an error - posted by "AT-Fieldless (JIRA)" <ji...@apache.org> on 2019/03/11 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11874) [checkpoint] Split CheckpointStorage interface to distinguish JM and TM side - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/03/11 18:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11875) Enhance stream operator API to support selective reading and EndOfInput event - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/03/12 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11876) Introduce the new interfaces TwoInputSelectable, BoundedOneInput and BoundedTwoInput - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/03/12 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11877) Implement the runtime handling of TwoInputSelectable - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/03/12 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11878) Implement the runtime handling of BoundedOneInput and BoundedTwoInput - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/03/12 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11879) Add JobGraph validators for the uses of TwoInputSelectable, BoundedOneInput and BoundedTwoInput - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/03/12 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11880) Add JobGraph validators for the uses of TwoInputSelectable, BoundedOneInput and BoundedTwoInput - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/03/12 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11881) Introduce code generated typed sort to blink table - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/12 03:23:00 UTC, 0 replies.
- contributor permission application - posted by Yan Gao <0t...@gmail.com> on 2019/03/12 07:54:19 UTC, 7 replies.
- [jira] [Created] (FLINK-11882) Introduce BytesHashMap to batch hash agg - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/12 07:56:00 UTC, 0 replies.
- Flink contributor application - posted by 朱国梁 <zh...@163.com> on 2019/03/12 08:08:59 UTC, 1 replies.
- [jira] [Created] (FLINK-11883) Harmonize the versions of the - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/03/12 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11884) Port Table to flink-api-java - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/03/12 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11885) Introduce RecordWriterBuilder for creating RecordWriter instance - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/03/12 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11886) update the output of cluster management script in jobmanager_high_availability doc - posted by "chunpinghe (JIRA)" <ji...@apache.org> on 2019/03/12 09:54:00 UTC, 0 replies.
- [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API - posted by Becket Qin <be...@gmail.com> on 2019/03/12 12:21:53 UTC, 2 replies.
- [jira] [Created] (FLINK-11887) Operator's Latency Metrics continues to increase - posted by "Suxing Lee (JIRA)" <ji...@apache.org> on 2019/03/12 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11888) Refine document of how to run end-to-end tests - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/12 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11889) Remove "stop" signal along with Stoppable interfaces - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/03/12 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11890) Replace Table API string-based expressions by a Java DSL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/03/12 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11891) Fix some script or test case bug in 1.8 RC - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/13 00:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/13 00:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11893) Update ecosystem page and add it to the navigation bar - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2019/03/13 01:52:00 UTC, 0 replies.
- Submitting a Flink Job via the Flink Dash Board - posted by Durga Durga <du...@gmail.com> on 2019/03/13 02:21:58 UTC, 3 replies.
- [jira] [Created] (FLINK-11894) AbstractRowSerializer.serializeToPages return type should be void - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/13 03:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11895) Allow FileSystem Configs to be altered at Runtime - posted by "Luka Jurukovski (JIRA)" <ji...@apache.org> on 2019/03/13 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11896) Introduce stream physical nodes - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/13 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11897) ExecutionGraphSuspendTest.testSuspendedOutOfRunning failed - posted by "chunpinghe (JIRA)" <ji...@apache.org> on 2019/03/13 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11898) Implement BinaryString call code generator - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/13 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11899) Introduce VectorizedColumnRowInputParquetFormat for blink runtime - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/13 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11900) Flink on Kubernetes sensitive about arguments placement - posted by " Mario Georgiev (JIRA)" <ji...@apache.org> on 2019/03/13 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11901) Update the year in NOTICE files - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/03/13 11:01:00 UTC, 0 replies.
- [CANCEL][VOTE] Release 1.8.0, release candidate #1 - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/13 11:25:36 UTC, 6 replies.
- [jira] [Created] (FLINK-11902) JarRunHandler wraps all exceptions in a RestHandlerException - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/13 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11903) Improve FileStateBackendTest by using JUnit's Parameterized - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/03/13 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11904) Improve MemoryStateBackendTest by using JUnit's Parameterized - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/03/13 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11905) BlockCompressionTest does not compile with Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/13 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11906) Getting error while submitting job - posted by "Ramesh Srinivasalu (JIRA)" <ji...@apache.org> on 2019/03/13 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11907) GenericTypeInfoTest fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/13 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11908) Port window classes into flink-api-java - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/03/13 15:18:01 UTC, 0 replies.
- [jira] [Created] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/03/13 16:35:00 UTC, 0 replies.
- Re: Backoff strategies for async IO functions? - posted by Rong Rong <wa...@gmail.com> on 2019/03/13 16:42:19 UTC, 2 replies.
- Status of FLINK-2491 (Checkpointing of shutdown sources) - posted by Maximilian Michels <mx...@apache.org> on 2019/03/13 17:04:45 UTC, 0 replies.
- [jira] [Created] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version - posted by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2019/03/13 20:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11911) KafkaTopicPartition is not a valid POJO - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/03/13 22:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka consumer - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2019/03/13 22:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11913) Cassandra connector should shade it's usage of cassandra-driver classes to avoid conflicts - posted by "Gustavo Momenté (JIRA)" <ji...@apache.org> on 2019/03/13 22:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11914) Expose a REST endpoint in JobManager to disconnect specific TaskManager - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2019/03/13 22:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11915) DataInputViewStream skip returns wrong value - posted by "Andrew Prudhomme (JIRA)" <ji...@apache.org> on 2019/03/14 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11916) Join with a Temporal Table should throw exception for left join - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/03/14 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11917) Allow state schema migration from Kryo to POJO / Avro - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/03/14 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11918) Deprecated Window and Rename it to GroupWindow - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/14 04:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11919) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "FROM user" at line 1, column 17. - posted by "thinktothings (JIRA)" <ji...@apache.org> on 2019/03/14 09:42:00 UTC, 0 replies.
- I want to contribute to Apache Flink. - posted by 徐小斌 <xu...@163.com> on 2019/03/14 09:42:28 UTC, 1 replies.
- [jira] [Created] (FLINK-11920) EnumValueSerializerUpgradeTest fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/14 09:48:00 UTC, 0 replies.
- [VOTE] Release 1.8.0, release candidate #2 - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/14 12:42:39 UTC, 22 replies.
- [jira] [Created] (FLINK-11921) Upgrade Calcite dependency to 1.19 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/03/14 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11922) Support MetricReporter factories - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/14 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11923) Move reporter instantiation into MetricRegistryConfiguration - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/14 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11924) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "EXISTS" at line 1, column 40. - posted by "thinktothings (JIRA)" <ji...@apache.org> on 2019/03/15 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11925) KryoSerializerSnapshot doesn't completely capture state / configuration of Kryo instance - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/03/15 05:38:00 UTC, 0 replies.
- Apply contributor permission - posted by Jacky Yin 殷传旺 <ja...@eoitek.com> on 2019/03/15 07:08:03 UTC, 0 replies.
- [jira] [Created] (FLINK-11926) The Description of Assigners allowing a fixed amount of lateness is not correct - posted by "chaiyongqiang (JIRA)" <ji...@apache.org> on 2019/03/15 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11927) Code clean up and refactor BinaryHashTable and LongHybridHashTable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/15 08:26:00 UTC, 0 replies.
- Re: Apply contributor permission - posted by Fabian Hueske <fh...@gmail.com> on 2019/03/15 08:29:19 UTC, 0 replies.
- [jira] [Created] (FLINK-11928) Create a Compression string writer for flink-connectors-filesystem - posted by "Shengnan YU (JIRA)" <ji...@apache.org> on 2019/03/15 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11929) remove useless transientBlobCache in ClusterEntrypoint - posted by "chunpinghe (JIRA)" <ji...@apache.org> on 2019/03/15 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11930) Split SegmentsUtil into some dedicated utilities - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/15 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11931) Avro Bulk Writer Factory for StreamingFileSink Bulk Format - posted by "Achyuth Narayan Samudrala (JIRA)" <ji...@apache.org> on 2019/03/15 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11932) Add support for generating optimized logical plan for 'select * from mytable' - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/15 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11933) Exception in thread "main" java.lang.RuntimeException: No data sinks have been created yet. A program needs at least one sink that consumes data. Examples are writing the data set or printing it. - posted by "thinktothings (JIRA)" <ji...@apache.org> on 2019/03/15 11:29:00 UTC, 0 replies.
- BroadcastStateITCase failure caused by insufficient number of network buffers - posted by Yu Li <li...@apache.org> on 2019/03/15 12:37:08 UTC, 2 replies.
- [jira] [Created] (FLINK-11934) Remove the deprecate methods in TableEnvironment - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/03/15 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11935) Remove DateTimeUtils pull-in and fix datetime casting problem - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/03/15 17:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue. - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2019/03/15 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/03/16 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11938) Introduce all the new components - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/03/16 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11939) Adjust components that need be modified - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/03/16 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11940) Reduce storage amplification for FSCSOS - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/03/16 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11941) Reuse single FileSegmentCheckpointStateOutputStream for multiple checkpoints - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/03/16 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11942) Flink kinesis connector throws kinesis producer daemon fatalError - posted by "indraneel r (JIRA)" <ji...@apache.org> on 2019/03/17 21:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11943) Support TopN feature for Flink SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/18 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11944) Support FirstRow and LastRow for SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/18 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11945) Support Over aggregation for SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/18 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11946) Introduce Exec nodes - posted by "Jing Zhang (JIRA)" <ji...@apache.org> on 2019/03/18 04:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11947) Support MapState key / value schema evolution for RocksDB - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/03/18 05:06:00 UTC, 0 replies.
- Expose per partition Kafka lag metric in Flink Kafka connector - posted by Shuyi Chen <su...@gmail.com> on 2019/03/18 06:14:08 UTC, 2 replies.
- [jira] [Created] (FLINK-11948) When kafka sink parallelism - posted by "qi quan (JIRA)" <ji...@apache.org> on 2019/03/18 06:24:00 UTC, 0 replies.
-
[jira] [Created] (FLINK-11949) Introduce DeclarativeAggregateFunction and AggsHandlerCodeGenerator to blink planner - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/18 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11950) Add missing dependencies in NOTICE file of flink-dist. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/18 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11951) Enhance UserDefinedFunction interface to allow more user defined types - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/18 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11952) Introduce Plugin Architecture for loading FileSystems - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/03/18 11:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11953) Introduce Plugin/Loading system and integrate it with FileSystem - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/03/18 11:03:00 UTC, 0 replies.
- [REMINDER] Please add entries for newly added dependencies to NOTICE file - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/18 11:03:25 UTC, 1 replies.
- [jira] [Created] (FLINK-11954) Provide unit test(s) for new plugin infrastructure - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/03/18 11:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11955) Modify build to move filesystems from lib to plugins folder - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/03/18 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11956) Remove shading from filesystems build - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/03/18 11:09:00 UTC, 0 replies.
- [DISCUSS] Introduction of a Table API Java Expression DSL - posted by Timo Walther <tw...@apache.org> on 2019/03/18 14:15:43 UTC, 8 replies.
- [jira] [Created] (FLINK-11957) Expose failure cause in the API response when dispatcher fails to submit a job - posted by "Mark Cho (JIRA)" <ji...@apache.org> on 2019/03/18 21:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11958) flink on windows yarn deploy failed - posted by "Matrix42 (JIRA)" <ji...@apache.org> on 2019/03/19 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11959) Introduce window operator for blink streaming runtime - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/19 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11960) Check all the builtin functions and operators are reasonable - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/19 04:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11961) Clear up and refactor the code generation of scalar functions and operators - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/19 06:03:00 UTC, 0 replies.
- Re: [REMINDER] Please add entries for newly added dependencies to NOTICE file - posted by Ufuk Celebi <uc...@apache.org> on 2019/03/19 06:15:37 UTC, 6 replies.
- [jira] [Created] (FLINK-11962) Huge Flink Checkpoint Size When Using "Group By" Clause With Table SQL - posted by "Ruoyu Dai (JIRA)" <ji...@apache.org> on 2019/03/19 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11963) Add time-based cleanup mechanism in history server - posted by "xymaqingxiang (JIRA)" <ji...@apache.org> on 2019/03/19 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11964) Avoid hash collision of partition and bucket in HybridHashTable - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/19 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11965) Provide a REST API for flink to submit plain SQL flink jobs. - posted by "chenminghua (JIRA)" <ji...@apache.org> on 2019/03/19 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11966) Add support for generating optimized logical plan for simple query(project, filter, values and union all) - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/19 09:00:00 UTC, 0 replies.
- [CANCEL][VOTE] Release 1.8.0, release candidate #2 - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/19 11:45:35 UTC, 0 replies.
- [VOTE] Release 1.8.0, release candidate #3 - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/19 11:52:50 UTC, 0 replies.
- [jira] [Created] (FLINK-11967) Add Column Operators/Operations - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/19 16:00:03 UTC, 0 replies.
- [PROGRESS UPDATE] [DISCUSS] Flink-Hive Integration and Catalogs - posted by Bowen Li <bo...@gmail.com> on 2019/03/19 23:15:48 UTC, 2 replies.
- [jira] [Created] (FLINK-11968) Fix runtime SingleElementIterator.iterator and remove table.SingleElementIterator - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/20 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11969) Add end2end stream sql test for unbounded operators - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/03/20 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed. - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/03/20 05:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11971) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/20 05:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/20 06:03:00 UTC, 0 replies.
- flink jira contributor permission - posted by "陶然(楚澄)" <ch...@alibaba-inc.com> on 2019/03/20 06:11:09 UTC, 4 replies.
- [jira] [Created] (FLINK-11973) computeSelfCost method should not return null to avoid NPE - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/20 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/20 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11975) Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)' - posted by "Jing Zhang (JIRA)" <ji...@apache.org> on 2019/03/20 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11976) PyFlink vectorized python udf with Pandas support - posted by "Yurui Zhou (JIRA)" <ji...@apache.org> on 2019/03/20 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11977) Enable PyFlink to interact with Pandas - posted by "Yurui Zhou (JIRA)" <ji...@apache.org> on 2019/03/20 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11979) Using Apache Arrow as the serialization format between Java runtime and Python worker - posted by "Yurui Zhou (JIRA)" <ji...@apache.org> on 2019/03/20 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11978) Enable vectorized Python UDF with Pandas api - posted by "Yurui Zhou (JIRA)" <ji...@apache.org> on 2019/03/20 09:02:00 UTC, 0 replies.
- [REMINDER] Flink Forward San Francisco in a few days - posted by Fabian Hueske <fh...@gmail.com> on 2019/03/20 10:02:49 UTC, 1 replies.
- contributor permission apply - posted by 李国伟 <25...@qq.com> on 2019/03/20 11:25:16 UTC, 3 replies.
- [jira] [Created] (FLINK-11980) Improve efficiency of iterating KeySelectionListener on notification - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/03/20 11:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11981) Introduce ProjectionCodeGenerator and HashCodeGenerator for BaseRow - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/20 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11982) org.apache.flink.table.api.NoMatchingTableFactoryException - posted by "pingle wang (JIRA)" <ji...@apache.org> on 2019/03/20 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11983) Refactor resolved aggregation reference expressions in blink - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/20 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11984) StreamingFileSink docs do not mention S3 savepoint caveats. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2019/03/20 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11985) Remove ignored command line parameter from yarn_setup.md - posted by "Guowei Ma (JIRA)" <ji...@apache.org> on 2019/03/20 14:40:00 UTC, 0 replies.
- [DISCUSS] Reorganizing Table-related Jira components some more - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/20 16:39:25 UTC, 9 replies.
- [jira] [Created] (FLINK-11986) Add micro benchmark for state operations - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/20 16:54:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-33: Standardize connector metrics - posted by Becket Qin <be...@gmail.com> on 2019/03/21 05:13:20 UTC, 4 replies.
- Facebook: Save Wilpattu One Srilanka's Most Loved Place - posted by dh...@gmail.com on 2019/03/21 06:25:01 UTC, 1 replies.
- [jira] [Created] (FLINK-11987) Kafka producer occasionally throws NullpointerException - posted by "LIU Xiao (JIRA)" <ji...@apache.org> on 2019/03/21 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11988) Remove legacy MockNetworkEnvironment - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/03/21 08:11:00 UTC, 0 replies.
- Re: [DISCUSS] Change underlying Frontend Architecture for Flink Web Dashboard - posted by Robert Metzger <rm...@apache.org> on 2019/03/21 09:18:55 UTC, 0 replies.
- [jira] [Created] (FLINK-11989) Enable metric reporter modules in jdk9 runs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/21 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11990) Streaming bucketing end-to-end test fail with hadoop 2.8 - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/21 11:17:00 UTC, 0 replies.
- 回复:[DISCUSS] Flink Kerberos Improvement - posted by "杨弢(杨弢)" <ya...@alibaba-inc.com> on 2019/03/21 11:26:56 UTC, 0 replies.
- [jira] [Created] (FLINK-11991) Set headers to use for CSV output - posted by "Julien Nioche (JIRA)" <ji...@apache.org> on 2019/03/21 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11992) Update Apache Parquet 1.10.1 - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2019/03/21 12:15:01 UTC, 0 replies.
- [CANCEL][VOTE] Release 1.8.0, release candidate #3 - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/21 13:17:26 UTC, 0 replies.
- [VOTE] Release 1.8.0, release candidate #4 - posted by Aljoscha Krettek <al...@apache.org> on 2019/03/21 16:52:15 UTC, 18 replies.
- Re: [DISCUSS] Flink Kerberos Improvement - posted by Rong Rong <wa...@gmail.com> on 2019/03/22 01:01:33 UTC, 0 replies.
- Re: [DISCUSS] Improvement to Flink Window Operator with Slicing - posted by Rong Rong <wa...@gmail.com> on 2019/03/22 01:24:28 UTC, 0 replies.
- [jira] [Created] (FLINK-11993) Introduce partitionable filesystem sink - posted by "Jing Zhang (JIRA)" <ji...@apache.org> on 2019/03/22 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11994) Introduce TableImpl and remove Table in flink-table-planner-blink - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/22 04:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11995) Kafka09SecuredRunITCase fails due to port conflict - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/22 10:09:00 UTC, 0 replies.
- Row.setField returning row itself - posted by Flavio Pompermaier <po...@okkam.it> on 2019/03/22 11:26:35 UTC, 3 replies.
- [jira] [Created] (FLINK-11996) Case class maximum of 22 fields - posted by "Wouter Zorgdrager (JIRA)" <ji...@apache.org> on 2019/03/22 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11997) ConcurrentModificationException: ZooKeeper unexpectedly modified - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2019/03/22 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11998) Flink Interactive Programming (Umbrella JIRA) - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2019/03/25 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11999) Introduce cache and invalidateCache API to Table - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2019/03/25 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12000) Introduce TableServiceManager to TableEnvironment - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2019/03/25 05:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12001) Test AvroExternalJarProgramITCase, get `JAR file does not exist` Error. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/25 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution - posted by "ryantaocer (JIRA)" <ji...@apache.org> on 2019/03/25 08:30:00 UTC, 1 replies.
- [jira] [Created] (FLINK-12003) Revert the config option about mapreduce.output.basename in HadoopOutputFormatBase - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/03/25 09:07:00 UTC, 0 replies.
- Contributor permission apply - posted by huang🙃 <24...@qq.com> on 2019/03/25 09:36:24 UTC, 1 replies.
- [jira] [Created] (FLINK-12004) Consider about POJO using method chaining when extract TypeInformation - posted by "jiawei chen (JIRA)" <ji...@apache.org> on 2019/03/25 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12005) [State TTL] Event time support - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/03/25 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12006) ZooKeeperHaServicesTest is unstable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/03/25 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12007) Cannot build for Scala 2.12 on Windows - posted by "Lodovico Giaretta (JIRA)" <ji...@apache.org> on 2019/03/25 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12008) Support read a whole directory or multiple input data files for read apis of HadoopInputs - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/03/25 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12009) The heartbeat timeout should be larger or equal than the heartbeat timeout - posted by "Bruno Aranda (JIRA)" <ji...@apache.org> on 2019/03/25 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12010) Kinesis Producer problems on Alpine Linux image - posted by " Mario Georgiev (JIRA)" <ji...@apache.org> on 2019/03/25 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12011) Add Dockerfile with Debian image in Flink distribution - posted by " Mario Georgiev (JIRA)" <ji...@apache.org> on 2019/03/25 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12012) BroadcastStateITCase does not use Test Environments - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2019/03/25 18:23:00 UTC, 0 replies.
- [DISCUSS] Remove forceAvro() and forceKryo() from the ExecutionConfig - posted by Stephan Ewen <se...@apache.org> on 2019/03/25 18:31:37 UTC, 5 replies.
- Applying for membership in development mailing list - posted by 张同学 <zh...@163.com> on 2019/03/26 02:39:12 UTC, 1 replies.
- be a contributor - posted by 君浩 <wa...@gmail.com> on 2019/03/26 02:44:10 UTC, 1 replies.
- write buffer low water mark and high water mark setup - posted by meijies <me...@yandex.com> on 2019/03/26 03:12:05 UTC, 1 replies.
- [jira] [Created] (FLINK-12013) Support calc and correlate in blink - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/26 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12014) Flink CEP Doc missing "SkipToNextStrategy" - posted by "Tom Goong (JIRA)" <ji...@apache.org> on 2019/03/26 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12015) TaskManagerRunnerTest is unstable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/03/26 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12016) Change package name in blink modules to avoid class conflict - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/03/26 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12017) Support to run a sql query : 'SELECT * FROM source' - posted by "Jing Zhang (JIRA)" <ji...@apache.org> on 2019/03/26 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12018) Add support for generating optimized logical plan for Sort and Rank - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/03/26 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12019) ZooKeeperHaServicesTest.testCloseAndCleanupAllDataWithUncle is unstable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/03/26 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12020) Add documentation for mesos-appmaster-job.sh - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/26 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12021) Let ResultConjunctFuture return future results in same order as futures - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/26 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12022) Enable StreamWriter to update file length on sync flush - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2019/03/26 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12023) Override TaskManager memory when submitting a Flink job - posted by "Michel Davit (JIRA)" <ji...@apache.org> on 2019/03/26 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12024) Bump universal Kafka connector to Kafka dependency to 2.2.0 - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2019/03/26 18:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12025) Support FOR SYSTEM_TIME AS OF in temporal table - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/03/27 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12026) Remove the `xxxInternal` method from TableImpl - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/27 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12027) Flink Web UI is not accessible in local mode - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/03/27 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12028) Add Column Operators(add/rename/drop) - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/27 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12029) Add Column selections - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/03/27 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/03/27 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12031) the registerFactory method of TypeExtractor Should not be private - posted by "frank wang (JIRA)" <ji...@apache.org> on 2019/03/27 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12032) KafkaProducerAtLeastOnceITCase failed to bind to address - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/27 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12033) KafkaITCase.testCancelingFullTopic failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/27 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12034) KafkaITCase.testAllDeletes failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/27 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12035) StreamingFileSink E2E failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/27 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12036) Simplify ExecutionGraph by removing legacy concurrency code - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/27 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12037) High parallelism E2E test failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/27 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12038) YARNITCase stalls on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/27 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12039) Remove ASSIGNED_SLOT_UPDATER in Execution.tryAssignResource - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/03/27 13:51:00 UTC, 0 replies.
- [DISCUSS] FLIP-37: Rework of the Table API Type System (Part 1) - posted by Timo Walther <tw...@apache.org> on 2019/03/27 15:32:05 UTC, 4 replies.
- [jira] [Created] (FLINK-12040) Remove unused akka dependencies in pom.xml - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/03/27 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12041) Introduce ResettableExternalBuffer to blink batch - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/03/28 04:03:00 UTC, 0 replies.
- Re: [DISCUSS] Python (and Non-JVM) Language Support in Flink - posted by jincheng sun <su...@gmail.com> on 2019/03/28 04:15:48 UTC, 2 replies.
- Re: [DISCUSS] FLIP-27: Refactor Source Interface - posted by Steven Wu <st...@gmail.com> on 2019/03/28 04:52:18 UTC, 1 replies.
- [jira] [Created] (FLINK-12042) RocksDBStateBackend mistakenly uses default filesystem - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2019/03/28 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12043) Null value check in array serializers classes - posted by "Quan Shi (JIRA)" <ji...@apache.org> on 2019/03/28 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12044) Flink CEP discards events as late if they have timestamps <= 0 - posted by "Arseniy Tashoyan (JIRA)" <ji...@apache.org> on 2019/03/28 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12045) Support force migration between incompatible state schemas/serializers - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/28 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12046) Increase records per invocation for serializerAvro benchmark to stabilize it - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/28 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12047) Savepoint connector to read / write / process savepoints - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2019/03/28 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12048) ZooKeeperHADispatcherTest failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/28 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12049) ClassLoaderUtilsTest fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/28 10:00:08 UTC, 0 replies.
- [jira] [Created] (FLINK-12050) BlockingShutdownTest fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/28 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12051) TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2019/03/28 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12052) Redistributed unevenly sized result partitions - posted by "ryantaocer (JIRA)" <ji...@apache.org> on 2019/03/28 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12053) Calculation of parallelism based on metrics/signals - posted by "ryantaocer (JIRA)" <ji...@apache.org> on 2019/03/28 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12054) HBaseConnectorITCase fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/28 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12055) Remove legacy class ActorSystemLoader - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/03/28 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12056) Remove legacy methods in LeaderRetrievalUtils - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2019/03/28 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12057) Refactor MemoryLogger to accept termination future instead of ActorSystem - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/28 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12058) Cancel checkpoint operations belonging to a discarded/aborted checkpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/28 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12059) How to increase outputQueueLength/inputQueueLength - posted by "WuXiZao (JIRA)" <ji...@apache.org> on 2019/03/28 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12060) Unify change pom version scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2019/03/28 16:19:00 UTC, 0 replies.
- Bump up the shaded dependency version - posted by mayo zhang <18...@163.com> on 2019/03/28 16:56:41 UTC, 1 replies.
- [jira] [Created] (FLINK-12061) Add more window operator contract tests to table runtime - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/29 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12062) Introduce bundle operator to streaming table runtime - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/03/29 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12063) Remove DateTimeUtils and fix datetime function problems in Blink planner - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/03/29 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12064) RocksDBKeyedStateBackend uses incorrect key serializer if reconfigure happens during restore - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/29 10:24:00 UTC, 0 replies.
- [Proposal] Shuffle resources lifecycle management - posted by Andrey Zagrebin <an...@ververica.com> on 2019/03/29 10:38:12 UTC, 0 replies.
- [jira] [Created] (FLINK-12065) E2E tests fail due to illegal-access warning on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/29 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12066) Remove StateSerializerProvider field in keyed state backend - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/03/29 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12067) Refactor the constructor of NetworkEnvironment - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/03/29 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12068) Backtrack fail over regions if intermediate results are unavailable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/29 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12069) Add proper lifecycle management for intermediate result partitions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/29 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12070) Make blocking result partitions consumable multiple times - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/03/29 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12071) HadoopRecoverableWriterTest fails on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/03/30 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12072) Unable to Capture Metrics of AsyncIO - posted by "sravan.korumilli (JIRA)" <ji...@apache.org> on 2019/03/31 06:55:00 UTC, 0 replies.