You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Dynamic Scaling - posted by Jamie Grier <ja...@data-artisans.com> on 2017/01/02 19:48:10 UTC, 0 replies.
- [jira] [Created] (FLINK-5403) Apache Flink Snapshot 1.2 Javadocs link does not have files like index.html, overview-summary.html or index-all.html - posted by "Markus Dale (JIRA)" <ji...@apache.org> on 2017/01/02 22:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5404) Consolidate and update S3 documentation - posted by "Markus Dale (JIRA)" <ji...@apache.org> on 2017/01/03 03:12:58 UTC, 0 replies.
- Datastream splitter - Confusing behaviour - posted by madhairsilence <ha...@tcs.com> on 2017/01/03 11:26:09 UTC, 2 replies.
- Categorize or GroupBy datastream data and process with CEP separately - posted by madhairsilence <ha...@tcs.com> on 2017/01/03 11:30:04 UTC, 6 replies.
- [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) - posted by Robert Metzger <rm...@apache.org> on 2017/01/03 12:43:50 UTC, 0 replies.
- [jira] [Created] (FLINK-5405) Add streaming connection to twitter through a internet proxy - posted by "Luis (JIRA)" <ji...@apache.org> on 2017/01/03 21:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5406) add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/01/04 07:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5407) Savepoint for iterative Task fails. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/04 11:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5408) RocksDB initialization can fail with an UnsatisfiedLinkError in the presence of multiple classloaders - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/04 23:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5409) Separate Job API from the Runtime - posted by "Matt Zimmer (JIRA)" <ji...@apache.org> on 2017/01/05 01:24:58 UTC, 0 replies.
- CheckpointedFunction applicability? - posted by Eron Wright <ew...@live.com> on 2017/01/05 03:40:40 UTC, 2 replies.
- [jira] [Created] (FLINK-5410) Running out of memory on Yarn - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2017/01/05 08:42:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5411) LocalStreamEnvironmentITCase#testRunIsolatedJob failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/05 13:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5412) Enable RocksDB tests on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/05 15:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5413) Convert TableEnvironmentITCases to unit tests - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/05 15:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5414) Bump up Calcite version to 1.11 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/05 16:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5415) ContinuousFileProcessingTest failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/05 16:42:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5416) Function wrappers should support CheckpointedFunction - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/01/05 16:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5417) Fix the wrong config file name - posted by "Tao Wang (JIRA)" <ji...@apache.org> on 2017/01/06 04:18:58 UTC, 0 replies.
- DataStream and CEP - Pattern not matching after applying a window - posted by madhairsilence <ha...@tcs.com> on 2017/01/06 10:05:22 UTC, 4 replies.
- [jira] [Created] (FLINK-5418) Estimated row size does not support nested types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/06 11:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5419) Taskmanager metrics not accessible via REST - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/06 13:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5420) Make the CEP library rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/01/06 13:38:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5421) Explicit restore method in Snapshotable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/01/06 14:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5422) Check for name collisions in the Rolling/BucketingSink - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/01/06 16:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5423) Implement Stochastic Outlier Selection - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2017/01/06 17:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5424) Improve Restart Strategy Logging - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2017/01/06 19:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5425) JobManager replaced by IP in metrics - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2017/01/07 02:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5426) Clean up the Flink Machine Learning library - posted by "Fokko Driesprong (JIRA)" <ji...@apache.org> on 2017/01/07 19:15:58 UTC, 0 replies.
- time format for akka status - posted by Alexey Demin <di...@gmail.com> on 2017/01/08 07:32:09 UTC, 3 replies.
- Re: [ANNOUNCE] Flink 1.1.4 Released - posted by Till Rohrmann <tr...@apache.org> on 2017/01/09 10:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-5427) Typo in the event_timestamps_watermarks doc - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/01/09 10:36:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5428) Decrease restart delay in RecoveryITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/09 10:50:58 UTC, 0 replies.
- Re: [FLINK-3615] Add support for non-native SQL types - posted by Till Rohrmann <tr...@apache.org> on 2017/01/09 10:58:24 UTC, 1 replies.
- Re: [DISCUSS] ElasticSearch in Flink Strategy - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/01/09 11:24:26 UTC, 5 replies.
- Re: [DISCUSS] schedule for execution from different list of ExecutionJobVertex - posted by Till Rohrmann <tr...@apache.org> on 2017/01/09 11:58:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5429) Code generate types between operators in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/09 14:04:58 UTC, 0 replies.
- Re: [DISCUSS] Proposed updates to Flink project site - posted by Mike Winters <mw...@gmail.com> on 2017/01/09 14:07:39 UTC, 12 replies.
- [jira] [Created] (FLINK-5430) Bring documentation up to speed for current feature set - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/09 15:40:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5431) time format for akka status - posted by "Alexey Diomin (JIRA)" <ji...@apache.org> on 2017/01/09 17:58:58 UTC, 0 replies.
- Slow duplicated tests - posted by Alexey Demin <di...@gmail.com> on 2017/01/09 19:11:19 UTC, 3 replies.
- [jira] [Created] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files - posted by "Yassine Marzougui (JIRA)" <ji...@apache.org> on 2017/01/09 22:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5433) initiate function of Aggregate does not take effect for DataStream aggregation - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/01/10 08:29:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2017/01/10 10:23:58 UTC, 0 replies.
- 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) - posted by shijinkui <sh...@huawei.com> on 2017/01/10 10:58:40 UTC, 10 replies.
- [DISCUSS] Improvements to flink's cost based optimizer - posted by Kurt Young <yk...@gmail.com> on 2017/01/10 14:22:31 UTC, 3 replies.
- [jira] [Created] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12 - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/01/10 14:27:58 UTC, 0 replies.
- [DISCUSS] proposal for the User Defined AGGregate (UDAGG) - posted by Shaoxuan Wang <ws...@gmail.com> on 2017/01/10 14:40:25 UTC, 5 replies.
- [jira] [Created] (FLINK-5436) UDF state without CheckpointedRestoring can result in restarting loop - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/10 15:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5437) Make CheckpointedRestoring error message more detailed - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/10 15:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5438) Typo in JobGraph generator Exception - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/10 15:30:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5439) Adjust max parallelism when migrating - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/10 15:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5440) Misleading error message when migrating and scaling down from savepoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/10 15:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5441) Directly allow SQL queries on a Table - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/10 15:47:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5442) Add test to fix ordinals of serialized enum StateDescriptor.Type - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/01/11 10:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5443) Create a path to migrate from the Rolling to the BucketingSink. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/01/11 10:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5444) Flink UI uses absolute URLs. - posted by "Joerg Schad (JIRA)" <ji...@apache.org> on 2017/01/11 10:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5445) flink kafka consumer should support rate control - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2017/01/11 11:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5446) System metrics reference incomplete - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/11 14:11:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5447) Sync documentation of built-in functions for Table API with SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/11 14:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5448) Fix typo in StateAssignmentOperation Exception - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/11 14:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5449) Time drift in MetricRegistry - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/01/11 14:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5450) WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/11 14:52:58 UTC, 0 replies.
- Flink CEP development is stalling - posted by Ivan Mushketyk <iv...@gmail.com> on 2017/01/11 15:23:58 UTC, 9 replies.
- [jira] [Created] (FLINK-5451) Extend JMX metrics documentation section - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/11 16:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5452) Make table unit tests pass under cluster mode - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/01/11 16:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5453) REST API request reference incomplete - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/11 16:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5454) Add Documentation about how to tune Checkpointing for large state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/11 20:11:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5455) Create documentation how to upgrade jobs and Flink framework versions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/11 20:13:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5456) Add docs about new state and checkpointing interfaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/11 20:15:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5457) Create documentation for Asynchronous I/O - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/11 20:16:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5458) Add documentation how to migrate from Flink 1.1. to Flink 1.2 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/11 20:17:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5459) Add documentation how to debug classloading and event time issues - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/11 20:18:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5460) Add documentation how to use Flink with Docker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/11 20:19:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5461) Remove Superflous TypeInformation Declaration - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/01/11 20:23:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5462) Flink job fails due to java.util.concurrent.CancellationException while snapshotting - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/11 20:29:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5463) RocksDB.disposeInternal does not react to interrupts, blocks task cancellation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/11 20:32:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/11 20:34:16 UTC, 0 replies.
- [jira] [Created] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/11 21:05:17 UTC, 0 replies.
- [jira] [Created] (FLINK-5466) Make production environment default in gulpfile - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/12 09:45:57 UTC, 0 replies.
- [jira] [Created] (FLINK-5467) Stateless chained tasks set legacy operator state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/12 11:06:05 UTC, 0 replies.
- [jira] [Created] (FLINK-5468) Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/12 11:36:52 UTC, 0 replies.
- FOSDEM 2017 Open Source Conference - Brussels - posted by Sharan F <sh...@apache.org> on 2017/01/12 12:12:10 UTC, 0 replies.
- [jira] [Created] (FLINK-5469) build_docs.sh -p fails on Windows Subsystem for Linux - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/12 14:48:52 UTC, 0 replies.
- [jira] [Created] (FLINK-5470) Requesting non-existing log/stdout file from TM crashes the it - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/12 15:02:05 UTC, 0 replies.
- [jira] [Created] (FLINK-5471) Properly inform JobClientActor about terminated Mesos framework - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/12 15:09:54 UTC, 0 replies.
- [jira] [Created] (FLINK-5472) Flink's web server does not support https requests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/12 15:16:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5473) setMaxParallelism() higher than 1 is possible on non-parallel operators - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/12 15:22:53 UTC, 0 replies.
- [jira] [Created] (FLINK-5474) Extend DC/OS documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/12 15:27:52 UTC, 0 replies.
- [jira] [Created] (FLINK-5475) Extend DC/OS documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/12 15:28:52 UTC, 0 replies.
- [jira] [Created] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/12 15:33:52 UTC, 0 replies.
- Backpressure rationale - posted by Gábor Gévay <gg...@gmail.com> on 2017/01/12 15:36:55 UTC, 1 replies.
- some questions about submit flink job on flink-yarn - posted by "huangwei (G)" <hu...@huawei.com> on 2017/01/13 08:02:59 UTC, 4 replies.
- [jira] [Created] (FLINK-5477) Summary columns not aligned correctly - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/13 09:29:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5478) Redis Sink Connector should allow update of command without reinstatiation - posted by "Atharva Inamdar (JIRA)" <ji...@apache.org> on 2017/01/13 10:24:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/01/13 10:50:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5480) User-provided hashes for operators - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/01/13 13:02:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5481) Cannot create Collection of Row - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2017/01/13 15:14:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5482) QueryableStateClient does not recover from a failed lookup due to a non-running job - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/13 15:26:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5483) Link to "linking modules not contained in binary distribution" broken in all connector documentations - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/01/13 15:31:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5484) Kryo serialization changed between 1.1 and 1.2 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/13 15:55:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5485) Mark compiled web frontend files as binary when processed by git diff - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/01/13 18:30:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/01/13 19:33:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5487) Proper at-least-once support for ElasticsearchSink - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/01/13 21:11:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/01/13 21:14:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5489) maven release:prepare fails due to invalid JDOM comments in pom.xml - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/01/13 22:47:26 UTC, 0 replies.
- Becoming a contributor JIRA - posted by Haohui Mai <wh...@apache.org> on 2017/01/14 05:17:31 UTC, 1 replies.
- Taking time off - posted by Maximilian Michels <mx...@apache.org> on 2017/01/14 08:03:29 UTC, 6 replies.
- [jira] [Created] (FLINK-5490) ContextEnvironment.getExecutionPlan() clears Sinks - posted by "Robert Schmidtke (JIRA)" <ji...@apache.org> on 2017/01/14 12:57:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5491) Document default settings for yarn cluster mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/15 11:38:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5492) BootstrapTools log wrong address of started ActorSystem - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/15 11:53:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5493) FlinkDistributionOverlay does not properly display missing environment variables - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/15 19:07:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5494) Improve Mesos documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/15 19:16:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5495) ZooKeeperMesosWorkerStore cannot be instantiated - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/15 19:20:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5496) ClassCastException when using Mesos HA mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/15 19:23:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5497) remove duplicated tests - posted by "Alexey Diomin (JIRA)" <ji...@apache.org> on 2017/01/15 20:12:26 UTC, 0 replies.
- Need guidance for write a client connector for 'Flink' - posted by Pawan Manishka Gunarathna <pa...@gmail.com> on 2017/01/16 05:18:00 UTC, 5 replies.
- [jira] [Created] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins - posted by "lincoln.lee (JIRA)" <ji...@apache.org> on 2017/01/16 06:46:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5499) Try to reuse the resource location of previous execution attempt when allocate slot - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2017/01/16 07:37:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5500) Error when created array literals - posted by "Yuhong Hong (JIRA)" <ji...@apache.org> on 2017/01/16 08:25:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5501) Determine whether the job starts from last JobManager failure - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2017/01/16 10:17:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5502) Add documentation about migrating from 1.1 to 1.2 - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/01/16 10:29:26 UTC, 0 replies.
- Flink Code Base Best Practices - posted by Ufuk Celebi <uc...@apache.org> on 2017/01/16 11:05:33 UTC, 2 replies.
- [jira] [Created] (FLINK-5503) mesos-appmaster.sh script could print return value message - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/16 11:18:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5504) mesos-appmaster.sh logs to wrong directory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/16 11:23:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5505) Rename recovery.zookeeper.path.mesos-workers into high-availability.zookeeper.path.mesos-workers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/16 11:28:26 UTC, 0 replies.
- [DISCUSS] (Not) tagging reviewers - posted by Stephan Ewen <se...@apache.org> on 2017/01/16 11:42:08 UTC, 16 replies.
- [jira] [Created] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - posted by "Miguel Carvalho Valente Esaguy Coimbra (JIRA)" <ji...@apache.org> on 2017/01/16 11:48:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5507) remove queryable list state sink - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/16 12:25:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5508) Remove Mesos dynamic class loading - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/16 13:26:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5509) Replace QueryableStateClient keyHashCode argument - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/16 14:03:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5510) Replace Scala Future with FlinkFuture in QueryableStateClient - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/16 14:07:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5511) Add support for outer joins with local predicates - posted by "lincoln.lee (JIRA)" <ji...@apache.org> on 2017/01/16 14:27:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5512) RabbitMQ documentation should inform that exactly-once holds for RMQSource only when parallelism is 1 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/01/16 15:23:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5513) Remove relocation of internal API classes - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/16 15:30:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5514) Implement an efficient physical execution for CUBE/ROLLUP/GROUPING SETS - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/16 15:49:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5515) fix unused kvState.getSerializedValue call in KvStateServerHandler - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/16 17:45:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5516) Hardcoded paths in flink-python - posted by "Felix seibert (JIRA)" <ji...@apache.org> on 2017/01/16 19:31:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5517) Upgrade hbase version to 1.3.0 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/01/17 01:31:26 UTC, 0 replies.
- [Dev] Dependencies issue related to implementing InputFormat Interface - posted by Pawan Manishka Gunarathna <pa...@gmail.com> on 2017/01/17 03:18:04 UTC, 5 replies.
- States split over to external storage - posted by Chen Qin <cq...@uber.com> on 2017/01/17 05:29:49 UTC, 5 replies.
- 答复: States split over to external storage - posted by liuxinchun <li...@huawei.com> on 2017/01/17 06:51:08 UTC, 2 replies.
- [jira] [Created] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open() - posted by "Jakub Havlik (JIRA)" <ji...@apache.org> on 2017/01/17 06:53:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5519) scala-maven-plugin version all change to 3.2.2 - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/01/17 07:08:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5520) Disable outer joins with non-equality predicates - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/17 07:56:26 UTC, 0 replies.
- New Flink team member - Kate Eri. - posted by Katherin Sotenko <ka...@gmail.com> on 2017/01/17 09:39:13 UTC, 6 replies.
- [jira] [Created] (FLINK-5521) remove unused KvStateRequestSerializer#serializeList - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/17 09:41:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5522) Storm LocalCluster can't run with powermock - posted by "liuyuzhong7 (JIRA)" <ji...@apache.org> on 2017/01/17 11:07:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5523) Improve access of fields in code generated functions with filters - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/17 11:22:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5524) Support early out for code generated conjunctive conditions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/17 11:28:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5525) Streaming Version of a Linear Regression model - posted by "Stavros Kontopoulos (JIRA)" <ji...@apache.org> on 2017/01/17 12:08:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5526) QueryableState: notify upon receiving a query but having queryable state disabled - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/17 12:42:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5527) QueryableState: requesting a non-existing key in MemoryStateBackend or FsStateBackend does not return the default value - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/17 13:22:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5528) tests: reduce the retry delay in QueryableStateITCase - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/17 13:51:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5529) Improve / extends windowing documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/17 13:59:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5530) race condition in AbstractRocksDBState#getSerializedValue - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/17 14:49:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5531) SSl code block formatting is broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/17 15:18:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5532) Make the marker windowassignes for the fast aligned windows non-extendable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/01/17 17:43:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5533) DCOS Integration - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/01/17 18:57:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5534) Config option: 'flink-options' - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/01/17 19:41:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5536) Config option: HA - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/01/17 19:42:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5535) Config option: HDFS - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/01/17 19:42:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5537) Config option: SSL - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/01/17 19:43:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5538) Config option: Kerberos - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/01/17 19:43:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5539) CLI: info/list/stop/cancel - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/01/17 19:46:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5540) CLI: savepoint - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/01/17 19:47:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/01/17 21:25:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5542) YARN client incorrectly uses local YARN config to check vcore capacity - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2017/01/17 22:36:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5543) customCommandLine tips in CliFrontend - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/01/18 00:31:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5544) Implement Internal Timer Service in RocksDB - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2017/01/18 03:40:26 UTC, 2 replies.
- [jira] [Created] (FLINK-5545) remove FlinkAggregateExpandDistinctAggregatesRule when we upgrade calcite - posted by "Zhenghua Gao (JIRA)" <ji...@apache.org> on 2017/01/18 07:53:27 UTC, 0 replies.
- [DISCUSS] Time-based releases in Flink - posted by Robert Metzger <rm...@apache.org> on 2017/01/18 08:19:18 UTC, 9 replies.
- [jira] [Created] (FLINK-5546) When multiple users run test, /tmp/cacheFile conflicts - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2017/01/18 09:13:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5547) Move checks for DataSetRel validity into constructor - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/18 09:17:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5548) Move - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/18 09:18:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5549) TypeExtractor fails with RuntimeException, but should use GGenericTypeInfoeneric - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/18 10:32:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5550) NotFoundException: Could not find job with id - posted by "jiwengang (JIRA)" <ji...@apache.org> on 2017/01/18 11:06:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5551) NPE at SourceStreamTask - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/01/18 11:08:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5552) Make the JMX port available through RESTful API - posted by "david.wang (JIRA)" <ji...@apache.org> on 2017/01/18 11:14:26 UTC, 0 replies.
- New contributor in flink - posted by Tao Meng <oa...@gmail.com> on 2017/01/18 12:44:04 UTC, 1 replies.
- [jira] [Created] (FLINK-5553) Job fails during deployment with IllegalStateException from subpartition request - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/18 15:07:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5554) Add sql operator to table api for getting columns from HBase - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2017/01/18 15:28:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5555) Add documentation about debugging watermarks - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/18 15:43:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5556) BarrierBuffer resets bytes written on spiller roll over - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/18 16:37:26 UTC, 0 replies.
- ApacheCon CFP closing soon (11 February) - posted by Rich Bowen <rb...@apache.org> on 2017/01/18 16:45:41 UTC, 0 replies.
- [jira] [Created] (FLINK-5557) Fix link in library methods - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/01/18 16:56:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5558) Replace TriangleCount with a Count analytic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/01/18 17:02:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5559) queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/18 17:18:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5560) Header in checkpoint stats summary misaligned - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/18 17:21:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5561) DataInputDeserializer#available returns one too few - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/18 17:51:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5563) Add density to vertex metrics - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/01/18 18:18:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5562) Driver fixes - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/01/18 18:18:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5564) User Defined Aggregates - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2017/01/18 19:48:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5565) Improve flink cost model framework - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/01/19 03:08:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5566) Introduce structure to hold table and column level statistics - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/01/19 03:11:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5567) Introduce and migrate current table statistics to FlinkStatistics - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/01/19 03:13:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5568) Introduce interface for catalog, and provide an in-memory implementation - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/01/19 03:16:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5569) Migrate current table registration to in-memory catalog - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/01/19 03:16:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5570) Support register external catalog to table environment - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/01/19 03:18:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5571) add open/close methods for UserDefinedFunction in TableAPI & SQL - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/01/19 03:21:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5572) ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2017/01/19 13:19:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5573) Kafka08ITCase.testStartFromZookeeperCommitOffsets fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/19 13:45:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5574) Add checkpoint statistics docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/19 14:16:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5575) add redirect to latest stable docs - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/01/19 14:25:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5576) extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/19 14:40:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5577) Each time application is submitted to yarn, application id increases by two - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/01/19 15:22:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5578) Each time application is submitted to yarn, application id increases by two - posted by "Yelei Feng (JIRA)" <ji...@apache.org> on 2017/01/19 15:23:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5579) Kerberos not working for Kafka connector using ticket cache - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/01/19 16:17:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5580) Kerberos keytabs not working for YARN deployment mode - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/01/19 16:22:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5581) Improve Kerberos security related documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/01/19 16:27:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5582) Add a general distributive aggregate function - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/19 16:57:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5583) Support flexible error handling in the Kafka consumer - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/01/19 20:08:27 UTC, 0 replies.
- Flink with Yarn on MapR - posted by Aniket Deshpande <ad...@kabbage.com> on 2017/01/19 23:27:12 UTC, 4 replies.
- [jira] [Created] (FLINK-5584) Support Sliding-count row-window on streaming sql - posted by "Yuhong Hong (JIRA)" <ji...@apache.org> on 2017/01/20 01:44:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5585) NullPointer Exception in JobManager.updateAccumulators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/20 10:12:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5586) Extend TableProgramsTestBase for object reuse modes - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/20 11:34:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5587) AsyncWaitOperatorTest timed out on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/20 11:37:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5588) Add a unit scaler based on different norms - posted by "Stavros Kontopoulos (JIRA)" <ji...@apache.org> on 2017/01/20 13:15:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5589) Tumbling group windows on batch tables do not consider object reuse - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/20 13:15:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5590) Create a proper internal state hierarchy - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/20 13:56:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5591) queryable state: request failures failing on the server side do not contain client stack trace - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/20 14:16:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2017/01/20 15:10:26 UTC, 0 replies.
- Unregistering Managed State in Operator Backend - posted by Paris Carbone <pa...@kth.se> on 2017/01/20 16:59:49 UTC, 8 replies.
- [jira] [Created] (FLINK-5593) Modify current dcos-flink implementation to use runit service - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2017/01/20 17:18:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5594) Use higher-resolution graphic on Flink project site homepage - posted by "Mike Winters (JIRA)" <ji...@apache.org> on 2017/01/20 17:43:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5595) Add links to sub-sections in the left-hand navigation bar - posted by "Mike Winters (JIRA)" <ji...@apache.org> on 2017/01/20 17:53:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5596) Add padding to nav menu on mobile site - posted by "Mike Winters (JIRA)" <ji...@apache.org> on 2017/01/20 18:13:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5597) Improve the LocalClusteringCoefficient documentation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2017/01/20 19:06:26 UTC, 0 replies.
- Need help on understanding flink runtime and window function - posted by Fritz Budiyanto <fb...@icloud.com> on 2017/01/20 19:09:49 UTC, 1 replies.
- [jira] [Created] (FLINK-5598) Return jar name when jar is uploaded - posted by "Sendoh (JIRA)" <ji...@apache.org> on 2017/01/20 23:33:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5599) State interface docs often refer to keyed state only - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/21 16:07:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5600) Improve error message when triggering savepoint without specified directory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/21 16:33:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5601) Window operator does not checkpoint watermarks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/21 16:42:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5602) Migration with RocksDB job led to NPE for next checkpoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/21 17:16:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5603) Use Flink's futures in QueryableStateClient - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/22 12:05:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5604) Replace QueryableStateClient constructor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/22 12:07:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5605) Make KvStateRequestSerializer package private - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/22 12:09:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5606) Remove magic number in key and namespace serialization - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/22 12:12:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5607) Move location lookup retry out of KvStateLocationLookupService - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/22 12:43:27 UTC, 0 replies.
- Strange segfaults in Flink 1.2 (probably not RocksDB related) - posted by Gyula Fóra <gy...@apache.org> on 2017/01/22 18:51:57 UTC, 4 replies.
- [jira] [Created] (FLINK-5608) Cancel button not always visible - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2017/01/22 20:46:26 UTC, 0 replies.
- GlobFilePathFilter NotSerializableException - posted by Andrew Psaltis <ps...@gmail.com> on 2017/01/22 23:07:56 UTC, 1 replies.
- [Dev] Flink 'InputFormat' Interface execution related problem - posted by Pawan Manishka Gunarathna <pa...@gmail.com> on 2017/01/23 07:44:01 UTC, 5 replies.
- [jira] [Created] (FLINK-5609) Add last update time to docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/23 09:10:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5610) Rename Installation and Setup to Project Setup - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/23 09:14:26 UTC, 0 replies.
- [Discuss] Some problem Unit test - posted by sjk <sh...@163.com> on 2017/01/23 09:17:24 UTC, 1 replies.
- [jira] [Created] (FLINK-5611) Add QueryableStateException type - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/23 10:00:35 UTC, 0 replies.
- [jira] [Created] (FLINK-5612) GlobPathFilter not-serializable exception - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/23 10:37:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5613) QueryableState: requesting a non-existing key in RocksDBStateBackend is not consistent with the MemoryStateBackend and FsStateBackend - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/23 10:54:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5614) Enable snapshot builds for release branches - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/23 11:02:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5615) queryable state: execute the QueryableStateITCase for all three state back-ends - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/23 11:28:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/01/23 12:22:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5617) Check new public APIs in 1.2 release - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/23 13:26:26 UTC, 0 replies.
- [DISCUSS] Development of SQL OVER / Table API Row Windows for streaming tables - posted by Fabian Hueske <fh...@gmail.com> on 2017/01/23 15:30:47 UTC, 24 replies.
- [jira] [Created] (FLINK-5618) Add queryable state documentation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/23 15:41:26 UTC, 0 replies.
- [Dev] Issue related to importing org.apache.flink.types.Row - posted by Pawan Manishka Gunarathna <pa...@gmail.com> on 2017/01/24 06:30:55 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.2.0 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2017/01/24 14:03:24 UTC, 7 replies.
- Re: clean up jira - posted by Robert Metzger <rm...@apache.org> on 2017/01/24 15:33:04 UTC, 3 replies.
- [Proposal] RichFsSinkFunction - posted by Seth Wiesman <sw...@mediamath.com> on 2017/01/24 17:06:28 UTC, 1 replies.
- [jira] [Created] (FLINK-5630) Followups to AggregationFunction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/24 19:12:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5631) [yarn] Support downloading additional jars from non-HDFS paths - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/01/24 22:55:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5632) Typo in StreamGraph - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/01/25 03:36:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job. - posted by "Giuliano Caliari (JIRA)" <ji...@apache.org> on 2017/01/25 05:53:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5634) Flink should not always redirect stdout to a file. - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2017/01/25 06:01:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2017/01/25 06:18:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5636) IO Metric for StreamTwoInputProcessor - posted by "david.wang (JIRA)" <ji...@apache.org> on 2017/01/25 08:25:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5637) Default Flink configuration contains whitespace characters, causing parser WARNings - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/25 10:16:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5638) Deadlock when closing two chained async I/O operators - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/25 11:03:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5639) Clarify License implications of RabbitMQ Connector - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/01/25 11:06:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5640) configure the explicit Unit Test file suffix - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/01/25 12:47:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5641) Directories of expired checkpoints are not cleaned up - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/25 13:13:26 UTC, 0 replies.
- [CANCELLED][VOTE] Release Apache Flink 1.2.0 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2017/01/25 13:13:57 UTC, 1 replies.
- #quesiton: documentation for knn/examples/fetching cluster numbers in red? - posted by Alex De Castro <al...@lab49.com> on 2017/01/25 13:23:58 UTC, 0 replies.
- flink-ml test - posted by Anton Solovev <An...@epam.com> on 2017/01/25 13:24:33 UTC, 8 replies.
- [jira] [Created] (FLINK-5642) queryable state: race condition with HeadListState - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/25 13:32:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5643) StateUtil.discardStateFuture fails when state future contains null value - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/25 13:39:27 UTC, 0 replies.
- STREAM SQL inner queries - posted by Radu Tudoran <ra...@huawei.com> on 2017/01/25 13:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5644) Task#lastCheckpointSize metric broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/25 13:58:27 UTC, 0 replies.
- [jira] [Created] (FLINK-5645) WebInterface does not show IO metrics for failed jobs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/25 16:08:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5646) REST api documentation missing details on jar upload - posted by "Cliff Resnick (JIRA)" <ji...@apache.org> on 2017/01/25 19:34:26 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.2.0 (RC2) - posted by Robert Metzger <rm...@apache.org> on 2017/01/25 20:14:04 UTC, 9 replies.
- [jira] [Created] (FLINK-5647) Fix RocksDB Backend Cleanup - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/01/25 21:09:26 UTC, 0 replies.
- TestBaseUtils refactoring - posted by Anton Solovev <An...@epam.com> on 2017/01/25 23:46:57 UTC, 3 replies.
- [jira] [Created] (FLINK-5648) Task Manager ID missing from logs link in Job Manager UI - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2017/01/25 23:53:26 UTC, 0 replies.
- [jira] [Created] (FLINK-5649) KryoException when starting job from Flink 1.2.0 rc0 savepoint - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2017/01/26 00:25:26 UTC, 0 replies.
- Flink 1.2.0 rc2 Bugs - posted by Scott Kidder <ki...@gmail.com> on 2017/01/26 00:29:15 UTC, 1 replies.
- Re: STREAM SQL inner queries - posted by Shaoxuan Wang <ws...@gmail.com> on 2017/01/26 03:35:39 UTC, 14 replies.
- [jira] [Created] (FLINK-5650) flink-python unit test costs more than half hour - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2017/01/26 07:43:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5651) state backends: forbid Iterator#remove() from the Iterable returned by HeapListState#get() - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/01/26 08:41:24 UTC, 0 replies.
- [Discuss] Declare class field's type in scala class field - posted by Jinkui Shi <sh...@163.com> on 2017/01/26 09:27:13 UTC, 3 replies.
- Stream SQL and Dynamic tables - posted by Radu Tudoran <ra...@huawei.com> on 2017/01/26 10:33:05 UTC, 6 replies.
- [jira] [Created] (FLINK-5652) Memory leak in AsyncDataStream - posted by "Dmitry Golubets (JIRA)" <ji...@apache.org> on 2017/01/26 11:56:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5653) Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/26 13:35:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/26 13:44:24 UTC, 2 replies.
- [jira] [Created] (FLINK-5655) Add event time OVER RANGE BETWEEN x PRECEDING aggregation to SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/26 13:48:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/26 13:49:24 UTC, 3 replies.
- [jira] [Created] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/26 13:52:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5658) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/01/26 13:54:24 UTC, 0 replies.
- Re: #quesiton: documentation for knn/examples/fetching cluster numbers in red? - posted by Till Rohrmann <tr...@apache.org> on 2017/01/26 14:00:09 UTC, 1 replies.
- [jira] [Created] (FLINK-5659) FileBaseUtils#deleteFileOrDirectory not thread-safe on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/01/26 14:46:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5660) Not properly cleaning PendingCheckpoints up - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/26 15:31:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5661) flink-mesos should shade its httpclient dependency away - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2017/01/26 16:12:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5662) Alias in front of output fails - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/26 16:20:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5663) Checkpoint fails because of closed registry - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/26 16:34:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5664) RocksDBBackend logging is noisy - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/26 16:38:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5665) Lingering files after failed checkpoint - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/26 16:51:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5666) Blob files are not cleaned up from ZK storage directory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/26 16:53:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5667) Possible state data loss when task fails while checkpointing - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/01/26 18:49:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5668) Reduce dependency on HDFS at job startup time - posted by "Bill Liu (JIRA)" <ji...@apache.org> on 2017/01/26 22:23:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5669) flink-streaming-contrib DataStreamUtils.collect in local environment mode fails when offline - posted by "Rick Cox (JIRA)" <ji...@apache.org> on 2017/01/26 22:59:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5670) Local RocksDB directories not cleaned up - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/27 09:21:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5671) Test ClassLoaderITCase#testJobsWithCustomClassLoader fails - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2017/01/27 10:08:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5672) Job fails with java.lang.IllegalArgumentException: port out of range:-1 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/27 10:39:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5673) NullPointerException in RemoteInputChannel.requestSubpartition - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/27 10:54:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5674) Stdout not present in logs files - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/27 11:11:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5675) Improve QueryableStateClient API - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/01/27 12:29:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5676) Grouping on nested fields does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/27 13:30:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5677) Validation layer should check whether field can be used as grouping key - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/27 13:43:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5678) User-defined TableFunctions do not support all types of parameters - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/01/27 14:03:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up - posted by "Andrew Efimov (JIRA)" <ji...@apache.org> on 2017/01/27 16:02:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5680) Document env.ssh.opts - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/01/27 16:46:24 UTC, 0 replies.
- [jira] [Created] (FLINK-5681) Make ReaperThread for SafetyNetCloseableRegistry a singleton - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/01/27 18:51:25 UTC, 0 replies.
- [jira] [Created] (FLINK-5682) Fix scala version in flink-streaming-scala - posted by "Bill Liu (JIRA)" <ji...@apache.org> on 2017/01/28 00:58:24 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.2.0 (RC3) - posted by Robert Metzger <rm...@apache.org> on 2017/01/30 07:40:58 UTC, 8 replies.
- es v5 support - posted by Sree V <sr...@yahoo.com.INVALID> on 2017/01/31 05:28:05 UTC, 1 replies.
- Re: Flink survey by data Artisans - posted by Mike Winters <mi...@data-artisans.com> on 2017/01/31 10:27:38 UTC, 0 replies.
- [jira] (FLINK-5693) ChecksumHashCode DataSetAnalytic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/01/31 17:16:51 UTC, 0 replies.
- [jira] (FLINK-5694) Collect DataSetAnalytic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/01/31 17:17:51 UTC, 0 replies.
- Call for abstracts open for Dataworks & Hadoop Summit San Jose - posted by Alan Gates <al...@gmail.com> on 2017/01/31 19:11:41 UTC, 0 replies.
- Conditional branching in Table API - posted by Chen Qin <cq...@uber.com> on 2017/01/31 23:29:51 UTC, 1 replies.