You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-4988) Elasticsearch 5.x support - posted by "Mike Dias (JIRA)" <ji...@apache.org> on 2016/11/01 03:21:58 UTC, 0 replies.
- Re: [DISCUSS][FLIP-4] Enhance Window Evictor in Flink - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/11/01 03:55:30 UTC, 1 replies.
- Re: [DISCUSS] Add Side Input/Broadcast Set For Streaming API - posted by Aljoscha Krettek <al...@apache.org> on 2016/11/01 13:52:49 UTC, 1 replies.
- [jira] [Created] (FLINK-4989) Completed job -> Properties: Misleading label - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/11/01 15:01:58 UTC, 0 replies.
- Re: [DISCUSSION] Timely function interface and timer params - posted by Aljoscha Krettek <al...@apache.org> on 2016/11/01 15:39:36 UTC, 1 replies.
- Disabling Jenkins for PRs - posted by Ufuk Celebi <uc...@apache.org> on 2016/11/01 17:23:43 UTC, 3 replies.
- [jira] [Created] (FLINK-4990) Remove JAR option from savepoint disposal - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/01 20:29:58 UTC, 0 replies.
- Re: [DISCUSS] FLIP-11: Table API Stream Aggregations - posted by Sean Wang <ws...@gmail.com> on 2016/11/02 03:49:05 UTC, 1 replies.
- [jira] [Created] (FLINK-4991) TestTask hangs in testWatchDogInterruptsTask - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/02 07:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/11/02 08:47:59 UTC, 0 replies.
- Re: [DISCUSS] FLIP-2 Extending Window Function Metadata - posted by Aljoscha Krettek <al...@apache.org> on 2016/11/02 09:16:11 UTC, 3 replies.
- [jira] [Created] (FLINK-4993) Don't Allow Trigger.onMerge() to return TriggerResult - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 09:51:58 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink 1.1.4 - posted by Ufuk Celebi <uc...@apache.org> on 2016/11/02 10:43:02 UTC, 4 replies.
- Assign a unique id to each line of a dataset - posted by Thomas FOURNIER <th...@gmail.com> on 2016/11/02 12:17:35 UTC, 1 replies.
- [FLINK-3848] Add ProjectableTableSource - posted by Anton Solovev <An...@epam.com> on 2016/11/02 12:53:36 UTC, 2 replies.
- [jira] [Created] (FLINK-4994) Don't Clear Trigger State and Merging Window Set When Purging - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 13:23:00 UTC, 0 replies.
- [FLINK-4492] Cleanup files from canceled snapshots - posted by Nikolay Vasilishin <Ni...@epam.com> on 2016/11/02 13:47:12 UTC, 0 replies.
- [jira] [Created] (FLINK-4995) YarnFlinkResourceManagerTest JobManager Lost Leadership test failed - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/02 14:23:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4996) Make CrossHint @Public - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/02 15:02:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4997) Extending Window Function Metadata - posted by "Ventura Del Monte (JIRA)" <ji...@apache.org> on 2016/11/02 15:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/02 15:42:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/02 16:01:02 UTC, 0 replies.
- [jira] [Created] (FLINK-5000) Rename Methods in ManagedInitializationContext - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/02 17:32:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/02 20:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/02 22:06:58 UTC, 0 replies.
- Re: [Discuss] FLIP-13 Side Outputs in Flink - posted by Chen Qin <cq...@uber.com> on 2016/11/03 03:14:38 UTC, 1 replies.
- [jira] [Created] (FLINK-5003) Provide Access to State Stores in Operator Snapshot Context - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/03 09:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5004) Add task manager option to disable queryable state server - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/03 12:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5005) Publish Scala 2.12 artifacts - posted by "Andrew Roberts (JIRA)" <ji...@apache.org> on 2016/11/03 13:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5006) SystemProcessingTimeServiceTest.testTimerSorting fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/03 13:23:59 UTC, 0 replies.
- [DISCUSS] Proposed updates to Flink project site - posted by Mike Winters <mw...@gmail.com> on 2016/11/03 14:37:02 UTC, 8 replies.
- [jira] [Created] (FLINK-5007) Retain externalized checkpoint on suspension - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/03 14:46:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5008) Update IDE setup documentation - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/03 15:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5009) FS checkpoints leave empty directory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/03 15:31:01 UTC, 0 replies.
- Re: [DISCUSS] Make FieldAccessor logic consistent with remaining API - posted by Márton Balassi <ba...@gmail.com> on 2016/11/03 15:42:24 UTC, 1 replies.
- [jira] [Created] (FLINK-5010) Decouple the death watch parameters from the Akka ask timeout - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/03 16:07:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/11/03 17:02:58 UTC, 0 replies.
- RideCleansingToKafka Filter Parameter Type - posted by daviD <du...@yahoo.com.INVALID> on 2016/11/04 09:22:06 UTC, 2 replies.
- [jira] [Created] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/04 09:51:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/04 09:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5014) RocksDBStateBackend misses good toString - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/04 10:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/04 10:11:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/04 10:21:58 UTC, 0 replies.
- WindowRunner? - posted by Radu Tudoran <ra...@huawei.com> on 2016/11/04 10:50:52 UTC, 0 replies.
- [jira] [Created] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/04 12:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5018) User configurable source idle timeout to work with WatermarkStatus emitting - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/04 12:43:58 UTC, 0 replies.
- "Cannot resolve map" - posted by Thomas FOURNIER <th...@gmail.com> on 2016/11/04 12:58:24 UTC, 1 replies.
- [jira] [Created] (FLINK-5019) Proper isRestored result for tasks that did not write state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/04 13:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5020) Make the GenericWriteAheadSink rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/04 15:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5021) Make the ContinuousFileReaderOperator rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/04 15:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/04 15:27:58 UTC, 0 replies.
- Hadoop Summit EU 2017 - posted by Alan Gates <al...@gmail.com> on 2016/11/04 17:13:22 UTC, 0 replies.
- Re: FLIP-6 and running many "small" jobs - posted by Maciek Próchniak <mp...@touk.pl> on 2016/11/04 19:36:00 UTC, 0 replies.
- Deterministic processing with out-of-order streams - posted by Jaromir Vanek <va...@gmail.com> on 2016/11/04 22:38:40 UTC, 4 replies.
- Stream processing via Kafka using Android - posted by li...@web.de on 2016/11/05 06:50:04 UTC, 1 replies.
- [jira] [Created] (FLINK-5023) Add get() method in State interface - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/07 02:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/07 02:24:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5025) Job fails because of Optimizer bug - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/11/07 10:19:59 UTC, 0 replies.
- RE: TopSpeedWindowing - in error: Could not forward element to next operator - posted by Ovidiu Cristian Marcu <ov...@huawei.com> on 2016/11/07 11:50:11 UTC, 0 replies.
- RE: [FLINK-3035] Redis as State Backend - posted by Ovidiu Cristian Marcu <ov...@huawei.com> on 2016/11/07 11:51:54 UTC, 2 replies.
- [jira] [Created] (FLINK-5026) Rename TimelyFlatMap to Process - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/07 13:24:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5027) FileSource finishes successfully with a wrong path - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/07 15:15:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5028) Stream Tasks must not go through clean shutdown logic on cancellation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/07 15:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5029) Implement KvState SSL - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/07 19:18:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5030) Support hostname verification - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/07 19:42:58 UTC, 0 replies.
- Could Not Submit Job DataStream Because No Connection to a JobManager - posted by daviD <du...@yahoo.com.INVALID> on 2016/11/07 19:53:09 UTC, 2 replies.
- Re: [jira] [Created] (FLINK-4898) Refactor HTTP handlers and Netty server/client - posted by Eron Wright <ew...@live.com> on 2016/11/07 20:17:52 UTC, 0 replies.
- [jira] [Created] (FLINK-5031) Consecutive DataStream.split() ignored - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/07 22:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5032) CsvOutputFormatTest fails on Windows OS - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/08 06:30:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5033) CEP operators don't properly advance time - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/08 13:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5034) Don't Write StateDescriptor to RocksDB Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/08 16:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/08 16:20:58 UTC, 0 replies.
- Left outer join - posted by Thomas FOURNIER <th...@gmail.com> on 2016/11/08 21:58:44 UTC, 2 replies.
- [jira] [Created] (FLINK-5036) Perform the grouping of keys in restoring instead of checkpointing - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/09 03:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5037) Instability in AbstractUdfStreamOperatorLifecycleTest - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/09 08:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5038) Errors in the "cancelTask" method prevent closeables from being closed early - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/09 12:14:58 UTC, 0 replies.
- [DISCUSS] Changing Window Cleanup Semantics - posted by Aljoscha Krettek <al...@apache.org> on 2016/11/09 13:22:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5039) Avro GenericRecord support is broken - posted by "Bruno Dumon (JIRA)" <ji...@apache.org> on 2016/11/09 13:43:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5040) Set correct input channel types with eager scheduling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/09 17:24:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 19:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5042) Convert old savepoints to new savepoints - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 20:01:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5043) Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 20:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/09 20:08:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5045) Latency markers emitted after output buffer pool destroyed - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/09 21:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5046) Avoid redundant serialization when creating the TaskDeploymentDescriptor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/10 00:46:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5047) Add tumbling group-windows for batch tables - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/11/10 03:18:58 UTC, 0 replies.
- RE: Apache Flink and Kudu integration - posted by ru...@accenture.com on 2016/11/10 07:56:13 UTC, 2 replies.
- [FLINK-4541] Support for SQL NOT IN operator - posted by Alexander Shoshin <Al...@epam.com> on 2016/11/10 10:26:39 UTC, 4 replies.
- [jira] [Created] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/10 10:30:59 UTC, 0 replies.
- [DISCUSS] Adding a dispose() method in the RichFunction. - posted by Kostas Kloudas <k....@data-artisans.com> on 2016/11/10 10:37:36 UTC, 2 replies.
- Re: [DISCUSS] FLIP-5 Only send data to each taskmanager once for broadcasts - posted by Felix Neutatz <ne...@googlemail.com> on 2016/11/10 11:24:48 UTC, 0 replies.
- Re: Flink ML recommender system API - posted by Gábor Hermann <ma...@gaborhermann.com> on 2016/11/10 11:46:24 UTC, 2 replies.
- RocksDB IO error - posted by zh...@accenture.com on 2016/11/10 13:22:25 UTC, 1 replies.
- [DISCUSS] FLIP-14: Loops API and Termination - posted by Paris Carbone <pa...@kth.se> on 2016/11/10 19:19:40 UTC, 13 replies.
- [jira] [Created] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/10 21:03:58 UTC, 0 replies.
- Travis CI - posted by Greg Hogan <co...@greghogan.com> on 2016/11/10 21:15:27 UTC, 1 replies.
- [jira] [Created] (FLINK-5050) JSON.org license is CatX - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/11/10 23:44:58 UTC, 0 replies.
- Flink using Yarn on MapR - posted by Naveen Tirupattur <nt...@maprtech.com> on 2016/11/11 06:36:29 UTC, 7 replies.
- [VOTE] Release Apache Flink 1.1.4 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/11/11 09:10:43 UTC, 8 replies.
- [jira] [Created] (FLINK-5051) Backwards compatibility for serializers in backend state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/11 09:53:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5052) Changing the maximum parallelism (number of key groups) of a job - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/11 10:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5053) Incremental / lightweight snapshots for checkpoints - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/11 10:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5054) Make the BucketingSink rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/11 12:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/11 13:51:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/11 15:24:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5057) Cancellation timeouts are picked from wrong config - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/12 19:15:58 UTC, 0 replies.
- Flink 4108 and 4061 - posted by Alberto Ramón <a....@gmail.com> on 2016/11/12 23:25:55 UTC, 0 replies.
- [jira] [Created] (FLINK-5058) taskManagerMemory attribute set wrong value in FlinkShell - posted by "yangping wu (JIRA)" <ji...@apache.org> on 2016/11/14 10:04:59 UTC, 0 replies.
- issue assignment (FLINK-5002) - posted by Roman Maier <Ro...@epam.com> on 2016/11/14 11:45:56 UTC, 1 replies.
- [jira] [Created] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/14 13:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5060) only serialise records once in RecordWriter#emit and RecordWriter#broadcastEmit - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/14 13:26:59 UTC, 0 replies.
- Re: [DISCUSS] Schedule and Scope for Flink 1.2 - posted by Flavio Pompermaier <po...@okkam.it> on 2016/11/14 13:47:37 UTC, 1 replies.
- [jira] [Created] (FLINK-5061) Remove ContinuousEventTimeTrigger - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/14 14:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5062) Ensure that all create threads have a proper name - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/14 15:32:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/14 15:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5064) Checkpoint messages are not scoped to the leader session ID - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/14 17:43:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5065) Resource leaks in case of lost checkpoint messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/14 17:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5066) prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/14 18:33:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5067) Make Flink compile with 1.8 Java compiler - posted by "Andrey Melentyev (JIRA)" <ji...@apache.org> on 2016/11/14 20:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5068) YARN HA: Job scheduled before TM is up leading to "Not enough free slots" error - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/11/15 08:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5069) Pending checkpoint statistics gauge - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/11/15 09:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5070) Unable to use Scala's BeanProperty with classes - posted by "Jakub Nowacki (JIRA)" <ji...@apache.org> on 2016/11/15 11:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5071) YARN: yarn.containers.vcores config not respected when checking for vcores - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/11/15 14:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5072) MetricFetcher Ask Timeout - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/15 15:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/15 19:59:58 UTC, 0 replies.
- [Discuss] State Backend use external HBase storage - posted by shijinkui <sh...@huawei.com> on 2016/11/16 02:10:52 UTC, 3 replies.
- [jira] [Created] (FLINK-5074) Implement a RunningJobRegistry based on Zookeeper - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/16 03:55:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/16 06:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5076) Shutting down TM when shutting down new mini cluster - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/16 07:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5077) testStreamTableSink falls unstable - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/16 07:49:58 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.1.4 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/11/16 08:42:27 UTC, 2 replies.
- [jira] [Created] (FLINK-5078) Introduce annotations for classes copied from Calcite - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/16 11:03:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5079) Failed to submit job to YARN cluster - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/16 11:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess - posted by "Jakub Nowacki (JIRA)" <ji...@apache.org> on 2016/11/16 13:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/16 15:33:58 UTC, 0 replies.
- Request for edit rights in Jira - posted by limcheehau lim <ch...@gmail.com> on 2016/11/16 16:37:58 UTC, 2 replies.
- [jira] [Created] (FLINK-5082) Pull ExecutionService lifecycle management out of the JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/16 17:33:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5083) Race condition in Rolling/Bucketing Sink pending files cleanup - posted by "Cliff Resnick (JIRA)" <ji...@apache.org> on 2016/11/16 20:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5084) Replace Java Table API integration tests by unit tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/16 23:07:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/17 00:25:58 UTC, 0 replies.
- Request for permissions in JIRA - posted by Boris Osipov <Bo...@epam.com> on 2016/11/17 07:42:28 UTC, 3 replies.
- Add Sonarqube analysis - posted by Boris Osipov <Bo...@epam.com> on 2016/11/17 09:10:39 UTC, 1 replies.
- [jira] [Created] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/11/17 10:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5087) Additional steps needed for the Java quickstart guide - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/11/17 10:59:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5088) Add option to limit subpartition queue length - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/17 14:09:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5089) Introduce Loop functions and Enforce Nesting on Data Streams - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2016/11/17 14:24:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5090) Expose optionally detailed metrics about network queue lengths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/17 18:43:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5091) Formalize the AppMaster environment for docker compability - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/17 20:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5092) Add maven profile with code coverage - posted by "Boris Osipov (JIRA)" <ji...@apache.org> on 2016/11/18 07:36:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/18 08:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5094) Support RichReduceFunction and RichFoldFunction as incremental window aggregation functions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/18 11:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5096) Make the RollingSink rescalable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/18 13:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/18 13:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/18 13:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5098) Detect network problems to eagerly time out ask operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/18 13:46:58 UTC, 0 replies.
- Flink survey by data Artisans - posted by Kostas Tzoumas <kt...@apache.org> on 2016/11/18 15:28:13 UTC, 4 replies.
- [jira] [Created] (FLINK-5099) Test testCancelPartitionRequest is instable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/18 17:26:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5100) Test testZooKeeperReelection is instable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/18 17:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5101) Test CassandraConnectorITCase instable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/18 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5102) Connection establishment does not react to interrupt - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/18 21:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5103) Process virtual memory and physical memory used size gauge - posted by "zhuhaifeng (JIRA)" <ji...@apache.org> on 2016/11/19 07:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5104) Implement BipartiteGraph validator - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/11/19 19:24:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5105) Improve ReduceState: value put into ReducingState should always be a copy - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/11/21 08:24:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5106) improving IncrementalAggregateReduceFunction - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/11/21 08:27:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/21 09:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5108) Remove ClientShutdownHook during job execution - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/21 10:26:58 UTC, 0 replies.
- [DISCUSS] Hold copies in HeapStateBackend - posted by Fabian Hueske <fh...@gmail.com> on 2016/11/21 10:30:03 UTC, 17 replies.
- [jira] [Created] (FLINK-5109) Invalid Content-Encoding Header in REST API responses - posted by "Móger Tibor László (JIRA)" <ji...@apache.org> on 2016/11/21 12:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5110) Remove the AbstractAlignedProcessingTimeWindowOperator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 13:52:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5111) Change the assignToKeyGroup() method to not use Object.hashCode() - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 14:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5112) Remove unused accumulator code from ArchivedExecutionJobVertex - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/21 14:59:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5113) Make all the testing Functions implement the CheckpointedFucntion interface. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 15:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5114) PartitionState update with finished execution fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 15:25:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5115) Minimum time between checkpoints computed from trigger timestamp - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 15:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5116) Missing RocksDB state backend factory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 15:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5117) Make the state of the AbstractAlignedProcessingTimeWindowOperator compatible with the WindowOperator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/21 15:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5118) Inconsistent records sent/received metrics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 15:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5119) Last taskmanager heartbeat not showing in web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 16:11:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5120) Show TM PID in web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 16:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5121) Integrate YARN application ID with web interface - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/21 16:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load - posted by "static-max (JIRA)" <ji...@apache.org> on 2016/11/21 21:47:58 UTC, 0 replies.
- Re: [DISCUSS] Merge batch and stream connector modules - posted by Fabian Hueske <fh...@gmail.com> on 2016/11/22 08:08:59 UTC, 1 replies.
- Kafka Sink stuck in cancelling - posted by Gyula Fóra <gy...@apache.org> on 2016/11/22 09:03:23 UTC, 3 replies.
- [jira] [Created] (FLINK-5123) Add description how to do proper shading to Flink docs. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/22 11:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5124) Support more temporal arithmetic - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/22 12:01:05 UTC, 0 replies.
- [jira] [Created] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/22 14:18:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5126) Remove Checked Exceptions from State Interfaces - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/22 14:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/11/22 15:01:07 UTC, 0 replies.
- [jira] [Created] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/11/22 15:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5129) make the BlobServer use a distributed file system - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/22 16:25:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5130) Remove Deprecated Methods from WindowedStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/22 16:47:58 UTC, 0 replies.
- [DISCUSS] @Public libraries - posted by Greg Hogan <co...@greghogan.com> on 2016/11/22 17:56:44 UTC, 4 replies.
- [jira] [Created] (FLINK-5131) Fine-grained Resource Configuration - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 02:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 03:30:58 UTC, 0 replies.
- [DISCUSS] deprecated function need more detail - posted by sjk <sh...@163.com> on 2016/11/23 03:42:16 UTC, 5 replies.
- [jira] [Created] (FLINK-5133) Add new setResource API for DataStream and DataSet - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 03:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating stream graph - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:01:04 UTC, 0 replies.
- [jira] [Created] (FLINK-5135) ResourceProfile should be expanded to correspond with ResourceSpec - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5136) ResourceManager should consider both slot resource profile and framework memory for requesting resource from cluster - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5137) Config JVM options and set onto the TaskManager container - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 06:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5138) The StateBackend provides the method to estimate memory usage based on hint of state size in ResourceSpec - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/11/23 07:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5139) consum kafka can set offset - posted by "jing lining (JIRA)" <ji...@apache.org> on 2016/11/23 07:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/23 07:53:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5141) Implement MiniClusterStreamEnvironment to run new mini cluster in flip-6 branch - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2016/11/23 08:54:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5142) Resource leak in CheckpointCoordinator - posted by "Frank Lauterwald (JIRA)" <ji...@apache.org> on 2016/11/23 09:33:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5143) Add EXISTS to list of supported operators - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/23 10:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/23 11:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5145) WebInterface to aggressive in pulling metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 12:06:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/11/23 13:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 13:33:58 UTC, 0 replies.
- Very wide csv files - posted by Anton Solovev <An...@epam.com> on 2016/11/23 13:48:16 UTC, 1 replies.
- [jira] [Created] (FLINK-5148) LocalFileSystem#delete can fail with NullpointerException - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 14:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5149) ContinuousEventTimeTrigger doesn't fire at the end of the window - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/11/23 14:59:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5150) WebUI metric-related resource leak - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/23 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5151) Add discussion about object mutations to heap-based state backend docs. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/23 16:11:58 UTC, 0 replies.
- FOSDEM 2017 HPC, Bigdata and Data Science DevRoom CFP is closing soon - posted by Roman Shaposhnik <ro...@shaposhnik.org> on 2016/11/23 21:11:19 UTC, 0 replies.
- [jira] [Created] (FLINK-5152) accepting NullValue for EV in Gelly examples - posted by "wouter ligtenberg (JIRA)" <ji...@apache.org> on 2016/11/24 09:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5153) Allow setting custom application tags for Flink on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/24 10:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5154) Duplicate TypeSerializer when writing RocksDB Snapshot - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/24 11:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/24 11:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5156) Consolidate streaming FieldAccessor functionality - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/11/24 13:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5157) Extending AllWindow Function Metadata - posted by "Ventura Del Monte (JIRA)" <ji...@apache.org> on 2016/11/24 14:38:59 UTC, 0 replies.
- Move Row, RowInputFormat to core package - posted by Anton Solovev <An...@epam.com> on 2016/11/24 15:46:34 UTC, 6 replies.
- [jira] [Created] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/24 16:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5159) Improve perfomance of inner joins with a single row input - posted by "Alexander Shoshin (JIRA)" <ji...@apache.org> on 2016/11/25 08:57:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5160) SecurityContextTest#testCreateInsecureHadoopCtx fails on windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/25 11:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5161) accepting NullValue for VV in Gelly examples and GSA - posted by "wouter ligtenberg (JIRA)" <ji...@apache.org> on 2016/11/25 11:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5162) BlobRecoveryItCase#testBlobServerRecovery fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/25 12:23:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks) - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/25 13:20:58 UTC, 0 replies.
- Start to contribute - posted by Minudika Malshan <mi...@gmail.com> on 2016/11/25 13:25:34 UTC, 1 replies.
- [jira] [Created] (FLINK-5164) Hadoop-compat IOFormat tests fail on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/25 14:07:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5165) Checkpointing tests using FsStatebackend fail on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/25 15:22:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5166) TextInputFormatTest.testNestedFileRead - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/25 23:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5167) StreamExecutionEnvironment's set function return `this` instead of void - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/26 00:21:58 UTC, 0 replies.
- Window's Checkpoint problem - posted by liuxinchun <li...@huawei.com> on 2016/11/26 02:30:52 UTC, 5 replies.
- [jira] [Created] (FLINK-5168) Scaladoc annotation link use [[]] instead of {@link} - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/26 08:13:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5169) Make consumption of input channels fair - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/28 08:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5170) getAkkaConfig will use localhost if hostname is specified - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/28 09:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5171) Wrong use of Preconditions.checkState in TaskManagerRunner - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/28 09:10:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5172) In RocksDBStateBackend, set flink-core and flink-streaming-java to "provided" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 10:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5173) Upgrade RocksDB dependency - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/28 10:37:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5174) Fix memory leak in the CEP library. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/11/28 10:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5175) StreamExecutionEnvironment's set function return `this` instead of void - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/11/28 11:30:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5176) Properly wait for component shutdown in Runner components - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/28 11:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5177) Improve nullability handling - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/11/28 12:56:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5178) allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/28 14:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5179) MetricRegistry life-cycle issues with HA - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/28 14:51:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5180) Include blocked on bounded queue length in back pressure stats - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/28 15:20:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5181) Add Tests in StateBackendTestBase that verify Default-Value Behaviour - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/11/28 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5182) Implement SSL file-shipping - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/11/28 18:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5183) [py] Support multiple jobs per Python plan file - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/11/28 20:00:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5184) Error result of compareSerialized in RowComparator class - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/11/29 06:58:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/11/29 07:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5186) Move Row and RowTypeInfo into Flink core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/29 08:52:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5187) Create analog of Row in core - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/29 08:54:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5188) Redirect dependencies - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/29 08:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5189) deprecate and delete Row in table api - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/11/29 08:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5190) ZooKeeperLeaderRetrievalService should not close the zk client when stop - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2016/11/29 09:27:59 UTC, 0 replies.
- Why there is no source code in flink-cep-scala_2.11-1.1.3-source.jar? - posted by liuxinchun <li...@huawei.com> on 2016/11/29 11:34:43 UTC, 1 replies.
- [jira] [Created] (FLINK-5191) ConnectedComponentsWithDeferredUpdateITCase failed - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/11/29 14:01:01 UTC, 0 replies.
- [jira] [Created] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/29 14:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5192) Provide better log config templates - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5194) Log heartbeats on TRACE level - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:29:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5195) Log JobManager configuration on start up - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5196) Don't log InputChannelDescriptor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5197) Late JobStatusChanges can interfere with running jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/29 14:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5198) Overwrite TaskState toString - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:36:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5199) Improve logging of submitted job graph actions in HA case - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:37:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5200) Display recovery information in Webfrontend - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/29 14:43:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5201) Promote loaded config properties to INFO - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 14:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5202) test timeout (no output for 300s) in YARNHighAvailabilityITCase - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/29 15:01:09 UTC, 0 replies.
- [jira] [Created] (FLINK-5203) YARNHighAvailabilityITCase fails to deploy YARN cluster - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/29 15:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5204) Flakey YARNSessionCapacitySchedulerITCase (NullPointerException) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/29 15:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5205) Asynchronous remove job messages can interfere with recovered or resubmitted jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/29 15:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5206) Flakey PythonPlanBinderTest - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/29 15:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5207) Decrease HadoopFileSystem logging - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/29 16:02:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5208) Increase application attempt timeout for the YARN tests on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/11/29 17:15:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5209) Fix TaskManager metrics - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/11/29 21:24:58 UTC, 0 replies.
- JIRA task Assignment - posted by 魏偉哲 <to...@gmail.com> on 2016/11/30 12:13:32 UTC, 1 replies.
- [jira] [Created] (FLINK-5210) Failing performCheckpoint method causes task to fail - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/30 14:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5211) Include an example configuration for all reporters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/11/30 14:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5212) Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/11/30 15:01:10 UTC, 0 replies.
- [jira] [Created] (FLINK-5213) Missing @Override in Task - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/11/30 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/30 17:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5215) Close checkpoint streams upon cancellation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/11/30 17:17:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/11/30 18:40:58 UTC, 0 replies.