dev@flink.apache.org, 2016-12

You are viewing a plain text version of this content. The canonical link for it is here.

- separation of JVMs for different applications - posted by Manu Zhang <ow...@gmail.com> on 2016/12/01 03:16:50 UTC, 1 replies.
- [DISCUSS] Handling event-time in continuous file processing. - posted by Kostas Kloudas <k....@data-artisans.com> on 2016/12/01 09:05:53 UTC, 2 replies.
- [jira] [Created] (FLINK-5217) Deprecated interface Checkpointed make clear suggestion - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/01 09:29:59 UTC, 0 replies.
- [FLINK-4604] Trouble with NULL type - posted by Anton Mushin <An...@epam.com> on 2016/12/01 11:19:24 UTC, 2 replies.
- [jira] [Created] (FLINK-5218) Eagerly close checkpoint streams on cancellation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/01 11:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5219) Add non-grouped session windows for batch tables - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/12/01 11:47:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5220) Flink SQL projection pushdown - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/02 01:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5221) Checkpointed workless in Window Operator - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2016/12/02 01:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5222) Rename StateBackend interface to StateBinder - posted by "MaGuowei (JIRA)" <ji...@apache.org> on 2016/12/02 02:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5223) Add documentation of UDTF in Table API & SQL - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/02 03:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5224) Improve UDTF: emit rows directly instead of buffering them - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/02 03:11:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5225) Add interface to override parameter types of UDTF's eval method - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/02 03:22:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5226) Eagerly project unused attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 09:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5227) Add warning to include flink-table in job fat jars - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/02 10:02:58 UTC, 0 replies.
- Join to FLINK Team - posted by Andrey Efimov <ae...@gmail.com> on 2016/12/02 10:47:02 UTC, 3 replies.
- [jira] [Created] (FLINK-5228) LocalInputChannel re-trigger request and release deadlock - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/02 11:07:59 UTC, 0 replies.
- [ANNOUNCE] Stability/Scalability effort and Pull Requests - posted by Stephan Ewen <se...@apache.org> on 2016/12/02 13:48:17 UTC, 1 replies.
- [jira] [Created] (FLINK-5229) Cleanup StreamTaskStates if a checkpoint operation of a subsequent operator fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/02 13:53:58 UTC, 0 replies.
- Re: [DISCUSS] FLIP-5 Only send data to each taskmanager once for broadcasts - posted by Felix Neutatz <ne...@googlemail.com> on 2016/12/02 13:55:01 UTC, 0 replies.
- [jira] [Created] (FLINK-5230) Safety nets against leaving dysfunctional JobManagers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5231) JobManager should exit on "OutOfMemoryError" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:12:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 14:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5233) Upgrade Jackson version because of class loader leak - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/02 14:20:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5234) Inform user about classpath configuration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/02 14:37:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5235) HBase classpath automatically added to Flink classpath - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/02 15:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5236) User jar classpath should come first in classpath - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/02 15:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5237) Consolidate and harmonize Window Translation Tests - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/02 15:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5238) Flip-6 mini cluster should start local TaskManagers if there is only one TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 16:06:58 UTC, 0 replies.
- [DISCUSS] Merging the FLIP-6 feature branch into the Master branch - posted by Stephan Ewen <se...@apache.org> on 2016/12/02 16:37:49 UTC, 5 replies.
- [jira] [Created] (FLINK-5239) Properly unpack thrown exceptions in RPC methods - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/02 16:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5240) Properly Close StateBackend in StreamTask when closing/canceling - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/02 17:09:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/02 17:30:59 UTC, 0 replies.
- Re: [DISCUSS] Proposed updates to Flink project site - posted by Maximilian Michels <mx...@apache.org> on 2016/12/02 17:39:31 UTC, 0 replies.
- Savepoints seem to not work properly on release-1.1 branch - posted by Gyula Fóra <gy...@gmail.com> on 2016/12/03 08:56:01 UTC, 4 replies.
- [jira] [Created] (FLINK-5242) Implement Scala API for BipartiteGraph - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/03 16:19:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5243) Implement an example for BipartiteGraph - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/03 16:20:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5244) Implement methods for BipartiteGraph transformations - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/03 16:25:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5245) Add support for BipartiteGraph mutations - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/03 16:27:58 UTC, 0 replies.
- [FLINK-4704 ] Move Table API to org.apache.flink.table - posted by Anton Mushin <An...@epam.com> on 2016/12/03 19:18:10 UTC, 6 replies.
- [jira] [Created] (FLINK-5246) Don't discard unknown checkpoint messages in the CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/03 19:20:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5247) Setting allowedLateness to a non-zero value should throw exception for processing-time windows - posted by "Rohit Agarwal (JIRA)" <ji...@apache.org> on 2016/12/03 20:13:58 UTC, 0 replies.
- 1.2-SNAPSHOT documentation - posted by Ken Krugler <kk...@transpac.com> on 2016/12/04 01:42:24 UTC, 5 replies.
- [jira] [Created] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/04 11:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5249) description of datastream rescaling doesn't match the figure - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/04 14:42:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5250) Make AbstractUdfStreamOperator aware of WrappingFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/05 00:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5251) Decouple StreamTableSourceScan with TableSourceTable - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/05 01:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5252) Migrate all YARN related configurations to ConfigOptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/05 01:55:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5253) Remove special treatment of "dynamic properties" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/05 01:59:58 UTC, 0 replies.
- 答复: [jira] [Created] (FLINK-5250) Make AbstractUdfStreamOperator aware of WrappingFunction - posted by liuxinchun <li...@huawei.com> on 2016/12/05 02:03:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5254) Implement Yarn HA Services - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/05 02:07:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/05 08:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5257) Display optimized logical plan when explaining table - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/05 09:39:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5258) reorganize the docs to improve navigation and reduce duplication - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/05 09:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5259) wrong execution environment in retry delays example - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/05 10:38:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5260) Add docs about how to react to cancellation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 11:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/05 12:44:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5262) Docs: Introduce a Gemfile.lock to avoid dependency range conflicts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/05 13:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5263) Add docs about JVM sharing between tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/05 14:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5264) Improve error message when assigning uid to intermediate operator. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/05 14:45:58 UTC, 0 replies.
- Re: [DISCUSS] Schedule and Scope for Flink 1.2 - posted by Robert Metzger <rm...@apache.org> on 2016/12/05 17:28:50 UTC, 29 replies.
- [jira] [Created] (FLINK-5265) Introduce state handle replication mode for CheckpointCoordinator - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/05 20:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/06 01:39:58 UTC, 0 replies.
- [DISCUSS] "Who's hiring on Flink" monthly thread in the mailing lists? - posted by Kostas Tzoumas <kt...@apache.org> on 2016/12/06 11:42:36 UTC, 5 replies.
- [jira] [Created] (FLINK-5267) TaskManager logs not scrollable - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/12/06 19:22:58 UTC, 0 replies.
- Travis build broken on missing licenses - posted by Márton Balassi <ba...@gmail.com> on 2016/12/06 22:08:51 UTC, 6 replies.
- Re: Monitoring backpressure - posted by "alan@opsclarity.com" <al...@opsclarity.com> on 2016/12/06 23:58:36 UTC, 1 replies.
- [jira] [Created] (FLINK-5268) Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5269) Convert string-based Table API tests into unit tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:33:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5270) Refactor the batch Scala-expression Table API tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:41:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5271) Refactor the batch SQL tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:46:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5272) Refactor the stream Scala-expression Table API tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:51:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5273) Refactor stream SQL tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 10:54:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5274) LocalInputChannel throws NPE if partition reader is released - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 12:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5275) InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 12:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 13:01:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5277) missing unit test for ensuring ResultPartition#add always recycles buffers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/07 14:40:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5278) Improve Task and checkpoint logging - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/07 15:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/07 16:51:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5280) Extend TableSource to support nested data - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 17:40:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5281) Extend KafkaJsonTableSources to support nested data - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/07 17:46:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5283) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/07 18:53:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5282) CheckpointStateOutputStream should be closed in finally block in SavepointV0Serializer#convertKeyedBackendState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/07 18:53:58 UTC, 0 replies.
- trouble using maven to deploy master branch to a private repo - posted by sblackmon <sb...@apache.org> on 2016/12/07 19:03:44 UTC, 3 replies.
- [jira] [Created] (FLINK-5284) Make output of bucketing sink compatible with other processing framework like mapreduce - posted by "Wenlong Lyu (JIRA)" <ji...@apache.org> on 2016/12/08 10:01:09 UTC, 0 replies.
- [jira] [Created] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/08 10:14:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5286) Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/08 11:15:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5287) Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/08 11:20:58 UTC, 0 replies.
- [DISCUSS] (FLINK-2980) Add support for CUBE / ROLLUP / GROUPING SETS in Table API - posted by Alexander Chermenin <a....@gmail.com> on 2016/12/08 12:11:33 UTC, 2 replies.
- [jira] [Created] (FLINK-5288) Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/08 13:04:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5289) NPE when using value state on non-keyed stream - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/08 13:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/08 13:49:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5291) Ensure backwards compatibility of the hashes used to generate JobVertexIds - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/08 13:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5292) Make the remaining operators backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:32:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5293) Make the Kafka consumer backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5294) Make the WindowOperator backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:36:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5295) Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:40:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/08 16:41:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/08 16:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5298) Web UI crashes when TM log not existant - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/12/08 16:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5299) DataStream support for arrays as keys - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/08 17:01:01 UTC, 0 replies.
- [jira] [Created] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/08 17:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5301) Can't upload job via Web UI when using a proxy - posted by "Mischa Krüger (JIRA)" <ji...@apache.org> on 2016/12/08 17:52:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5302) Log failure cause at Execution - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/08 23:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/09 07:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5304) Change method name from crossApply to join in Table API - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/09 09:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5305) Documentation of collect() should mention parameter akka.framesize - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2016/12/09 09:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/09 11:22:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5307) Log configuration for every reporter - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/09 12:13:58 UTC, 0 replies.
- Re: Flink survey by data Artisans - posted by Mike Winters <mw...@gmail.com> on 2016/12/09 13:33:46 UTC, 0 replies.
- [jira] [Created] (FLINK-5308) download links to previous releases are incomplete - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/09 14:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5309) documentation links on the home page point to 1.2-SNAPSHOT - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/09 16:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5310) Harden the RocksDB JNI library loading - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/09 16:49:59 UTC, 0 replies.
- Reg. custom sinks in Flink - posted by Meghashyam Sandeep V <vr...@gmail.com> on 2016/12/09 18:26:31 UTC, 4 replies.
- [jira] [Created] (FLINK-5311) Write user documentation for BipartiteGraph - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/09 22:21:58 UTC, 0 replies.
- How to merge messages from all partitions - posted by Naveen Tirupattur <nt...@maprtech.com> on 2016/12/10 02:46:00 UTC, 1 replies.
- Re: [Discuss] FLIP-13 Side Outputs in Flink - posted by Chen Qin <cq...@uber.com> on 2016/12/10 04:42:09 UTC, 0 replies.
- [jira] [Created] (FLINK-5312) Implement Standalone Setup v2.0 - posted by "Manu Zhang (JIRA)" <ji...@apache.org> on 2016/12/10 11:26:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5313) Supporting all tpch queries - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/12 01:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5314) Add tpch query explain test - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/12 05:28:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5315) Support distinct aggregations in table api - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2016/12/12 05:43:58 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.1.4 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/12/12 08:27:37 UTC, 2 replies.
- Re: [DISCUSS] FLIP-14: Loops API and Termination - posted by Paris Carbone <pa...@kth.se> on 2016/12/12 11:13:34 UTC, 2 replies.
- [jira] [Created] (FLINK-5316) Make the GenericWriteAheadSink backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/12 14:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5317) Make the continuous file processing code backwards compatible, - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/12 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-5318) Make the Rolling/Bucketing sink backwards compatible. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/12/12 14:06:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5319) ClassCastException when reusing an inherited method as KeySelector for different classes - posted by "Alexander Chermenin (JIRA)" <ji...@apache.org> on 2016/12/12 16:07:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction) - posted by "Yassine Marzougui (JIRA)" <ji...@apache.org> on 2016/12/12 16:43:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5321) FlinkMiniCluster does not start Jobmanager MetricQueryService - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/12 17:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5322) yarn.taskmanager.env value does not appear in System.getenv - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/12/12 18:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5323) CheckpointNotifier should be removed from docs - posted by "Abhishek Singh (JIRA)" <ji...@apache.org> on 2016/12/12 23:09:58 UTC, 0 replies.
- Minor Cleanup of StreamGraphGeneator - posted by Chen Qin <cq...@uber.com> on 2016/12/13 07:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5324) JVM Opitons will be work both for YarnApplicationMasterRunner and YarnTaskManager with yarn mode - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2016/12/13 07:54:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/13 08:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/13 09:07:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5327) Remove IOException from StateObject::getStateSize - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/13 09:11:58 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.1.4 (RC2) - posted by Ufuk Celebi <uc...@apache.org> on 2016/12/13 10:50:49 UTC, 0 replies.
- [jira] [Created] (FLINK-5328) ConnectedComponentsITCase testJobWithoutObjectReuse fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/13 12:36:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5329) MetricList is being cut off - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/12/13 12:54:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5330) Harden KafkaConsumer08Test - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/13 14:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5331) PythonPlanBinderTest idling extremely long - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/13 15:51:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5332) Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/13 19:48:58 UTC, 0 replies.
- [VOTE] Release Apache Flink 1.1.4 (RC3) - posted by Ufuk Celebi <uc...@apache.org> on 2016/12/13 22:04:55 UTC, 6 replies.
- Re: Travis CI - posted by Henry Saputra <he...@gmail.com> on 2016/12/14 02:52:18 UTC, 5 replies.
- [jira] [Created] (FLINK-5333) Keep Windows scripts in sync with shell scripts - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/14 08:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5334) outdated scala SBT quickstart example - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2016/12/14 09:16:00 UTC, 0 replies.
- [ANNOUNCE] New Flink community mailing list - posted by Kostas Tzoumas <kt...@apache.org> on 2016/12/14 09:46:44 UTC, 0 replies.
- [jira] [Created] (FLINK-5335) Allow ListCheckpointed user functions to return null - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/14 11:12:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5336) Make Path immutable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 12:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5337) Introduce backwards compatible state to task assignment - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/12/14 13:15:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5338) Make printing sinks non-parallel - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/14 14:26:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5339) Ensure Flink works with Log4j version 2 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/14 14:27:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5340) I would like a metric exposing job uptime - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/12/14 23:03:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5341) Add a metric exposing how many times a job has been restarted - posted by "Dan Bress (JIRA)" <ji...@apache.org> on 2016/12/14 23:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5342) Setting the parallelism automatically for DataSet Operators base on cost model - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/12/15 05:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5343) Add option to CsvTableSink to overwrite files - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/15 09:07:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5344) docs don't build in dockerized jekyll - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/15 14:37:58 UTC, 0 replies.
- Re: Task manager processes crashing one after the other - posted by Robert Metzger <rm...@apache.org> on 2016/12/15 15:05:13 UTC, 0 replies.
- [jira] [Created] (FLINK-5345) IOManager failed to properly clean up temp file directory - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/15 15:20:58 UTC, 0 replies.
- 1.2 SNAPSHOT - java.lang.VerifyError on YARN - posted by Dominik Bruhn <do...@dbruhn.de> on 2016/12/15 16:10:54 UTC, 2 replies.
- [jira] [Created] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/15 16:52:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/15 20:02:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5348) Support custom field names for RowTypeInfo - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/16 02:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5349) Fix code sample for Twitter connector - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/16 07:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5350) Don't overwrite existing Jaas config property - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/12/16 09:47:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5351) Make the TypeExtractor support functions with more than 2 inputs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/12/16 10:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5352) Restore RocksDB 1.1.3 memory behavior - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/16 11:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/12/16 12:54:58 UTC, 0 replies.
- Who's hiring, December 2016 - posted by Kostas Tzoumas <kt...@apache.org> on 2016/12/16 13:46:00 UTC, 1 replies.
- [jira] [Created] (FLINK-5354) Split up Table API documentation into multiple pages - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/16 14:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5355) Handle AmazonKinesisException gracefully in Kinesis Streaming Connector - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2016/12/16 15:21:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/16 15:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5357) WordCountTable fails - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/12/16 15:55:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5358) Support Row in TypeExtractor - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/16 16:24:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5359) Job Exceptions view doesn't scroll - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/16 21:54:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5360) Fix arguments names in WindowedStream - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/16 22:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5361) Flink shouldn't require Kerberos credentials - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/17 02:21:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5362) Implement methods to access BipartiteGraph properties - posted by "Ivan Mushketyk (JIRA)" <ji...@apache.org> on 2016/12/18 09:02:59 UTC, 0 replies.
- [jira] [Created] (FLINK-5363) Fire timers when window state is currently empty - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/18 17:31:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5364) Rework JAAS configuration to support user-supplied entries - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/19 00:50:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5365) Mesos AppMaster/TaskManager should obey sigterm - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/12/19 01:10:58 UTC, 0 replies.
- Stream Iterations - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2016/12/19 04:35:01 UTC, 1 replies.
- [RESULT] [VOTE] Release Apache Flink 1.1.4 (RC3) - posted by Ufuk Celebi <uc...@apache.org> on 2016/12/19 10:19:14 UTC, 0 replies.
- [jira] [Created] (FLINK-5366) Add end-to-end tests for Savepoint Backwards Compatibility - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/19 10:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5367) restore updates lost when merging recent doc refactoring - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2016/12/19 12:29:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list - posted by "Sendoh (JIRA)" <ji...@apache.org> on 2016/12/19 15:08:58 UTC, 2 replies.
- [VOTE] Release Apache Flink 1.1.4 (RC4) - posted by Ufuk Celebi <uc...@apache.org> on 2016/12/19 15:15:22 UTC, 4 replies.
- [DISCUSS] ElasticSearch in Flink Strategy - posted by Robert Metzger <rm...@apache.org> on 2016/12/19 15:46:04 UTC, 1 replies.
- [jira] [Created] (FLINK-5369) jsr305 and logging dependencies should be 'provided' by default - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/12/19 16:40:58 UTC, 0 replies.
- [DISCUSS] Merging FLIP-6 feature branch - posted by Stephan Ewen <se...@apache.org> on 2016/12/19 19:38:18 UTC, 0 replies.
- [jira] [Created] (FLINK-5370) build failure for unit test of FileInputFormatTest and GlobFilePathFilterTest - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/20 02:41:58 UTC, 0 replies.
- Status of Flink-Calcite integration - posted by Haohui Mai <ri...@gmail.com> on 2016/12/20 04:27:34 UTC, 3 replies.
- Re: [DISCUSS] Add Side Input/Broadcast Set For Streaming API - posted by Gábor Gévay <gg...@gmail.com> on 2016/12/20 10:59:51 UTC, 0 replies.
- InputGate consumedSubpartitionIndex in ALL_TO_ALL distribution pattern - posted by Luis Alves <lm...@gmail.com> on 2016/12/20 11:46:02 UTC, 1 replies.
- [jira] [Created] (FLINK-5371) Add documentation for async I/O - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/12/20 11:48:58 UTC, 0 replies.
- Flink gives incorrect result when event time windowing used - posted by Jaromir Vanek <va...@gmail.com> on 2016/12/20 13:56:22 UTC, 5 replies.
- [jira] [Created] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 16:47:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5373) Extend Unit Tests for StateAssignmentOperation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 17:06:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5374) Extend Unit Tests for RegisteredBackendStateMetaInfo - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/12/20 17:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5375) Fix watermark documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/12/20 17:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/20 18:45:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5377) Improve savepoint docs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/12/21 11:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5378) Update Scopt version to 3.5.0 - posted by "Lorenz Bühmann (JIRA)" <ji...@apache.org> on 2016/12/21 11:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5379) Flink CliFrontend does not return when not logged in with kerberos - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 13:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5380) Number of outgoing records not reported in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 14:33:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5381) Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 15:35:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5382) Taskmanager log download button causes 404 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 15:39:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5383) TaskManager fails with SIGBUS when loading RocksDB - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/12/21 16:07:58 UTC, 0 replies.
- clean up jira - posted by Anton Solovev <An...@epam.com> on 2016/12/21 17:18:34 UTC, 2 replies.
- [jira] [Created] (FLINK-5384) clean up jira issues - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/21 17:23:58 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 1.1.4 (RC4) - posted by Ufuk Celebi <uc...@apache.org> on 2016/12/21 18:00:51 UTC, 0 replies.
- [jira] [Created] (FLINK-5385) Add a help function to create Row - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/12/22 06:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5386) Refacturing Window Clause - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2016/12/22 07:43:58 UTC, 0 replies.
- Information regarding RichParallelSourceFunction - posted by Saikat Maitra <sa...@gmail.com> on 2016/12/22 08:12:38 UTC, 3 replies.
- [jira] [Created] (FLINK-5387) Lightweight Event Time Window - posted by "Syinchwun Leo (JIRA)" <ji...@apache.org> on 2016/12/22 08:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5388) Remove private access of edges and vertices of Gelly Graph class - posted by "wouter ligtenberg (JIRA)" <ji...@apache.org> on 2016/12/23 13:25:58 UTC, 0 replies.
- [ANNOUNCE] Flink 1.1.4 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/12/23 15:40:56 UTC, 3 replies.
- Dynamic Scaling - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2016/12/23 19:11:52 UTC, 1 replies.
- Getting started with FLINK-4088 - posted by Minudika Malshan <mi...@gmail.com> on 2016/12/23 21:19:41 UTC, 1 replies.
- [jira] [Created] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/23 22:30:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/24 00:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/12/24 01:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5392) flink-dist build failed when change scala version to 2.11 - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2016/12/26 01:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5393) Apache flink for IOT - posted by "suhasjk (JIRA)" <ji...@apache.org> on 2016/12/26 06:59:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5394) the estimateRowCount method of DataSetCalc didn't work - posted by "zhangjing (JIRA)" <ji...@apache.org> on 2016/12/27 11:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5395) support locally build distribution by script create_release_files.sh - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/27 12:23:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5396) flink-dist replace scala version in opt.xml by change-scala-version.sh - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/27 12:26:58 UTC, 0 replies.
- [FLINK-3615] Add support for non-native SQL types - posted by Alexander Chermenin <a....@gmail.com> on 2016/12/28 08:38:35 UTC, 0 replies.
- [jira] [Created] (FLINK-5397) Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/28 08:56:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5398) Exclude generated files in module flink-batch-connectors in license checking - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/29 02:18:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5399) Add more information to checkpoint result of TriggerSavepointSuccess - posted by "shijinkui (JIRA)" <ji...@apache.org> on 2016/12/29 04:52:58 UTC, 0 replies.
- How to add flink dependency in pom - posted by Liang Chen <ch...@gmail.com> on 2016/12/29 16:06:20 UTC, 5 replies.
- [jira] [Created] (FLINK-5400) Add accessor to folding states in RuntimeContext - posted by "Xiaogang Shi (JIRA)" <ji...@apache.org> on 2016/12/30 02:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5401) Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/30 09:29:58 UTC, 0 replies.
- [jira] [Created] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture - posted by "Anton Solovev (JIRA)" <ji...@apache.org> on 2016/12/30 09:32:58 UTC, 0 replies.
- [DISCUSS] schedule for execution from different list of ExecutionJobVertex - posted by sjk <sh...@163.com> on 2016/12/30 10:03:05 UTC, 0 replies.