commits@flink.apache.org, 2017-02

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

- flink git commit: [hotfix] [doc] Fix broken externalized checkpoint reference link - posted by tz...@apache.org on 2017/02/02 06:10:24 UTC, 1 replies.
- svn commit: r18075 - /release/flink/flink-1.2.0/ - posted by rm...@apache.org on 2017/02/02 11:02:16 UTC, 0 replies.
- svn commit: r18076 - in /release/flink: flink-0.10.2/ flink-1.0.3/ flink-1.1.1/ flink-1.1.2/ flink-1.1.3/ - posted by rm...@apache.org on 2017/02/02 11:08:41 UTC, 0 replies.
- [1/4] flink-web git commit: Add changelog for 1.2.0 release - posted by rm...@apache.org on 2017/02/02 12:33:48 UTC, 0 replies.
- [2/4] flink-web git commit: Add changelog for 1.2.0 release - posted by rm...@apache.org on 2017/02/02 12:33:49 UTC, 0 replies.
- [3/4] flink-web git commit: Add changelog for 1.2.0 release - posted by rm...@apache.org on 2017/02/02 12:33:50 UTC, 0 replies.
- [4/4] flink-web git commit: Add changelog for 1.2.0 release - posted by rm...@apache.org on 2017/02/02 12:33:51 UTC, 0 replies.
- flink git commit: [FLINK-5502] [docs] Add migration guide in docs. - posted by al...@apache.org on 2017/02/02 15:35:54 UTC, 1 replies.
- flink git commit: [FLINK-5474] [docs] Extend DC/OS documentation - posted by tr...@apache.org on 2017/02/02 21:00:42 UTC, 1 replies.
- flink git commit: [FLINK-5494] [docs] Add more details to the Mesos documentation - posted by tr...@apache.org on 2017/02/02 21:27:06 UTC, 1 replies.
- flink git commit: [FLINK-5700] [docs] Document akka.client.timeout configuration parameter - posted by tr...@apache.org on 2017/02/02 21:33:20 UTC, 0 replies.
- [1/2] flink git commit: [docs] Fix Markdown code example in REST API - posted by uc...@apache.org on 2017/02/03 09:19:10 UTC, 1 replies.
- [2/2] flink git commit: [docs] Update version to 1.2 - posted by uc...@apache.org on 2017/02/03 09:19:11 UTC, 0 replies.
- [2/2] flink git commit: [docs] Update version to 1.3-SNAPSHOT - posted by uc...@apache.org on 2017/02/03 09:21:49 UTC, 0 replies.
- flink git commit: [docs] Set version to 1.1.4 - posted by uc...@apache.org on 2017/02/03 09:23:34 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-5499] [JobManager] Reuse the resource location of prior execution attempt in allocating slot - posted by se...@apache.org on 2017/02/03 12:37:27 UTC, 0 replies.
- [2/6] flink git commit: [hotfix] [jobmanager] Cleanups in the ExecutionGraph - posted by se...@apache.org on 2017/02/03 12:37:28 UTC, 0 replies.
- [3/6] flink git commit: [hotfix] [jobmanager] Reduce complexits when archiving ExecutionVertex - posted by se...@apache.org on 2017/02/03 12:37:29 UTC, 0 replies.
- [4/6] flink git commit: [hotfix] Minor code cleanups in the ExecutionGraph's Execution - posted by se...@apache.org on 2017/02/03 12:37:30 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-5499] [JobManager] Make the location preferences combined by state and inputs. - posted by se...@apache.org on 2017/02/03 12:37:31 UTC, 0 replies.
- [6/6] flink git commit: [hotfix] [tests] Increase timeout for AkkaRpcActorTest to mitigate occasional CI test timeouts - posted by se...@apache.org on 2017/02/03 12:37:32 UTC, 0 replies.
- flink git commit: [FLINK-5708] [docs] Remove duplicate configuration option - posted by gr...@apache.org on 2017/02/03 18:42:21 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-2211] [ml] Generalize ALS API - posted by tr...@apache.org on 2017/02/05 20:57:46 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5652] [asyncIO] Cancel timers when completing a StreamRecordQueueEntry - posted by tr...@apache.org on 2017/02/05 20:57:47 UTC, 0 replies.
- flink git commit: [FLINK-5652] [asyncIO] Cancel timers when completing a StreamRecordQueueEntry - posted by tr...@apache.org on 2017/02/05 20:59:45 UTC, 0 replies.
- buildbot failure in on flink-docs-release-1.2 - posted by bu...@apache.org on 2017/02/06 01:08:37 UTC, 0 replies.
- flink git commit: [FLINK-5709] Add Max Parallelism to Parallel Execution Doc - posted by al...@apache.org on 2017/02/06 12:43:58 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-5693] [gelly] ChecksumHashCode DataSetAnalytic - posted by gr...@apache.org on 2017/02/06 15:45:35 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5694] [gelly] Collect DataSetAnalytic - posted by gr...@apache.org on 2017/02/06 15:45:36 UTC, 0 replies.
- [1/4] flink-web git commit: Put Flink 1.2.0 on website - posted by rm...@apache.org on 2017/02/06 15:52:21 UTC, 0 replies.
- [2/4] flink-web git commit: Put Flink 1.2.0 on website - posted by rm...@apache.org on 2017/02/06 15:52:22 UTC, 0 replies.
- [3/4] flink-web git commit: Put Flink 1.2.0 on website - posted by rm...@apache.org on 2017/02/06 15:52:23 UTC, 0 replies.
- [4/4] flink-web git commit: Put Flink 1.2.0 on website - posted by rm...@apache.org on 2017/02/06 15:52:24 UTC, 0 replies.
- [1/2] flink git commit: [docs][state] add missing Java syntax highlighting to documentation - posted by uc...@apache.org on 2017/02/06 16:10:02 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5618] [docs] Add queryable state (user) documentation - posted by uc...@apache.org on 2017/02/06 16:10:03 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5618] [docs] Add queryable state (user) documentation - posted by uc...@apache.org on 2017/02/06 16:10:45 UTC, 0 replies.
- [2/2] flink git commit: [docs][state] add missing Java syntax highlighting to documentation - posted by uc...@apache.org on 2017/02/06 16:10:46 UTC, 0 replies.
- flink git commit: [docs] Add production readiness checklist - posted by uc...@apache.org on 2017/02/06 16:13:08 UTC, 1 replies.
- flink git commit: [docs] Add migration documentation - posted by uc...@apache.org on 2017/02/06 16:15:06 UTC, 1 replies.
- flink git commit: [docs] Fix typo in code snippet - posted by uc...@apache.org on 2017/02/06 16:16:45 UTC, 1 replies.
- flink git commit: [FLINK-5575] [docs] Add outdated release warning - posted by uc...@apache.org on 2017/02/06 16:28:27 UTC, 0 replies.
- flink git commit: [FLINK-5721] Add FoldingState to State Documentation - posted by al...@apache.org on 2017/02/06 16:29:45 UTC, 1 replies.
- flink git commit: [FLINK-5575][docs] in old releases, warn users and guide them to the latest stable docs - posted by uc...@apache.org on 2017/02/06 17:07:25 UTC, 3 replies.
- flink git commit: [FLINK-5575] [docs] Rework outdated release warning - posted by uc...@apache.org on 2017/02/06 17:14:18 UTC, 1 replies.
- flink git commit: [FLINK-5618][docs] createSerializer must actually get a non-null ExecutionConfig - posted by uc...@apache.org on 2017/02/06 17:28:26 UTC, 1 replies.
- flink git commit: [FLINK-5652] [asyncIO] Fix AsyncWaitOperatorTest.testTimeoutCleanup - posted by tr...@apache.org on 2017/02/06 17:53:05 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2883] [docs] Add documentation to forbid key-modifying ReduceFunction - posted by gr...@apache.org on 2017/02/06 19:40:04 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5680] [docs] Document env.ssh.opts - posted by gr...@apache.org on 2017/02/06 19:40:05 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5680] [docs] Document env.ssh.opts - posted by gr...@apache.org on 2017/02/06 19:43:15 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2883] [docs] Add documentation to forbid key-modifying ReduceFunction - posted by gr...@apache.org on 2017/02/06 19:43:16 UTC, 0 replies.
- buildbot success in on flink-docs-release-1.2 - posted by bu...@apache.org on 2017/02/07 01:33:14 UTC, 0 replies.
- [flink] Git Push Summary - posted by rm...@apache.org on 2017/02/07 10:09:35 UTC, 4 replies.
- flink git commit: [FLINK-5699] [savepoints] Check target dir when cancelling with savepoint - posted by uc...@apache.org on 2017/02/07 10:48:16 UTC, 1 replies.
- flink git commit: [FLINK-5732] [docs] Set version to full version - posted by uc...@apache.org on 2017/02/07 12:26:23 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4988] [elasticsearch] Restructure Elasticsearch connectors - posted by tz...@apache.org on 2017/02/07 14:47:56 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4988] [elasticsearch] Restructure Elasticsearch connectors - posted by tz...@apache.org on 2017/02/07 14:47:57 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4988] [elasticsearch] Restructure Elasticsearch connectors - posted by tz...@apache.org on 2017/02/07 14:47:58 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4988] Elasticsearch 5.x support - posted by tz...@apache.org on 2017/02/07 14:47:59 UTC, 0 replies.
- flink git commit: [FLINK-5702] [doc] At-least-once configuration info for FlinkKafkaProducer - posted by tz...@apache.org on 2017/02/07 15:25:56 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-5727] [table] Unify API of batch and stream TableEnvironments. - posted by fh...@apache.org on 2017/02/07 23:59:12 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [docs] Fix error in docs for zipping elements. - posted by fh...@apache.org on 2017/02/07 23:59:13 UTC, 0 replies.
- flink git commit: [hotfix] [docs] Fix error in docs for zipping elements. - posted by fh...@apache.org on 2017/02/08 00:00:05 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5153] Add test for YARN application tags - posted by rm...@apache.org on 2017/02/08 17:40:53 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5153] Support YARN application tags - posted by rm...@apache.org on 2017/02/08 17:40:54 UTC, 0 replies.
- flink git commit: Fix compile error - posted by uc...@apache.org on 2017/02/09 16:06:46 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5748] [jobmanager] Make the 'future executor' a ScheduledExecutorService - posted by se...@apache.org on 2017/02/09 16:12:04 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5748] [jobmanager] Make the 'future executor' a ScheduledExecutorService - posted by se...@apache.org on 2017/02/09 16:12:05 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4912] Introduce RECONCILIATING state in ExecutionGraph and Execution for JobManager failure recovery - posted by se...@apache.org on 2017/02/09 16:13:30 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5132] [core] Introduce the ResourceSpec to define required resource factors in API - posted by se...@apache.org on 2017/02/09 16:13:31 UTC, 0 replies.
- buildbot success in on flink-docs-release-1.0 - posted by bu...@apache.org on 2017/02/10 03:44:26 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5517] Upgrade hbase version to 1.3.0 - posted by tz...@apache.org on 2017/02/10 06:03:08 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [doc] Fix broken Flink on Windows link - posted by tz...@apache.org on 2017/02/10 06:03:09 UTC, 0 replies.
- flink git commit: [hotfix] [doc] Fix broken Flink on Windows link - posted by tz...@apache.org on 2017/02/10 06:04:48 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5017] [streaming] Introduce StreamStatus to facilitate idle sources - posted by al...@apache.org on 2017/02/10 14:50:03 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5017] [streaming] Introduce StreamStatus to facilitate idle sources - posted by al...@apache.org on 2017/02/10 14:50:04 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-5766] [distributed coordination] Unify the handling of NoResourceAvailableException - posted by se...@apache.org on 2017/02/10 15:33:40 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-5759] [jobmanager] Set UncaughtExceptionHandlers for JobManager's Future and I/O thread pools - posted by se...@apache.org on 2017/02/10 15:33:41 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-5718] [core] TaskManagers exit the JVM on fatal exceptions. - posted by se...@apache.org on 2017/02/10 15:33:42 UTC, 0 replies.
- [4/4] flink git commit: [hotfix] [dist] Add notice about memory pre-allocation to default 'flink-conf.yaml' - posted by se...@apache.org on 2017/02/10 15:33:43 UTC, 0 replies.
- flink git commit: [FLINK-5415] Harden ContinuousFileProcessingTest - posted by al...@apache.org on 2017/02/10 16:21:42 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [core] Improve FlinkFuture synchronous actions by avoiding creation of ExecutionContext - posted by se...@apache.org on 2017/02/10 18:03:47 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [core] Add tests for Futures applying multiple functions - posted by se...@apache.org on 2017/02/10 18:03:48 UTC, 0 replies.
- flink git commit: [FLINK-5712] [config] update several deprecated configuration options - posted by tr...@apache.org on 2017/02/12 15:23:45 UTC, 0 replies.
- flink git commit: [FLINK-1979] [ml] Add logistic loss, hinge loss and regularization penalties for optimization - posted by tr...@apache.org on 2017/02/12 19:41:37 UTC, 0 replies.
- buildbot success in on flink-docs-release-1.1 - posted by bu...@apache.org on 2017/02/13 03:25:39 UTC, 1 replies.
- Build failed in Jenkins: flink-snapshot-deployment #374 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/13 03:33:16 UTC, 0 replies.
- flink git commit: [hotfix] [tests] Correct EitherTypeInfoTest to respect equals-hashcode contract - posted by tr...@apache.org on 2017/02/13 14:37:28 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5662] [table] Rework internal type handling of Table API - posted by tw...@apache.org on 2017/02/13 16:51:22 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5662] [table] Rework internal type handling of Table API - posted by tw...@apache.org on 2017/02/13 16:51:23 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5662] [table] Rework internal type handling of Table API - posted by tw...@apache.org on 2017/02/13 16:51:24 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5631] [yarn] Support downloading additional jars from non-HDFS paths. - posted by se...@apache.org on 2017/02/13 19:53:49 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5729] [examples] Add hostname option to SocketWindowWordCount examples - posted by se...@apache.org on 2017/02/13 19:53:50 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #375 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/14 04:25:25 UTC, 0 replies.
- flink-web git commit: Add Jark to Community People - posted by ja...@apache.org on 2017/02/14 09:05:00 UTC, 0 replies.
- flink git commit: [FLINK-5406] [table] Add normalization phase for predicate logical plan rewriting - posted by tw...@apache.org on 2017/02/14 13:34:38 UTC, 0 replies.
- flink git commit: [FLINK-5690][docs] Add note on shading to best practices guide - posted by rm...@apache.org on 2017/02/14 14:05:22 UTC, 0 replies.
- flink git commit: [FLINK-5566] [table] Add containers for table and column statistics. - posted by fh...@apache.org on 2017/02/14 14:33:59 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5788] [docs] Improve documentation of FileSystem and specify the data persistence contract. - posted by se...@apache.org on 2017/02/14 14:48:51 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5553] [network] keep the original throwable in PartitionRequestClientHandler - posted by se...@apache.org on 2017/02/14 14:48:52 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5762] [runtime] Protect initializeState() and open() by the same lock - posted by se...@apache.org on 2017/02/14 14:48:53 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2908] [web frontend] Redraw web plan when browser resized - posted by gr...@apache.org on 2017/02/14 22:08:26 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2908] [web frontend] Redraw web plan when browser resized - posted by gr...@apache.org on 2017/02/14 22:08:27 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2908] [web frontend] Redraw web plan when browser resized - posted by gr...@apache.org on 2017/02/14 22:08:28 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2168] Add HBaseTableSource for batch tables. - posted by fh...@apache.org on 2017/02/15 09:41:25 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2168] Refactor HBaseTableSource and extend tests. - posted by fh...@apache.org on 2017/02/15 09:41:26 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5745] [runtime] Extract ExecutorThreadFactory#FatalExitExceptionHandler - posted by uc...@apache.org on 2017/02/15 10:31:50 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5745] [network] Set uncaught exception handler for Netty threads - posted by uc...@apache.org on 2017/02/15 10:31:51 UTC, 0 replies.
- flink git commit: [FLINK-5796] [docs] Fix broken links - posted by uc...@apache.org on 2017/02/15 10:33:56 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-5790] [core] Use list types when ListStateDescriptor extends StateDescriptor - posted by se...@apache.org on 2017/02/15 12:21:12 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5790] [core] Followups and tests for the StateDescriptor changes - posted by se...@apache.org on 2017/02/15 12:21:13 UTC, 0 replies.
- flink git commit: [FLINK-5807] [docs] Improved wording for home page - posted by uc...@apache.org on 2017/02/15 12:54:55 UTC, 1 replies.
- flink git commit: [FLINK-5806] [runtime] Fix TaskExecutionState toString - posted by uc...@apache.org on 2017/02/15 12:57:28 UTC, 1 replies.
- [1/2] flink git commit: [hotfix] [streaming] Properly mark non-transported fields as transient in AbstractStreamOperator - posted by se...@apache.org on 2017/02/15 14:12:48 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5800] [checkpointing] Create CheckpointSteamFactory only once per operator - posted by se...@apache.org on 2017/02/15 14:12:49 UTC, 0 replies.
- flink git commit: [FLINK-5714] [table] Use a builder pattern for creating CsvTableSource - posted by tw...@apache.org on 2017/02/15 15:15:00 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4280] [kafka] Explicit start position configuration for FlinkKafkaConsumer - posted by tz...@apache.org on 2017/02/15 15:44:13 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4280] [kafka] Explicit start position configuration for FlinkKafkaConsumer - posted by tz...@apache.org on 2017/02/15 15:44:14 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5805] [docs] Improvements to docs for ProcessFunction - posted by se...@apache.org on 2017/02/15 17:57:27 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5793] [runtime] fix running slot may not be add to AllocatedMap in SlotPool bug - posted by se...@apache.org on 2017/02/15 17:57:28 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5771] [core] Fix multi-char delimiter detection in DelimitedInputFormat. - posted by fh...@apache.org on 2017/02/15 22:54:41 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5567] [table] Introduce and migrate current table statistics to FlinkStatistic. - posted by fh...@apache.org on 2017/02/15 22:54:42 UTC, 0 replies.
- flink git commit: [FLINK-5771] [core] Fix multi-char delimiter detection in DelimitedInputFormat. - posted by fh...@apache.org on 2017/02/15 22:59:03 UTC, 1 replies.
- flink-web git commit: Rebuild website - posted by ja...@apache.org on 2017/02/16 09:03:14 UTC, 0 replies.
- flink git commit: [FLINK-5751] [docs] Fix some broken links - posted by uc...@apache.org on 2017/02/16 09:10:49 UTC, 1 replies.
- flink git commit: [hotfix] [tests] Stabilize FastFailuresITCase - posted by se...@apache.org on 2017/02/16 09:53:16 UTC, 0 replies.
- flink git commit: [FLINK-5814] [build] Fix packaging flink-dist in unclean source directory - posted by se...@apache.org on 2017/02/16 12:24:40 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-5800] [checkpointing] Create CheckpointSteamFactory only once per operator - posted by se...@apache.org on 2017/02/16 16:07:59 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-5805] [docs] Improvements to docs for ProcessFunction - posted by se...@apache.org on 2017/02/16 16:08:00 UTC, 0 replies.
- [3/6] flink git commit: [hotfix] [streaming] Properly mark non-transported fields as transient in AbstractStreamOperator - posted by se...@apache.org on 2017/02/16 16:08:01 UTC, 0 replies.
- [4/6] flink git commit: [hotfix] [tests] Stabilize FastFailuresITCase - posted by se...@apache.org on 2017/02/16 16:08:02 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-5814] [build] Fix packaging flink-dist in unclean source directory - posted by se...@apache.org on 2017/02/16 16:08:03 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-5705] [WebMonitor] WebMonitor request/response use UTF-8 explicitly - posted by se...@apache.org on 2017/02/16 16:08:04 UTC, 0 replies.
- flink git commit: [FLINK-5773] Use akka.actor.Status.Failure class to send failures via AskSupport - posted by tr...@apache.org on 2017/02/16 16:10:25 UTC, 1 replies.
- flink git commit: [FLINK-5811] [tests] Harden YarnClusterDescriptorTest - posted by tr...@apache.org on 2017/02/16 16:14:13 UTC, 0 replies.
- flink git commit: [FLINK-5705] [WebMonitor] WebMonitor request/response use UTF-8 explicitly - posted by se...@apache.org on 2017/02/16 16:15:39 UTC, 0 replies.
- flink git commit: [FLINK-5624] [table] Add SQL support for tumbling windows on streaming tables. - posted by fh...@apache.org on 2017/02/16 17:39:18 UTC, 0 replies.
- flink git commit: [FLINK-5751] [docs] Add link check script - posted by uc...@apache.org on 2017/02/17 12:47:03 UTC, 0 replies.
- flink git commit: [FLINK-5616] [tests] Harden YarnIntraNonHaMasterServicesTest.testClosingReportsToLeader - posted by tr...@apache.org on 2017/02/17 12:53:19 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5825] [webui] Fix image loading in YARN - posted by uc...@apache.org on 2017/02/17 16:12:27 UTC, 1 replies.
- [2/3] flink git commit: [FLINK-5825] [webui] Rebuild web frontend - posted by uc...@apache.org on 2017/02/17 16:12:28 UTC, 1 replies.
- [3/3] flink git commit: [FLINK-5825] [webui] Rebuild web frontend - posted by uc...@apache.org on 2017/02/17 16:12:29 UTC, 1 replies.
- [1/8] flink git commit: [FLINK-5237] Consolidate and harmonize Window Translation Tests - posted by al...@apache.org on 2017/02/17 16:24:11 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-5237] Consolidate and harmonize Window Translation Tests - posted by al...@apache.org on 2017/02/17 16:24:12 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-4997] Add doc for ProcessWindowFunction - posted by al...@apache.org on 2017/02/17 16:24:13 UTC, 0 replies.
- [4/8] flink git commit: [hotfix] Fix trailing whitespace in WindowedStream.java - posted by al...@apache.org on 2017/02/17 16:24:14 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-4997] [streaming] Introduce ProcessWindowFunction - posted by al...@apache.org on 2017/02/17 16:24:15 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-4997] [streaming] Introduce ProcessWindowFunction - posted by al...@apache.org on 2017/02/17 16:24:16 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-4997] Add ProcessWindowFunction support for .aggregate() - posted by al...@apache.org on 2017/02/17 16:24:17 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-4997] [streaming] Add ProcessWindowFunction to Scala API - posted by al...@apache.org on 2017/02/17 16:24:18 UTC, 0 replies.
- flink git commit: [FLINK-5751] [docs] Fix tab in check_links script - posted by uc...@apache.org on 2017/02/17 17:08:46 UTC, 0 replies.
- flink git commit: [FLINK-5837][docs] improving readability of the queryable state docs - posted by uc...@apache.org on 2017/02/18 16:54:04 UTC, 1 replies.
- [01/19] flink git commit: [FLINK-5817] [tests] Use TemporaryFold to create temp files and folds for test - posted by se...@apache.org on 2017/02/20 00:55:15 UTC, 0 replies.
- [02/19] flink git commit: [FLINK-5522] [storm compatibility] Move Storm LocalCluster based test to a separate class - posted by se...@apache.org on 2017/02/20 00:55:16 UTC, 0 replies.
- [03/19] flink git commit: [FLINK-5497] [tests] Remove duplicated tests for hash tables - posted by se...@apache.org on 2017/02/20 00:55:17 UTC, 0 replies.
- [04/19] flink git commit: [FLINK-5129] [distributed runtime] BlobCache to directly accesses Blobs from distrinbuted file system if possible - posted by se...@apache.org on 2017/02/20 00:55:18 UTC, 0 replies.
- [05/19] flink git commit: [hotfix] [docs] Updated DC/OS setup instructions. - posted by se...@apache.org on 2017/02/20 00:55:19 UTC, 0 replies.
- [06/19] flink git commit: [FLINK-5828] [distributed runtime] Fix initialization of Blob storage directories - posted by se...@apache.org on 2017/02/20 00:55:20 UTC, 0 replies.
- [07/19] flink git commit: [hotfix] [core] Add missing @PublicEvolving annotations to classes in flink-core. - posted by se...@apache.org on 2017/02/20 00:55:21 UTC, 0 replies.
- [08/19] flink git commit: [FLINK-5739] [client] Fix NullPointerException in CliFrontend - posted by se...@apache.org on 2017/02/20 00:55:22 UTC, 0 replies.
- [09/19] flink git commit: [FLINK-5817] [test] (followup) Fix temporary folder and temp file path generation - posted by se...@apache.org on 2017/02/20 00:55:23 UTC, 0 replies.
- [10/19] flink git commit: [FLINK-4813] [test-utils] Make the hadoop-minikdc dependency optional - posted by se...@apache.org on 2017/02/20 00:55:24 UTC, 0 replies.
- [11/19] flink git commit: [FLINK-5669] [contrib] Change DataStreamUtils to use the loopback address (127.0.0.1) with local environments. - posted by se...@apache.org on 2017/02/20 00:55:25 UTC, 0 replies.
- [12/19] flink git commit: [FLINK-5640] [build] Configure the explicit Unit Test file suffix - posted by se...@apache.org on 2017/02/20 00:55:26 UTC, 0 replies.
- [13/19] flink git commit: [FLINK-5277] [tests] Add unit tests for ResultPartition#add() in case of failures - posted by se...@apache.org on 2017/02/20 00:55:27 UTC, 0 replies.
- [14/19] flink git commit: [FLINK-5812] [core] Cleanups in FileSystem (round 1) - posted by se...@apache.org on 2017/02/20 00:55:28 UTC, 0 replies.
- [15/19] flink git commit: [FLINK-5747] [distributed coordination] Eager scheduling allocates slots and deploys tasks in bulk - posted by se...@apache.org on 2017/02/20 00:55:29 UTC, 0 replies.
- [16/19] flink git commit: [FLINK-5747] [distributed coordination] Eager scheduling allocates slots and deploys tasks in bulk - posted by se...@apache.org on 2017/02/20 00:55:30 UTC, 0 replies.
- [17/19] flink git commit: [hotfix] [core] Add missing @Internal annotations to classes in flink-core. - posted by se...@apache.org on 2017/02/20 00:55:31 UTC, 0 replies.
- [18/19] flink git commit: [hotfix] [tests] Use random actor names in JobManagerHARecoveryTest to avoid name collisions - posted by se...@apache.org on 2017/02/20 00:55:32 UTC, 0 replies.
- [19/19] flink git commit: [FLINK-5812] [core] Cleanups in FileSystem (round 2) - posted by se...@apache.org on 2017/02/20 00:55:33 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [docs] Updated DC/OS setup instructions. - posted by se...@apache.org on 2017/02/20 01:08:27 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5828] [distributed runtime] Fix initialization of Blob storage directories - posted by se...@apache.org on 2017/02/20 01:08:28 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-5739] [client] Fix NullPointerException in CliFrontend - posted by se...@apache.org on 2017/02/20 11:06:57 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-5669] [contrib] Change DataStreamUtils to use the loopback address (127.0.0.1) with local environments. - posted by se...@apache.org on 2017/02/20 11:06:58 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-5640] [build] Configure the explicit Unit Test file suffix - posted by se...@apache.org on 2017/02/20 11:06:59 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-5817] [test] (followup) Fix temporary folder and temp file path generation - posted by se...@apache.org on 2017/02/20 11:07:00 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-5817] [tests] Use TemporaryFold to create temp files and folds for test - posted by se...@apache.org on 2017/02/20 11:07:01 UTC, 0 replies.
- [6/9] flink git commit: [hotfix] [tests] Use random actor names in JobManagerHARecoveryTest to avoid name collisions - posted by se...@apache.org on 2017/02/20 11:07:02 UTC, 0 replies.
- [7/9] flink git commit: [hotfix] [core] Add missing @PublicEvolving annotations to classes in flink-core. - posted by se...@apache.org on 2017/02/20 11:07:03 UTC, 0 replies.
- [8/9] flink git commit: [hotfix] [core] Add missing @Internal annotations to classes in flink-core. - posted by se...@apache.org on 2017/02/20 11:07:04 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-4813] [test-utils] Make the hadoop-minikdc dependency optional - posted by se...@apache.org on 2017/02/20 11:07:05 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5749] [build] Unset HADOOP_HOME and HADOOP_CONF_DIR variables for tests - posted by se...@apache.org on 2017/02/20 13:28:30 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-5723] [web frontend] Use 'Used' instead of 'Initial' in TaskManager memory consumption view - posted by se...@apache.org on 2017/02/20 13:28:31 UTC, 1 replies.
- flink git commit: [FLINK-5842] [docs] Fix ES5 "since" version - posted by uc...@apache.org on 2017/02/20 14:36:03 UTC, 0 replies.
- flink git commit: [FLINK-5571] [table] add open and close methods for UserDefinedFunction - posted by tw...@apache.org on 2017/02/20 14:39:26 UTC, 0 replies.
- [1/4] flink-web git commit: Use global variable on links to documentation - posted by uc...@apache.org on 2017/02/20 14:44:42 UTC, 0 replies.
- [2/4] flink-web git commit: Update Connectors section on 'Ecosystem' page to point to 1.2 docs - posted by uc...@apache.org on 2017/02/20 14:44:43 UTC, 0 replies.
- [3/4] flink-web git commit: Update links in 'Introduction' page and add 1.2.0 to All Releases on 'Downloads' page - posted by uc...@apache.org on 2017/02/20 14:44:44 UTC, 0 replies.
- [4/4] flink-web git commit: Rebuild website - posted by uc...@apache.org on 2017/02/20 14:44:45 UTC, 0 replies.
- [1/2] flink-web git commit: Update slides.md - posted by uc...@apache.org on 2017/02/20 14:46:32 UTC, 0 replies.
- [2/2] flink-web git commit: Rebuild website - posted by uc...@apache.org on 2017/02/20 14:46:33 UTC, 2 replies.
- [1/2] flink-web git commit: get the poweredby page to render properly - posted by uc...@apache.org on 2017/02/20 14:58:10 UTC, 0 replies.
- [1/2] flink-web git commit: [FLINK-3457] Link to Apache Flink meetups from the 'Community' section of the website - posted by uc...@apache.org on 2017/02/20 15:00:37 UTC, 0 replies.
- flink git commit: [hotfix] [doc] Document that the `AsyncCollector` can only be completed once - posted by tr...@apache.org on 2017/02/20 15:12:25 UTC, 1 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #382 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/21 04:25:22 UTC, 0 replies.
- [1/6] flink git commit: [hotfix] [core] Deprecate unused and redundant config parameter 'flink.base.dir.path' - posted by se...@apache.org on 2017/02/21 11:09:11 UTC, 0 replies.
- [2/6] flink git commit: [hotfix] [jobmanager] Minor code cleanups in JobGraph and CheckpointCoordinator - posted by se...@apache.org on 2017/02/21 11:09:12 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-5074] [runtime] Add a ZooKeeper-based RunningJobRegistry - posted by se...@apache.org on 2017/02/21 11:09:13 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-4770] [core] Introduce 'CoreOptions' - posted by se...@apache.org on 2017/02/21 11:09:14 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-5821] [state backends] Rename the 'StateBackend' to 'StateBinder' and create root StateBackend interface - posted by se...@apache.org on 2017/02/21 11:09:15 UTC, 0 replies.
- [6/6] flink git commit: [hotfix] [tests] Fix minor JavaDoc link errors - posted by se...@apache.org on 2017/02/21 11:09:16 UTC, 0 replies.
- flink git commit: [FLINK-3163] [scripts] Configure Flink for NUMA systems - posted by gr...@apache.org on 2017/02/21 16:54:51 UTC, 0 replies.
- flink git commit: [FLINK-5795] [table] Improve UDF&UDTF to support constructor with parameter - posted by ja...@apache.org on 2017/02/22 02:03:39 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-5877] [docs] Fix Async I/O Scala snippet - posted by se...@apache.org on 2017/02/22 11:51:29 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-5763] [checkpoints] Acknowledge with explicit ID and CheckpointMetrics - posted by se...@apache.org on 2017/02/22 11:51:30 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-5763] [checkpoints] Add isSavepoint() to CheckpointProperties - posted by se...@apache.org on 2017/02/22 11:51:31 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-5763] [checkpoints] Move CheckpointMetrics out of CheckpointMetaData - posted by se...@apache.org on 2017/02/22 11:51:32 UTC, 0 replies.
- flink git commit: [FLINK-5876] [docs] Mention Scala extensions in queryable state docs - posted by uc...@apache.org on 2017/02/22 12:45:38 UTC, 1 replies.
- flink git commit: [FLINK-5836] [flip6] Fix race condition between offer slot and submit task - posted by tr...@apache.org on 2017/02/22 14:45:49 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5701] [kafka] FlinkKafkaProducer should check asyncException on checkpoints - posted by tz...@apache.org on 2017/02/22 17:20:48 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5716] [streaming] Make StreamSourceContexts aware of source idleness - posted by tz...@apache.org on 2017/02/22 17:20:49 UTC, 0 replies.
- flink git commit: [FLINK-5701] [kafka] FlinkKafkaProducer should check asyncException on checkpoints - posted by tz...@apache.org on 2017/02/22 17:22:38 UTC, 0 replies.
- flink git commit: FLINK-5731 Spilt up tests into three disjoint groups - posted by rm...@apache.org on 2017/02/22 19:30:42 UTC, 0 replies.
- flink git commit: [FLINK-5894] [docs] Fix misleading HA docs - posted by uc...@apache.org on 2017/02/23 12:49:33 UTC, 1 replies.
- flink git commit: [FLINK-5716] Add StreamStatusMaintainer mock in StreamSourceOperatorTest - posted by al...@apache.org on 2017/02/23 13:22:58 UTC, 0 replies.
- flink git commit: [hotfix] [kafka] Indent Kafka010FetcherTest with tabs instead of spaces - posted by tz...@apache.org on 2017/02/23 15:28:51 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4856] Add MapState for keyed state - posted by al...@apache.org on 2017/02/23 16:06:27 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4856] Add MapState for keyed state - posted by al...@apache.org on 2017/02/23 16:06:28 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5895] [runtime] Decrease logging aggressiveness of FileSystemSafetyNet - posted by se...@apache.org on 2017/02/23 16:42:35 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5877] [docs] Fix Async I/O Scala snippet - posted by se...@apache.org on 2017/02/23 16:42:36 UTC, 0 replies.
- flink git commit: [FLINK-5885] [docs] Fix Cassandra Scala snippet - posted by se...@apache.org on 2017/02/23 16:45:59 UTC, 0 replies.
- [1/7] flink git commit: [hotfix] [docs] Fix JavaDoc errors in 'flink-streaming-java' - posted by se...@apache.org on 2017/02/23 19:10:29 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-5763] [checkpoints] Followup on adding CheckpointOptions - posted by se...@apache.org on 2017/02/23 19:10:30 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-5763] [checkpoints] Add CheckpointOptions - posted by se...@apache.org on 2017/02/23 19:10:31 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-5763] [checkpoints] Add CheckpointOptions - posted by se...@apache.org on 2017/02/23 19:10:32 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-5763] [checkpoints] Add CheckpointOptions - posted by se...@apache.org on 2017/02/23 19:10:33 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-5887] [checkpointing] Make CheckpointBarrier type immutable. - posted by se...@apache.org on 2017/02/23 19:10:34 UTC, 0 replies.
- [7/7] flink git commit: [hotfix] [checkpoints] Remove equals()/hashCode() from CompletedCheckpoint as semantic equality is not well defined. - posted by se...@apache.org on 2017/02/23 19:10:35 UTC, 0 replies.
- flink git commit: [FLINK-5767] [table] Add interface for user-defined aggregate functions and built-in aggregate functions. - posted by fh...@apache.org on 2017/02/24 09:09:24 UTC, 0 replies.
- flink git commit: [FLINK-5845] [cep] Unify keyed and non-keyed operators. - posted by kk...@apache.org on 2017/02/24 10:12:35 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-5885] [docs] Fix Cassandra Scala snippet - posted by se...@apache.org on 2017/02/24 11:28:29 UTC, 0 replies.
- [2/4] flink git commit: [hotfix] [tests] Remove sysout logging in KvStateLocationTest - posted by se...@apache.org on 2017/02/24 11:28:30 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-5854] [core] Add base Flink Exception classes - posted by se...@apache.org on 2017/02/24 11:28:31 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-5895] [runtime] Decrease logging aggressiveness of FileSystemSafetyNet - posted by se...@apache.org on 2017/02/24 11:28:32 UTC, 0 replies.
- flink git commit: [FLINK-5743] Mark WindowedStream.aggregate() methods as PublicEvolving - posted by al...@apache.org on 2017/02/24 13:08:45 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5799] [rpc] Let RpcService.scheduleRunnable return a ScheduledFuture - posted by tr...@apache.org on 2017/02/24 13:49:22 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5798] [rpc] Let the RpcService provide a ScheduledExecutorService - posted by tr...@apache.org on 2017/02/24 13:49:23 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5487] [elasticsearch] At-least-once Elasticsearch Sink - posted by tz...@apache.org on 2017/02/24 15:05:22 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5353] [elasticsearch] User-provided failure handler for ElasticsearchSink - posted by tz...@apache.org on 2017/02/24 15:05:23 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5122] [elasticsearch] Retry temporary Elasticsearch request errors. - posted by tz...@apache.org on 2017/02/24 15:05:24 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5899] [table] Fix translation of batch event-time tumbling windows with non-partial aggregation functions. - posted by fh...@apache.org on 2017/02/24 16:31:46 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5710] [table] Add proctime() function to indicate processing time in Stream SQL. - posted by fh...@apache.org on 2017/02/24 16:31:47 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] [core] Changing PublicEvolving anntoation of Archiveable to Internal. - posted by fh...@apache.org on 2017/02/24 16:31:48 UTC, 0 replies.
- flink git commit: [FLINK-5896][docs] improve readability of event time docs - posted by uc...@apache.org on 2017/02/26 17:22:22 UTC, 1 replies.
- flink git commit: [FLINK-5772] [elasticsearch] Allow Elasticsearch 1.x tests to rerun on failure - posted by tz...@apache.org on 2017/02/27 10:34:03 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5849] [kafka] Move FlinkKafkaConsumer start offset determination to open() - posted by tz...@apache.org on 2017/02/27 17:49:24 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5849] [kafka] Move FlinkKafkaConsumer start offset determination to open() - posted by tz...@apache.org on 2017/02/27 17:49:25 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] [kafka] Cleanup star / unused imports in all Flink Kafka tests - posted by tz...@apache.org on 2017/02/27 17:49:26 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-3475] [table] Add support for DISTINCT aggregates in SQL queries. - posted by fh...@apache.org on 2017/02/27 23:35:22 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5907] [java] Fix handling of trailing empty fields in CsvInputFormat. - posted by fh...@apache.org on 2017/02/27 23:35:23 UTC, 0 replies.
- flink git commit: [FLINK-5907] [java] Fix handling of trailing empty fields in CsvInputFormat. - posted by fh...@apache.org on 2017/02/27 23:50:41 UTC, 0 replies.
- flink git commit: [FLINK-5871] [cep] Enforce uniqueness of pattern names in CEP. - posted by kk...@apache.org on 2017/02/28 10:26:47 UTC, 0 replies.
- flink git commit: [FLINK-3903] [docs] Add Homebrew installation docs - posted by uc...@apache.org on 2017/02/28 10:28:04 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-5157] [streaming] Introduce ProcessAllWindowFunction - posted by al...@apache.org on 2017/02/28 13:13:42 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5157] [streaming] Introduce ProcessAllWindowFunction - posted by al...@apache.org on 2017/02/28 13:13:43 UTC, 0 replies.
- flink git commit: [FLINK-5420] [cep] Make the CEP operators rescalable - posted by kk...@apache.org on 2017/02/28 18:06:03 UTC, 0 replies.
- [01/11] flink git commit: [FLINK-5501] [runtime] Extend RunningJobRegistry to job status created/running/done - posted by se...@apache.org on 2017/02/28 18:36:44 UTC, 0 replies.
- [02/11] flink git commit: [hotfix] [runtime] Reduce the gazillion deprecation warnings from the backwards-compatible savepoint path - posted by se...@apache.org on 2017/02/28 18:36:45 UTC, 0 replies.
- [03/11] flink git commit: [FLINK-5133] [core] Add new setResource API for DataStream and DataSet - posted by se...@apache.org on 2017/02/28 18:36:46 UTC, 0 replies.
- [04/11] flink git commit: [FLINK-5929] [tests] Fix SavepointITCase instability - posted by se...@apache.org on 2017/02/28 18:36:47 UTC, 0 replies.
- [05/11] flink git commit: [FLINK-5501] [runtime] Followups and improvements to RunningJobsRegistry - posted by se...@apache.org on 2017/02/28 18:36:48 UTC, 0 replies.
- [06/11] flink git commit: [FLINK-5897] [checkpoints] Make checkpoint externalization not depend strictly on FileSystems - posted by se...@apache.org on 2017/02/28 18:36:49 UTC, 0 replies.
- [07/11] flink git commit: [FLINK-5133] [core] Followups for ResourceSpec on DataSet / DataStream API - posted by se...@apache.org on 2017/02/28 18:36:50 UTC, 0 replies.
- [08/11] flink git commit: [FLINK-5501] [runtime] Make config key for ZooKeeper path for running registry consistent with other keys - posted by se...@apache.org on 2017/02/28 18:36:51 UTC, 0 replies.
- [09/11] flink git commit: [FLINK-5928] [checkpoints] Add CheckpointCoordinatorExternalizedCheckpointsTest - posted by se...@apache.org on 2017/02/28 18:36:52 UTC, 0 replies.
- [10/11] flink git commit: [FLINK-5822] [state backends] Make JobManager / Checkpoint Coordinator aware of the root state backend - posted by se...@apache.org on 2017/02/28 18:36:53 UTC, 0 replies.
- [11/11] flink git commit: [hotfix] [tests] Fix test instability in SavepointITCase - posted by se...@apache.org on 2017/02/28 18:36:54 UTC, 0 replies.
- flink git commit: [FLINK-5921] [table] Add custom data types for rowtime and proctime. - posted by fh...@apache.org on 2017/02/28 23:43:06 UTC, 0 replies.