You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-3308) [py] Remove debug mode - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/01 10:02:39 UTC, 0 replies.
- DataExchangeMode.BATCH in iterations - posted by Fridtjof Sander <fs...@mailbox.tu-berlin.de> on 2016/02/01 11:47:41 UTC, 3 replies.
- [jira] [Created] (FLINK-3309) [py] Resolve maven warnings - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/01 12:05:39 UTC, 0 replies.
- JobClientActorSubmissionTimeoutException - posted by Hilmi Yildirim <Hi...@dfki.de> on 2016/02/01 14:39:22 UTC, 5 replies.
- [DISCUSS] Release 0.10.2 - posted by Ufuk Celebi <uc...@apache.org> on 2016/02/01 20:07:21 UTC, 9 replies.
- [jira] [Created] (FLINK-3310) Add back pressure statistics to web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/01 20:12:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/01 20:56:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3312) Add convenience accessor methods for extended state interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/01 21:58:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3313) Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 11:56:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3314) Early cancel calls can cause Tasks to not cancel properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 12:17:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3315) Fix Slot Sharing in Streaming API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/02 12:23:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/02 13:41:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3317) Add timeout handler to CEP operator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 14:34:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3318) Add support for quantifiers to CEP's pattern API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 14:42:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3319) Add or operator to CEP's pattern API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 14:50:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3320) Add not operator to CEP's pattern API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 14:53:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/02 15:21:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/02 16:26:39 UTC, 0 replies.
- Re: Memory manager behavior in iterative jobs - posted by Gábor Gévay <gg...@gmail.com> on 2016/02/02 16:27:32 UTC, 0 replies.
- Re: Release Flink 1.0.0 - posted by Robert Metzger <rm...@apache.org> on 2016/02/02 19:12:20 UTC, 3 replies.
- Limitations on grouped ReduceFunction - posted by Greg Hogan <co...@greghogan.com> on 2016/02/02 21:54:57 UTC, 1 replies.
- Connector Documentation missing - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/02/03 14:24:19 UTC, 5 replies.
- [jira] [Created] (FLINK-3324) Flume connector not documented - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/03 15:33:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3323) Nifi connector not documented - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/03 15:33:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/03 15:42:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic - posted by "Farouk Salem (JIRA)" <ji...@apache.org> on 2016/02/03 16:36:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. - posted by "Kostas (JIRA)" <ji...@apache.org> on 2016/02/03 18:53:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/03 21:06:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/04 00:56:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/02/04 05:05:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3331) Test instability: LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/04 09:09:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3332) Provide an exactly-once Cassandra connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/04 11:21:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3333) Documentation about object reuse should be improved - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/04 11:37:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/04 13:31:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3335) DataSourceTask object reuse when disabled - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/04 14:45:39 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.10.2 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/02/04 15:18:28 UTC, 10 replies.
- [jira] [Created] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/04 18:28:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/04 18:39:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/04 19:14:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3339) Checkpointing NPE when using filterWithState - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/04 20:11:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3340) Fix object juggling in reduce drivers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/04 23:17:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/05 07:08:39 UTC, 0 replies.
- New instable test? - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/02/05 11:06:37 UTC, 1 replies.
- [jira] [Created] (FLINK-3342) Operator checkpoint statistics state size overflow - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/05 11:49:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3343) Exception while using Kafka 0.9 connector - posted by "Farouk Salem (JIRA)" <ji...@apache.org> on 2016/02/05 13:28:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/05 13:49:40 UTC, 0 replies.
- [ANNOUNCE] Please annotate public interfaces! - posted by Robert Metzger <rm...@apache.org> on 2016/02/05 15:07:27 UTC, 9 replies.
- [jira] [Created] (FLINK-3345) Restart TaskManager in case of a Akka quarantine event - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/05 15:47:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3346) Replace Akka death watch with own heartbeats - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/05 15:58:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/05 16:03:40 UTC, 0 replies.
- Want Flink startup issues :-) - posted by Dongwon Kim <ea...@postech.ac.kr> on 2016/02/05 17:14:50 UTC, 7 replies.
- [jira] [Created] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/02/05 17:52:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3349) planVisualizer doesn't work! - posted by "Riccardo Diomedi (JIRA)" <ji...@apache.org> on 2016/02/05 18:14:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3350) Increase timeouts on Travis Builds - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/06 15:47:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3351) RocksDB Backend cannot determine correct local db path - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/06 21:12:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3352) RocksDB Backend cannot determine correct hdfs path - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/06 22:20:39 UTC, 0 replies.
- Tips for testing - posted by Stefano Baghino <st...@radicalbit.io> on 2016/02/06 22:31:36 UTC, 5 replies.
- [jira] [Created] (FLINK-3353) CSV-related tests may fail depending on locale - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/06 22:56:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3354) RocksDB should compute checkpoint size based on backup file size - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/06 23:30:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/07 00:05:39 UTC, 0 replies.
- Re: Case style anonymous functions not supported by Scala API - posted by Stefano Baghino <st...@radicalbit.io> on 2016/02/07 12:44:24 UTC, 11 replies.
- Contributing - posted by Deepak Koli <de...@gmail.com> on 2016/02/07 14:45:07 UTC, 1 replies.
- [jira] [Created] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/07 19:38:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3357) Drop JobId.toShortString() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 20:48:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 20:54:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3359) Make RocksDB file copies asynchronous - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 20:56:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3360) Clear up StateBackend, AbstractStateBackend abstractions - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/07 21:04:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3361) Wrong error messages for execution retry delay and akka ask pause config values - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 21:17:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3362) Potential overflow in NettyBufferPool#getNumberOfAllocatedBytes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/08 00:29:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3363) JobManager does not shut down dedicated executor properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 11:52:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3364) Don't initialize SavepointStore in JobManager constructor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/08 13:10:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3365) BlobLibraryCacheManager does not shutdown Timer thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 13:21:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3366) Rename @Experimental annotation to @PublicEvolving - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/08 13:39:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3367) Annotate all user-facing API classes with @Public or @PublicEvolving - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/08 13:43:39 UTC, 0 replies.
- Remove final flag from ResultPartitionWriter class - posted by Chesnay Schepler <ch...@apache.org> on 2016/02/08 13:57:31 UTC, 1 replies.
- [jira] [Created] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/08 16:38:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/08 16:40:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3370) Add an aligned version of the window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:16:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3371) Move TriggerCotext and TriggerResult to their own classes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:18:39 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 0.10.2 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/02/08 18:26:41 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.10.2 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/02/08 18:37:38 UTC, 11 replies.
- [jira] [Created] (FLINK-3372) Setting custom YARN application name is ignored - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/02/08 18:39:39 UTC, 0 replies.
- Option to disable chaining? - posted by Greg Hogan <co...@greghogan.com> on 2016/02/08 19:34:18 UTC, 6 replies.
- [jira] [Created] (FLINK-3373) Using a newer library of Apache HttpClient than 4.2.6 will get class loading problems - posted by "Jakob Sultan Ericsson (JIRA)" <ji...@apache.org> on 2016/02/09 09:41:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3374) CEPITCase testSimplePatternEventTime fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/09 10:02:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3375) Allow Watermark Generation in the Kafka Source - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 11:45:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3376) Add an illustration of Event Time and Watermarks to the docsq - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 11:56:18 UTC, 0 replies.
- User Feedback - posted by Martin Neumann <mn...@sics.se> on 2016/02/09 15:35:35 UTC, 3 replies.
- [jira] [Created] (FLINK-3377) Remove final flag from ResultPatitionWriter class - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/09 15:49:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3378) Consolidate TestingCluster and FokableFlinkMiniCluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/09 16:13:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3379) Refactor TimestampExtractor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 16:53:18 UTC, 0 replies.
- Breaking changes in the Streaming API - posted by Stephan Ewen <se...@apache.org> on 2016/02/09 16:54:58 UTC, 1 replies.
- [jira] [Created] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/02/09 17:48:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/09 17:52:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3381) Unstable Test: JobManagerSubmittedJobGraphsRecoveryITCase - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/02/09 17:52:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3383) Separate Maven deployment from CI testing - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/09 18:30:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3384) Create atomic closable queue for communication between Kafka Threads - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 15:59:18 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 0.10.2 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/02/10 19:50:01 UTC, 0 replies.
- [jira] [Created] (FLINK-3385) Fix outer join skipping unprobed partitions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/10 20:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/11 12:28:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 14:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3388) Expose task accumulators via JMX - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/11 14:30:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3389) Add Pre-defined Options settings for RocksDB State backend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 15:33:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3390) Savepoint resume is not retried - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/02/11 15:40:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3391) Typo in SavepointITCase - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/02/11 15:48:18 UTC, 0 replies.
- StateBackend - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/02/11 20:28:39 UTC, 4 replies.
- [jira] [Created] (FLINK-3392) Unprotected access to elements in ClosableBlockingQueue#size() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/11 23:21:18 UTC, 0 replies.
- Opening a discussion on FlinkML - posted by Theodore Vasiloudis <th...@gmail.com> on 2016/02/12 10:23:24 UTC, 11 replies.
- [ANNOUNCE] Flink 0.10.2 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/02/12 12:57:20 UTC, 7 replies.
- [jira] [Created] (FLINK-3393) ExternalProcessRunner wait to finish copying error stream - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/12 14:36:18 UTC, 0 replies.
- FlinkML NeuralNetworks - posted by Trevor Grant <tr...@gmail.com> on 2016/02/12 14:45:57 UTC, 4 replies.
- [jira] [Created] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse) - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/12 17:30:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3395) Polishing the web UI - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/12 20:37:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3396) Job submission Savepoint restore logic flawed - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/12 21:11:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/14 21:48:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/15 04:15:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3399) Count with timeout trigger - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/15 05:26:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3400) RocksDB Backend does not work when not in Flink lib folder - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/15 12:08:18 UTC, 0 replies.
- Design Draft - Streaming Table API Syntax - posted by Fabian Hueske <fh...@gmail.com> on 2016/02/15 16:58:23 UTC, 0 replies.
- [jira] [Created] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/15 18:44:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3402) Refactor Common Parts of Stream/Batch Documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/15 19:03:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3403) Create Section "Working with Time" in Streaming Guide - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/15 19:05:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:18:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3405) Extend NiFiSource with interface StoppableFunction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:29:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3406) Extend RabbitMQ source with interface StoppableFunction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:32:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3407) Extend TwitterSource with interface StoppableFunction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:34:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3408) Make STOP signal reliable - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:39:18 UTC, 0 replies.
- Flink 1.0.0 Release Candidate 0: Please help testing - posted by Robert Metzger <rm...@apache.org> on 2016/02/15 20:47:18 UTC, 2 replies.
- [jira] [Created] (FLINK-3409) Integrate STOP with Savepoints - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:48:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3410) setting setNumberOfExecutionRetries to 0 still leads to RESTARTs. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/15 21:26:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3411) Failed recovery can lead to removal of HA state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/16 10:44:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3412) Remove implicit conversions JavaStream / ScalaStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 11:13:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3413) Remove implicit Seq to DataStream conversion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 11:17:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3414) Add Scala API for CEP's pattern definition - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/16 11:54:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3415) TimestampExctractor accepts negative watermarks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 14:57:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3416) [py] .bat files fail when path contains spaces - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/16 15:04:18 UTC, 0 replies.
- H2O integration - posted by Simone Robutti <si...@radicalbit.io> on 2016/02/16 16:29:40 UTC, 2 replies.
- [jira] [Created] (FLINK-3417) Add RocksDB StateBackendFactory and integrate with Flink Config - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/16 17:26:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/16 17:35:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3419) Drop partitionByHash from DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/16 17:42:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 19:10:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3421) Remove all unused ClassTag context bounds in the Streaming Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 19:59:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3422) Scramble HashPartitioner hashes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 22:16:18 UTC, 0 replies.
- Adding TaskManager's - posted by Deepak Jha <dk...@gmail.com> on 2016/02/16 22:41:39 UTC, 9 replies.
- [jira] [Created] (FLINK-3423) ExternalProcessRunnerTest fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 09:58:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:43:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:44:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:45:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3427) Add watermark monitoring to JobManager web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/17 11:59:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/17 12:04:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3429) Add histogram-based timestamp/watermark extractor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/17 12:08:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 12:12:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3431) Add retrying logic for RocksDB snapshots - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/17 13:22:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3432) ZookeeperOffsetHandlerTest fails on windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 13:55:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3433) Return value from ObjectInputStream#read() should be checked in AvroOutputFormat#readObject - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/17 14:31:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/17 14:41:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3435) Change interplay of Ingestion Time and Event Time - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 16:55:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3436) Remove ComplexIntegrationITCase - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 17:40:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3437) Fix UI router state for job plan - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/17 17:50:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/17 18:00:20 UTC, 0 replies.
- Guarantees for object reuse modes and documentation - posted by Fabian Hueske <fh...@gmail.com> on 2016/02/17 18:17:27 UTC, 9 replies.
- Hi all - posted by Josep Rubio <jo...@datag.es> on 2016/02/17 20:14:08 UTC, 3 replies.
- Affiity Propagation - posted by Josep Rubio <jo...@datag.es> on 2016/02/17 20:33:22 UTC, 2 replies.
- Re: Extending and improving our "How to contribute" page - posted by Martin Liesenberg <ma...@gmail.com> on 2016/02/18 09:31:46 UTC, 6 replies.
- [jira] [Created] (FLINK-3439) Remove final Long.MAX_VALUE Watermark in StreamSource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/18 11:12:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3440) Kafka should also checkpoint partitions where no initial offset was retrieved - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 14:00:21 UTC, 0 replies.
- [jira] [Created] (FLINK-3441) Revisit quickstarts exclusion policy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/18 14:11:18 UTC, 0 replies.
- Dense matricies in FlinkML - posted by Trevor Grant <tr...@gmail.com> on 2016/02/18 17:14:01 UTC, 7 replies.
- [jira] [Created] (FLINK-3442) Expose savepoint button on web ui - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/18 18:03:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3443) JobManager cancel and clear everything fails jobs instead of cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/18 19:02:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/18 20:49:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3445) make JDBCInputFormat implement ResultTypeQueryable - posted by "Ken Geis (JIRA)" <ji...@apache.org> on 2016/02/18 22:08:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3446) Back pressure tracker throws NPE for archived jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/18 22:12:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3447) Package Gelly algorithms by framework - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/18 23:29:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3448) Move initialization of handlers to start() method - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/19 12:04:18 UTC, 0 replies.
- cancel running stream job - posted by Nikolaas s <ni...@gmail.com> on 2016/02/19 12:08:38 UTC, 3 replies.
- [jira] [Created] (FLINK-3449) createInput swallows exception if TypeExtractor fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/19 12:29:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3450) RocksDB Backed Window Fails with KryoSerializer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/19 14:55:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/19 15:11:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3452) Procuring more Travis CI build capacity for Flink - posted by "Wes McKinney (JIRA)" <ji...@apache.org> on 2016/02/19 15:18:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3453) Fix TaskManager logs exception when sampling backpressure while task completes - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/19 15:56:18 UTC, 0 replies.
- Introducing a PR template - posted by Martin Liesenberg <ma...@gmail.com> on 2016/02/19 18:19:26 UTC, 5 replies.
- [jira] [Created] (FLINK-3454) Add test dependencies on packaged jars - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/19 18:58:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3455) Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/19 19:53:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3456) Backpressure Monitoring does not work for Kafka Sources - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/19 22:17:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3457) Link to Apache Flink meetups from the 'Community' section of the website - posted by "Slim Baltagi (JIRA)" <ji...@apache.org> on 2016/02/21 14:00:20 UTC, 0 replies.
- [jira] [Created] (FLINK-3458) Shading broken in flink-shaded-hadoop - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/21 14:28:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3459) Make build SBT compatible - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/21 14:31:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3460) Make flink-streaming-connectors' flink dependencies provided - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/21 14:33:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/22 12:03:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3462) Add position and magic number checks to record (de)serializers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/22 14:26:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3463) Implement Calc Support - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/22 15:13:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3464) Add SBT build tool description to quickstart documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/22 15:41:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/22 15:43:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3465) Add SBT template script - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/22 15:43:18 UTC, 0 replies.
- Fix version - posted by Greg Hogan <co...@greghogan.com> on 2016/02/22 16:43:36 UTC, 1 replies.
- [jira] [Created] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/22 17:02:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3468) Change Timestamp Extractors to not support negative timestamps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/22 18:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3469) Fix documentation for grouping keys - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/22 18:52:18 UTC, 0 replies.
- Key expressions vs case class fields - posted by Greg Hogan <co...@greghogan.com> on 2016/02/22 19:18:37 UTC, 1 replies.
- [jira] [Created] (FLINK-3470) EventTime WindowAssigners should error on negative timestamps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/22 19:30:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3471) JDBCInputFormat cannot handle null fields of certain types - posted by "Ken Geis (JIRA)" <ji...@apache.org> on 2016/02/22 22:18:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3472) JDBCInputFormat.nextRecord(..) has misleading message on NPE - posted by "Ken Geis (JIRA)" <ji...@apache.org> on 2016/02/22 22:22:18 UTC, 0 replies.
- Testing Flink - posted by "Graeber, Michael" <mi...@here.com> on 2016/02/22 22:29:02 UTC, 1 replies.
- [jira] [Created] (FLINK-3473) Add partial aggregate support in Flink - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 08:39:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3474) Partial aggregate interface design and sort-based implementation - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 08:47:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3475) DISTINCT aggregate function support - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 09:38:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3476) Support hash-based partial aggregate - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 09:49:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 10:09:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3478) Flink serves arbitary files through the web interface - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/23 10:17:19 UTC, 0 replies.
- [jira] [Created] (FLINK-3479) Add hash-based strategy for CombineFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 10:35:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3480) Add hash-based strategy for ReduceFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 10:40:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3481) KafkaShortRetention08ITCase.testAutoOffsetReset failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 12:25:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3482) Implement Union Support - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/23 16:38:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3483) Job graph visualization not working properly in OS X Chrome - posted by "Zach Cox (JIRA)" <ji...@apache.org> on 2016/02/23 16:40:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3484) Add setSlotSharingGroup documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 18:32:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3485) The accumulator value doest seem to be right - posted by "sahitya pavurala (JIRA)" <ji...@apache.org> on 2016/02/24 03:26:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3486) [SQL] Use Project to rename all record fields would fail following Project. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/24 07:44:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3487) [SQL] FilterAggregateTransposeRule does not transform logical plan as desired. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/24 07:51:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/24 09:41:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3489) Refactor Table API before merging into master - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/24 10:00:26 UTC, 0 replies.
- [jira] [Created] (FLINK-3490) Bump Chill version to 0.7.4 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/24 10:27:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/24 10:36:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3492) Allow users to define a min pause between checkpoints - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/24 11:05:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3493) Update plan visualizer to web frontend version - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 11:29:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3494) Integrate plan visualizer with web page - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 11:31:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3495) RocksDB Tests can't run on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/24 12:20:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3496) Flink-ml tests fail on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/24 12:47:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3497) Add SQL scalar functions to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/24 13:48:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3498) Implement TRIM, SUBSTRING as reference design for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/24 14:03:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3499) Possible ghost references in ZooKeeper completed checkpoint store - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 17:25:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3500) ExecutionGraphRestartTest testFailingExecutionAfterRestart fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 18:38:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3501) flink-runtime-0.10.2-hadoop-1 jar problem - posted by "Paul Harris (JIRA)" <ji...@apache.org> on 2016/02/25 02:34:19 UTC, 0 replies.
- [jira] [Created] (FLINK-3502) [SQL] AggregateProjectPullUpConstantsRule fails on certain group keys order. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 03:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3503) [SQL] ProjectJoinTransposeRule fails to push down project. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:00:22 UTC, 0 replies.
- [jira] [Created] (FLINK-3504) [SQL] Join fails while have expression inside join condition. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:12:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3505) JoinUnionTransposeRule fails to push Join past Union. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:34:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3506) ReduceExpressionsRule does not remove duplicate expression in Filter - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 07:09:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3507) PruneEmptyRules does not prune empty node as expected. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 07:28:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 09:07:18 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.0.0 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2016/02/25 11:34:54 UTC, 18 replies.
- [jira] [Created] (FLINK-3509) Update Hadoop versions in release script and on travis to the latest minor version - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/25 13:55:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3510) Pattern class class-level comment misses type argument - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/25 15:10:18 UTC, 0 replies.
- Inconvenient (unforeseen?) consequences of PR #1683 - posted by Márton Balassi <ba...@gmail.com> on 2016/02/25 15:36:59 UTC, 10 replies.
- [jira] [Created] (FLINK-3511) Flink library examples not runnable withput adding dependencies - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/02/25 15:43:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3512) Savepoint backend should not revert to "jobmanager" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/25 16:48:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/25 16:50:18 UTC, 0 replies.
- Running stream examples (newbie) - posted by Tara Athan <ta...@gmail.com> on 2016/02/25 17:13:14 UTC, 1 replies.
- Playing with EventTime in DataStreams - posted by Nam-Luc Tran <na...@euranova.eu> on 2016/02/25 18:14:39 UTC, 4 replies.
- [jira] [Created] (FLINK-3514) Add support for slowly changing streaming broadcast variables - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/25 18:59:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3515) Make the "file monitoring source" exactly-once - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/25 19:19:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram still fails :( - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/25 19:54:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3517) Number of job and task managers not checked in scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/25 20:03:18 UTC, 0 replies.
- JDBC Streaming Connector - posted by Timothy Farkas <ti...@gmail.com> on 2016/02/26 01:23:31 UTC, 4 replies.
- [jira] [Created] (FLINK-3518) Stale docs for quickstart setup - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/26 09:30:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/26 11:23:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3520) Periodic watermark operator should emit current watermark in close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 11:59:18 UTC, 0 replies.
- Congrats on 1000 stars on Github - posted by Theodore Vasiloudis <th...@gmail.com> on 2016/02/26 13:56:06 UTC, 1 replies.
- [jira] [Created] (FLINK-3521) Make Iterable part of method signature for WindowFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/26 14:33:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3522) Storm examples "PrintSampleStream" throws an error if called without arguments - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 15:09:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 15:17:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3524) Provide a JSONSerialisationSchema in the kafka connector package - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 15:22:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3525) Missing call to super#close() in TimestampsAndPeriodicWatermarksOperator#close() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/26 18:10:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3526) ProcessingTime Window Assigner and Trigger are broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 20:06:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3527) Scala DataStream has no transform method - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/26 20:56:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3528) Add Incremental Fold for Non-Keyed Window Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/26 21:22:18 UTC, 0 replies.
- [CANCELLED][VOTE] Release Apache Flink 1.0.0 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2016/02/27 10:25:12 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.0.0 (RC2) - posted by Robert Metzger <rm...@apache.org> on 2016/02/27 10:25:50 UTC, 2 replies.
- [jira] [Created] (FLINK-3529) Add pull request template - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2016/02/27 20:49:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 11:31:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3531) KafkaShortRetention09ITCase.testAutoOffsetReset fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 11:32:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3532) Flink-gelly-examples jar contains an underscore instead of an hyphen - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 11:58:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3533) Update the Gelly docs wrt examples and cluster execution - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/29 12:25:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3534) Cancelling a running job can lead to restart instead of stopping - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/29 12:28:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3535) Decrease logging verbosity of StackTraceSampleCoordinator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/29 13:57:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3536) Make clearer distinction between event time and processing time - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 14:42:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3537) Faulty code generation for disjunctions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/29 14:58:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3538) DataStream join API does not enforce consistent usage - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 15:13:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3539) Sync running Execution and Task instances via heartbeats - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/29 15:45:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3540) Hadoop 2.6.3 build contains /com/google/common (guava) classes in flink-dist.jar - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/29 15:57:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 16:14:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3542) FlinkKafkaConsumer09 cannot handle changing number of partitions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 16:47:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3543) Introduce ResourceManager component - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/29 17:50:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3544) ResourceManager runtime components - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/29 18:06:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3545) ResourceManager: YARN integration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/29 18:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3546) Streaming Table API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/29 19:02:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3547) Add support for streaming projection, selection, and union - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/29 19:10:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3548) Remove unnecessary generic parameter from SingleOutputStreamOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/29 19:21:18 UTC, 0 replies.
- [CANCELLED][VOTE] Release Apache Flink 1.0.0 (RC2) - posted by Robert Metzger <rm...@apache.org> on 2016/02/29 21:47:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3549) Make streaming examples more streaming - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/29 22:04:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3550) Rework stream join example - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/29 22:05:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3551) Sync Scala and Java Streaming Examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/29 22:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3552) Change socket WordCount to be properly windowed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/29 22:08:18 UTC, 0 replies.