You are viewing a plain text version of this content. The canonical link for it is here.
- Re: cascading-flink 1.0 results - posted by Fabian Hueske <fh...@gmail.com> on 2016/04/01 00:44:07 UTC, 1 replies.
- Failing Test - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/04/01 09:24:22 UTC, 6 replies.
- [jira] [Created] (FLINK-3686) resourcemanager.ClusterShutdownITCase sometimes fails - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/01 10:57:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3687) runtime.leaderelection.ZooKeeperLeaderElectionTest fails - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/01 11:01:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3688) ClassCastException in StreamRecordSerializer when WindowOperator.trigger() is called and TimeCharacteristic = ProcessingTime - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/01 11:36:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3689) JobManager blocks cluster shutdown when not connected to ResourceManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/01 14:26:25 UTC, 0 replies.
- Re: [VOTE] Release Apache Flink 1.0.1 (RC1) - posted by Aljoscha Krettek <al...@apache.org> on 2016/04/01 14:59:36 UTC, 10 replies.
- Announcing S-link-y - posted by Bobby Evans <ev...@yahoo-inc.com.INVALID> on 2016/04/01 15:51:15 UTC, 1 replies.
- CEP blog post - posted by Till Rohrmann <tr...@apache.org> on 2016/04/01 15:56:51 UTC, 6 replies.
- [jira] [Created] (FLINK-3690) Create documentation on the new ResourceManager component - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2016/04/01 17:32:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord - posted by "Gna Phetsarath (JIRA)" <ji...@apache.org> on 2016/04/01 21:44:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3692) Develop a Kafka state backend - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/04/04 03:45:25 UTC, 0 replies.
- FYI: Updated Slides Section - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/04 11:33:59 UTC, 4 replies.
- FYI: Added Documentation on Basic Concepts - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/04 11:39:11 UTC, 3 replies.
- Dynamic Scaling: State Sharding - posted by Till Rohrmann <tr...@apache.org> on 2016/04/04 13:58:04 UTC, 2 replies.
- [jira] [Created] (FLINK-3693) JobManagerHAJobGraphRecoveryITCase.testClientNonDetachedListeningBehaviour is unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/04 14:15:25 UTC, 0 replies.
- Broken links after doc resturcturing - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/04/04 14:53:05 UTC, 6 replies.
- Re: Aggregation Design Questions - posted by Stephan Ewen <se...@apache.org> on 2016/04/04 14:56:41 UTC, 0 replies.
- returns method in scala api - posted by Judit Fehér <fe...@gmail.com> on 2016/04/04 15:08:12 UTC, 3 replies.
- [jira] [Created] (FLINK-3694) Document stoppable function interface for custom sources - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/04 16:11:25 UTC, 0 replies.
- Re: Apache Flink <=> Apache Ignite integration - posted by Robert Metzger <rm...@apache.org> on 2016/04/04 16:35:57 UTC, 4 replies.
- [jira] [Created] (FLINK-3695) ValueArray types - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/04 17:14:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3696) Some Union tests fail for TableConfigMode.EFFICIENT - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/04 17:58:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3697) keyBy() with nested POJO computes invalid field position indexes - posted by "Ron Crocker (JIRA)" <ji...@apache.org> on 2016/04/04 21:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3698) Scala Option can't be used as a key - posted by "Timur Fayruzov (JIRA)" <ji...@apache.org> on 2016/04/05 00:12:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3699) Allow per-job Kerberos authentication - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/04/05 10:20:25 UTC, 0 replies.
- [DISCUSS] Allowed Lateness in Flink - posted by Aljoscha Krettek <al...@apache.org> on 2016/04/05 12:23:21 UTC, 3 replies.
- [jira] [Created] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/05 12:38:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3701) Cant call execute after first execution - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2016/04/05 13:55:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/05 14:19:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3703) Add sequence matching semantics to discard matched events - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/05 14:21:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/05 16:18:25 UTC, 0 replies.
- Table API / SQL Queries and Code Generation - posted by Gábor Horváth <xa...@gmail.com> on 2016/04/05 16:25:52 UTC, 3 replies.
- Re: Powered by Flink - posted by Robert Metzger <rm...@apache.org> on 2016/04/05 17:08:21 UTC, 2 replies.
- [jira] [Created] (FLINK-3705) Provide explanation for Hadoop dependencies and how to configure it - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/05 17:26:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/05 17:44:25 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.0.1 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/05 19:17:22 UTC, 0 replies.
- [jira] [Created] (FLINK-3707) Add missing Rich(Flat)JoinCoGroupFunction - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/06 11:18:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3708) Scala API for CEP - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/06 13:48:25 UTC, 0 replies.
- [ANNOUNCE] Flink 1.0.1 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/06 14:00:29 UTC, 0 replies.
- Re: RichMapPartitionFunction - problems with collect - posted by Sergio Ramírez <sr...@correo.ugr.es> on 2016/04/06 17:01:20 UTC, 4 replies.
- [jira] [Created] (FLINK-3709) [streaming] Graph event rates over time - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/04/06 18:49:25 UTC, 0 replies.
- [DISCUSS] Macro-benchmarking for performance tuning and regression detection - posted by Greg Hogan <co...@greghogan.com> on 2016/04/06 18:56:58 UTC, 3 replies.
- [jira] [Created] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/04/07 00:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3711) Scala fold() example syntax incorrect - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/04/07 06:00:28 UTC, 0 replies.
- [jira] [Created] (FLINK-3712) YARN client dynamic properties are not passed correctly to the leader election service on the client - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/07 11:17:26 UTC, 0 replies.
- [jira] [Created] (FLINK-3713) DisposeSavepoint message uses system classloader to discard state - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/07 11:47:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3714) Add Support for "Allowed Lateness" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/07 14:17:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/07 14:26:25 UTC, 0 replies.
- Re: Expected duration for cascading-flink tests? - posted by Fabian Hueske <fh...@gmail.com> on 2016/04/07 16:38:42 UTC, 0 replies.
- [jira] [Created] (FLINK-3716) Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/07 22:41:25 UTC, 0 replies.
- Intellij code style - posted by Dawid Wysakowicz <wy...@gmail.com> on 2016/04/08 12:30:11 UTC, 7 replies.
- [jira] [Created] (FLINK-3717) Add functionality to get the current offset of a source with a FileInputFormat - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/08 12:31:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3718) Add Option For Completely Async Backup in RocksDB State Backend - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/08 13:43:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3719) WebInterface: Moving the barrier between graph and stats - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/04/08 13:53:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3720) Add warm starts for models - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2016/04/08 16:58:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3721) Min and max accumulators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/08 21:03:25 UTC, 0 replies.
- Unique ID of an operator - posted by Deepak Jha <dk...@gmail.com> on 2016/04/08 23:46:12 UTC, 2 replies.
- Re: Multi-Layer Perceptron - posted by Robert Metzger <rm...@apache.org> on 2016/04/09 12:08:01 UTC, 0 replies.
- [jira] [Created] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/04/09 12:40:25 UTC, 0 replies.
- Kryo StackOverflowError - posted by Andrew Palumbo <ap...@outlook.com> on 2016/04/10 04:42:33 UTC, 12 replies.
- [jira] [Created] (FLINK-3723) Aggregate Functions and scalar expressions shouldn't be mixed in select - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/10 11:07:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3724) testJoinPushThroughJoin fails for TableConfigMode=EFFICIENT - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 11:30:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3725) Exception in thread "main" scala.MatchError: ... (of class scala.Tuple4) - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/11 13:18:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3726) Error while reading configuration: Cannot read property 0 - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/11 14:08:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3727) Add support for embedded streaming SQL (projection, filter, union) - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 15:33:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3728) Find a way to exclude unsupported SQL features - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 15:48:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3729) Several SQL tests fail on Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/11 18:08:25 UTC, 0 replies.
- [DISCUSS] Release Flink 1.0.2 - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/11 18:32:19 UTC, 6 replies.
- [jira] [Created] (FLINK-3730) Fix RocksDB Local Directory Initialization - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/11 18:55:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3731) Embedded SQL outer joins should fail during translation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 19:06:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3732) Potential null deference in ExecutionConfig#equals() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/11 19:42:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/11 19:46:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/11 19:54:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3735) Embedded SQL union should fail during translation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/11 19:58:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3736) Move toRexNode and toAggCall logic into Expressions - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/11 20:01:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3737) WikipediaEditsSourceTest.testWikipediaEditsSource() fails locally - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/11 20:37:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3738) Refactor TableEnvironment and TranslationContext - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/11 21:58:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3739) Add a null literal to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/12 12:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3740) Session Window State is Not Checkpointed - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/12 16:11:25 UTC, 0 replies.
- Flink Interpreter w/ yarn-session - posted by Andrea Sella <an...@radicalbit.io> on 2016/04/12 17:12:20 UTC, 5 replies.
- [jira] [Created] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found. - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 19:05:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3742) Add Multi Layer Perceptron Predictor - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2016/04/12 20:15:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3743) Upgrate breeze from 0.11.2 to 0.12 - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 23:22:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3744) LocalFlinkMiniClusterITCase times out occasionally when building locally - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/12 23:33:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3745) TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/13 00:54:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3746) WebRuntimeMonitorITCase.testNoCopyFromJar failing intermittently - posted by "Todd Lisonbee (JIRA)" <ji...@apache.org> on 2016/04/13 01:21:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3747) Consolidate TimestampAssigner Methods in Kafka Consumer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/13 10:57:25 UTC, 0 replies.
- Sqoop-like module in Flink - posted by Flavio Pompermaier <po...@okkam.it> on 2016/04/13 12:45:46 UTC, 2 replies.
- [jira] [Created] (FLINK-3748) Add CASE function to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/13 12:59:25 UTC, 0 replies.
- Issue deploying a topology to flink with a java api - posted by star jlong <jl...@yahoo.fr.INVALID> on 2016/04/13 14:23:31 UTC, 25 replies.
- [jira] [Created] (FLINK-3749) Improve decimal handling - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/13 14:35:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3750) Make JDBCInputFormat a parallel source - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/04/13 16:02:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3751) default Operator names are inconsistent - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/13 16:02:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3752) Add Per-Kafka-Partition Watermark Generation to the docs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/04/13 21:05:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3753) KillerWatchDog should not use kill on toKill thread - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/14 03:53:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI - posted by "Yijie Shen (JIRA)" <ji...@apache.org> on 2016/04/14 04:06:25 UTC, 0 replies.
- Issue regarding the submission of a topology to a remote flink cluster. - posted by ned dogg <ne...@gmail.com> on 2016/04/14 09:18:54 UTC, 12 replies.
- [jira] [Created] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/14 11:05:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3756) Introduce state hierarchy in CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/14 11:12:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3757) addAccumulator does not throw Exception on duplicate accumulator name - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/14 12:03:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3758) Add possibility to register accumulators in custom triggers - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/14 12:14:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3759) Table API should throw exception is null value is encountered in non-null mode. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/14 15:34:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3760) Fix StateDescriptor.readObject - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/14 16:01:25 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.0.2 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/14 16:04:45 UTC, 1 replies.
- Surprising order of events in union of two streams - posted by Gary Verhaegen <ga...@euranova.eu> on 2016/04/14 16:18:35 UTC, 4 replies.
- FLINK-3750 (JDBCInputFormat) - posted by Flavio Pompermaier <po...@okkam.it> on 2016/04/14 16:59:11 UTC, 17 replies.
- [RESULT] [VOTE] Release Apache Flink 1.0.2 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/14 18:19:33 UTC, 0 replies.
- [jira] [Created] (FLINK-3761) Introduce key group state backend - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/14 18:59:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3762) Kryo StackOverflowError due to disabled Kryo Reference tracking - posted by "Andrew Palumbo (JIRA)" <ji...@apache.org> on 2016/04/14 20:00:29 UTC, 0 replies.
- Adding custom monitoring to Flink - posted by Maxim <mf...@gmail.com> on 2016/04/14 20:59:24 UTC, 3 replies.
- [jira] [Created] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters - posted by "Robert Batts (JIRA)" <ji...@apache.org> on 2016/04/15 05:57:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/15 12:23:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3765) ScalaShellITCase deadlocks spuriously - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/15 12:25:25 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.0.2 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/15 12:47:06 UTC, 1 replies.
- [jira] [Created] (FLINK-3766) Add a new tab for monitoring metrics in the web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/15 14:22:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3767) Show timeline also for running tasks, not only for finished ones - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/15 14:26:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3768) Clustering Coefficient - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/15 18:57:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange - posted by "Robert Batts (JIRA)" <ji...@apache.org> on 2016/04/15 22:44:28 UTC, 0 replies.
- Flink optimizer optimizations - posted by CPC <ac...@gmail.com> on 2016/04/15 22:50:40 UTC, 4 replies.
- [jira] [Created] (FLINK-3770) Fix TriangleEnumerator performance - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/16 12:03:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3771) Methods for translating Graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/16 13:02:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3772) Graph algorithms for vertex and edge degree - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/16 16:28:25 UTC, 0 replies.
- Re: GSoC Project Proposal Draft: Code Generation in Serializers - posted by Gábor Horváth <xa...@gmail.com> on 2016/04/16 17:51:48 UTC, 11 replies.
- [jira] [Created] (FLINK-3773) Scanners are left unclosed in SqlExplainTest - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/17 02:34:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/18 10:32:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3775) Flink Scala shell does not respect Flink configuration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/18 11:27:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3776) Flink Scala shell does not allow to set configuration for local execution - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/18 11:31:25 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.0.2 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/18 11:52:44 UTC, 5 replies.
- [jira] [Created] (FLINK-3777) Add open and close methods to manage IF lifecycle - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/04/18 12:04:25 UTC, 0 replies.
- Savepoint for time windows - posted by Ozan DENİZ <oz...@outlook.com> on 2016/04/18 15:11:00 UTC, 4 replies.
- Problem with flink while development - posted by Jitendra Agrawal <ji...@northgateps.com> on 2016/04/18 16:07:21 UTC, 3 replies.
- [VOTE] Release Apache Flink 1.0.2 (RC3) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/18 17:29:36 UTC, 24 replies.
- [jira] [Created] (FLINK-3778) ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/18 18:03:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3779) Add support for queryable state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/18 18:23:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3780) Jaccard Similarity - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/18 18:48:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/18 19:20:25 UTC, 0 replies.
- Bug in Scala Shell - posted by Trevor Grant <tr...@gmail.com> on 2016/04/18 23:35:00 UTC, 2 replies.
- [jira] [Created] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close - posted by "Chenguang He (JIRA)" <ji...@apache.org> on 2016/04/18 23:39:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3783) Support weighted random sampling with reservoir - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2016/04/19 08:15:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction - posted by "Sergio Ramírez (JIRA)" <ji...@apache.org> on 2016/04/19 10:31:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3785) Add REST resource to query information about checkpointing - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2016/04/19 12:54:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3786) Add BigDecimal and BigInteger as Basic types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/19 14:15:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3787) Yarn client does not report unfulfillable container constraints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/19 14:46:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3788) Local variable values are not distributed to task runners - posted by "Andreas C. Osowski (JIRA)" <ji...@apache.org> on 2016/04/19 16:28:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3789) Overload methods which trigger program execution to allow naming job - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/19 16:48:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3790) Rolling File sink does not pick up hadoop configuration - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/20 15:34:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3791) Flink CLI must has arguments to specify zookeeper cluster required to work with Standalone HA cluster - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/20 16:21:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3792) RowTypeInfo equality should not depend on field names - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/20 16:35:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3793) Re-organize the Table API and SQL docs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/20 18:53:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3794) Add checks for unsupported operations in streaming table API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/04/20 19:01:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3795) Cancel button is hidden on MacBook Pro 13'' - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/20 19:06:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3796) FileSourceFunction doesn't respect InputFormat's life cycle methods - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/20 19:10:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3797) Restart flow button - posted by "Maxim Dobryakov (JIRA)" <ji...@apache.org> on 2016/04/20 19:11:25 UTC, 0 replies.
- [jira] [Created] (FLINK-3798) Clean up RocksDB state backend access modifiers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/20 21:26:25 UTC, 0 replies.
- Strange error in Kafka consumer - posted by Gyula Fóra <gy...@apache.org> on 2016/04/21 11:28:30 UTC, 0 replies.
- [jira] [Created] (FLINK-3799) Graph checksum should execute single job - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/21 14:27:25 UTC, 0 replies.
- [DISCUSS] Add N-Ary Stream Operator - posted by Aljoscha Krettek <al...@apache.org> on 2016/04/21 15:56:33 UTC, 2 replies.
- [jira] [Created] (FLINK-3800) ExecutionGraphs can become orphans - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/21 17:05:25 UTC, 0 replies.
- [DISCUSS] Methods for translating Graphs - posted by Greg Hogan <co...@greghogan.com> on 2016/04/21 18:06:47 UTC, 2 replies.
- [DISCUSS] Graph algorithms for vertex and edge degree - posted by Greg Hogan <co...@greghogan.com> on 2016/04/21 18:52:53 UTC, 5 replies.
- [DISCUSS] Release Flink 1.0.3 - posted by Robert Metzger <rm...@apache.org> on 2016/04/21 19:04:00 UTC, 12 replies.
- [jira] [Created] (FLINK-3801) Upgrade Joda-Time library to 2.9.3 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/21 19:20:25 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.0.2 (RC3) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/21 20:24:36 UTC, 0 replies.
- [jira] [Created] (FLINK-3802) Add Very Fast Reservoir Sampling - posted by "Chenguang He (JIRA)" <ji...@apache.org> on 2016/04/21 22:31:13 UTC, 0 replies.
- Pull request failed Travis...what's next? - posted by Sourigna Phetsarath <gn...@teamaol.com> on 2016/04/21 23:18:46 UTC, 4 replies.
- [jira] [Created] (FLINK-3803) Checkpoint Stats Tracker Reads from Wrong Configuration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/04/22 13:46:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3804) Update YARN documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/22 14:17:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3805) BloomFilter initialized with no memory available - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/22 17:50:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3806) Revert use of DataSet.count() in Gelly - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/22 19:50:13 UTC, 0 replies.
- flink-git - an experiment in exactly-once semantics - posted by Eron Wright <ew...@live.com> on 2016/04/23 00:23:12 UTC, 1 replies.
- [ANNOUNCE] Flink 1.0.2 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/23 11:48:44 UTC, 0 replies.
- Eclipse Problems - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/04/25 00:14:35 UTC, 13 replies.
- Partition problem - posted by Andrew Palumbo <ap...@outlook.com> on 2016/04/25 01:40:24 UTC, 5 replies.
- [jira] [Created] (FLINK-3807) FastFailuresITCase deadlocks on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/25 14:06:12 UTC, 0 replies.
- Parallelizing ExecutionConfig.fromCollection - posted by Greg Hogan <co...@greghogan.com> on 2016/04/25 15:45:44 UTC, 2 replies.
- [jira] [Created] (FLINK-3808) Refactor the whole file monitoring source to take a fileInputFormat as an argument. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/25 16:41:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3809) Missing break in ZooKeeperLeaderRetrievalService#handleStateChange() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/25 18:36:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3810) Missing break in ZooKeeperLeaderElectionService#handleStateChange() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/04/25 18:39:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3811) Refactor ExecutionEnvironment in TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/25 21:39:12 UTC, 0 replies.
- Read JSON file as input - posted by Punit Naik <na...@gmail.com> on 2016/04/26 08:06:23 UTC, 14 replies.
- [jira] [Created] (FLINK-3812) Kafka09ITCase testAllDeletes fails on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/04/26 10:20:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 10:53:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3814) Update code style guide regarding Preconditions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 12:50:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3815) Replace Guava Preconditions usage in flink-gelly - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:10:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3816) Replace Guava Preconditions usage in flink-clients - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:12:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3817) Remove unused Guava dependency from RocksDB StateBackend - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:14:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3818) Remove Guava dependency from flink-gelly-examples - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:26:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3819) Replace Guava Preconditions usage in flink-gelly-scala - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 13:30:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3820) ScalaShellITCase.testPreventRecreationBatch deadlocks on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 13:48:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3821) Reduce Guava usage in flink-java - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/04/26 14:31:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3822) Document checksum functions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/26 15:04:12 UTC, 0 replies.
- Data locality and scheduler - posted by CPC <ac...@gmail.com> on 2016/04/26 16:59:47 UTC, 3 replies.
- Question on Testing - posted by Chenguang He <ga...@gmail.com> on 2016/04/26 17:51:52 UTC, 1 replies.
- [jira] [Created] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 18:17:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3824) ResourceManager may repeatedly connect to outdated JobManager in HA mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/04/26 18:50:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3825) Update CEP documentation to include Scala API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/26 18:51:13 UTC, 0 replies.
- Updated Gelly Roadmap - posted by Vasiliki Kalavri <va...@gmail.com> on 2016/04/26 18:57:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3826) Broken test: StreamCheckpointingITCase - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/27 10:51:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3827) Flink modules include unused dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:36:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3828) flink-runtime - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:38:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3830) flink-scala - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3829) flink-java - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:38:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3833) flink-test-utils - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3834) flink-statebackend-rocksdb - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3832) flink-streaming-scala - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3831) flink-streaming-java - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/04/27 11:39:12 UTC, 0 replies.
- Master test stability poor - posted by Till Rohrmann <tr...@apache.org> on 2016/04/27 12:12:02 UTC, 8 replies.
- Backporting a patch to a release branch - posted by Stefano Baghino <st...@radicalbit.io> on 2016/04/27 13:38:48 UTC, 6 replies.
- [jira] [Created] (FLINK-3835) JSON execution plan not helpful to debug plans with KeySelectors - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/27 14:44:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3836) Change Histogram to enable Long counters - posted by "Maximilian Bode (JIRA)" <ji...@apache.org> on 2016/04/27 16:26:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3837) Create FLOOR/CEIL function - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/04/27 16:53:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3838) CLI parameter parser is munging application params - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/04/27 18:49:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3839) Support wildcards in classpath parameters - posted by "Ken Krugler (JIRA)" <ji...@apache.org> on 2016/04/27 19:00:17 UTC, 0 replies.
- flatMap issue - posted by Punit Naik <na...@gmail.com> on 2016/04/28 08:06:23 UTC, 4 replies.
- [jira] [Created] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/28 08:41:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/28 08:46:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3842) Fix handling null record/row in generated code - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2016/04/28 10:47:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3843) StreamFaultToleranceTestBase hangs in case of test failure. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/04/28 13:42:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3844) Checkpoint failures should not always lead to job failures - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/04/28 15:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/28 17:01:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3846) Graph.removeEdges also removes duplicate edges - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/28 17:13:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3847) Reorganize package structure of flink-table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 17:53:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3848) Add ProjectableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 17:58:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3849) Add FilterableTableSource interface and translation rule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:02:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:09:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3851) Add interface to register external catalogs in the TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/04/28 18:44:12 UTC, 0 replies.
- taskmanager.heap.mb recommendation - posted by Greg Hogan <co...@greghogan.com> on 2016/04/28 23:18:39 UTC, 1 replies.
- [VOTE] Release Apache Flink 1.0.3 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/29 10:10:59 UTC, 1 replies.
- groupBy on a Dataset of Maps - posted by Punit Naik <na...@gmail.com> on 2016/04/29 10:13:23 UTC, 5 replies.
- [jira] [Created] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/04/29 11:01:12 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.0.3 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/29 11:13:37 UTC, 0 replies.
- TypeVariable problems - posted by Martin Neumann <mn...@sics.se> on 2016/04/29 12:12:35 UTC, 0 replies.
- [jira] [Created] (FLINK-3853) Reduce object creation in Gelly utility mappers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/04/29 14:49:12 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.0.3 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/04/29 15:12:35 UTC, 0 replies.
- [jira] [Created] (FLINK-3854) Support Avro key-value rolling sink - posted by "Igor Berman (JIRA)" <ji...@apache.org> on 2016/04/30 00:45:12 UTC, 0 replies.
- [jira] [Created] (FLINK-3855) Upgrade Jackson version - posted by "Tatu Saloranta (JIRA)" <ji...@apache.org> on 2016/04/30 05:29:12 UTC, 0 replies.