commits@flink.apache.org, 2016-09

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

- buildbot failure in on flink-docs-release-1.1 - posted by bu...@apache.org on 2016/09/01 01:01:58 UTC, 2 replies.
- buildbot failure in on flink-docs-release-0.10 - posted by bu...@apache.org on 2016/09/01 03:01:48 UTC, 9 replies.
- buildbot failure in on flink-docs-release-0.9 - posted by bu...@apache.org on 2016/09/01 04:01:59 UTC, 3 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #206 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/09/01 04:26:39 UTC, 0 replies.
- flink git commit: [hotfix] Fixes unstable ContinuousFileMonitoringTest. - posted by al...@apache.org on 2016/09/01 08:10:31 UTC, 0 replies.
- flink git commit: [hotfix] [test-stability] Properly fail if ZooKeeperTestEnvironment cannot delete ZNodes - posted by tr...@apache.org on 2016/09/01 09:48:57 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/01 10:14:50 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/01 10:14:51 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/01 10:14:52 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/01 10:14:53 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/01 10:14:54 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/01 10:14:55 UTC, 0 replies.
- flink git commit: [FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as protected - posted by tr...@apache.org on 2016/09/01 10:30:11 UTC, 0 replies.
- flink git commit: [hotfix] [tests] Fix CassandraConnectorITCase on Java 7 profiles - posted by se...@apache.org on 2016/09/01 11:41:29 UTC, 0 replies.
- buildbot failure in on flink-docs-master - posted by bu...@apache.org on 2016/09/02 00:02:18 UTC, 1 replies.
- buildbot success in on flink-docs-release-1.1 - posted by bu...@apache.org on 2016/09/02 01:24:16 UTC, 1 replies.
- buildbot success in on flink-docs-release-0.10 - posted by bu...@apache.org on 2016/09/02 03:14:27 UTC, 8 replies.
- Build failed in Jenkins: flink-snapshot-deployment #207 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/09/02 07:24:11 UTC, 0 replies.
- flink git commit: [FLINK-4570] revert Scalastyle version to 0.5.0 - posted by mx...@apache.org on 2016/09/02 12:56:53 UTC, 0 replies.
- flink git commit: [hotfix] Add self rpc gateway registration to TestingSerialRpcService - posted by tr...@apache.org on 2016/09/02 12:59:57 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4455] [FLINK-4424] [networkenv] Make NetworkEnvironment independent of ActorGateway and JobManager association - posted by tr...@apache.org on 2016/09/02 13:05:40 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4455] [FLINK-4424] [networkenv] Make NetworkEnvironment independent of ActorGateway and JobManager association - posted by tr...@apache.org on 2016/09/02 13:05:41 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #208 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/09/02 13:41:36 UTC, 0 replies.
- flink git commit: [FLINK-3497] [table] Add IS (NOT) TRUE/IS (NOT) FALSE functions - posted by tw...@apache.org on 2016/09/02 14:31:33 UTC, 0 replies.
- flink git commit: [FLINK-4570] disable Scalastyle for flink-mesos Utils file - posted by mx...@apache.org on 2016/09/02 15:15:07 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-4525] [core] (followup) Remove remaining redundant code for pre-defined strictly local assignments. - posted by se...@apache.org on 2016/09/02 15:36:05 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-4490] [distributed coordination] (part 2) Make slots independent of 'Instance'. - posted by se...@apache.org on 2016/09/02 15:36:06 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-4490] [distributed coordination] (part 2) Make slots independent of 'Instance'. - posted by se...@apache.org on 2016/09/02 15:36:07 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-4567] [runtime] Enhance SerializedThrowable to properly mimic Exception causes - posted by se...@apache.org on 2016/09/02 15:36:08 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-4566] [network runtime] Properly preserve exception causes for ProducerFailedException - posted by se...@apache.org on 2016/09/02 15:36:09 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-4490] [distributed coordination] (part 3) Rename methods on 'Instance' to have more intuitive names - posted by se...@apache.org on 2016/09/02 15:36:10 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-4490] [distributed coordination] (part 1) Change InstanceConnectionInfo to TaskManagerLocation - posted by se...@apache.org on 2016/09/02 15:36:11 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-4490] [distributed coordination] (part 1) Change InstanceConnectionInfo to TaskManagerLocation - posted by se...@apache.org on 2016/09/02 15:36:12 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4567] [runtime] Enhance SerializedThrowable to properly mimic Exception causes - posted by se...@apache.org on 2016/09/02 15:42:19 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4566] [network runtime] Properly preserve exception causes for ProducerFailedException - posted by se...@apache.org on 2016/09/02 15:42:20 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #209 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/09/02 15:42:44 UTC, 0 replies.
- flink git commit: [FLINK-3580] [table] Add current time point functions - posted by tw...@apache.org on 2016/09/02 15:45:14 UTC, 0 replies.
- flink git commit: [FLINK-4570] remove conflicting Unicode character - posted by mx...@apache.org on 2016/09/02 16:06:00 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #210 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/09/02 16:56:44 UTC, 0 replies.
- buildbot success in on flink-docs-release-0.9 - posted by bu...@apache.org on 2016/09/03 04:18:02 UTC, 2 replies.
- buildbot success in on flink-docs-master - posted by bu...@apache.org on 2016/09/04 00:26:33 UTC, 0 replies.
- svn commit: r15153 - in /release/flink: flink-0.10.0/ flink-0.10.1/ flink-1.0.0/ flink-1.0.1/ flink-1.0.2/ flink-1.1.0/ flink-1.1.2/ - posted by rm...@apache.org on 2016/09/04 08:48:31 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4459] [distributed runtime] Introduce SlotProvider for Scheduler - posted by se...@apache.org on 2016/09/04 21:10:48 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4459] [distributed runtime] Introduce SlotProvider for Scheduler - posted by se...@apache.org on 2016/09/04 21:10:49 UTC, 0 replies.
- flink git commit: [FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not reachable - posted by tr...@apache.org on 2016/09/05 09:15:50 UTC, 0 replies.
- flink-web git commit: Added Release 1.1.2 announcement - posted by rm...@apache.org on 2016/09/05 09:57:55 UTC, 0 replies.
- flink git commit: [hotfix] Delete leftover (superseded) StreamTaskAsyncCheckpointTest - posted by al...@apache.org on 2016/09/05 10:27:06 UTC, 0 replies.
- flink git commit: [FLINK-4073] fix stability of TaskManagerFailure test - posted by mx...@apache.org on 2016/09/05 14:21:53 UTC, 0 replies.
- flink git commit: [FLINK-4073] remove unstable testing code in TaskManagerFailure test - posted by mx...@apache.org on 2016/09/06 10:56:02 UTC, 0 replies.
- flink git commit: [FLINK-4559][kinesis-connector] Fix AWSUtil.getCredentialsProvider() to not return null - posted by tz...@apache.org on 2016/09/06 12:16:05 UTC, 0 replies.
- flink git commit: [FLINK-4265] [dataset api] Add a NoOpOperator - posted by gr...@apache.org on 2016/09/06 14:16:39 UTC, 0 replies.
- [1/2] flink-web git commit: [FLINK-4585] Fix broken links in index.md - posted by rm...@apache.org on 2016/09/07 20:27:59 UTC, 0 replies.
- [2/2] flink-web git commit: Rebuild site - posted by rm...@apache.org on 2016/09/07 20:28:00 UTC, 0 replies.
- [flink] Git Push Summary - posted by rm...@apache.org on 2016/09/08 06:09:53 UTC, 0 replies.
- [1/2] flink-web git commit: add guideline about merge commits - posted by mx...@apache.org on 2016/09/08 08:54:01 UTC, 0 replies.
- [2/2] flink-web git commit: update website - posted by mx...@apache.org on 2016/09/08 08:54:02 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokensFor() - posted by ch...@apache.org on 2016/09/08 10:05:28 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4595] Close FileOutputStream in ParameterTool - posted by ch...@apache.org on 2016/09/08 10:05:29 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster - posted by tr...@apache.org on 2016/09/08 15:17:46 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster - posted by tr...@apache.org on 2016/09/08 15:17:47 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster - posted by tr...@apache.org on 2016/09/08 15:17:48 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster - posted by tr...@apache.org on 2016/09/08 15:17:49 UTC, 0 replies.
- flink git commit: [FLINK-4456] Replace Akka specific types by interfaces in Task - posted by tr...@apache.org on 2016/09/08 15:23:59 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-4566] [network runtime] Properly preserve exception causes for ProducerFailedException [Forced Update!] - posted by tr...@apache.org on 2016/09/08 15:28:23 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-4567] [runtime] Enhance SerializedThrowable to properly mimic Exception causes - posted by tr...@apache.org on 2016/09/08 15:28:24 UTC, 0 replies.
- [03/50] [abbrv] flink git commit: [FLINK-3580] [table] Add current time point functions - posted by tr...@apache.org on 2016/09/08 15:28:25 UTC, 0 replies.
- [04/50] [abbrv] flink git commit: [FLINK-4570] remove conflicting Unicode character - posted by tr...@apache.org on 2016/09/08 15:28:26 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [FLINK-4459] [distributed runtime] Introduce SlotProvider for Scheduler - posted by tr...@apache.org on 2016/09/08 15:28:27 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-4459] [distributed runtime] Introduce SlotProvider for Scheduler - posted by tr...@apache.org on 2016/09/08 15:28:28 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [hotfix] Delete leftover (superseded) StreamTaskAsyncCheckpointTest - posted by tr...@apache.org on 2016/09/08 15:28:29 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [FLINK-4073] fix stability of TaskManagerFailure test - posted by tr...@apache.org on 2016/09/08 15:28:30 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [FLINK-4073] remove unstable testing code in TaskManagerFailure test - posted by tr...@apache.org on 2016/09/08 15:28:31 UTC, 0 replies.
- [10/50] [abbrv] flink git commit: [FLINK-4559][kinesis-connector] Fix AWSUtil.getCredentialsProvider() to not return null - posted by tr...@apache.org on 2016/09/08 15:28:32 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [FLINK-4265] [dataset api] Add a NoOpOperator - posted by tr...@apache.org on 2016/09/08 15:28:33 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokensFor() - posted by tr...@apache.org on 2016/09/08 15:28:34 UTC, 0 replies.
- [13/50] [abbrv] flink git commit: [FLINK-4595] Close FileOutputStream in ParameterTool - posted by tr...@apache.org on 2016/09/08 15:28:35 UTC, 0 replies.
- [14/50] [abbrv] flink git commit: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster - posted by tr...@apache.org on 2016/09/08 15:28:36 UTC, 0 replies.
- [15/50] [abbrv] flink git commit: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster - posted by tr...@apache.org on 2016/09/08 15:28:37 UTC, 0 replies.
- [16/50] [abbrv] flink git commit: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster - posted by tr...@apache.org on 2016/09/08 15:28:38 UTC, 0 replies.
- [17/50] [abbrv] flink git commit: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster - posted by tr...@apache.org on 2016/09/08 15:28:39 UTC, 0 replies.
- [18/50] [abbrv] flink git commit: [FLINK-4456] Replace Akka specific types by interfaces in Task - posted by tr...@apache.org on 2016/09/08 15:28:40 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-4368] [distributed runtime] Eagerly initialize the RPC endpoint members - posted by tr...@apache.org on 2016/09/08 15:28:41 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [FLINK-4346] [rpc] Add new RPC abstraction - posted by tr...@apache.org on 2016/09/08 15:28:42 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-4346] [rpc] Add new RPC abstraction - posted by tr...@apache.org on 2016/09/08 15:28:43 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEndpoint - posted by tr...@apache.org on 2016/09/08 15:28:44 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies - posted by tr...@apache.org on 2016/09/08 15:28:45 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies - posted by tr...@apache.org on 2016/09/08 15:28:46 UTC, 0 replies.
- [25/50] [abbrv] flink git commit: [FLINK-4386] [rpc] Add a utility to verify calls happen in the Rpc Endpoint's main thread - posted by tr...@apache.org on 2016/09/08 15:28:47 UTC, 0 replies.
- [26/50] [abbrv] flink git commit: [FLINK-4383] [rpc] Eagerly serialize remote rpc invocation messages - posted by tr...@apache.org on 2016/09/08 15:28:48 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [FLINK-4373] [cluster management] Introduce SlotID, AllocationID, ResourceProfile - posted by tr...@apache.org on 2016/09/08 15:28:49 UTC, 0 replies.
- [28/50] [abbrv] flink git commit: [FLINK-4392] [rpc] Make RPC Service thread-safe - posted by tr...@apache.org on 2016/09/08 15:28:50 UTC, 0 replies.
- [29/50] [abbrv] flink git commit: [FLINK-4403] [rpc] Use relative classloader for proxies, rather than system class loader. - posted by tr...@apache.org on 2016/09/08 15:28:51 UTC, 0 replies.
- [30/50] [abbrv] flink git commit: [FLINK-4414] [cluster] Add getAddress method to RpcGateway - posted by tr...@apache.org on 2016/09/08 15:28:52 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [FLINK-4382] [rpc] Buffer rpc calls until the RpcEndpoint has been started - posted by tr...@apache.org on 2016/09/08 15:28:53 UTC, 0 replies.
- [32/50] [abbrv] flink git commit: [FLINK-4355] [cluster management] Implement TaskManager side of registration at ResourceManager. - posted by tr...@apache.org on 2016/09/08 15:28:54 UTC, 0 replies.
- [33/50] [abbrv] flink git commit: [FLINK-4434] [rpc] Add a testing RPC service. - posted by tr...@apache.org on 2016/09/08 15:28:55 UTC, 0 replies.
- [34/50] [abbrv] flink git commit: [hotfix] Remove RecoveryMode from JobMaster - posted by tr...@apache.org on 2016/09/08 15:28:56 UTC, 0 replies.
- [35/50] [abbrv] flink git commit: [FLINK-4355] [cluster management] Add tests for the TaskManager -> ResourceManager registration. - posted by tr...@apache.org on 2016/09/08 15:28:57 UTC, 0 replies.
- [36/50] [abbrv] flink git commit: [FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters - posted by tr...@apache.org on 2016/09/08 15:28:58 UTC, 0 replies.
- [37/50] [abbrv] flink git commit: [FLINK-4443] [rpc] Add support for rpc gateway and rpc endpoint inheritance - posted by tr...@apache.org on 2016/09/08 15:28:59 UTC, 0 replies.
- [38/50] [abbrv] flink git commit: [FLINK-4363] Implement TaskManager basic startup of all components in java - posted by tr...@apache.org on 2016/09/08 15:29:00 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [FLINK-4347][cluster management] Implement SlotManager core - posted by tr...@apache.org on 2016/09/08 15:29:01 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [FLINK-4516] leader election of resourcemanager - posted by tr...@apache.org on 2016/09/08 15:29:02 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [hotfix] [clustermgnt] Set pending registration properly in TaskExecutorToResourceManagerConnection - posted by tr...@apache.org on 2016/09/08 15:29:03 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not reachable - posted by tr...@apache.org on 2016/09/08 15:29:04 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/08 15:29:05 UTC, 0 replies.
- [44/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/08 15:29:06 UTC, 0 replies.
- [45/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/08 15:29:07 UTC, 0 replies.
- [46/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/08 15:29:08 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/08 15:29:09 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/08 15:29:10 UTC, 0 replies.
- [49/50] [abbrv] flink git commit: [hotfix] Add self rpc gateway registration to TestingSerialRpcService - posted by tr...@apache.org on 2016/09/08 15:29:11 UTC, 0 replies.
- [50/50] [abbrv] flink git commit: [FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as protected - posted by tr...@apache.org on 2016/09/08 15:29:12 UTC, 0 replies.
- flink git commit: [hotfix] [taskmanager] Fixes TaskManager component creation at startup - posted by tr...@apache.org on 2016/09/08 16:49:27 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4522] [docs] Gelly link broken in homepage - posted by gr...@apache.org on 2016/09/08 21:12:45 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4257] [gelly] Handle delegating algorithm change of class - posted by gr...@apache.org on 2016/09/08 21:12:46 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4571] [gelly] Configurable little parallelism in Gelly drivers - posted by gr...@apache.org on 2016/09/08 21:12:47 UTC, 0 replies.
- flink git commit: [FLINK-3497] [table] Add POSITION/OVERLAY functions - posted by tw...@apache.org on 2016/09/09 10:05:30 UTC, 0 replies.
- flink git commit: [FLINK-4601] [java] Check for empty string properly - posted by tw...@apache.org on 2016/09/09 10:17:53 UTC, 0 replies.
- flink git commit: [FLINK-4592] [table] Fix flaky test ScalarFunctionsTest.testCurrentTimePoint - posted by tw...@apache.org on 2016/09/09 11:20:51 UTC, 0 replies.
- flink git commit: [FLINK-3580] [table] Add QUARTER function - posted by tw...@apache.org on 2016/09/09 15:24:08 UTC, 0 replies.
- flink git commit: [FLINK-3497] [table] Add SQRT function - posted by tw...@apache.org on 2016/09/15 10:05:56 UTC, 0 replies.
- flink git commit: [FLINK-4599] [table] Add 'explain()' also to StreamTableEnvironment - posted by tw...@apache.org on 2016/09/15 15:51:05 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4389] Expose metrics to WebFrontend - posted by ch...@apache.org on 2016/09/15 17:18:38 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4389] Expose metrics to WebFrontend - posted by ch...@apache.org on 2016/09/15 17:18:39 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4389] Expose metrics to WebFrontend - posted by ch...@apache.org on 2016/09/15 17:18:40 UTC, 0 replies.
- [4/4] flink git commit: [hotfix] [metrics] Add missing @Internal annotations - posted by ch...@apache.org on 2016/09/15 17:18:41 UTC, 0 replies.
- flink git commit: [FLINK-4589] [DataStream API] Fix Merging of Covering Window in MergingWindowSet - posted by se...@apache.org on 2016/09/16 09:49:29 UTC, 1 replies.
- [1/4] flink git commit: [FLINK-4626] Add missing break in MEtricStore#add() - posted by ch...@apache.org on 2016/09/16 10:35:24 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4612] Close FileWriter using try with resources - posted by ch...@apache.org on 2016/09/16 10:35:25 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4608] Use short-circuit AND in Max/Min AggregationFunction - posted by ch...@apache.org on 2016/09/16 10:35:26 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4607] Close FileInputStream in ParameterTool and other - posted by ch...@apache.org on 2016/09/16 10:35:27 UTC, 0 replies.
- flink git commit: [FLINK-4622] Include 'savepoint' in the CLI help message - posted by ch...@apache.org on 2016/09/16 12:15:53 UTC, 0 replies.
- flink git commit: [FLINK-4081] [core] [table] FieldParsers should support empty strings - posted by tw...@apache.org on 2016/09/19 14:25:16 UTC, 0 replies.
- flink git commit: [FLINK-4625] [core] Add a safety net to forcibly terminate JVM is clean shutdown freezed. - posted by se...@apache.org on 2016/09/19 20:26:10 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by mx...@apache.org on 2016/09/20 08:54:54 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by mx...@apache.org on 2016/09/20 08:54:55 UTC, 0 replies.
- flink git commit: [FLINK-4610] [core] Replace keySet/getValue with entrySet in UdfAnalyzerUtils - posted by se...@apache.org on 2016/09/20 12:05:37 UTC, 0 replies.
- flink git commit: [FLINK-4247] [table] CsvTableSource.getDataSet() expects Java ExecutionEnvironment - posted by tw...@apache.org on 2016/09/20 14:08:10 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4572] [gelly] Convert to negative in LongValueToIntValue - posted by gr...@apache.org on 2016/09/20 14:12:39 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4609] [java-api] Remove redundant check for null in CrossOperator - posted by gr...@apache.org on 2016/09/20 14:12:40 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4594] [core] Validate lower bound in MathUtils.checkedDownCast - posted by gr...@apache.org on 2016/09/20 14:12:41 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4638] [core] Fix exception message for MemorySegment - posted by gr...@apache.org on 2016/09/20 14:12:42 UTC, 0 replies.
- flink git commit: [FLINK-4268] [core] Add a parsers for BigDecimal/BigInteger - posted by tw...@apache.org on 2016/09/20 14:44:52 UTC, 0 replies.
- flink git commit: [FLINK-2662] [dataSet] [optimizer] Fix merging of unions with multiple outputs. - posted by fh...@apache.org on 2016/09/20 19:55:13 UTC, 1 replies.
- [1/5] flink git commit: [FLINK-3929] additional fixes for keytab security - posted by mx...@apache.org on 2016/09/20 20:08:58 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-3929] conditionally skip RollingSinkSecuredITCase - posted by mx...@apache.org on 2016/09/20 20:08:59 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-3929] Added Keytab based Kerberos support to enable secure Flink cluster deployment(addresses HDHS, Kafka and ZK services) - posted by mx...@apache.org on 2016/09/20 20:09:00 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-3929] Added Keytab based Kerberos support to enable secure Flink cluster deployment(addresses HDHS, Kafka and ZK services) - posted by mx...@apache.org on 2016/09/20 20:09:01 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-3929] Added Keytab based Kerberos support to enable secure Flink cluster deployment(addresses HDHS, Kafka and ZK services) - posted by mx...@apache.org on 2016/09/20 20:09:02 UTC, 0 replies.
- flink git commit: [FLINK-4361] Introduce Flink's own future abstraction - posted by tr...@apache.org on 2016/09/21 08:09:53 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-4610] [core] Replace keySet/getValue with entrySet in UdfAnalyzerUtils [Forced Update!] - posted by tr...@apache.org on 2016/09/21 09:52:34 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-4247] [table] CsvTableSource.getDataSet() expects Java ExecutionEnvironment - posted by tr...@apache.org on 2016/09/21 09:52:35 UTC, 0 replies.
- [03/50] [abbrv] flink git commit: [FLINK-4572] [gelly] Convert to negative in LongValueToIntValue - posted by tr...@apache.org on 2016/09/21 09:52:36 UTC, 0 replies.
- [04/50] [abbrv] flink git commit: [FLINK-4594] [core] Validate lower bound in MathUtils.checkedDownCast - posted by tr...@apache.org on 2016/09/21 09:52:37 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [FLINK-4609] [java-api] Remove redundant check for null in CrossOperator - posted by tr...@apache.org on 2016/09/21 09:52:38 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-4638] [core] Fix exception message for MemorySegment - posted by tr...@apache.org on 2016/09/21 09:52:39 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [FLINK-4268] [core] Add a parsers for BigDecimal/BigInteger - posted by tr...@apache.org on 2016/09/21 09:52:40 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [FLINK-2662] [dataSet] [optimizer] Fix merging of unions with multiple outputs. - posted by tr...@apache.org on 2016/09/21 09:52:41 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [FLINK-3929] conditionally skip RollingSinkSecuredITCase - posted by tr...@apache.org on 2016/09/21 09:52:42 UTC, 0 replies.
- [10/50] [abbrv] flink git commit: [FLINK-3929] additional fixes for keytab security - posted by tr...@apache.org on 2016/09/21 09:52:43 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [FLINK-3929] Added Keytab based Kerberos support to enable secure Flink cluster deployment(addresses HDHS, Kafka and ZK services) - posted by tr...@apache.org on 2016/09/21 09:52:44 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [FLINK-3929] Added Keytab based Kerberos support to enable secure Flink cluster deployment(addresses HDHS, Kafka and ZK services) - posted by tr...@apache.org on 2016/09/21 09:52:45 UTC, 0 replies.
- [13/50] [abbrv] flink git commit: [FLINK-3929] Added Keytab based Kerberos support to enable secure Flink cluster deployment(addresses HDHS, Kafka and ZK services) - posted by tr...@apache.org on 2016/09/21 09:52:46 UTC, 0 replies.
- [14/50] [abbrv] flink git commit: [FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies - posted by tr...@apache.org on 2016/09/21 09:52:47 UTC, 0 replies.
- [15/50] [abbrv] flink git commit: [FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies - posted by tr...@apache.org on 2016/09/21 09:52:48 UTC, 0 replies.
- [16/50] [abbrv] flink git commit: [FLINK-4368] [distributed runtime] Eagerly initialize the RPC endpoint members - posted by tr...@apache.org on 2016/09/21 09:52:49 UTC, 0 replies.
- [17/50] [abbrv] flink git commit: [FLINK-4346] [rpc] Add new RPC abstraction - posted by tr...@apache.org on 2016/09/21 09:52:50 UTC, 0 replies.
- [18/50] [abbrv] flink git commit: [FLINK-4346] [rpc] Add new RPC abstraction - posted by tr...@apache.org on 2016/09/21 09:52:51 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-4383] [rpc] Eagerly serialize remote rpc invocation messages - posted by tr...@apache.org on 2016/09/21 09:52:52 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [FLINK-4392] [rpc] Make RPC Service thread-safe - posted by tr...@apache.org on 2016/09/21 09:52:53 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEndpoint - posted by tr...@apache.org on 2016/09/21 09:52:54 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [FLINK-4386] [rpc] Add a utility to verify calls happen in the Rpc Endpoint's main thread - posted by tr...@apache.org on 2016/09/21 09:52:55 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [FLINK-4373] [cluster management] Introduce SlotID, AllocationID, ResourceProfile - posted by tr...@apache.org on 2016/09/21 09:52:56 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [FLINK-4355] [cluster management] Implement TaskManager side of registration at ResourceManager. - posted by tr...@apache.org on 2016/09/21 09:52:57 UTC, 0 replies.
- [25/50] [abbrv] flink git commit: [FLINK-4403] [rpc] Use relative classloader for proxies, rather than system class loader. - posted by tr...@apache.org on 2016/09/21 09:52:58 UTC, 0 replies.
- [26/50] [abbrv] flink git commit: [FLINK-4382] [rpc] Buffer rpc calls until the RpcEndpoint has been started - posted by tr...@apache.org on 2016/09/21 09:52:59 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [FLINK-4414] [cluster] Add getAddress method to RpcGateway - posted by tr...@apache.org on 2016/09/21 09:53:00 UTC, 0 replies.
- [28/50] [abbrv] flink git commit: [FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters - posted by tr...@apache.org on 2016/09/21 09:53:01 UTC, 0 replies.
- [29/50] [abbrv] flink git commit: [FLINK-4443] [rpc] Add support for rpc gateway and rpc endpoint inheritance - posted by tr...@apache.org on 2016/09/21 09:53:02 UTC, 0 replies.
- [30/50] [abbrv] flink git commit: [FLINK-4434] [rpc] Add a testing RPC service. - posted by tr...@apache.org on 2016/09/21 09:53:03 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [FLINK-4355] [cluster management] Add tests for the TaskManager -> ResourceManager registration. - posted by tr...@apache.org on 2016/09/21 09:53:04 UTC, 0 replies.
- [32/50] [abbrv] flink git commit: [hotfix] Remove RecoveryMode from JobMaster - posted by tr...@apache.org on 2016/09/21 09:53:05 UTC, 0 replies.
- [33/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/21 09:53:06 UTC, 0 replies.
- [34/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/21 09:53:07 UTC, 0 replies.
- [35/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/21 09:53:08 UTC, 0 replies.
- [36/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/21 09:53:09 UTC, 0 replies.
- [37/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/21 09:53:10 UTC, 0 replies.
- [38/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/21 09:53:11 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [hotfix] [clustermgnt] Set pending registration properly in TaskExecutorToResourceManagerConnection - posted by tr...@apache.org on 2016/09/21 09:53:12 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [FLINK-4363] Implement TaskManager basic startup of all components in java - posted by tr...@apache.org on 2016/09/21 09:53:13 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [FLINK-4347][cluster management] Implement SlotManager core - posted by tr...@apache.org on 2016/09/21 09:53:14 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [FLINK-4516] leader election of resourcemanager - posted by tr...@apache.org on 2016/09/21 09:53:15 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as protected - posted by tr...@apache.org on 2016/09/21 09:53:16 UTC, 0 replies.
- [44/50] [abbrv] flink git commit: [hotfix] Add self rpc gateway registration to TestingSerialRpcService - posted by tr...@apache.org on 2016/09/21 09:53:17 UTC, 0 replies.
- [45/50] [abbrv] flink git commit: [FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not reachable - posted by tr...@apache.org on 2016/09/21 09:53:18 UTC, 0 replies.
- [46/50] [abbrv] flink git commit: [hotfix] [taskmanager] Fixes TaskManager component creation at startup - posted by tr...@apache.org on 2016/09/21 09:53:19 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by tr...@apache.org on 2016/09/21 09:53:20 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by tr...@apache.org on 2016/09/21 09:53:21 UTC, 0 replies.
- [49/50] [abbrv] flink git commit: [FLINK-4361] Introduce Flink's own future abstraction - posted by tr...@apache.org on 2016/09/21 09:53:22 UTC, 0 replies.
- [50/50] [abbrv] flink git commit: [hotfix] Remove unused imports from SlotRequestRegistered/Rejected and ResourceSlot - posted by tr...@apache.org on 2016/09/21 09:53:23 UTC, 0 replies.
- flink git commit: [FLINK-3042] [FLINK-3060] [types] Define a way to let types create their own TypeInformation - posted by tw...@apache.org on 2016/09/21 12:12:44 UTC, 0 replies.
- flink git commit: [hotfix] Add methods defined in the gateway to the ResourceManager and TaskExecutor - posted by tr...@apache.org on 2016/09/21 12:16:06 UTC, 0 replies.
- flink git commit: [FLINK-4640] [streaming api] Ensure that the state descriptors properly initialize the serializers. - posted by se...@apache.org on 2016/09/21 13:12:33 UTC, 0 replies.
- flink git commit: [FLINK-4654] [docs] Small improvements to the docs. - posted by gr...@apache.org on 2016/09/21 14:40:33 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-4645] [core] Adjust signatures of 'registerTypeWithKryoSerializer(...)' methods to allow simpler passing of classes without generic casting. - posted by se...@apache.org on 2016/09/21 15:54:14 UTC, 0 replies.
- [2/6] flink git commit: [hotfix] [docs] Parametrized version of quickstart script and artifacts in the quickstart docs - posted by se...@apache.org on 2016/09/21 15:54:15 UTC, 0 replies.
- [3/6] flink git commit: [hotfix] [streaming api] Add proper deprecation JavaDocs - posted by se...@apache.org on 2016/09/21 15:54:16 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-4640] [streaming api] Ensure that the state descriptors properly initialize the serializers. - posted by se...@apache.org on 2016/09/21 15:54:17 UTC, 0 replies.
- [5/6] flink git commit: [hotfix] [tests] Fix race condition in RescalingITCase that could make the test stuck in a blocking call until timeout - posted by se...@apache.org on 2016/09/21 15:54:18 UTC, 0 replies.
- [6/6] flink git commit: [docs] Update docs on data types and serialization, to include type hints, type registration, and serializer registration. - posted by se...@apache.org on 2016/09/21 15:54:19 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction - posted by tr...@apache.org on 2016/09/21 16:20:46 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction - posted by tr...@apache.org on 2016/09/21 16:20:47 UTC, 0 replies.
- flink git commit: [FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in its executor - posted by tr...@apache.org on 2016/09/21 16:32:25 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-4537] [cluster management] ResourceManager registration with JobManager - posted by mx...@apache.org on 2016/09/21 20:02:21 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-4537] rebase and refine - posted by mx...@apache.org on 2016/09/21 20:02:22 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-4535] [cluster management] resourceManager process the registration from TaskExecutor - posted by mx...@apache.org on 2016/09/21 20:02:23 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-4535] rebase and refine - posted by mx...@apache.org on 2016/09/21 20:02:24 UTC, 0 replies.
- flink git commit: [FLINK-4248] [core] [table] CsvTableSource does not support reading SqlTimeTypeInfo types - posted by tw...@apache.org on 2016/09/22 09:13:38 UTC, 0 replies.
- flink git commit: [hotfix] fix ResourceManagerGateway - posted by mx...@apache.org on 2016/09/22 11:57:23 UTC, 0 replies.
- flink git commit: [FLINK-3580] [table] Add OVERLAPS function - posted by tw...@apache.org on 2016/09/22 12:03:34 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4628] [core] Provide user class loader during input split assignment - posted by se...@apache.org on 2016/09/22 12:42:57 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4603] [checkpoints] Fix user code classloading in KeyedStateBackend - posted by se...@apache.org on 2016/09/22 12:42:58 UTC, 0 replies.
- [1/5] flink git commit: [hotfix] Minor code cleanup in StreamTask - posted by se...@apache.org on 2016/09/23 12:01:21 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4556] [distributed runtime] Make Queryable State Key-Group Aware - posted by se...@apache.org on 2016/09/23 12:01:22 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-4663] [jdbc] Fix JDBCOutputFormat log message - posted by se...@apache.org on 2016/09/23 12:01:23 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4665] [misc] Remove unnecessary boxing/unboxing of primitive types in various places - posted by se...@apache.org on 2016/09/23 12:01:24 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-4666] [core] Declare constants as final in ParameterTool - posted by se...@apache.org on 2016/09/23 12:01:25 UTC, 0 replies.
- flink git commit: [FLINK-4663] [jdbc] Fix JDBCOutputFormat log message - posted by se...@apache.org on 2016/09/23 12:16:33 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4494] Expose the TimeServiceProvider from the Task to each Operator. - posted by al...@apache.org on 2016/09/23 13:13:52 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4496] Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. - posted by al...@apache.org on 2016/09/23 13:13:53 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] Replace registerTimer/getTime by TimeServiceProvider in Context - posted by al...@apache.org on 2016/09/23 13:13:54 UTC, 0 replies.
- flink git commit: [FLINK-4550] [table] Clearly define SQL operator table - posted by tw...@apache.org on 2016/09/23 15:01:42 UTC, 0 replies.
- flink git commit: [FLINK-4549] [table] Test and document implicitly supported SQL functions - posted by tw...@apache.org on 2016/09/23 15:36:23 UTC, 0 replies.
- flink git commit: [FLINK-4482] [checkpoints] Make numUnsuccessfulCheckpointsTriggers an atomic integer - posted by se...@apache.org on 2016/09/23 16:49:24 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4664] [gelly] Add translator to NullValue - posted by gr...@apache.org on 2016/09/23 18:48:16 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4668] [clients] Fix positive random int generation - posted by gr...@apache.org on 2016/09/23 18:48:17 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4485] close and remove user class loader after job completion - posted by mx...@apache.org on 2016/09/24 11:48:41 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4555] wait for ResourceManager to cleanly unregister application - posted by mx...@apache.org on 2016/09/24 11:48:42 UTC, 0 replies.
- flink git commit: [FLINK-4485] close and remove user class loader after job completion - posted by mx...@apache.org on 2016/09/24 11:58:44 UTC, 0 replies.
- flink git commit: [FLINK-4485] close classloader in absence of reference holders - posted by mx...@apache.org on 2016/09/24 12:20:18 UTC, 0 replies.
- flink git commit: [FLINK-4485] close and remove user class loader after job completion [Forced Update!] - posted by mx...@apache.org on 2016/09/24 12:21:34 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [rpc] Add RpcConnectionTest to validate that connection buildup fails fast when endpoint is unreachable. - posted by se...@apache.org on 2016/09/26 07:56:04 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4408] [JobManager] Introduce JobMasterRunner and implement job submission & setting up the ExecutionGraph - posted by se...@apache.org on 2016/09/26 07:56:05 UTC, 0 replies.
- flink git commit: [FLINK-4672] [taskmanager] Do not decorate Actor Kill messages - posted by se...@apache.org on 2016/09/26 09:25:24 UTC, 0 replies.
- flink git commit: [hotfix] Fix restart strategy class loading by using not lower cased class name - posted by tr...@apache.org on 2016/09/26 10:01:18 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4218] [checkpoints] Do not rely on FileSystem to determing state sizes - posted by se...@apache.org on 2016/09/26 12:11:41 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4672] [taskmanager] Do not decorate Actor Kill messages - posted by se...@apache.org on 2016/09/26 12:11:42 UTC, 0 replies.
- flink git commit: [FLINK-4580] [rpc] Report rpc invocation exceptions to the caller - posted by tr...@apache.org on 2016/09/26 12:27:23 UTC, 0 replies.
- flink git commit: [FLINK-4662] Bump Calcite version up to 1.9 - posted by tw...@apache.org on 2016/09/26 13:59:09 UTC, 0 replies.
- flink git commit: [FLINK-4684] [checkpoints] Remove redundant class loader from CheckpointCoordinator - posted by se...@apache.org on 2016/09/26 16:06:04 UTC, 0 replies.
- flink git commit: [FLINK-4590] [table] Some Table API tests are failing when debug lvl is set to DEBUG - posted by tw...@apache.org on 2016/09/26 16:54:00 UTC, 0 replies.
- flink git commit: [FLINK-4252] [table] Validate input and output classes of Table API - posted by tw...@apache.org on 2016/09/26 17:03:11 UTC, 0 replies.
- flink git commit: [FLINK-4241] [table] Cryptic expression parser exceptions - posted by tw...@apache.org on 2016/09/26 17:12:08 UTC, 0 replies.
- flink git commit: [FLINK-4671] [table] Table API can not be built - posted by tw...@apache.org on 2016/09/27 08:28:28 UTC, 0 replies.
- flink git commit: [FLINK-4687] [rpc] Add getAddress to RpcService - posted by tr...@apache.org on 2016/09/27 11:46:21 UTC, 0 replies.
- flink git commit: [FLINK-4530] [rpc] Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by se...@apache.org on 2016/09/27 15:17:17 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] [tests] Speed up streaming state tests by skipping default retry delay. - posted by se...@apache.org on 2016/09/27 15:18:23 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4685] [checkpoints] Gather sync/async duration and alignment information for task checkpoints - posted by se...@apache.org on 2016/09/27 15:18:24 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4696] [core] Limit number of Akka threads in local minicluster setups - posted by se...@apache.org on 2016/09/27 15:18:25 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4690] Use direct executor to run slot allocation future handler - posted by tr...@apache.org on 2016/09/27 16:40:31 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4690] Replace SlotAllocationFuture with flink's own future - posted by tr...@apache.org on 2016/09/27 16:40:32 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4361] Introduce Flink's own future abstraction - posted by tr...@apache.org on 2016/09/27 16:40:33 UTC, 0 replies.
- flink git commit: [FLINK-4695] Introduce MetricRegistryConfiguration to encapsulate MetricRegistry parameters - posted by tr...@apache.org on 2016/09/27 17:19:37 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4543] [network] Fix potential deadlock in SpilledSubpartitionViewAsyncIO. - posted by se...@apache.org on 2016/09/27 17:47:16 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4560] [build] Enforcer Java version >= 1.7 via Maven enforcer plugin - posted by se...@apache.org on 2016/09/27 17:47:17 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-4346] [rpc] Add new RPC abstraction [Forced Update!] - posted by tr...@apache.org on 2016/09/28 08:20:44 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-4346] [rpc] Add new RPC abstraction - posted by tr...@apache.org on 2016/09/28 08:20:45 UTC, 0 replies.
- [03/50] [abbrv] flink git commit: [FLINK-4383] [rpc] Eagerly serialize remote rpc invocation messages - posted by tr...@apache.org on 2016/09/28 08:20:46 UTC, 0 replies.
- [04/50] [abbrv] flink git commit: [FLINK-4386] [rpc] Add a utility to verify calls happen in the Rpc Endpoint's main thread - posted by tr...@apache.org on 2016/09/28 08:20:47 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [FLINK-4368] [distributed runtime] Eagerly initialize the RPC endpoint members - posted by tr...@apache.org on 2016/09/28 08:20:48 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-4392] [rpc] Make RPC Service thread-safe - posted by tr...@apache.org on 2016/09/28 08:20:49 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEndpoint - posted by tr...@apache.org on 2016/09/28 08:20:50 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies - posted by tr...@apache.org on 2016/09/28 08:20:51 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies - posted by tr...@apache.org on 2016/09/28 08:20:52 UTC, 0 replies.
- [10/50] [abbrv] flink git commit: [FLINK-4403] [rpc] Use relative classloader for proxies, rather than system class loader. - posted by tr...@apache.org on 2016/09/28 08:20:53 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [FLINK-4414] [cluster] Add getAddress method to RpcGateway - posted by tr...@apache.org on 2016/09/28 08:20:54 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [FLINK-4355] [cluster management] Implement TaskManager side of registration at ResourceManager. - posted by tr...@apache.org on 2016/09/28 08:20:55 UTC, 0 replies.
- [13/50] [abbrv] flink git commit: [FLINK-4382] [rpc] Buffer rpc calls until the RpcEndpoint has been started - posted by tr...@apache.org on 2016/09/28 08:20:56 UTC, 0 replies.
- [14/50] [abbrv] flink git commit: [FLINK-4373] [cluster management] Introduce SlotID, AllocationID, ResourceProfile - posted by tr...@apache.org on 2016/09/28 08:20:57 UTC, 0 replies.
- [15/50] [abbrv] flink git commit: [hotfix] [clustermgnt] Set pending registration properly in TaskExecutorToResourceManagerConnection - posted by tr...@apache.org on 2016/09/28 08:20:58 UTC, 0 replies.
- [16/50] [abbrv] flink git commit: [hotfix] Remove RecoveryMode from JobMaster - posted by tr...@apache.org on 2016/09/28 08:20:59 UTC, 0 replies.
- [17/50] [abbrv] flink git commit: [FLINK-4355] [cluster management] Add tests for the TaskManager -> ResourceManager registration. - posted by tr...@apache.org on 2016/09/28 08:21:00 UTC, 0 replies.
- [18/50] [abbrv] flink git commit: [FLINK-4434] [rpc] Add a testing RPC service. - posted by tr...@apache.org on 2016/09/28 08:21:01 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters - posted by tr...@apache.org on 2016/09/28 08:21:02 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [FLINK-4443] [rpc] Add support for rpc gateway and rpc endpoint inheritance - posted by tr...@apache.org on 2016/09/28 08:21:03 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as protected - posted by tr...@apache.org on 2016/09/28 08:21:04 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [FLINK-4363] Implement TaskManager basic startup of all components in java - posted by tr...@apache.org on 2016/09/28 08:21:05 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [FLINK-4347][cluster management] Implement SlotManager core - posted by tr...@apache.org on 2016/09/28 08:21:06 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/28 08:21:07 UTC, 0 replies.
- [25/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/28 08:21:08 UTC, 0 replies.
- [26/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/28 08:21:09 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/28 08:21:10 UTC, 0 replies.
- [28/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/28 08:21:11 UTC, 0 replies.
- [29/50] [abbrv] flink git commit: [FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of the rpc package - posted by tr...@apache.org on 2016/09/28 08:21:12 UTC, 0 replies.
- [30/50] [abbrv] flink git commit: [FLINK-4516] leader election of resourcemanager - posted by tr...@apache.org on 2016/09/28 08:21:13 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by tr...@apache.org on 2016/09/28 08:21:14 UTC, 0 replies.
- [32/50] [abbrv] flink git commit: [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol - posted by tr...@apache.org on 2016/09/28 08:21:15 UTC, 0 replies.
- [33/50] [abbrv] flink git commit: [hotfix] Remove unused imports from SlotRequestRegistered/Rejected and ResourceSlot - posted by tr...@apache.org on 2016/09/28 08:21:16 UTC, 0 replies.
- [34/50] [abbrv] flink git commit: [hotfix] Add self rpc gateway registration to TestingSerialRpcService - posted by tr...@apache.org on 2016/09/28 08:21:17 UTC, 0 replies.
- [35/50] [abbrv] flink git commit: [FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not reachable - posted by tr...@apache.org on 2016/09/28 08:21:18 UTC, 0 replies.
- [36/50] [abbrv] flink git commit: [hotfix] [taskmanager] Fixes TaskManager component creation at startup - posted by tr...@apache.org on 2016/09/28 08:21:19 UTC, 0 replies.
- [37/50] [abbrv] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction - posted by tr...@apache.org on 2016/09/28 08:21:20 UTC, 0 replies.
- [38/50] [abbrv] flink git commit: [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction - posted by tr...@apache.org on 2016/09/28 08:21:21 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [FLINK-4535] [cluster management] resourceManager process the registration from TaskExecutor - posted by tr...@apache.org on 2016/09/28 08:21:22 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [hotfix] Add methods defined in the gateway to the ResourceManager and TaskExecutor - posted by tr...@apache.org on 2016/09/28 08:21:23 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in its executor - posted by tr...@apache.org on 2016/09/28 08:21:24 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [FLINK-4537] [cluster management] ResourceManager registration with JobManager - posted by tr...@apache.org on 2016/09/28 08:21:25 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [FLINK-4537] rebase and refine - posted by tr...@apache.org on 2016/09/28 08:21:26 UTC, 0 replies.
- [44/50] [abbrv] flink git commit: [FLINK-4408] [JobManager] Introduce JobMasterRunner and implement job submission & setting up the ExecutionGraph - posted by tr...@apache.org on 2016/09/28 08:21:27 UTC, 0 replies.
- [45/50] [abbrv] flink git commit: [hotfix] fix ResourceManagerGateway - posted by tr...@apache.org on 2016/09/28 08:21:28 UTC, 0 replies.
- [46/50] [abbrv] flink git commit: [hotfix] [rpc] Add RpcConnectionTest to validate that connection buildup fails fast when endpoint is unreachable. - posted by tr...@apache.org on 2016/09/28 08:21:29 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [FLINK-4535] rebase and refine - posted by tr...@apache.org on 2016/09/28 08:21:30 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [FLINK-4580] [rpc] Report rpc invocation exceptions to the caller - posted by tr...@apache.org on 2016/09/28 08:21:31 UTC, 0 replies.
- [49/50] [abbrv] flink git commit: [FLINK-4687] [rpc] Add getAddress to RpcService - posted by tr...@apache.org on 2016/09/28 08:21:32 UTC, 0 replies.
- [50/50] [abbrv] flink git commit: [FLINK-4530] [rpc] Generalize TaskExecutorToResourceManagerConnection to be reusable - posted by tr...@apache.org on 2016/09/28 08:21:33 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4505] [cluster mngt] Implement TaskManager component's startup - posted by tr...@apache.org on 2016/09/28 09:14:59 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by tr...@apache.org on 2016/09/28 09:15:00 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4505] [cluster mngt] Separate TaskManager service configuration from TaskManagerConfiguration; Implement TaskManagerRunner - posted by tr...@apache.org on 2016/09/28 09:15:01 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-4606] Integrate the new ResourceManager with the existed FlinkResourceManager - posted by mx...@apache.org on 2016/09/28 15:15:49 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-4703] RpcCompletenessTest: Add support for type arguments and subclasses - posted by mx...@apache.org on 2016/09/28 15:15:50 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-4606] integrate features of old ResourceManager - posted by mx...@apache.org on 2016/09/28 15:15:51 UTC, 0 replies.
- flink git commit: [hotfix] Replace TaskManager.createTaskManagerComponents by TaskManagerServices - posted by tr...@apache.org on 2016/09/28 15:32:38 UTC, 0 replies.
- flink git commit: [FLINK-3656] [table] Reduce number of ITCases - posted by tw...@apache.org on 2016/09/29 08:10:14 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4708] [build] Properly scope Kerberos Test Cluster dependency for tests - posted by se...@apache.org on 2016/09/29 12:45:56 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4710] [build] Remove Guice Dependency from Hadoop2 - posted by se...@apache.org on 2016/09/29 12:45:57 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-3656] [table] Consolidate ITCases - posted by tw...@apache.org on 2016/09/29 13:47:48 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-3656] [table] Consolidate ITCases - posted by tw...@apache.org on 2016/09/29 13:47:49 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-3656] [table] Consolidate ITCases - posted by tw...@apache.org on 2016/09/29 13:47:50 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #238 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2016/09/30 03:33:38 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4711] Let the Task trigger partition state requests and handle their responses - posted by tr...@apache.org on 2016/09/30 07:07:56 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4711] Let the Task trigger partition state requests and handle their responses - posted by tr...@apache.org on 2016/09/30 07:07:57 UTC, 0 replies.
- [01/10] flink git commit: [FLINK-4573] [web dashboard] Fix potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler - posted by se...@apache.org on 2016/09/30 12:47:51 UTC, 0 replies.
- [02/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state - posted by se...@apache.org on 2016/09/30 12:47:52 UTC, 0 replies.
- [03/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state - posted by se...@apache.org on 2016/09/30 12:47:53 UTC, 0 replies.
- [04/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state - posted by se...@apache.org on 2016/09/30 12:47:54 UTC, 0 replies.
- [05/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state - posted by se...@apache.org on 2016/09/30 12:47:55 UTC, 0 replies.
- [06/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state - posted by se...@apache.org on 2016/09/30 12:47:56 UTC, 0 replies.
- [07/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state - posted by se...@apache.org on 2016/09/30 12:47:57 UTC, 0 replies.
- [08/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state - posted by se...@apache.org on 2016/09/30 12:47:58 UTC, 0 replies.
- [09/10] flink git commit: [FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and don't block on polls - posted by se...@apache.org on 2016/09/30 12:47:59 UTC, 0 replies.
- [10/10] flink git commit: [FLINK-4379] [checkpoints] Fix minor bug and improve debug logging - posted by se...@apache.org on 2016/09/30 12:48:00 UTC, 0 replies.
- flink git commit: [FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and don't block on polls - posted by se...@apache.org on 2016/09/30 14:47:16 UTC, 0 replies.