You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09 - posted by "Sudhanshu Sekhar Lenka (JIRA)" <ji...@apache.org> on 2016/10/01 07:06:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4723) Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/10/01 10:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file is used - posted by "Melmoth (JIRA)" <ji...@apache.org> on 2016/10/01 11:36:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist - posted by "Jordan Ganoff (JIRA)" <ji...@apache.org> on 2016/10/02 00:32:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4726) Quickstart: Java API - Broken - posted by "itiel (JIRA)" <ji...@apache.org> on 2016/10/02 11:41:20 UTC, 0 replies.
- Using Flink - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2016/10/03 06:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/10/03 08:48:20 UTC, 0 replies.
- Assign issue - posted by Nikolay Vasilishin <Ni...@epam.com> on 2016/10/03 09:33:14 UTC, 8 replies.
- Duplicate sort keys - posted by Greg Hogan <co...@greghogan.com> on 2016/10/03 14:04:17 UTC, 1 replies.
- [jira] [Created] (FLINK-4728) Replace reference equality with object equality - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/03 18:04:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4729) Use optional VertexCentric CombineFunction - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/03 18:11:20 UTC, 0 replies.
- [DISCUSS] Mesos version dependency - posted by Eron Wright <ew...@live.com> on 2016/10/04 02:06:56 UTC, 2 replies.
- [jira] [Created] (FLINK-4730) Introduce CheckpointMetaData - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/04 07:58:20 UTC, 0 replies.
- Re: Does the job name affect checkpointing? - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/04 08:01:33 UTC, 0 replies.
- [jira] [Created] (FLINK-4731) HeapKeyedStateBackend restorig broken for scale-in - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/04 09:05:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4732) Maven junction plugin security threat - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/10/04 09:12:20 UTC, 0 replies.
- Re: Releasing Flink 1.1.3 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2016/10/04 09:12:29 UTC, 11 replies.
- [DISCUSS] Bump HBase version for hadoop-2 to 1.2.3 - posted by Fabian Hueske <fh...@gmail.com> on 2016/10/04 09:38:14 UTC, 3 replies.
- [jira] [Created] (FLINK-4733) Port WebFrontend to new metric system - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/04 09:55:20 UTC, 0 replies.
- Flink ML recommender system API - posted by Gábor Hermann <ma...@gaborhermann.com> on 2016/10/04 10:47:49 UTC, 3 replies.
- Flink scala or Java - Dataload from CSV to database.. - posted by ram kumar <ra...@gmail.com> on 2016/10/04 12:18:13 UTC, 1 replies.
- [jira] [Created] (FLINK-4734) Remove use of Tuple setField for fixed position - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/04 13:51:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4735) Migrate some job execution related akka messages to rpc calls - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/10/04 14:59:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4736) Don't duplicate fields in Ordering - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/04 15:37:20 UTC, 0 replies.
- Some questions about Table API and FlinkSQL - posted by Anton Mushin <An...@epam.com> on 2016/10/04 16:04:20 UTC, 2 replies.
- [jira] [Created] (FLINK-4737) Add more compression algorithms to FileInputFormat - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/04 16:06:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4738) Port TaskManager logic to TaskExecutor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/04 17:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4739) Adding packaging details for the Elasticsearch connector - posted by "Steffen Hausmann (JIRA)" <ji...@apache.org> on 2016/10/04 18:23:20 UTC, 0 replies.
- [Discuss] Upgrade JUnit to 4.12 - posted by Greg Hogan <co...@greghogan.com> on 2016/10/04 19:07:17 UTC, 4 replies.
- [jira] [Created] (FLINK-4740) Upgrade testing libraries - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/04 20:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4741) WebRuntimeMonitor does not shut down all of it's threads (EventLoopGroups) on exit. - posted by "Joseph Sims (JIRA)" <ji...@apache.org> on 2016/10/04 22:06:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4742) NPE in WindowOperator.trigger() on shutdown - posted by "Matt Zimmer (JIRA)" <ji...@apache.org> on 2016/10/05 02:24:20 UTC, 0 replies.
- AWS S3 and Reshift - posted by sunny patel <su...@gmail.com> on 2016/10/05 06:15:02 UTC, 0 replies.
- [jira] [Created] (FLINK-4743) The sqrt/power function not accept the real data types. - posted by "Anton Mushin (JIRA)" <ji...@apache.org> on 2016/10/05 10:38:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4744) Introduce usercode class loader to deserialize partitionable operator state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/05 12:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4745) Convert KafkaTableSource test to unit tests - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/10/05 12:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4746) Replace TaskManagerRuntimeInfo by TaskManagerConfiguration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/05 12:29:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4747) Instability due to pending processing timers on operator close - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/05 14:03:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4748) Fix shutdown of automatic watermark context - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/05 14:04:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4749) Remove redundant processing time timers and futures in the window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/05 14:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4750) Ensure that active processing time triggers complete before closing operators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/05 14:07:20 UTC, 0 replies.
- KafkaProducer can not be instantiated - posted by Timo Walther <tw...@apache.org> on 2016/10/05 14:51:02 UTC, 5 replies.
- [jira] [Created] (FLINK-4751) Extend Flink's futures to support combining two futures - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/05 16:15:20 UTC, 0 replies.
- Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/10/06 02:49:05 UTC, 6 replies.
- [jira] [Created] (FLINK-4752) Improve session window documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/06 08:28:20 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.1.3 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/06 08:29:37 UTC, 5 replies.
- [jira] [Created] (FLINK-4753) Kafka 0.8 connector's Periodic Offset Committer should synchronize on checkpoint lock - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/10/06 11:22:20 UTC, 0 replies.
- Flink Gelly - posted by df...@web.de on 2016/10/06 11:29:34 UTC, 6 replies.
- [jira] [Created] (FLINK-4754) Make number of retained checkpoints user configurable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/10/06 12:03:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4755) Create ContainerID; Rename ResourceID into ProcessID and InstanceID into RegistrationID - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/06 14:18:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4756) NullPointerException on submiting a job with StreamExecutionEnvironment.createRemoteEnvironment to a flink cluster - posted by "Ruwen Moos (JIRA)" <ji...@apache.org> on 2016/10/06 14:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/06 16:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4758) Remove IOReadableWritable from classes where not needed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/06 16:52:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4759) Unclosed DataOutputViewStream in JavaSerializer - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/10/06 17:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4760) Kafka 09 Consumer failed to initialize state causing job to restart - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/10/06 22:47:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4761) Web UI can't display large log files - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/10/07 08:35:20 UTC, 0 replies.
- Issue in implementation of window operation - posted by MOHAMMAD SHAKIR <mo...@iiitd.ac.in> on 2016/10/07 08:46:39 UTC, 1 replies.
- [jira] [Created] (FLINK-4762) Use plural in time interval units - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/10/07 09:07:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4763) Documentation doesn't update nightly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/10/07 11:51:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4765) Migrate ConfigConstants to ConfigOptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/07 12:10:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4764) Introduce config options - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/07 12:10:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4768) Migrate High Availability configuration options - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/07 12:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4766) Migrate TaskManager configuration options - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/07 12:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4767) Migrate JobManager configuration options - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/07 12:12:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4769) Migrate Metrics configuration options - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/07 12:13:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4770) Migrate Job Execution configuration options - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/07 12:13:20 UTC, 0 replies.
- [FLINK-3035] Redis as State Backend - posted by Ovidiu Cristian Marcu <ov...@huawei.com> on 2016/10/07 14:31:59 UTC, 5 replies.
- [jira] [Created] (FLINK-4771) Compression for AvroOutputFormat - posted by "Lars Bachmann (JIRA)" <ji...@apache.org> on 2016/10/07 14:45:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4772) Store metrics in MetricStore as strings - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/07 14:49:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4773) Introduce an OperatorIOMetricGroup - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/07 14:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4774) QueryScopeInfo scope concatenation broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/07 14:58:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4775) Simplify access to MetricStore - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/07 15:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4776) Move ExecutionGraph initialization into a dedicated class - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/07 17:58:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4777) ContinuousFileMonitoringFunction may throw IOException when files are moved - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/10/07 18:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4778) Update program example in /docs/setup/cli.md due to the change in FLINK-2021 - posted by "Pattarawat Chormai (JIRA)" <ji...@apache.org> on 2016/10/07 19:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4779) Restoring from savepoint fails when BucketingSink has not yet created folder - posted by "static-max (JIRA)" <ji...@apache.org> on 2016/10/07 21:03:20 UTC, 0 replies.
- Allow TypeInfofactory regisration via ExecutionConfig - posted by Alexander Alexandrov <al...@gmail.com> on 2016/10/08 14:00:56 UTC, 2 replies.
- Re: Exception from in-progress implementation of Python API bulk iterations - posted by Geoffrey Mon <ge...@gmail.com> on 2016/10/08 17:27:40 UTC, 7 replies.
- [jira] [Created] (FLINK-4780) Ability to use UDP protocol in metrics-graphite - posted by "Maciej Prochniak (JIRA)" <ji...@apache.org> on 2016/10/09 08:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4781) Add User Defined Function(UDF) API for DataStream - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2016/10/09 08:31:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4782) log4j & slf4j-log4j are present in jar-with-dependencies artifacts - posted by "Maciej Prochniak (JIRA)" <ji...@apache.org> on 2016/10/09 11:56:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4783) Allow to register TypeInfoFactories manually - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/10 08:15:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4784) MetricQueryService actor name collision - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/10 08:39:20 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.1.3 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/10 09:05:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4785) Flink string parser doesn't handle string fields containing double quotes - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/10/10 09:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4786) BarrierBufferTest test instability - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/10 09:44:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4787) Add REST API call for cancel-with-savepoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/10/10 10:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4788) State backend class cannot be loaded, because fully qualified name converted to lower-case - posted by "Florian Koenig (JIRA)" <ji...@apache.org> on 2016/10/10 10:34:20 UTC, 0 replies.
- Type problem in RichFlatMapFunction when using GenericArray type - posted by Martin Junghanns <m....@mailbox.org> on 2016/10/10 11:31:58 UTC, 6 replies.
- [jira] [Created] (FLINK-4789) Avoid Kafka partition discovery on restore and share consumer instance for discovery and data consumption - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/10 13:05:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4790) FlinkML - Error of type while using readCsvFile - posted by "Thomas FOURNIER (JIRA)" <ji...@apache.org> on 2016/10/10 13:22:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4791) Fix issues caused by expression reduction - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/10/10 15:05:20 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.1.3 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/10 16:52:26 UTC, 6 replies.
- [jira] [Created] (FLINK-4792) Update documentation - QuickStart - FlinkML - posted by "Thomas FOURNIER (JIRA)" <ji...@apache.org> on 2016/10/10 16:55:20 UTC, 0 replies.
- S3/S3A support - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2016/10/10 22:13:35 UTC, 4 replies.
- [jira] [Created] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds - posted by "Ted Dunning (JIRA)" <ji...@apache.org> on 2016/10/11 01:38:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4794) partition_by_hash() crashes if no parameter is provided - posted by "Yakov Goldberg (JIRA)" <ji...@apache.org> on 2016/10/11 01:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4795) CsvStringify crashes in case of tuple in tuple, t.e. ("a", True, (1,5)) - posted by "Yakov Goldberg (JIRA)" <ji...@apache.org> on 2016/10/11 01:53:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4796) Extend SinkFunction to include also the event timestamp - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/11 08:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4797) Add Flink 1.1 savepoint backwards compatability - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/10/11 08:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/11 09:57:20 UTC, 0 replies.
- Re: [DISCUSS] Removing delete*Timer from the WindowOperator.Context - posted by Aljoscha Krettek <al...@apache.org> on 2016/10/11 12:02:51 UTC, 3 replies.
- [jira] [Created] (FLINK-4799) Re-add build-target symlink to project root - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/10/11 12:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4800) Refactor the ContinuousFileMonitoringFunction code and the related tests. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/10/11 14:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/10/11 16:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4802) distinct() implicitly uses 0th field, when called without a parameter - posted by "Yakov Goldberg (JIRA)" <ji...@apache.org> on 2016/10/11 17:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4803) Job Cancel can hang forever waiting for OutputFormat.close() - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/10/11 18:49:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4804) Grouping.first() function usage fails - posted by "Yakov Goldberg (JIRA)" <ji...@apache.org> on 2016/10/11 19:14:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4805) Stringify() crashes with Python3 (run with pyflink3) - posted by "Yakov Goldberg (JIRA)" <ji...@apache.org> on 2016/10/11 23:07:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4806) ResourceManager stop listening JobManager's leader address - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/10/12 01:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4807) ResourceManager clean up JobManager's registration - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/10/12 01:29:20 UTC, 0 replies.
- Re: Use specific worker for heavy computations - posted by Robert Metzger <rm...@apache.org> on 2016/10/12 08:35:08 UTC, 1 replies.
- Re: 答复: 答复: [DISCUSS] add netty tcp/restful pushed source support - posted by Robert Metzger <rm...@apache.org> on 2016/10/12 08:38:34 UTC, 1 replies.
- [jira] [Created] (FLINK-4808) Allow skipping failed checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/12 08:52:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4809) Operators should tolerate checkpoint failures - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/12 09:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/12 09:17:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4811) Checkpoint Overview should list failed checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/12 09:18:20 UTC, 0 replies.
- [DISCUSS] Support Suspending and Resuming of Flink Jobs - posted by SHI Xiaogang <sh...@gmail.com> on 2016/10/12 09:51:44 UTC, 2 replies.
- [jira] [Created] (FLINK-4812) Export currentLowWatermark metric also for sources - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/12 09:55:20 UTC, 0 replies.
- Re: currentLowWatermark metric not reported for all tasks? - posted by Robert Metzger <rm...@apache.org> on 2016/10/12 09:55:31 UTC, 1 replies.
- [jira] [Created] (FLINK-4813) Having flink-test-utils as a dependency outside Flink fails the build - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/12 12:51:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/10/12 16:18:20 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.1.3 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/12 16:54:46 UTC, 0 replies.
- RE：[DISCUSS] FLIP-11: Table API Stream Aggregations - posted by "王绍翾(大沙)" <sh...@alibaba-inc.com> on 2016/10/12 18:03:21 UTC, 4 replies.
- [jira] [Created] (FLINK-4815) Automatic fallback to earlier checkpoints when checkpoint restore fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/12 18:30:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4816) Executions from "DEPLOYING" should retain restored checkpoint information - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/12 19:11:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/12 19:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4818) RestartStrategy should track how many failed restore attempts the same checkpoint has and fall back to earlier checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/12 19:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4819) Checkpoint metadata+data inspection tool (view / update) - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/10/12 20:34:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels. - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2016/10/12 20:35:21 UTC, 0 replies.
- java.lang.IllegalArgumentException: JDBC-Class not found. - org.postgresql.jdbc.Driver - posted by sunny patel <su...@gmail.com> on 2016/10/12 21:18:27 UTC, 1 replies.
- [jira] [Created] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/10/13 07:06:20 UTC, 0 replies.
- Re: How to contribute to Streaming Table API and StreamSQL - posted by Juho Autio <ju...@rovio.com> on 2016/10/13 07:51:12 UTC, 1 replies.
- 答复: RE：[DISCUSS] FLIP-11: Table API Stream Aggregations - posted by Zhangrucong <zh...@huawei.com> on 2016/10/13 09:10:13 UTC, 5 replies.
- [jira] [Created] (FLINK-4822) Ensure that the Kafka 0.8 connector is compatible with kafka-consumer-groups.sh - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/13 10:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value - posted by "Sajeev Ramakrishnan (JIRA)" <ji...@apache.org> on 2016/10/13 11:23:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/13 12:21:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/10/13 14:13:20 UTC, 0 replies.
- [DISCUSS] Drop Hadoop 1 support with Flink 1.2 - posted by Robert Metzger <rm...@apache.org> on 2016/10/13 14:47:36 UTC, 12 replies.
- [ANNOUNCE] Flink 1.1.3 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/13 15:23:29 UTC, 0 replies.
- [jira] [Created] (FLINK-4826) Add keytab based kerberos support to run Flink in Mesos environment - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/10/13 22:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4827) Sql on streaming example use scala with wrong variable name - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2016/10/14 03:45:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4828) execute stream job asynchronously - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/10/14 09:21:21 UTC, 0 replies.
- [DISCUSS] Deprecate Hadoop source method from (batch) ExecutionEnvironment - posted by Fabian Hueske <fh...@gmail.com> on 2016/10/14 09:29:22 UTC, 3 replies.
- [jira] [Created] (FLINK-4829) Accumulators are not thread safe - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/14 09:56:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4830) Show latency statistics in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/14 12:43:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4831) IMplement a log4j metric reporter - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/14 13:26:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4832) Count/Sum 0 elements - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/10/14 13:48:20 UTC, 0 replies.
- A master project about implementing Cypher on Apache Flink - posted by Mengqi Yang <me...@gmail.com> on 2016/10/14 21:48:03 UTC, 1 replies.
- [jira] [Created] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/10/15 08:20:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4834) Implement unified High Availability Services Abstraction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/16 20:08:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4835) Implement standalone High Availability Services - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/16 20:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4836) Implement Mini Cluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/16 20:14:20 UTC, 0 replies.
- Flink Metrics - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2016/10/17 03:26:11 UTC, 3 replies.
- [jira] [Created] (FLINK-4837) flink-streaming-akka source connector - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/10/17 04:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4838) remove STREAM keyword in StreamSQLExample - posted by "Manu Zhang (JIRA)" <ji...@apache.org> on 2016/10/17 04:47:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4839) JobManager handle TaskManager's slot offering - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/10/17 05:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4840) Introduce an OperatorSystemMetricGroup - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/10/17 08:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4841) Suicide TaskManager if Task doesn't react to cancel signal - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/10/17 09:40:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4842) Introduce test to enforce order of operator / udf lifecycles - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/17 10:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4843) Introduce Test for FsCheckpointStateOutputStream::getPos - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/17 10:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4844) Partitionable Raw Keyed/Operator State - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/17 12:04:58 UTC, 0 replies.
- [DISCUSS] Schedule and Scope for Flink 1.2 - posted by Fabian Hueske <fh...@gmail.com> on 2016/10/17 12:18:33 UTC, 7 replies.
- [jira] [Created] (FLINK-4845) Fix Job Exceptions page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/17 12:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4846) FlinkML - Pass "env" has an implicit parameter in MLUtils.readLibSVM - posted by "Thomas FOURNIER (JIRA)" <ji...@apache.org> on 2016/10/17 13:42:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4847) Let RpcEndpoint.start/shutDown throw exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/17 14:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4849) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/10/17 17:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/10/17 17:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4850) FlinkML - SVM predict Operation for Vector and not LaveledVector - posted by "Thomas FOURNIER (JIRA)" <ji...@apache.org> on 2016/10/18 09:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4851) Add FatalErrorHandler and MetricRegistry to ResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/18 13:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4852) ClassCastException when assigning Watermarks with TimeCharacteristic.ProcessingTime - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/10/18 14:32:58 UTC, 0 replies.
- [DISCUSS] Defining the Semantics of StreamingSQL - posted by Fabian Hueske <fh...@gmail.com> on 2016/10/18 14:43:05 UTC, 2 replies.
- [jira] [Created] (FLINK-4853) Clean up JobManager registration at the ResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/18 14:59:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4854) Efficient Batch Operator in Streaming - posted by "Xiaowei Jiang (JIRA)" <ji...@apache.org> on 2016/10/19 01:32:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4855) Add partitionedKeyBy to DataStream - posted by "Xiaowei Jiang (JIRA)" <ji...@apache.org> on 2016/10/19 01:46:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4856) Add MapState for keyed streams - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/10/19 02:01:06 UTC, 0 replies.
- Add MapState for keyed streams - posted by SHI Xiaogang <sh...@gmail.com> on 2016/10/19 02:18:34 UTC, 9 replies.
- Type erasure problem solely on cluster execution - posted by Martin Junghanns <m....@mailbox.org> on 2016/10/19 06:52:48 UTC, 2 replies.
- Removing flink-contrib/flink-operator-stats - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/19 12:00:22 UTC, 5 replies.
- [jira] [Created] (FLINK-4857) ZooKeeperUtils have a throws exception clause without throwing exceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/19 12:23:58 UTC, 0 replies.
- FlinkML - Evaluate function should manage LabeledVector - posted by Thomas FOURNIER <th...@gmail.com> on 2016/10/19 13:05:47 UTC, 5 replies.
- [jira] [Created] (FLINK-4858) Remove Legacy Checkpointing Interfaces - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/19 14:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/19 14:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4860) Sort performance - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/19 16:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4861) Package optional project artifacts - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/19 19:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger - posted by "Manu Zhang (JIRA)" <ji...@apache.org> on 2016/10/20 04:33:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4863) states of merging window and trigger are set to different TimeWindows on merge - posted by "Manu Zhang (JIRA)" <ji...@apache.org> on 2016/10/20 07:03:58 UTC, 0 replies.
- Efficient Batch Operator in Streaming - posted by Xiaowei Jiang <xi...@gmail.com> on 2016/10/20 07:50:51 UTC, 2 replies.
- Add partitionedKeyBy to DataStream - posted by Xiaowei Jiang <xi...@gmail.com> on 2016/10/20 07:53:30 UTC, 1 replies.
- FLIP-6 and running many "small" jobs - posted by Maciek Próchniak <mp...@touk.pl> on 2016/10/20 08:07:17 UTC, 1 replies.
- Implicit class RichExecutionEnvironment - Can't use MlUtils.readLibSVM(path) in QUickStart guide - posted by Thomas FOURNIER <th...@gmail.com> on 2016/10/20 12:05:38 UTC, 4 replies.
- [jira] [Created] (FLINK-4864) Shade Calcite dependency in flink-table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/10/20 12:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4865) FlinkML - Add EvaluateDataSet operation for LabeledVector - posted by "Thomas FOURNIER (JIRA)" <ji...@apache.org> on 2016/10/20 12:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/20 12:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4867) Investigate code generation for improving sort performance - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/10/20 15:29:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4868) Insertion sort could avoid the swaps - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/10/20 16:09:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4869) Store record pointer after record keys - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/20 16:33:59 UTC, 0 replies.
- TopSpeedWindowing - in error: Could not forward element to next operator - posted by Ovidiu Cristian Marcu <ov...@huawei.com> on 2016/10/20 16:38:37 UTC, 3 replies.
- [jira] [Created] (FLINK-4870) ContinuousFileMonitoringFunction does not properly handle absolut Windows paths - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/20 16:42:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/20 17:29:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4872) Type erasure problem exclusively on cluster execution - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/10/20 17:36:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4873) Add config option to specify "home directory" for YARN client resource sharing - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/10/20 19:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4874) Enabling Flink web interface in local execution - posted by "Krishna Prasad Anna Ramesh Kumar (JIRA)" <ji...@apache.org> on 2016/10/21 01:35:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4875) operator name not correctly inferred - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/21 08:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost - posted by "Bram Vogelaar (JIRA)" <ji...@apache.org> on 2016/10/21 08:28:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4877) Refactorings around FLINK-3674 (User Function Timers) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/21 09:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4878) ReduceTaskExternalITCase.testMultiLevelMergeCombiningReduceTask test instable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/21 09:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2016/10/21 09:42:58 UTC, 0 replies.
- [FLINK-4832] Count/Sum 0 elements - posted by Anton Mushin <An...@epam.com> on 2016/10/21 11:54:42 UTC, 1 replies.
- [jira] [Created] (FLINK-4880) FlinkML - Implement Feature hashing (Data pre-processing) - posted by "Thomas FOURNIER (JIRA)" <ji...@apache.org> on 2016/10/21 11:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4881) Docker: Remove dependency on shared volumes - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/10/21 12:16:58 UTC, 0 replies.
- [DISCUSS] FLIP-13: Consistent Processing with Loops - posted by Paris Carbone <pa...@kth.se> on 2016/10/21 12:54:36 UTC, 4 replies.
- [jira] [Created] (FLINK-4882) Cleanup throws exception clause in HighAvailabilityServices - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/21 12:58:58 UTC, 0 replies.
- [FLINK-2118] Table API fails on composite filter conditions - posted by Alexander Shoshin <Al...@epam.com> on 2016/10/21 14:37:42 UTC, 1 replies.
- [jira] [Created] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/21 14:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4884) Eagerly Store MergingWindowSet in State in WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/21 15:54:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4885) Improve the Elasticsearch configuration flexibility - posted by "Mike Dias (JIRA)" <ji...@apache.org> on 2016/10/22 06:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4886) Example in Machine Learning Quickstart Guide causes error - posted by "Lim Chee Hau (JIRA)" <ji...@apache.org> on 2016/10/22 16:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4887) Replace ActorGateway by TaskGateway interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/22 17:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4888) instantiated job manager metrics missing important job statistics - posted by "Philipp von dem Bussche (JIRA)" <ji...@apache.org> on 2016/10/22 21:50:58 UTC, 0 replies.
- Python API iteration issues - posted by Geoffrey Mon <ge...@gmail.com> on 2016/10/23 02:58:53 UTC, 3 replies.
- [jira] [Created] (FLINK-4889) Make InstanceManager independent of ActorRef - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/23 13:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4890) FileInputFormatTest#testExcludeFiles fails on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/24 08:32:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4891) Remove flink-contrib/flink-operator-stats - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/10/24 09:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4892) Snapshot TimerService using Key-Grouped State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/24 10:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4893) Use single RecordSerializer per RecordWriter - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/10/24 10:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4894) Don't block on buffer request after broadcastEvent - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/10/24 10:08:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4895) Drop support for Hadoop 1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/24 13:31:58 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.1.4 - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/24 13:32:28 UTC, 12 replies.
- [jira] [Created] (FLINK-4896) PageRank algorithm for directed graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/24 20:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4897) Implement Dispatcher - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/10/24 23:01:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4898) Refactor HTTP handlers and Netty server/client - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/10/24 23:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4899) Implement DCOS package - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/10/25 00:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-4900) Implement Docker image support - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/10/25 00:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4901) Build DCOS Docker image - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/10/25 02:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4902) Flink Task Chain not getting input in a distributed manner - posted by "Sajeev Ramakrishnan (JIRA)" <ji...@apache.org> on 2016/10/25 03:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4903) Introduce non async future methods - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/25 08:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4904) Add a limit for how much data may be spilled in checkpoint alignments - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/25 08:51:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/25 09:52:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4906) Use constants for the name of system-defined metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/25 09:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4907) Add Test for Timers/State Provided by AbstractStreamOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/25 10:19:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4908) Add docs about evaluate operation to all predictors - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/10/25 12:46:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4909) JDBC Input format cast exception management - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2016/10/25 13:20:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4910) Introduce safety net for closing file system streams - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/25 13:32:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4911) Non-disruptive JobManager Failures - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/25 14:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4912) Introduce RECONCILIATING state in ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/25 14:37:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/10/25 14:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4915) Define parameters for reconciliation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/25 14:47:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4914) Define parameters for reconciliation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/25 14:47:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4916) BufferSpiller should distribute files across temp directories - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/25 15:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4917) Deprecate "CheckpointedAsynchronously" interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/25 15:36:58 UTC, 0 replies.
- [Discuss] FLIP-13 Side Outputs in Flink - posted by Chen Qin <cq...@uber.com> on 2016/10/25 16:00:00 UTC, 3 replies.
- [jira] [Created] (FLINK-4918) Add SSL support to Mesos artifact server - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/10/25 16:38:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4919) Add secure cookie support for the cluster deployed in Mesos environment - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/10/25 16:40:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4920) Add a Scala Function Gauge - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/25 17:26:58 UTC, 0 replies.
- SVMITSuite Testing - posted by Jesse Bannon <je...@parallelmachines.com> on 2016/10/25 18:10:01 UTC, 2 replies.
- [jira] [Created] (FLINK-4921) Upgrade to Mesos 1.0.1 - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/10/26 02:05:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4922) Write documentation - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/10/26 02:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4923) Expose input/output queued buffers and buffer usage as a metric for a Task - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/10/26 02:18:58 UTC, 0 replies.
- DataStream#explain - posted by Anton Solovev <An...@epam.com> on 2016/10/26 08:29:51 UTC, 4 replies.
- [jira] [Created] (FLINK-4924) Simplify Operator Test Harness Constructors - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/26 10:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4925) Integrate meters into IOMetricGroups - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/26 10:19:58 UTC, 0 replies.
- FLIP-6 and FLIP-12 - posted by Stephan Ewen <se...@apache.org> on 2016/10/26 11:05:29 UTC, 2 replies.
- [jira] [Created] (FLINK-4926) Implement FLIP-6 Flink-on-YARN jobs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/26 11:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4927) Implement YARN Resource Manager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/26 11:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4928) Implement YARN Application Master Runner - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/26 11:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4929) Implement YARN TaskManager Runner - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/26 11:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4930) Implement FLIP-6 YARN client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/26 11:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4931) Implement FLIP-6 YARN client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/26 11:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4932) Don't let ExecutionGraph fail when in state Restarting - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/26 12:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4933) ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/26 12:05:58 UTC, 0 replies.
- [HEADS UP] Introducing ConfigOptions - posted by Stephan Ewen <se...@apache.org> on 2016/10/26 12:36:05 UTC, 7 replies.
- [jira] [Created] (FLINK-4934) Triadic Census - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/26 14:03:58 UTC, 0 replies.
- Flink 1.2-SNAPSHOT Bucketing Sink problem - posted by Ozan DENİZ <oz...@outlook.com> on 2016/10/26 16:30:11 UTC, 3 replies.
- [jira] [Created] (FLINK-4935) Submit job with savepoint via REST API - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/10/26 17:01:58 UTC, 0 replies.
- [DISCUSS] Make FieldAccessor logic consistent with remaining API - posted by Fabian Hueske <fh...@gmail.com> on 2016/10/26 18:54:05 UTC, 2 replies.
- [jira] [Created] (FLINK-4936) Operator names for Gelly inputs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/26 19:08:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4937) Add incremental group window aggregation for streaming Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/10/26 21:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4938) Unnecessary update() call for Views to be removed in ViewUpdater#run() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/10/27 00:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4939) GenericWriteAheadSink: Decouple the subtask that created a pending checkpoint from the one that commits it. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/10/27 08:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4940) Add Support for Broadcast/Global State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/27 10:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4941) Show ship strategy in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/27 12:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4942) Improve processing performance of HeapInternalTimerService with key groups - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/27 12:36:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4943) flink-mesos/ConfigConstants: Typo: YYARN -> YARN - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/10/27 13:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4944) Replace Akka's deatch watch with own heartbeat on the TM side - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/27 14:40:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4945) KafkaConsumer logs wrong warning about confirmation for unknown checkpoint - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/27 16:40:58 UTC, 0 replies.
- Contributing to flink-web - posted by Greg Hogan <co...@greghogan.com> on 2016/10/27 17:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-4946) Load jar files from subdirectories of lib - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/27 19:10:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4947) Make all configuration possible via flink-conf.yaml and CLI. - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/10/27 19:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4948) Consider using checksums or similar to detect bad checkpoints - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/10/27 19:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-4949) Refactor Gelly driver inputs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/27 21:11:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4950) Add support to include multiple Yarn application entries in Yarn properties file - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/10/27 22:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4951) Better Javadocs for KeyedStream.flatMap - posted by "Manu Zhang (JIRA)" <ji...@apache.org> on 2016/10/28 03:03:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4952) Add Scala API for KeyedStream.flatMap - posted by "Manu Zhang (JIRA)" <ji...@apache.org> on 2016/10/28 03:07:58 UTC, 0 replies.
- Apache Flink and Kudu integration - posted by ru...@accenture.com on 2016/10/28 06:33:08 UTC, 1 replies.
- [jira] [Created] (FLINK-4953) Allow querying time in window functions - posted by "Manu Zhang (JIRA)" <ji...@apache.org> on 2016/10/28 06:54:58 UTC, 0 replies.
- Re: [DISCUSS] FLIP-11: Table API Stream Aggregations - posted by Jark Wu <wu...@alibaba-inc.com> on 2016/10/28 08:05:29 UTC, 1 replies.
- trouble with type casting - posted by Anton Solovev <An...@epam.com> on 2016/10/28 09:42:21 UTC, 2 replies.
- Re: [DISCUSS] Add Side Input/Broadcast Set For Streaming API - posted by venturadelmonte <ve...@gmail.com> on 2016/10/28 09:59:52 UTC, 0 replies.
- [jira] [Created] (FLINK-4954) Remove stashing from AkkaRpcActor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/28 11:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4955) Add Translations Tests for KeyedStream.flatMap(TimelyFlatMapFunction) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/28 11:59:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4956) Introduce convenient methods for testing checkpoint/restore in StreamTaskTestHarness - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/10/28 12:07:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4957) Provide API for TimelyCoFlatMapFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/28 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-4958) Send slot report to RM when registering - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/28 12:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4959) Write Documentation for Timely FlatMap Functions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/10/28 13:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4960) Enable testing of different re-scaling scenarios in the AbstractStreamOperatorTestHarness to - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/10/28 13:55:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4961) SGD for Matrix Factorization - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2016/10/28 14:07:58 UTC, 0 replies.
- [DISCUSSION] Timely function interface and timer params - posted by Gyula Fóra <gy...@apache.org> on 2016/10/28 14:54:49 UTC, 3 replies.
- [jira] [Created] (FLINK-4962) Improve exception information about operand type inference failed in UDF SQL validation - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/10/28 15:01:02 UTC, 0 replies.
- [jira] [Created] (FLINK-4963) Tabulate edge direction for directed VertexMetrics - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/28 16:28:58 UTC, 0 replies.
- Why checkpointing is synchronized with data processing? - posted by Renjie Liu <li...@gmail.com> on 2016/10/29 04:05:54 UTC, 1 replies.
- [jira] [Created] (FLINK-4964) FlinkML - Add StringIndexer - posted by "Thomas FOURNIER (JIRA)" <ji...@apache.org> on 2016/10/29 21:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4965) AllPairsShortestPaths - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/30 12:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4966) BetweennessCentrality - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/30 12:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4967) RockDB state backend fails on Windows - posted by "Yassine Marzougui (JIRA)" <ji...@apache.org> on 2016/10/30 17:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4968) Replace direct JobManager ActorGateways by JobManagerGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/30 18:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4969) TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos. - posted by "radu (JIRA)" <ji...@apache.org> on 2016/10/31 09:09:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4970) Parameterize vertex value for SSSP - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/10/31 12:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4971) Unify Stream Sinks and OutputFormats - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/31 13:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4972) CoordinatorShutdownTestrelies on race for success - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/10/31 13:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4973) Flakey Yarn tests due to recently added latency marker - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/31 15:32:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4974) RescalingITCase.testSavepointRescalingInPartitionedOperatorState unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/10/31 16:40:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4975) Add a limit for how much data may be buffered during checkpoint alignment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/31 16:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4976) Add a way to abort in flight checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/31 16:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4977) Enum serialization does not work properly - posted by "Sean Winard (JIRA)" <ji...@apache.org> on 2016/10/31 17:50:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4978) Present dropdown list with possible entry points for job - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/10/31 18:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4979) Submit Job view: Replace checkboxes for job entry with a link on the job name - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/10/31 18:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-4980) Include example source code in Flink binary distribution - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2016/10/31 18:14:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4981) Job Plan view: Not very readable and informative - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/10/31 18:17:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4982) quickstart example: Can't see the output - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/10/31 18:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4983) Web UI: Add favicon - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/10/31 18:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4984) Add Cancellation Barriers to BarrierTracker and BarrierBuffer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/31 18:54:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4985) Report Declined/Canceled Checkpoints to Checkpoint Coordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/10/31 18:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4986) Harden JobMaster logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/31 23:51:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4987) Harden slot pool logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/10/31 23:57:58 UTC, 0 replies.