You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [DISCUSS] FLIP-6 - Flink Deployment and Process Model - Standalone, Yarn, Mesos, Kubernetes, etc. - posted by Kurt Young <yk...@gmail.com> on 2016/08/01 01:44:49 UTC, 5 replies.
- Re: Introduction - posted by Márton Balassi <ba...@gmail.com> on 2016/08/01 02:47:29 UTC, 5 replies.
- [jira] [Created] (FLINK-4285) Non-existing example in Flink quickstart setup documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/01 07:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4286) Have Kafka examples that use the Kafka 0.9 connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/01 07:52:21 UTC, 0 replies.
- Re: [DISCUSS] FLIP-2 Extending Window Function Metadata - posted by Stephan Ewen <se...@apache.org> on 2016/08/01 07:59:19 UTC, 1 replies.
- [jira] [Created] (FLINK-4287) Unable to access secured HBase from a yarn-session. - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/01 08:02:20 UTC, 0 replies.
- Re: [VOTE] Release Apache Flink 1.1.0 (RC1) - posted by Stephan Ewen <se...@apache.org> on 2016/08/01 08:27:58 UTC, 13 replies.
- [jira] [Created] (FLINK-4288) Make it possible to unregister tables - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 08:39:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4289) Source files have executable flag set - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 09:10:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4290) CassandraConnectorTest deadlocks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 09:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4291) No log entry for unscheduled reporters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 09:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4292) HCatalog project incorrectly set up - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 10:00:25 UTC, 0 replies.
- [jira] [Created] (FLINK-4293) Malformatted Apache Haders - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 10:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4294) Allow access of composite type fields - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 11:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4295) CoGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/01 13:05:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4296) Scheduler accepts more tasks than it has task slots available - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/01 13:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/01 13:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4298) Clean up Storm Compatibility Dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/01 13:58:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4299) Show loss of job manager in Client - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 14:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4300) Improve error message for different Scala versions of JM and Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 15:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4301) Parameterize Flink version in Quickstart bash script - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 15:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4302) Add JavaDocs to MetricConfig - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/01 15:43:20 UTC, 0 replies.
- Re: [DISCUSS] FLIP-5 Only send data to each taskmanager once for broadcasts - posted by Stephan Ewen <se...@apache.org> on 2016/08/01 15:51:29 UTC, 8 replies.
- Map Reduce Sorting - posted by Hilmi Yildirim <Hi...@dfki.de> on 2016/08/01 16:25:17 UTC, 4 replies.
- [jira] [Created] (FLINK-4303) Add CEP examples - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/01 16:39:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4304) Jar names that contain whitespace cause problems in web client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/02 09:18:20 UTC, 0 replies.
- Re: [DISCUSS] FLIP-3 - Organization of Documentation - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/02 09:39:49 UTC, 8 replies.
- [jira] [Created] (FLINK-4305) Build pull requests with Jenkins - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/02 09:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4306) Fix Flink and Storm dependencies in flink-storm and flink-storm-examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 12:19:20 UTC, 0 replies.
- Re: [DISCUSS] FLIP-7 Expose metrics to WebInterface - posted by Stephan Ewen <se...@apache.org> on 2016/08/02 12:34:37 UTC, 4 replies.
- [jira] [Created] (FLINK-4307) Broken user-facing API for ListState - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/02 16:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4308) Allow uploaded jar directory to be configurable - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/02 17:57:20 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.1.0 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/02 18:32:56 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.1.0 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/02 21:29:39 UTC, 5 replies.
- [jira] [Created] (FLINK-4309) Potential null pointer dereference in DelegatingConfiguration#keySet() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/03 01:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/03 12:24:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4311) TableInputFormat fails when reused on next split - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/03 12:30:20 UTC, 0 replies.
- [ANNOUNCE] Introducing a feature branch for FLIP-6 (cluster management) - posted by Stephan Ewen <se...@apache.org> on 2016/08/03 18:05:08 UTC, 2 replies.
- Conceptual difference Windows and DataSet - posted by Kevin Jacobs <ke...@cern.ch> on 2016/08/04 08:36:50 UTC, 2 replies.
- AW: [ANNOUNCE] Introducing a feature branch for FLIP-6 (clustermanagement) - posted by fh...@gmail.com on 2016/08/04 10:41:07 UTC, 1 replies.
- [jira] [Created] (FLINK-4312) Remove Serializabiliy of ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/04 14:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4313) Inconsistent code for Key/Value in the CheckpointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/04 17:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4314) Test instability in JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 09:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4315) Remove Hadoop Dependency from flink-java - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 10:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4316) Make flink-core independent of Hadoop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 12:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4317) Restructure documentation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 12:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4318) Make master docs build target version-specific - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/05 13:10:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4319) Rework Cluster Management (FLIP-6) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 14:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4320) Fix misleading ScheduleMode names - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 15:47:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4321) Initialize TaskExecutions directly with their starting state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 16:44:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 17:42:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/05 18:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4324) Enable Akka SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/05 19:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4325) Implement Web UI HTTPS - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/05 19:10:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/06 00:02:21 UTC, 0 replies.
- Re: Cassandra statebackend - posted by Chen Qin <qi...@gmail.com> on 2016/08/06 05:31:24 UTC, 3 replies.
- [jira] [Created] (FLINK-4327) Error in link to downlad version for hadoop 2.7 and scala 2.11 - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/08/07 11:30:26 UTC, 0 replies.
- release 1.1 rc2 confusion - posted by CPC <ac...@gmail.com> on 2016/08/07 17:22:28 UTC, 1 replies.
- [jira] [Created] (FLINK-4328) Harden JobManagerHA*ITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/08 08:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4329) Streaming File Source Must Correctly Handle Timestamps/Watermarks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/08 12:00:25 UTC, 0 replies.
- [jira] [Created] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/08 13:41:20 UTC, 0 replies.
- [DISCUSS] API breaking change in DataStream Windows - posted by Stephan Ewen <se...@apache.org> on 2016/08/08 14:11:23 UTC, 7 replies.
- [jira] [Created] (FLINK-4331) Flink is not able to serialize scala classes / Task Not Serializable - posted by "Pushpendra Jaiswal (JIRA)" <ji...@apache.org> on 2016/08/08 14:41:20 UTC, 0 replies.
- [ANNOUNCE] Flink 1.1.0 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/08 16:36:26 UTC, 5 replies.
- [jira] [Created] (FLINK-4332) Savepoint Serializer mixed read()/readFully() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/08 17:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4333) Name mixup in Savepoint versions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/08 17:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4334) Shaded Hadoop1 jar not fully excluded in Quickstart - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/08/08 20:22:21 UTC, 0 replies.
- [DISCUSS] updating apache-flink homebrew formula - posted by "Wright, Eron" <ew...@live.com> on 2016/08/08 22:59:17 UTC, 5 replies.
- [jira] [Created] (FLINK-4335) Add jar id, and job parameters information to job status rest call - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/08 23:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4336) Expose ability to take a savepoint from job manager rest api - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/08 23:31:20 UTC, 0 replies.
- Flink 1.1.0 : Hadoop 1/2 compatibility mismatch - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2016/08/09 07:45:25 UTC, 4 replies.
- [jira] [Created] (FLINK-4337) Remove unnecessary Scala suffix from Hadoop1 artifact - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 08:35:20 UTC, 0 replies.
- [DISCUSS] Streaming connector contributions - posted by Robert Metzger <rm...@apache.org> on 2016/08/09 08:43:33 UTC, 11 replies.
- [jira] [Created] (FLINK-4338) Implement Slot Pool - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 09:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4339) Implement Slot Pool Core - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 09:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/09 13:08:20 UTC, 0 replies.
- N-ary stream operators - status - posted by Gábor Gévay <gg...@gmail.com> on 2016/08/09 15:54:45 UTC, 4 replies.
- [VOTE] Release Apache Flink 1.1.1 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/09 16:27:45 UTC, 13 replies.
- TaskManager Transfer buffers - posted by David Herzog <hd...@googlemail.com> on 2016/08/09 16:41:04 UTC, 1 replies.
- [jira] [Created] (FLINK-4341) Checkpoint state size grows unbounded when task parallelism not uniform - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/08/09 20:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4342) Fix dependencies of flink-connector-filesystem - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 20:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4343) Implement new TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:04:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4344) Implement new JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4345) Implement new ResourceManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:33:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4346) Implement basic RPC abstraction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/09 22:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4347) Implement SlotManager for new ResourceManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/10 03:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4348) implement communication from ResourceManager to TaskManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/10 08:31:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4349) ResourceManager interaction - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 08:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4350) ResourceManager interaction - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 08:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4351) TaskExecutor interaction - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:00:29 UTC, 0 replies.
- [jira] [Created] (FLINK-4352) JobClient interaction - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:03:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4353) cluster components failure process - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4354) TaskManager to ResourceManager heartbeats - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4355) TaskManager registration at ResourceManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4356) JobMaster HA - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/10 09:24:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4357) TaskManager responses slot allocation - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4358) TaskManager deploys task into slot - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 09:52:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4359) Add INTERVAL type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/10 09:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4360) TaskManager slot registration at JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 10:00:25 UTC, 0 replies.
- [jira] [Created] (FLINK-4361) Replace Scala Futures - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 10:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4362) Auto generate message sender classes via Java Proxies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 10:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4363) TaskManager basic startup of all components - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 10:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4364) TaskManage responses heartbeats from JobManager - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/10 10:54:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4365) [metrics] MetricConfig has no documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/10 11:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4366) Enforce parallelism=1 For AllWindowedStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/10 13:24:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4367) Offer separate API for watermark generation and timestamp extraction - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/10 14:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4368) Eagerly initialize RrcProtocol members - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 16:27:20 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.1.1 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/10 16:45:04 UTC, 0 replies.
- [jira] [Created] (FLINK-4369) Evictingwindowoperator Must Actually Evict Elements - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/10 17:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/10 17:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4371) Add ability to take savepoints from job manager RESTful API - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/10 18:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4372) Add ability to take savepoints from job manager web UI - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/10 18:14:20 UTC, 0 replies.
- expose side output stream - posted by Chen Qin <qi...@gmail.com> on 2016/08/10 22:41:45 UTC, 4 replies.
- [jira] [Created] (FLINK-4373) Introduce SlotID & ResourceProfile - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/11 07:42:20 UTC, 0 replies.
- [ANNOUNCE] Flink 1.1.1 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/11 08:00:57 UTC, 0 replies.
- [jira] [Created] (FLINK-4374) GroupReduce Broken for null Date - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/11 10:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4375) defined rpc protocols provided by job manager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/11 12:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4376) implement job manager init procedure - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/11 12:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4377) akka.remote.OversizedPayloadException: Discarding oversized payload - posted by "Sajeev Ramakrishnan (JIRA)" <ji...@apache.org> on 2016/08/11 13:00:24 UTC, 0 replies.
- [jira] [Created] (FLINK-4378) Enable RollingSink to custom HDFS client configuration - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/11 13:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4379) Add Rescalable Non-Partitioned State - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/11 13:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4380) Introduce KeyGroupAssigner and Max-Parallelism Parameter - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/11 13:55:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4381) Refactor State to Prepare For Key-Group State Backends - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/11 14:03:20 UTC, 0 replies.
- [DISCUSS] Breaking Savepoint Compatibility from 1.1 to 1.2 - posted by Aljoscha Krettek <al...@apache.org> on 2016/08/11 14:52:43 UTC, 3 replies.
- [jira] [Created] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/11 15:18:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/11 15:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/11 15:32:20 UTC, 0 replies.
- [DISCUSS] FLIP-8: Rescalable Non-Partitioned State - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/11 17:19:38 UTC, 8 replies.
- [jira] [Created] (FLINK-4385) Union on Timestamp fields does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/11 17:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/11 18:01:20 UTC, 0 replies.
- [DISCUSS] (Meta)data Driven Window Triggers - posted by Kevin Jacobs <ke...@cern.ch> on 2016/08/12 07:45:30 UTC, 1 replies.
- [jira] [Created] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/12 08:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4388) Race condition during initialization of MemorySegmentFactory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/12 09:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4389) Expose metrics to Webfrontend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/12 11:38:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4390) Add throws clause verification to RpcCompletenessTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/12 13:52:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4391) Provide support for asynchronous operations over streams - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/08/13 14:14:20 UTC, 0 replies.
- Some thoughts about the lower-level Flink APIs - posted by Jamie Grier <ja...@data-artisans.com> on 2016/08/13 15:48:07 UTC, 10 replies.
- [jira] [Created] (FLINK-4392) Make RPC Service Thread Safe - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/13 16:33:20 UTC, 0 replies.
- Nested field expressions PR - posted by Gábor Gévay <gg...@gmail.com> on 2016/08/14 19:35:56 UTC, 0 replies.
- Assigning an issue to self on JIRA - posted by Sunny T <ts...@gmail.com> on 2016/08/14 20:48:13 UTC, 8 replies.
- [FLINK-4309] - Need a shepherd - posted by Sunny T <ts...@gmail.com> on 2016/08/15 04:22:25 UTC, 2 replies.
- [jira] [Created] (FLINK-4393) Failed to serialize accumulators for task - posted by "Sajeev Ramakrishnan (JIRA)" <ji...@apache.org> on 2016/08/15 06:24:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4394) RMQSource: The QueueName is not accessible to subclasses - posted by "Dominik Bruhn (JIRA)" <ji...@apache.org> on 2016/08/15 07:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4395) Eager processing of late arrivals in CEP operator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/15 07:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4396) MetricRegistry class not found at startup of jobmanager - posted by "RWenden (JIRA)" <ji...@apache.org> on 2016/08/15 12:41:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4397) Unstable test SlotCountExceedingParallelismTest.tearDown - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/15 14:19:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/15 14:21:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4399) Add support for oversized messages - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/15 16:02:20 UTC, 0 replies.
- Jenkins and Travis CI failing - posted by Sunny T <ts...@gmail.com> on 2016/08/15 16:41:29 UTC, 4 replies.
- Custom Tumbling Window Assigner - posted by dan bress <da...@gmail.com> on 2016/08/15 17:05:57 UTC, 3 replies.
- <无主题> - posted by Renkai <ga...@gmail.com> on 2016/08/16 03:39:05 UTC, 1 replies.
- [jira] [Created] (FLINK-4400) Leadership Election among JobManagers - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/08/16 06:22:20 UTC, 0 replies.
- [DISCUSS] Some thoughts about unify Stream SQL and Batch SQL grammer - posted by Jark Wu <wu...@alibaba-inc.com> on 2016/08/16 07:29:09 UTC, 16 replies.
- [jira] [Created] (FLINK-4401) Add docs about ordering in streams - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/16 08:42:20 UTC, 0 replies.
- [DISCUSS] FLIP-9: Trigger DSL - posted by Kostas Kloudas <k....@data-artisans.com> on 2016/08/16 10:34:29 UTC, 15 replies.
- [jira] [Created] (FLINK-4402) Wrong metrics parameter names in documentation - posted by "RWenden (JIRA)" <ji...@apache.org> on 2016/08/16 13:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4403) RPC proxy classloading should use Flink class' classloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/16 19:16:20 UTC, 0 replies.
- [HEADS-UP] Dev Week 33 - posted by Aljoscha Krettek <al...@apache.org> on 2016/08/16 20:34:54 UTC, 3 replies.
- [jira] [Created] (FLINK-4404) Implement Data Transfer SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/17 05:22:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4405) Implement Blob Server SSL - posted by "Suresh Krishnappa (JIRA)" <ji...@apache.org> on 2016/08/17 05:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4406) Implement job master registration at resource manager - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/17 06:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4407) Implement the trigger DSL - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/17 07:04:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4408) JobSubmission - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/08/17 08:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/17 09:28:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4410) Split checkpoint times into synchronous and asynchronous part - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/17 09:47:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4411) [py] Chained dual input children are not properly propagated - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/17 10:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4412) [py] Chaining does not properly handle broadcast variables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/08/17 11:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4413) Improve savepoint restore error messages - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/17 12:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4414) Remove restriction on RpcService.getAddress - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/17 14:45:20 UTC, 0 replies.
- [DISCUSS] Move Redis and Flume connectors to Apache Bahir and redirect contributions there - posted by Robert Metzger <rm...@apache.org> on 2016/08/17 15:24:24 UTC, 6 replies.
- [jira] [Created] (FLINK-4415) Enhance Trigger Interface with onFire() and onCleanup() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/08/17 15:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4416) Provide a programmatic way to load a Yarn config - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/17 15:56:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/17 16:50:20 UTC, 0 replies.
- Reducing the JIRA PR message verbosity - posted by Neelesh Salian <ns...@cloudera.com> on 2016/08/17 20:52:56 UTC, 7 replies.
- [jira] [Created] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/08/17 22:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4419) Batch improvement for supporting dfs as a ResultPartitionType - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/08/18 02:56:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4420) Introduce star(*) to select all of the columns in the table - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/18 05:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4421) Make clocks and time measurements monotonous - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/18 10:48:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4422) Convert all time interval measurements to System.nanoTime() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/18 10:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4423) Introduce a Clock utility for monotonous system timestamps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/18 11:01:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4424) Make network environment start-up/shutdown independent of JobManager association - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/18 12:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4425) "Out Of Memory" during savepoint deserialization - posted by "Sergii Koshel (JIRA)" <ji...@apache.org> on 2016/08/18 14:03:21 UTC, 0 replies.
- [FLINK-305] Code test coverage - how FLINK using it? - posted by Pavel Fadeev <pa...@gmail.com> on 2016/08/18 22:36:15 UTC, 7 replies.
- [jira] [Created] (FLINK-4426) Unable to create proxy to the ResourceManager - posted by "Harpreet Sawhney (JIRA)" <ji...@apache.org> on 2016/08/18 23:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4427) Add slot / container releasing logic to SlotManager (Standalone / Yarn / Mesos) - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/19 03:45:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4428) Method map/flatMapWithState may need a eviction policy - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/19 06:06:23 UTC, 0 replies.
- [jira] [Created] (FLINK-4429) Move Redis Sink from Flink to Bahir - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/19 08:25:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4430) prevent BLOCKING partition data lose when task is finished - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/19 09:00:30 UTC, 0 replies.
- [jira] [Created] (FLINK-4431) Introduce a "VisibleForTesting" annotation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 10:06:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4432) (YARN) JobManager web port is no longer available in configuration page in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/19 14:48:20 UTC, 0 replies.
- [DISCUSS] FLIP-10: Unify Savepoints and Checkpoints - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/19 15:58:31 UTC, 3 replies.
- [jira] [Created] (FLINK-4433) Refactor the StreamSource. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/19 16:33:20 UTC, 0 replies.
- [DISCUSS] Python API for Fllink libraries - posted by Ivan Mushketyk <iv...@gmail.com> on 2016/08/19 20:07:42 UTC, 5 replies.
- [jira] [Created] (FLINK-4434) Add a testing RPC service - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 21:39:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/19 22:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/20 00:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/20 00:19:20 UTC, 0 replies.
- [FLINK-1707] Add an Affinity Propagation Library Method - posted by Josep Rubio <jo...@datag.es> on 2016/08/20 22:21:43 UTC, 0 replies.
- [jira] [Created] (FLINK-4438) FlinkML Quickstart Guide implies incorrect type for test data - posted by "Ahmad Ragab (JIRA)" <ji...@apache.org> on 2016/08/21 07:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid - posted by "Gheorghe Gheorghe (JIRA)" <ji...@apache.org> on 2016/08/21 13:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4440) Make API for edge/vertex creation less verbose - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/21 16:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4441) RocksDB statebackend makes all operators appear stateful - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/21 19:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4442) Implement Standalone ResourceManager - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/22 04:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4443) Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/08/22 05:48:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4444) Add a DFSInputChannel and DFSSubPartition - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/08/22 06:47:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4445) Ignore unmatched state when restoring from savepoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/22 08:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4446) Move Flume Sink from Flink to Bahir - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/22 14:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4447) Include NettyConfig options on Configurations page - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/22 19:00:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4448) Use Listeners to monitor execution status - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/08/23 01:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4449) Heartbeat Manager between ResourceManager and TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/23 07:45:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4450) update storm version to 1.0.0 - posted by "yuzhongliu (JIRA)" <ji...@apache.org> on 2016/08/23 11:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4451) Throw exception when remote connection cannot be resolved - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 14:22:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4452) TaskManager network buffer guages - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/23 14:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4453) Scala code example in Window documentation shows Java - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/23 14:58:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4454) Lookups for JobManager address in config - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/23 15:54:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 16:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4456) Replace ActorGateway in RuntimeEnvironment by interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:04:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4457) Make the ExecutionGraph independent of Akka - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4458) Remove ForkableFlinkMiniCluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:30:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4459) Introduce SlotProvider to Scheduler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/23 17:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4460) Expose Late Arriving Events - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2016/08/23 18:28:20 UTC, 0 replies.
- [DISCUSS] [FLINK-3950] Meter interface - posted by Ivan Mushketyk <iv...@gmail.com> on 2016/08/23 20:21:09 UTC, 0 replies.
- [DISCUSS][FLINK-3414] Scala API for CEP's pattern definition - posted by Ivan Mushketyk <iv...@gmail.com> on 2016/08/23 20:39:18 UTC, 0 replies.
- [jira] [Created] (FLINK-4461) Ensure all the classes are tagged with suitable annotations - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/24 07:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4462) Add RUN_TIME retention policy for all the flink annotations - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/08/24 07:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4463) FLIP-3: Restructure Documentation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:30:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4464) Add docs about version upgrades - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4465) Add docs about system architecture - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:40:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4467) Add docs about project structure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:42:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4466) Add a metric availability test. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/24 09:42:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4468) Add documentation about processing semantics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4469) Add support for user defined table function in Table API & SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/24 09:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4470) Add docs about Failure and Recovery Model - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4472) Add docs about Security - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4471) Rocks backend fully async snapshot restore fails with custom serializers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/08/24 09:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4473) Add docs about end-to-end exactly once latency - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4474) Add docs about Testing & Test Utilities - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 09:58:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4475) Add docs about Debugging - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 10:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4476) Add docs about Tuning - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 10:03:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4477) Add and consolidate existing docs about data types - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/24 10:05:20 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.1.2 - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/24 10:25:03 UTC, 8 replies.
- [jira] [Created] (FLINK-4478) Implement heartbeat logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/24 13:35:21 UTC, 0 replies.
- Additional project downloads - posted by Greg Hogan <co...@greghogan.com> on 2016/08/24 15:04:31 UTC, 7 replies.
- [jira] [Created] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/24 15:05:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4480) Incorrect link to elastic.co in documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/24 15:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4481) Maximum results for pairwise algorithms - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/08/24 19:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/24 23:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4483) Complete test coverage integration - posted by "Pavel Fadeev (JIRA)" <ji...@apache.org> on 2016/08/24 23:18:22 UTC, 0 replies.
- Task manager processes crashing one after the other - posted by Gyula Fóra <gy...@apache.org> on 2016/08/25 07:40:48 UTC, 7 replies.
- [jira] [Created] (FLINK-4484) FLIP-10: Unify Savepoints and Checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/25 12:38:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 13:05:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 13:31:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4487) Need tools for managing the yarn-session better - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 13:36:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4488) Prevent cluster shutdown after job execution for non-detached jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/25 13:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4489) Implement TaskManager's SlotManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/25 14:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4490) Decouple Slot and Instance - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/08/25 14:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4491) Handle index.number_of_shards in the ES connector - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/08/25 14:40:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4492) Cleanup files from canceled snapshots - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/25 14:40:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4493) Unify the snapshot output format for keyed-state backends - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/25 14:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/25 15:13:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4495) Running multiple jobs on yarn (without yarn-session) - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/08/25 15:14:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/08/25 15:19:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 16:18:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4498) Better Cassandra sink documentation - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 16:46:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4499) Introduce findbugs maven plugin - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/25 17:35:20 UTC, 0 replies.
- Fwd: Enabling Encryption between slaves in Flink - posted by Vinay Patil <vi...@gmail.com> on 2016/08/25 18:51:10 UTC, 1 replies.
- [jira] [Created] (FLINK-4500) Cassandra sink can lose messages - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 22:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4501) Cassandra sink can lose messages - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 22:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/08/25 23:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/08/26 06:13:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4504) Support user to decide whether the result of an operator is presistent - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/08/26 07:37:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4505) Implement abstract TaskManagerFactory to bring up TaskManager for different modes - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/08/26 09:39:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true - posted by "Michael Wong (JIRA)" <ji...@apache.org> on 2016/08/26 10:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4507) Deprecate savepoint backend config - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 12:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4508) Consolidate DummyEnvironment and MockEnvironment for Tests - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/08/26 14:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4509) Specify savepoint directory per savepoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 14:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4510) Always create CheckpointCoordinator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 14:35:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4511) Schedule periodic savepoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 14:39:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4512) Add option for persistent checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/08/26 14:49:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/08/26 15:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/26 17:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4515) org.apache.flink.runtime.jobmanager.JobInfo class is not backwards compatible with 1.1 released version - posted by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2016/08/26 20:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4516) ResourceManager leadership election - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/27 04:19:20 UTC, 0 replies.
- Apache siddhi into Flink - posted by "Aparup Banerjee (apbanerj)" <ap...@cisco.com> on 2016/08/27 06:23:30 UTC, 0 replies.
- [jira] [Created] (FLINK-4517) scala code refactoring - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/08/27 09:15:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4518) maxLineLength change to 120 - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/08/27 10:26:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4519) scala maxLineLength increased to 120 - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/08/27 10:31:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library - posted by "Hao Chen (JIRA)" <ji...@apache.org> on 2016/08/28 03:00:27 UTC, 0 replies.
- [jira] [Created] (FLINK-4521) Fix "Submit new Job" panel in development mode - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/08/28 08:54:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4522) Gelly link broken in homepage - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/08/28 11:49:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/08/28 14:40:20 UTC, 0 replies.
- Check-pointing configuration - posted by Bhupesh Chawda <bh...@apache.org> on 2016/08/29 06:47:29 UTC, 2 replies.
- why job submit timeout is 21474835 second - posted by 时金魁 <sh...@163.com> on 2016/08/29 08:22:47 UTC, 3 replies.
- Yarn node went down... - posted by Niels Basjes <Ni...@basjes.nl> on 2016/08/29 08:31:52 UTC, 2 replies.
- [jira] [Created] (FLINK-4524) JobManagerProcessReapingTest.testReapProcessOnFailure unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/08/29 09:03:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4525) Drop the "eager split pre-assignment" code paths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/29 10:00:29 UTC, 0 replies.
- [jira] [Created] (FLINK-4526) ApplicationClient: remove redundant proxy messages - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/29 13:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4527) Drop the "flinkAccumulators" from the Execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/29 13:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4528) Mark runAsync and scheduleAsync methods protected - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/29 13:48:20 UTC, 0 replies.
- Scheduling of Flink jobs - posted by Bhupesh Chawda <bh...@apache.org> on 2016/08/29 14:04:29 UTC, 0 replies.
- [jira] [Created] (FLINK-4529) Move JobMaster, TaskExecutor and ResourceManager out of the rpc package - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/29 14:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4530) Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/08/29 15:38:20 UTC, 0 replies.
- Memory Management in Streaming mode - posted by Shen Li <cs...@gmail.com> on 2016/08/29 15:53:45 UTC, 1 replies.
- [jira] [Created] (FLINK-4531) Thread.stop() is deprecated - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/29 17:26:20 UTC, 0 replies.
- [HEADS-UP] Dev Week 35 - posted by Aljoscha Krettek <al...@apache.org> on 2016/08/30 09:28:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4532) Allow independent metrics reporter for tasks - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2016/08/30 10:16:21 UTC, 0 replies.
- ApacheCon Seville CFP closes September 9th - posted by Rich Bowen <rb...@apache.org> on 2016/08/30 15:03:41 UTC, 0 replies.
- [jira] [Created] (FLINK-4533) Unprotected access to meters in StatsDReporter#report() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/30 17:30:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() w.r.t. state.bucketStates - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/08/30 17:33:22 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.1.2 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2016/08/30 21:30:51 UTC, 4 replies.
- Streaming - memory management - posted by Roshan Naik <ro...@hortonworks.com> on 2016/08/30 21:52:54 UTC, 4 replies.
- [jira] [Created] (FLINK-4535) ResourceManager process registration from TaskExecutor - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/08/31 02:55:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4536) Possible thread leak in Task Manager - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/08/31 04:42:20 UTC, 0 replies.
- Fwd: NullPointerException in beam stream runner - posted by Demin Alexey <di...@gmail.com> on 2016/08/31 09:27:08 UTC, 5 replies.
- [jira] [Created] (FLINK-4537) ResourceManager registration with JobManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 10:30:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4538) Implement slot allocation protocol with JobMaster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 11:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4539) Duplicate/inconsistent logic for physical memory size in classes "Hardware" and "EnvironmentInformation" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/31 12:04:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4540) Detached job execution may prevent cluster shutdown - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/08/31 12:52:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4541) Support for SQL NOT IN operator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/31 13:16:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4542) Add support for MULTISET type and operations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/08/31 13:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/31 14:26:20 UTC, 0 replies.
- [DISCUSS] Automated code quality check in Flink - posted by Ivan Mushketyk <iv...@gmail.com> on 2016/08/31 14:37:35 UTC, 0 replies.
- [jira] [Created] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/08/31 15:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4545) Flink automatically manages TM network buffer - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/08/31 18:46:20 UTC, 0 replies.