commits@flink.apache.org, 2017-03

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

- [1/2] flink git commit: [FLINK-5402] [tests] Increase JUnit timeouts in AkkaRpcServiceTest - posted by uc...@apache.org on 2017/03/01 15:15:08 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5389] [tests] Increate ask timeout in JobSubmitTest - posted by uc...@apache.org on 2017/03/01 15:15:09 UTC, 0 replies.
- flink git commit: [FLINK-5794] [doc] Update the documentation about “UDF/UDTF" support have parameters constructor. - posted by ja...@apache.org on 2017/03/02 02:54:33 UTC, 0 replies.
- flink git commit: [FLINK-4422] [kafka] Convert all time interval measurements to System.nanoTime() - posted by tz...@apache.org on 2017/03/02 06:55:36 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-5852] Move handler JSON generation code into static methods - posted by ch...@apache.org on 2017/03/02 10:40:35 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-5852] Move handler JSON generation code into static methods - posted by ch...@apache.org on 2017/03/02 10:40:36 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-5870] Handlers define REST URLs - posted by ch...@apache.org on 2017/03/02 10:40:37 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-5870] Handlers define REST URLs - posted by ch...@apache.org on 2017/03/02 10:40:38 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5938] Replace ExecutionContext by Executor in Scheduler - posted by tr...@apache.org on 2017/03/02 11:24:21 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-5934] Set the Scheduler in the ExecutionGraph via its constructor - posted by tr...@apache.org on 2017/03/02 11:24:22 UTC, 1 replies.
- flink git commit: [FLINK-5934] Set the Scheduler in the ExecutionGraph via its constructor - posted by tr...@apache.org on 2017/03/02 13:03:27 UTC, 0 replies.
- flink git commit: [FLINK-5948] Fix error in Python zip_with_index documentation - posted by ch...@apache.org on 2017/03/02 14:14:26 UTC, 0 replies.
- flink git commit: [FLINK-5524] [table] Support early out for code generated AND/OR conditions - posted by tw...@apache.org on 2017/03/02 15:17:49 UTC, 0 replies.
- flink git commit: [FLINK-5827] [table] Exception when do filter after join a udtf which returns a POJO type - posted by tw...@apache.org on 2017/03/02 15:33:21 UTC, 0 replies.
- flink git commit: [FLINK-5945] [core] Close function in OuterJoinOperatorBase#executeOnCollections - posted by gr...@apache.org on 2017/03/02 15:38:11 UTC, 2 replies.
- [1/2] flink git commit: [FLINK-5941] Integrate Archiver pattern into handlers - posted by ch...@apache.org on 2017/03/02 17:27:39 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5941] Integrate Archiver pattern into handlers - posted by ch...@apache.org on 2017/03/02 17:27:40 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5768] [table] Refactor DataSet and DataStream aggregations to use UDAGG interface. - posted by fh...@apache.org on 2017/03/02 20:32:42 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5768] [table] Refactor DataSet and DataStream aggregations to use UDAGG interface. - posted by fh...@apache.org on 2017/03/02 20:32:43 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5768] [table] Refactor DataSet and DataStream aggregations to use UDAGG interface. - posted by fh...@apache.org on 2017/03/02 20:32:44 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4896] [gelly] PageRank algorithm for directed graphs - posted by gr...@apache.org on 2017/03/02 23:33:22 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5597] [docs] Improve the LocalClusteringCoefficient documentation - posted by gr...@apache.org on 2017/03/02 23:33:23 UTC, 0 replies.
- flink git commit: [FLINK-5937] [doc] Add documentation about the stream task lifecycle - posted by kk...@apache.org on 2017/03/03 11:59:48 UTC, 0 replies.
- flink git commit: [FLINK-5917] [statebackends] Remove size() method from MapState - posted by sr...@apache.org on 2017/03/03 13:17:43 UTC, 0 replies.
- flink git commit: [FLINK-5864] [cep] Fix duplicate output patterns problem - posted by kk...@apache.org on 2017/03/03 13:23:22 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5927] [table] Remove old Aggregate interface, built-in functions, and tests. - posted by fh...@apache.org on 2017/03/03 13:27:33 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5955] [table] Fix aggregations with ObjectReuse enabled by pairwise merging of accumulators. - posted by fh...@apache.org on 2017/03/03 13:27:34 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] [table] Fix initialization of accumulators for MIN and MAX aggregates. - posted by fh...@apache.org on 2017/03/03 13:27:35 UTC, 0 replies.
- [1/2] flink-web git commit: Add Stefan Richter to committer list - posted by sr...@apache.org on 2017/03/03 13:34:26 UTC, 0 replies.
- [2/2] flink-web git commit: Rebuild website - posted by sr...@apache.org on 2017/03/03 13:34:27 UTC, 0 replies.
- flink git commit: [FLINK-5219] [table] Add non-grouped session windows for batch tables. - posted by fh...@apache.org on 2017/03/03 15:53:19 UTC, 0 replies.
- flink git commit: [FLINK-5586] [table] Extend TableProgramsClusterTestBase for object reuse mode - posted by ku...@apache.org on 2017/03/04 01:46:43 UTC, 0 replies.
- flink git commit: [FLINK-5067] Java 8 build fixes - posted by rm...@apache.org on 2017/03/04 11:14:33 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #394 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/05 03:35:40 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #395 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/06 03:35:36 UTC, 0 replies.
- flink git commit: [FLINK-5965] [docs] Fix minor typo on DropWizard wrappers - posted by uc...@apache.org on 2017/03/06 09:09:40 UTC, 1 replies.
- flink git commit: [FLINK-3347] [akka] Add QuarantineMonitor which shuts a quarantined actor system and JVM down - posted by tr...@apache.org on 2017/03/06 13:38:42 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-4460] Update doc: ProcessFunction now possible on DataStream - posted by al...@apache.org on 2017/03/06 15:52:09 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-4460] Make CoProcessFunction abstract, add default onTime() method - posted by al...@apache.org on 2017/03/06 15:52:10 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-4460] Make ProcessFunction abstract, add default onTime() method - posted by al...@apache.org on 2017/03/06 15:52:11 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-4660] Allow CoProcessFunction on non-keyed ConnectedStreams - posted by al...@apache.org on 2017/03/06 15:52:12 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-4660] Allow ProcessFunction on DataStream - posted by al...@apache.org on 2017/03/06 15:52:13 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #396 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/07 03:36:17 UTC, 0 replies.
- flink git commit: [FLINK-5645] Store accumulators/metrics for canceled/failed tasks - posted by ch...@apache.org on 2017/03/07 11:42:41 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5956] [table] Add retract method for AggregateFunction. - posted by fh...@apache.org on 2017/03/07 17:56:50 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5803] [table] Add support for procTime partitioned OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/07 17:56:51 UTC, 0 replies.
- flink git commit: [FLINK-5916] [yarn] make env.java.opts.jobmanager and env.java.opts.taskmanager working in YARN mode - posted by tr...@apache.org on 2017/03/07 21:47:18 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #397 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/08 03:36:34 UTC, 0 replies.
- flink git commit: [FLINK-4326] [scripts] Flink foreground services - posted by uc...@apache.org on 2017/03/08 09:54:46 UTC, 1 replies.
- flink git commit: [FLINK-5722] [table] Add dedicated DataSetDistinct operator. - posted by tw...@apache.org on 2017/03/08 13:15:33 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-3427] [webui] Rebuild web UI - posted by uc...@apache.org on 2017/03/08 14:28:48 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-3427] [webui] Rebuild web UI - posted by uc...@apache.org on 2017/03/08 14:28:49 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-3427] [webui] Rebuild web UI - posted by uc...@apache.org on 2017/03/08 14:28:50 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-3427] [webui] Refactorings to watermark tracking - posted by uc...@apache.org on 2017/03/08 14:28:51 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-3427] [webui] Add watermark tracking - posted by uc...@apache.org on 2017/03/08 14:28:52 UTC, 0 replies.
- flink git commit: [FLINK-5414] [table] Bump up Calcite version to 1.11. (Jark Wu and Haohui Mai) - posted by tw...@apache.org on 2017/03/08 15:28:35 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5047] [table] Add sliding group-windows for batch tables - posted by tw...@apache.org on 2017/03/08 16:03:23 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5047] [table] Add sliding group-windows for batch tables - posted by tw...@apache.org on 2017/03/08 16:03:24 UTC, 0 replies.
- flink git commit: [FLINK-5983] [table] Convert FOR into WHILE loops for aggregation functions. - posted by tw...@apache.org on 2017/03/08 17:07:11 UTC, 0 replies.
- buildbot failure in on flink-docs-release-1.2 - posted by bu...@apache.org on 2017/03/09 01:00:08 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #398 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/09 03:36:17 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-3679] [kafka] Allow Kafka consumer to skip corrupted messages - posted by tz...@apache.org on 2017/03/09 06:06:48 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-3679] [kafka] Improve null record handling for FlinkKafkaConsumer - posted by tz...@apache.org on 2017/03/09 06:06:49 UTC, 0 replies.
- flink git commit: [hotfix] [FLINK-3679] Improve Javadocs of DeserializationSchemas - posted by tz...@apache.org on 2017/03/09 06:39:23 UTC, 0 replies.
- flink git commit: [FLINK-6002] [docs] Quickstart download not rendered correctly - posted by uc...@apache.org on 2017/03/09 10:10:02 UTC, 0 replies.
- flink git commit: [FLINK-5963] [table] Remove prepare mapper of DataSetAggregate. - posted by tw...@apache.org on 2017/03/09 10:28:47 UTC, 0 replies.
- flink git commit: [FLINK-5984] [table] Add resetAccumulator method for AggregateFunction - posted by tw...@apache.org on 2017/03/09 11:09:36 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-5824] Fix String/byte conversions without explicit encoding - posted by se...@apache.org on 2017/03/09 12:02:26 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-5824] Fix String/byte conversions without explicit encoding - posted by se...@apache.org on 2017/03/09 12:02:27 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-5598] [web frontend] Return filename after jar upload - posted by se...@apache.org on 2017/03/09 12:02:28 UTC, 0 replies.
- [4/9] flink git commit: [hotfix] [checkpoints] Cleanups in PendingCheckpoint - posted by se...@apache.org on 2017/03/09 12:02:29 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-4545] [network] remove fixed-size BufferPool instances - posted by se...@apache.org on 2017/03/09 12:02:30 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-4545] [network] remove fixed-size BufferPool instances - posted by se...@apache.org on 2017/03/09 12:02:31 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-5830] [distributed coordination] Handle OutOfMemory and fatal errors during process async message in akka rpc actor - posted by se...@apache.org on 2017/03/09 12:02:32 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-5135] [runtime] Expand the fields in ResourceProfile based on ResourceSpec - posted by se...@apache.org on 2017/03/09 12:02:33 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-5824] (followup) Minor code cleanups in CheckForbiddenMethodsUsage - posted by se...@apache.org on 2017/03/09 12:02:34 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5909] [gelly] Interface for GraphAlgorithm results - posted by gr...@apache.org on 2017/03/09 15:11:25 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-5909] [gelly] Interface for GraphAlgorithm results - posted by gr...@apache.org on 2017/03/09 15:11:26 UTC, 1 replies.
- [flink] Git Push Summary - posted by gr...@apache.org on 2017/03/09 15:14:04 UTC, 3 replies.
- flink git commit: [FLINK-5838] [scripts] Print shell script usage - posted by gr...@apache.org on 2017/03/09 18:03:36 UTC, 0 replies.
- flink git commit: [FLINK-5804] [table] Add support for procTime non-partitioned OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/09 18:12:18 UTC, 0 replies.
- buildbot success in on flink-docs-release-1.2 - posted by bu...@apache.org on 2017/03/10 01:30:28 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #399 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/10 03:36:57 UTC, 0 replies.
- buildbot failure in on flink-docs-release-0.9 - posted by bu...@apache.org on 2017/03/10 05:00:10 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-6010] [docs] Correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section - posted by se...@apache.org on 2017/03/10 13:42:43 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-6005] [misc] Fix some ArrayList initializations without initial size - posted by se...@apache.org on 2017/03/10 13:42:44 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-5976] [tests] Deduplicate Tokenizer in tests - posted by se...@apache.org on 2017/03/10 13:42:45 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-5980] [core] Expose max-parallelism value in RuntimeContext. - posted by se...@apache.org on 2017/03/10 13:42:46 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-4545] [network] Allow LocalBufferPool to limited the number of used buffers - posted by se...@apache.org on 2017/03/10 13:42:47 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-4545] [network] Allow LocalBufferPool to limited the number of used buffers - posted by se...@apache.org on 2017/03/10 13:42:48 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-4545] [network] Small adjustments to LocalBufferPool with limited the number of used buffers - posted by se...@apache.org on 2017/03/10 13:42:49 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5910] [gelly] Framework for Gelly examples - posted by gr...@apache.org on 2017/03/10 15:52:00 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled - posted by gr...@apache.org on 2017/03/10 15:52:01 UTC, 0 replies.
- flink git commit: [FLINK-5874] Restrict key types in the DataStream API. - posted by kk...@apache.org on 2017/03/10 22:18:48 UTC, 0 replies.
- flink git commit: [FLINK-5954] [table] Always assign names to the windows in SQL queries on streams. - posted by fh...@apache.org on 2017/03/10 23:30:52 UTC, 0 replies.
- flink git commit: [FLINK-6023] fix process function doc examples - posted by ku...@apache.org on 2017/03/11 02:32:29 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #400 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/11 03:35:53 UTC, 0 replies.
- buildbot success in on flink-docs-release-0.9 - posted by bu...@apache.org on 2017/03/11 05:23:43 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #401 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/12 03:35:39 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #402 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/13 03:35:37 UTC, 0 replies.
- flink git commit: [FLINK-5881] [table] ScalarFunction(UDF) should support variable types and variable arguments - posted by tw...@apache.org on 2017/03/13 09:33:39 UTC, 0 replies.
- flink git commit: [FLINK-5882] [table] TableFunction (UDTF) should support variable types and variable arguments - posted by tw...@apache.org on 2017/03/13 09:58:30 UTC, 0 replies.
- flink git commit: [FLINK-5971] [flip-6] Add timeout for registered jobs on the ResourceManager - posted by tr...@apache.org on 2017/03/13 14:03:58 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization - posted by tz...@apache.org on 2017/03/13 15:39:35 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-3123] [kafka] Allow custom specific start offsets for FlinkKafkaConsumer - posted by tz...@apache.org on 2017/03/13 15:39:36 UTC, 0 replies.
- flink git commit: [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization - posted by tz...@apache.org on 2017/03/13 15:43:45 UTC, 1 replies.
- flink git commit: [FLINK-6007] Allow key removal from within the watermark callback. - posted by kk...@apache.org on 2017/03/13 19:07:16 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #403 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/14 03:36:13 UTC, 0 replies.
- flink git commit: [FLINK-5942] [checkpoint] Harden ZooKeeperStateHandleStore to handle corrupt data - posted by tr...@apache.org on 2017/03/14 08:14:34 UTC, 2 replies.
- flink git commit: [FLINK-5441] [table] Directly allow SQL queries on a Table - posted by tw...@apache.org on 2017/03/14 08:17:41 UTC, 0 replies.
- flink git commit: [FLINK-5940] [checkpoint] Harden ZooKeeperCompletedCheckpointStore.recover method - posted by tr...@apache.org on 2017/03/14 08:23:40 UTC, 2 replies.
- flink git commit: [hotfix] [log] Log proper user defined state backend in StreamTask - posted by tr...@apache.org on 2017/03/14 13:57:27 UTC, 0 replies.
- [1/7] flink-web git commit: [FLINK-5594] Higher resolution nav bar logo and homepage graphic - posted by rm...@apache.org on 2017/03/14 14:15:05 UTC, 0 replies.
- [2/7] flink-web git commit: [FLINK-5594] Higher resolution nav bar logo and homepage graphic - posted by rm...@apache.org on 2017/03/14 14:15:06 UTC, 0 replies.
- [3/7] flink-web git commit: [FLINK-5594] Higher resolution nav bar logo and homepage graphic - posted by rm...@apache.org on 2017/03/14 14:15:07 UTC, 0 replies.
- [4/7] flink-web git commit: Rebuild site - posted by rm...@apache.org on 2017/03/14 14:15:08 UTC, 0 replies.
- [5/7] flink-web git commit: Rebuild site - posted by rm...@apache.org on 2017/03/14 14:15:09 UTC, 0 replies.
- [6/7] flink-web git commit: Rebuild site - posted by rm...@apache.org on 2017/03/14 14:15:10 UTC, 0 replies.
- [7/7] flink-web git commit: Rebuild site - posted by rm...@apache.org on 2017/03/14 14:15:11 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5949] [yarn] Don't check Kerberos credentials for non-Kerberos authentication methods - posted by tz...@apache.org on 2017/03/14 17:00:33 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-3398] [kafka] Allow disabling offset committing for FlinkKafkaConsumer - posted by tz...@apache.org on 2017/03/14 17:00:34 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6006] [kafka] Always use complete restored state in FlinkKafkaConsumer - posted by tz...@apache.org on 2017/03/14 17:10:41 UTC, 0 replies.
- flink git commit: [FLINK-6040] [table] DataStreamUserDefinedFunctionITCase occasionally fails - posted by ku...@apache.org on 2017/03/15 01:13:50 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #404 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/15 03:35:55 UTC, 0 replies.
- flink git commit: [hotfix] [tests] Improve mocking in ZooKeeperCompletedCheckpointStore.testCheckpointRecovery - posted by tr...@apache.org on 2017/03/15 08:08:22 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5635] [docker] Improvements for Docker on Flink experience - posted by uc...@apache.org on 2017/03/15 13:13:37 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5635] [docker] Use start-foreground in Docker entrypoint - posted by uc...@apache.org on 2017/03/15 13:13:38 UTC, 0 replies.
- flink git commit: [FLINK-6001] Fix ContinuousEventTimeTrigger firing without state - posted by al...@apache.org on 2017/03/15 13:42:23 UTC, 1 replies.
- flink git commit: [FLINK-6061] [state backends] Throw IllegalStateException when using RocksDB keyed state with no key set - posted by sr...@apache.org on 2017/03/15 14:28:29 UTC, 0 replies.
- flink git commit: [FLINK-6006] [kafka] Always use complete restored state in FlinkKafkaConsumer - posted by tz...@apache.org on 2017/03/15 14:37:03 UTC, 0 replies.
- flink git commit: [FLINK-6044] Replace all unintentional calls to InputStream#read(...) with InputStream#readFully(...) - posted by sr...@apache.org on 2017/03/15 15:00:46 UTC, 2 replies.
- flink git commit: [hotfix] [doc] Fix error in ProcessFunction example. - posted by kk...@apache.org on 2017/03/15 15:57:03 UTC, 0 replies.
- flink git commit: [FLINK-6051] [metrics] [docs] Fix scope keys on Configuration page - posted by ch...@apache.org on 2017/03/15 16:15:11 UTC, 1 replies.
- flink git commit: [FLINK-6018] Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState() - posted by al...@apache.org on 2017/03/15 17:44:29 UTC, 0 replies.
- flink git commit: [FLINK-5962] [checkpoints] Remove scheduled cancel-task from timer queue to prevent memory leaks - posted by se...@apache.org on 2017/03/15 19:28:45 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #405 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/16 03:35:44 UTC, 0 replies.
- flink git commit: [FLINK-5701] [kafka] FlinkKafkaProducer should check asyncException on checkpoints - posted by tz...@apache.org on 2017/03/16 04:42:25 UTC, 0 replies.
- flink git commit: [FLINK-6064][flip6] fix BlobServer connection in TaskExecutor - posted by tr...@apache.org on 2017/03/16 09:49:53 UTC, 0 replies.
- flink git commit: [FLINK-6032] [cep] Clean-up operator state when not needed. - posted by kk...@apache.org on 2017/03/16 10:40:04 UTC, 0 replies.
- flink git commit: [hotfix] Remove auto-boxing in ContinuousEventTimeTrigger - posted by al...@apache.org on 2017/03/16 13:12:55 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-5962] [checkpoints] Remove scheduled cancel-task from timer queue to prevent memory leaks - posted by se...@apache.org on 2017/03/16 14:05:42 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-5692] [core] (followups) Add an Option to Deactivate Kryo Fallback for Serializers - posted by se...@apache.org on 2017/03/16 14:05:43 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-5692] [core] Add an Option to Deactivate Kryo Fallback for Serializers - posted by se...@apache.org on 2017/03/16 14:05:44 UTC, 0 replies.
- [4/8] flink git commit: [hotfix] [core] Fix/cleanup serialization test for ExecutionConfig - posted by se...@apache.org on 2017/03/16 14:05:45 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-5756] [rocksdb] Add mini benchmarks to reproduce 'merge' performance problems - posted by se...@apache.org on 2017/03/16 14:05:46 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-4422] [clients] Convert time interval measurements to System.nanoTime() in 'flink-clients' - posted by se...@apache.org on 2017/03/16 14:05:47 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-4754] [checkpoints] Make number of retained checkpoints user configurable - posted by se...@apache.org on 2017/03/16 14:05:48 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-4754] [checkpoints] Small followups to the configuration of number of retained checkpoints. - posted by se...@apache.org on 2017/03/16 14:05:49 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-6041] [streaming api] Move StreamingFunctionUtils to 'org.apache.flink.streaming.util' - posted by se...@apache.org on 2017/03/16 15:10:34 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-6009] [java api] Deprecate DataSetUtils#checksumHashCode - posted by se...@apache.org on 2017/03/16 15:10:35 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5134] [runtime] Aggregate ResourceSpec for chained operators when generating job graph - posted by se...@apache.org on 2017/03/16 15:10:36 UTC, 0 replies.
- [1/2] flink git commit: [refactor] [py] General code clean-up - posted by ch...@apache.org on 2017/03/16 16:05:46 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5650] [py] Continuously check PyProcess health while waiting for incoming connection - posted by ch...@apache.org on 2017/03/16 16:05:47 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend - posted by sr...@apache.org on 2017/03/16 17:34:26 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend - posted by sr...@apache.org on 2017/03/16 17:34:27 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend - posted by sr...@apache.org on 2017/03/16 17:34:28 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend - posted by sr...@apache.org on 2017/03/16 17:34:29 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #406 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/17 03:35:30 UTC, 0 replies.
- flink git commit: [FLINK-5650] [py] Continuously check PyProcess health while waiting for incoming connection - posted by ch...@apache.org on 2017/03/17 07:02:53 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (1) - posted by ku...@apache.org on 2017/03/17 10:03:03 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (1) - posted by ku...@apache.org on 2017/03/17 10:03:04 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (2) - posted by ku...@apache.org on 2017/03/17 10:03:05 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (2) - posted by ku...@apache.org on 2017/03/17 10:03:06 UTC, 0 replies.
- flink git commit: [FLINK-5981] [security] Make SSL pick up configured protocols and cipher suites - posted by se...@apache.org on 2017/03/17 11:14:18 UTC, 0 replies.
- flink git commit: [hotfix] Added missing documentation in StateTransformationFunction - posted by sr...@apache.org on 2017/03/17 12:46:13 UTC, 0 replies.
- flink git commit: [FLINK-6076] Refactor HeartbeatManager to extend HeartbeatTarget - posted by tr...@apache.org on 2017/03/17 14:52:49 UTC, 0 replies.
- svn commit: r18780 - /release/flink/KEYS - posted by rm...@apache.org on 2017/03/17 14:54:48 UTC, 0 replies.
- svn commit: r18781 - /release/flink/KEYS - posted by rm...@apache.org on 2017/03/17 14:56:11 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5932] initializeState() before legacy state restoring in operator - posted by kk...@apache.org on 2017/03/17 15:35:26 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-5846] [cep] Make the CEP operators backwards compatible with Flink 1.1 - posted by kk...@apache.org on 2017/03/17 15:35:27 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4364] [heartbeats] Implement TaskManager side of heartbeat from JobManager - posted by tr...@apache.org on 2017/03/17 16:00:23 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4364] Introduce HeartbeatServices for the HeartbeatManager instantiation - posted by tr...@apache.org on 2017/03/17 16:00:24 UTC, 0 replies.
- svn commit: r18782 - /release/flink/KEYS - posted by rm...@apache.org on 2017/03/17 16:09:15 UTC, 0 replies.
- flink git commit: [FLINK-5985] Report no task states for stateless tasks on checkpointing - posted by sr...@apache.org on 2017/03/17 17:16:07 UTC, 1 replies.
- flink git commit: Commit for release 1.1.5 - posted by tz...@apache.org on 2017/03/17 17:21:50 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism() - posted by al...@apache.org on 2017/03/17 22:03:59 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5808] Move max keygroup constants to ExecutionConfig - posted by al...@apache.org on 2017/03/17 22:04:00 UTC, 1 replies.
- [3/3] flink git commit: [FLINK-5808] Move default parallelism to StreamingJobGraphGenerator - posted by al...@apache.org on 2017/03/17 22:04:01 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #407 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/18 03:35:44 UTC, 0 replies.
- [01/11] flink git commit: [FLINK-4460] Catch side output OutputTag id clashes - posted by al...@apache.org on 2017/03/18 07:13:40 UTC, 0 replies.
- [02/11] flink git commit: [FLINK-4460] Add ITCase to verify watermark forwarding for side outputs - posted by al...@apache.org on 2017/03/18 07:13:41 UTC, 0 replies.
- [03/11] flink git commit: [FLINK-4460] Add side outputs for ProcessFunction - posted by al...@apache.org on 2017/03/18 07:13:42 UTC, 0 replies.
- [04/11] flink git commit: [FLINK-4460] Add support for side outputs - posted by al...@apache.org on 2017/03/18 07:13:43 UTC, 0 replies.
- [05/11] flink git commit: [FLINK-4460] Provide late-data output for window operations - posted by al...@apache.org on 2017/03/18 07:13:44 UTC, 0 replies.
- [06/11] flink git commit: [FLINK-4460] Expose OutputTag constructor that takes TypeInformation - posted by al...@apache.org on 2017/03/18 07:13:45 UTC, 0 replies.
- [07/11] flink git commit: [FLINK-4460] Add proper side output API for Scala API - posted by al...@apache.org on 2017/03/18 07:13:46 UTC, 0 replies.
- [08/11] flink git commit: [FLINK-4460] Make chaining work with side outputs - posted by al...@apache.org on 2017/03/18 07:13:47 UTC, 0 replies.
- [09/11] flink git commit: [FLINK-4460] Add documentation for side outputs - posted by al...@apache.org on 2017/03/18 07:13:48 UTC, 0 replies.
- [10/11] flink git commit: [FLINK-4460] Add side output ITCase for multiple side out consumers - posted by al...@apache.org on 2017/03/18 07:13:49 UTC, 0 replies.
- [11/11] flink git commit: [FLINK-4460] Add WindowOperatorContractTest tests for late data emission - posted by al...@apache.org on 2017/03/18 07:13:50 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5808] Move default parallelism to StreamingJobGraphGenerator - posted by al...@apache.org on 2017/03/18 08:39:03 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism() - posted by al...@apache.org on 2017/03/18 08:39:05 UTC, 0 replies.
- flink git commit: [FLINK-5568] [table] Introduce ExternalCatalog interface, integrated with calcite and provide an in-memory implementation for testing. - posted by ku...@apache.org on 2017/03/18 13:39:50 UTC, 0 replies.
- flink git commit: [FLINK-6068] [table] Support If() as a built-in function. - posted by ku...@apache.org on 2017/03/18 14:08:49 UTC, 0 replies.
- flink git commit: [FLINK-6111] [py] Remove unnecessary sleeps - posted by ch...@apache.org on 2017/03/18 15:13:08 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #408 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/19 03:35:39 UTC, 0 replies.
- flink git commit: [FLINK-5183] [py] Support mulitple jobs per plan file - posted by ch...@apache.org on 2017/03/19 20:21:20 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #409 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/20 03:35:39 UTC, 0 replies.
- flink git commit: [FLINK-6122] Add Travis build status to README - posted by uc...@apache.org on 2017/03/20 09:47:18 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5883] [core] Re-adding the Exception-thrown code for ListKeyGroupedIterator when the iterator is requested the second time - posted by se...@apache.org on 2017/03/20 14:41:01 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5995] [checkpoints] Harden test for state descriptor passing to OperatorState - posted by se...@apache.org on 2017/03/20 14:41:02 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5995] [checkpoints] Fix serializer initialization for Operator State - posted by se...@apache.org on 2017/03/20 14:41:03 UTC, 0 replies.
- flink git commit: [docs] Document per-Kafka-partition watermarks - posted by se...@apache.org on 2017/03/20 14:43:14 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-6027] [checkpoints] Suppress (and log) exceptions thrown by the subsuming of completed checkppoints - posted by se...@apache.org on 2017/03/20 15:54:43 UTC, 0 replies.
- [2/2] flink git commit: [docs] Document per-Kafka-partition watermarks - posted by se...@apache.org on 2017/03/20 15:54:44 UTC, 0 replies.
- flink git commit: [FLINK-5999] [resMgnr] Move JobLeaderIdService shut down into ResourceManagerRunner - posted by tr...@apache.org on 2017/03/20 17:38:14 UTC, 0 replies.
- flink git commit: [hotfix] Harden TaskExecutorTest#testHeartbeatTimeoutWithJobManager by increasing timeout - posted by tr...@apache.org on 2017/03/20 17:43:33 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #410 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/21 03:35:34 UTC, 0 replies.
- flink git commit: [FLINK-6050] [robustness] Register exception handler on thenAccept futures - posted by tr...@apache.org on 2017/03/21 09:55:47 UTC, 0 replies.
- flink git commit: [FLINK-6037] [table] Metadata provider didn't work in SQL - posted by tw...@apache.org on 2017/03/21 10:52:14 UTC, 0 replies.
- flink git commit: [FLINK-6124] [table] support max/min aggregations for string type - posted by tw...@apache.org on 2017/03/21 11:22:59 UTC, 0 replies.
- flink git commit: [FLINK-6138] [table] Create the ListStateDescriptor with the aggregationStateType instead of a serializer. - posted by ja...@apache.org on 2017/03/21 12:59:50 UTC, 0 replies.
- flink git commit: Revert "[FLINK-6122] Add Travis build status to README" - posted by uc...@apache.org on 2017/03/21 14:00:26 UTC, 0 replies.
- flink git commit: [FLINK-6132] [cleanup] Remove redundant code in CliFrontend - posted by tr...@apache.org on 2017/03/21 14:18:22 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4326] [scripts] [fixup] Fix taskmanager bash script - posted by se...@apache.org on 2017/03/21 14:55:06 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6000] [scripts] Fix starting HA cluster with start-cluster.sh - posted by se...@apache.org on 2017/03/21 14:55:07 UTC, 0 replies.
- flink git commit: [FLINK-6084][Cassandra] Promote transitive dependencies - posted by rm...@apache.org on 2017/03/21 20:30:49 UTC, 1 replies.
- [1/6] flink git commit: [FLINK-6000] [scripts] Fix starting HA cluster with start-cluster.sh - posted by se...@apache.org on 2017/03/21 20:37:57 UTC, 0 replies.
- [2/6] flink git commit: [hotfix] Clean up StringUtils and remove unused methods. - posted by se...@apache.org on 2017/03/21 20:37:58 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-6144] [config] Port JobManager configuration options to ConfigOption - posted by se...@apache.org on 2017/03/21 20:37:59 UTC, 0 replies.
- [4/6] flink git commit: [hotfix] [config] Minor improvements to JobManagerOptions docs and harmonization of config parameters. - posted by se...@apache.org on 2017/03/21 20:38:00 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-6056] [build] Add rat exclude for 'tools/flink*' - posted by se...@apache.org on 2017/03/21 20:38:01 UTC, 0 replies.
- [6/6] flink git commit: [hotfix] Clean up AbstractID and make it immutable. - posted by se...@apache.org on 2017/03/21 20:38:02 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #411 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/22 03:35:56 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-6134] Set UUID(0L, 0L) as default leader session id - posted by tr...@apache.org on 2017/03/22 11:14:24 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6134] Set UUID(0L, 0L) as default leader session id - posted by tr...@apache.org on 2017/03/22 11:14:25 UTC, 0 replies.
- flink git commit: [FLINK-6080] Unclosed ObjectOutputStream in NFA#serialize() - posted by kk...@apache.org on 2017/03/22 12:43:16 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-1579] [refactor] Add WebFrontendBootstrap for code reuse - posted by uc...@apache.org on 2017/03/22 14:46:29 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-1579] [webui] Implement History Server - posted by uc...@apache.org on 2017/03/22 14:46:30 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-1579] [webui] Implement History Server - posted by uc...@apache.org on 2017/03/22 14:46:31 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-1579] [webui] Rebuild web frontend - posted by uc...@apache.org on 2017/03/22 14:46:32 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-1579] [webui] Rebuild web frontend - posted by uc...@apache.org on 2017/03/22 14:46:33 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-6139] [doc] Add documentation for running Flink on MapR - posted by tz...@apache.org on 2017/03/22 14:51:56 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6139] [build] Add "mapr" build profile - posted by tz...@apache.org on 2017/03/22 14:51:57 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-6139] [build] Add "mapr" build profile - posted by tz...@apache.org on 2017/03/22 14:57:53 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6139] [doc] Add documentation for running Flink on MapR - posted by tz...@apache.org on 2017/03/22 14:57:54 UTC, 0 replies.
- svn commit: r18875 - /release/flink/flink-1.1.5/ - posted by rm...@apache.org on 2017/03/22 15:44:59 UTC, 0 replies.
- flink git commit: [FLINK-5067][hotfix] Fix snapshot deployment - posted by rm...@apache.org on 2017/03/22 16:01:58 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #412 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/03/22 16:56:24 UTC, 0 replies.
- flink git commit: [FLINK-6170] [metrics] Don't rely on stats snapshot for checkpoint metrics - posted by uc...@apache.org on 2017/03/22 20:21:27 UTC, 1 replies.
- [1/3] flink-web git commit: Update latest version of 1.1 series to 1.1.5 - posted by tz...@apache.org on 2017/03/23 08:14:05 UTC, 0 replies.
- [2/3] flink-web git commit: Add release 1.1.5 blog post - posted by tz...@apache.org on 2017/03/23 08:14:06 UTC, 0 replies.
- [3/3] flink-web git commit: Rebuild website - posted by tz...@apache.org on 2017/03/23 08:14:07 UTC, 0 replies.
- flink git commit: [docs] Set version to 1.1.5 - posted by tz...@apache.org on 2017/03/23 08:55:43 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-3318] Backward compatibility of CEP NFA - posted by kk...@apache.org on 2017/03/23 12:47:24 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-3318] Add support for quantifiers to CEP's pattern API - posted by kk...@apache.org on 2017/03/23 12:47:25 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-3318] Add support for quantifiers to CEP's pattern API - posted by kk...@apache.org on 2017/03/23 12:47:26 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-4354] [heartbeat] Add heartbeats between the ResourceManager and TaskExecutor - posted by tr...@apache.org on 2017/03/23 12:59:09 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4354] [heartbeat] Implement heartbeat logic between TaskManager and ResourceManager - posted by tr...@apache.org on 2017/03/23 12:59:10 UTC, 0 replies.
- flink git commit: [hotfix][scripts] Fix zookeeper quorum regex - posted by rm...@apache.org on 2017/03/23 14:12:07 UTC, 0 replies.
- flink git commit: [FLINK-6129] [metrics] Stop query actor of MetricRegistry - posted by tr...@apache.org on 2017/03/23 14:13:53 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] Fix various small issues in WindowOperatorContractTest - posted by tz...@apache.org on 2017/03/23 15:30:08 UTC, 0 replies.
- [2/3] flink git commit: [hotfix] Add EvictingWindowOperatorContractTest - posted by tz...@apache.org on 2017/03/23 15:30:09 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5972] Don't allow shrinking merging windows - posted by tz...@apache.org on 2017/03/23 15:30:10 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types - posted by tz...@apache.org on 2017/03/24 05:10:15 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types - posted by tz...@apache.org on 2017/03/24 05:10:16 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] Add EvictingWindowOperatorContractTest - posted by tz...@apache.org on 2017/03/24 05:51:18 UTC, 0 replies.
- [2/3] flink git commit: [hotfix] Fix various small issues in WindowOperatorContractTest - posted by tz...@apache.org on 2017/03/24 05:51:19 UTC, 0 replies.
- flink git commit: [hotfix] Remove validateRunsInMainThread from TaskExecutor to fix TaskExecutorTest - posted by tr...@apache.org on 2017/03/24 09:33:18 UTC, 0 replies.
- flink git commit: [FLINK-6182] Fix possible NPE in SourceStreamTask - posted by uc...@apache.org on 2017/03/24 11:27:15 UTC, 1 replies.
- flink git commit: Commit for release 1.2.1 - posted by rm...@apache.org on 2017/03/24 13:56:54 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled - posted by gr...@apache.org on 2017/03/24 16:22:55 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6128] [tests] Optimize JVM options to improve test performance - posted by gr...@apache.org on 2017/03/24 16:22:56 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend (backport from 1.3) - posted by sr...@apache.org on 2017/03/24 17:51:43 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend (backport from 1.3) - posted by sr...@apache.org on 2017/03/24 17:51:44 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend (backport from 1.3) - posted by sr...@apache.org on 2017/03/24 17:51:45 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-5658] [table] Add event-time OVER ROWS/RANGE UNBOUNDED PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/24 19:23:35 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization. - posted by fh...@apache.org on 2017/03/24 19:23:36 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-5570] [table] Register ExternalCatalogs in TableEnvironment. - posted by fh...@apache.org on 2017/03/24 19:23:37 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-5990] [table] Add event-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/24 19:23:38 UTC, 0 replies.
- [5/5] flink git commit: [hotfix] [table] Improved code documentation for external catalog. - posted by fh...@apache.org on 2017/03/24 19:23:39 UTC, 0 replies.
- flink git commit: [hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window. - posted by fh...@apache.org on 2017/03/24 20:28:21 UTC, 0 replies.
- flink git commit: [hotfix] [kafka] Add log info for partitions subscribed by FlinkKafkaConsumer subtasks - posted by tz...@apache.org on 2017/03/25 06:10:20 UTC, 0 replies.
- flink git commit: [FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface. - posted by fh...@apache.org on 2017/03/25 07:00:32 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction - posted by al...@apache.org on 2017/03/25 16:01:36 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction - posted by al...@apache.org on 2017/03/25 16:01:37 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] Make GC test more strict in WindowOperatorContractTest - posted by al...@apache.org on 2017/03/25 16:01:38 UTC, 0 replies.
- flink git commit: [hotfix] [docs] Fix broken links - posted by uc...@apache.org on 2017/03/27 10:13:27 UTC, 0 replies.
- flink git commit: [FLINK-5911] [gelly] Command-line parameters - posted by gr...@apache.org on 2017/03/27 10:55:16 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions. - posted by kk...@apache.org on 2017/03/28 16:01:16 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions. - posted by kk...@apache.org on 2017/03/28 16:01:17 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions. - posted by kk...@apache.org on 2017/03/28 16:01:18 UTC, 0 replies.
- [4/4] flink git commit: comments - posted by kk...@apache.org on 2017/03/28 16:01:19 UTC, 0 replies.
- flink git commit: [FLINK-6207] Duplicate TypeSerializers for async snapshots of CopyOnWriteStateTable - posted by sr...@apache.org on 2017/03/28 17:16:02 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams - posted by sr...@apache.org on 2017/03/28 18:05:51 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams - posted by sr...@apache.org on 2017/03/28 18:05:52 UTC, 0 replies.
- flink git commit: [FLINK-6211] [kinesis] Fix AT_TIMESTAMP config validation for FlinkKinesisConsumer - posted by tz...@apache.org on 2017/03/29 14:28:00 UTC, 0 replies.
- [1/3] flink-web git commit: New blog post about Table & SQL API's current state - posted by tw...@apache.org on 2017/03/29 16:47:38 UTC, 0 replies.
- [2/3] flink-web git commit: Rebuild website and update date of release 1.1.5 - posted by tw...@apache.org on 2017/03/29 16:47:39 UTC, 0 replies.
- [3/3] flink-web git commit: Rebuild website and update date of release 1.1.5 - posted by tw...@apache.org on 2017/03/29 16:47:40 UTC, 0 replies.
- [1/7] flink git commit: [hotfix] [dist. coordination] Clean up exception signature of ExecutionGraph - posted by se...@apache.org on 2017/03/29 22:51:08 UTC, 0 replies.
- [2/7] flink git commit: [hotfix] [dist. coordination] Add safety check for execution graph state transitions - posted by se...@apache.org on 2017/03/29 22:51:09 UTC, 0 replies.
- [3/7] flink git commit: [hotfix] [dist. coordination] Small code cleanups in ExecutionGraph and related classes - posted by se...@apache.org on 2017/03/29 22:51:10 UTC, 0 replies.
- [4/7] flink git commit: [hotfix] [dist. coordination] Move metrics out of the Execution Graph - posted by se...@apache.org on 2017/03/29 22:51:11 UTC, 0 replies.
- [5/7] flink git commit: [hotfix] [dist. coordination] Fix waiting for execution termination - posted by se...@apache.org on 2017/03/29 22:51:12 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-5340] [metrics] Add an uptime and downtime metric to the Execution Graph. - posted by se...@apache.org on 2017/03/29 22:51:13 UTC, 0 replies.
- [7/7] flink git commit: [hotfix] [dist. coordination] Remove redundant method 'ExecutionVertex.getSimpleName()' - posted by se...@apache.org on 2017/03/29 22:51:14 UTC, 0 replies.
- flink git commit: [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/30 07:53:41 UTC, 0 replies.
- flink git commit: [FLINK-6165] [cep] Implement internal continuity for looping states. - posted by kk...@apache.org on 2017/03/30 11:22:34 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/30 22:03:06 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window. - posted by fh...@apache.org on 2017/03/30 22:03:07 UTC, 0 replies.
- [01/50] [abbrv] flink git commit: [FLINK-6139] [build] Add "mapr" build profile - posted by fh...@apache.org on 2017/03/30 22:04:12 UTC, 0 replies.
- [02/50] [abbrv] flink git commit: [FLINK-5067][hotfix] Fix snapshot deployment - posted by fh...@apache.org on 2017/03/30 22:04:13 UTC, 0 replies.
- [03/50] [abbrv] flink git commit: [FLINK-6170] [metrics] Don't rely on stats snapshot for checkpoint metrics - posted by fh...@apache.org on 2017/03/30 22:04:14 UTC, 0 replies.
- [04/50] [abbrv] flink git commit: [FLINK-3318] Backward compatibility of CEP NFA - posted by fh...@apache.org on 2017/03/30 22:04:15 UTC, 0 replies.
- [05/50] [abbrv] flink git commit: [FLINK-3318] Add support for quantifiers to CEP's pattern API - posted by fh...@apache.org on 2017/03/30 22:04:16 UTC, 0 replies.
- [06/50] [abbrv] flink git commit: [FLINK-3318] Add support for quantifiers to CEP's pattern API - posted by fh...@apache.org on 2017/03/30 22:04:17 UTC, 0 replies.
- [07/50] [abbrv] flink git commit: [FLINK-4354] [heartbeat] Add heartbeats between the ResourceManager and TaskExecutor - posted by fh...@apache.org on 2017/03/30 22:04:18 UTC, 0 replies.
- [08/50] [abbrv] flink git commit: [FLINK-4354] [heartbeat] Implement heartbeat logic between TaskManager and ResourceManager - posted by fh...@apache.org on 2017/03/30 22:04:19 UTC, 0 replies.
- [09/50] [abbrv] flink git commit: [hotfix][scripts] Fix zookeeper quorum regex - posted by fh...@apache.org on 2017/03/30 22:04:20 UTC, 0 replies.
- [10/50] [abbrv] flink git commit: [FLINK-6129] [metrics] Stop query actor of MetricRegistry - posted by fh...@apache.org on 2017/03/30 22:04:21 UTC, 0 replies.
- [11/50] [abbrv] flink git commit: [hotfix] Fix various small issues in WindowOperatorContractTest - posted by fh...@apache.org on 2017/03/30 22:04:22 UTC, 0 replies.
- [12/50] [abbrv] flink git commit: [hotfix] Add EvictingWindowOperatorContractTest - posted by fh...@apache.org on 2017/03/30 22:04:23 UTC, 0 replies.
- [13/50] [abbrv] flink git commit: [FLINK-5972] Don't allow shrinking merging windows - posted by fh...@apache.org on 2017/03/30 22:04:24 UTC, 0 replies.
- [14/50] [abbrv] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types - posted by fh...@apache.org on 2017/03/30 22:04:25 UTC, 0 replies.
- [15/50] [abbrv] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types - posted by fh...@apache.org on 2017/03/30 22:04:26 UTC, 0 replies.
- [16/50] [abbrv] flink git commit: [hotfix] Remove validateRunsInMainThread from TaskExecutor to fix TaskExecutorTest - posted by fh...@apache.org on 2017/03/30 22:04:27 UTC, 0 replies.
- [17/50] [abbrv] flink git commit: [FLINK-6182] Fix possible NPE in SourceStreamTask - posted by fh...@apache.org on 2017/03/30 22:04:28 UTC, 0 replies.
- [18/50] [abbrv] flink git commit: [FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled - posted by fh...@apache.org on 2017/03/30 22:04:29 UTC, 0 replies.
- [19/50] [abbrv] flink git commit: [FLINK-6128] [tests] Optimize JVM options to improve test performance - posted by fh...@apache.org on 2017/03/30 22:04:30 UTC, 0 replies.
- [20/50] [abbrv] flink git commit: [FLINK-5658] [table] Add event-time OVER ROWS/RANGE UNBOUNDED PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/30 22:04:31 UTC, 0 replies.
- [21/50] [abbrv] flink git commit: [FLINK-5990] [table] Add event-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/30 22:04:32 UTC, 0 replies.
- [22/50] [abbrv] flink git commit: [hotfix] [table] Improved code documentation for external catalog. - posted by fh...@apache.org on 2017/03/30 22:04:33 UTC, 0 replies.
- [23/50] [abbrv] flink git commit: [FLINK-5570] [table] Register ExternalCatalogs in TableEnvironment. - posted by fh...@apache.org on 2017/03/30 22:04:34 UTC, 0 replies.
- [24/50] [abbrv] flink git commit: [FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization. - posted by fh...@apache.org on 2017/03/30 22:04:35 UTC, 0 replies.
- [25/50] [abbrv] flink git commit: [hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window. - posted by fh...@apache.org on 2017/03/30 22:04:36 UTC, 0 replies.
- [26/50] [abbrv] flink git commit: [FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface. - posted by fh...@apache.org on 2017/03/30 22:04:37 UTC, 0 replies.
- [27/50] [abbrv] flink git commit: [FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction - posted by fh...@apache.org on 2017/03/30 22:04:38 UTC, 0 replies.
- [28/50] [abbrv] flink git commit: [FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction - posted by fh...@apache.org on 2017/03/30 22:04:39 UTC, 0 replies.
- [29/50] [abbrv] flink git commit: [hotfix] Make GC test more strict in WindowOperatorContractTest - posted by fh...@apache.org on 2017/03/30 22:04:40 UTC, 0 replies.
- [30/50] [abbrv] flink git commit: [hotfix] [docs] Fix broken links - posted by fh...@apache.org on 2017/03/30 22:04:41 UTC, 0 replies.
- [31/50] [abbrv] flink git commit: [FLINK-5911] [gelly] Command-line parameters - posted by fh...@apache.org on 2017/03/30 22:04:42 UTC, 0 replies.
- [32/50] [abbrv] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions. - posted by fh...@apache.org on 2017/03/30 22:04:43 UTC, 0 replies.
- [33/50] [abbrv] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions. - posted by fh...@apache.org on 2017/03/30 22:04:44 UTC, 0 replies.
- [34/50] [abbrv] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions. - posted by fh...@apache.org on 2017/03/30 22:04:45 UTC, 0 replies.
- [35/50] [abbrv] flink git commit: comments - posted by fh...@apache.org on 2017/03/30 22:04:46 UTC, 0 replies.
- [36/50] [abbrv] flink git commit: [FLINK-6207] Duplicate TypeSerializers for async snapshots of CopyOnWriteStateTable - posted by fh...@apache.org on 2017/03/30 22:04:47 UTC, 0 replies.
- [37/50] [abbrv] flink git commit: [FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams - posted by fh...@apache.org on 2017/03/30 22:04:48 UTC, 0 replies.
- [38/50] [abbrv] flink git commit: [FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams - posted by fh...@apache.org on 2017/03/30 22:04:49 UTC, 0 replies.
- [39/50] [abbrv] flink git commit: [FLINK-6211] [kinesis] Fix AT_TIMESTAMP config validation for FlinkKinesisConsumer - posted by fh...@apache.org on 2017/03/30 22:04:50 UTC, 0 replies.
- [40/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Clean up exception signature of ExecutionGraph - posted by fh...@apache.org on 2017/03/30 22:04:51 UTC, 0 replies.
- [41/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Small code cleanups in ExecutionGraph and related classes - posted by fh...@apache.org on 2017/03/30 22:04:52 UTC, 0 replies.
- [42/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Add safety check for execution graph state transitions - posted by fh...@apache.org on 2017/03/30 22:04:53 UTC, 0 replies.
- [43/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Fix waiting for execution termination - posted by fh...@apache.org on 2017/03/30 22:04:54 UTC, 0 replies.
- [44/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Move metrics out of the Execution Graph - posted by fh...@apache.org on 2017/03/30 22:04:55 UTC, 0 replies.
- [45/50] [abbrv] flink git commit: [FLINK-5340] [metrics] Add an uptime and downtime metric to the Execution Graph. - posted by fh...@apache.org on 2017/03/30 22:04:56 UTC, 0 replies.
- [46/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Remove redundant method 'ExecutionVertex.getSimpleName()' - posted by fh...@apache.org on 2017/03/30 22:04:57 UTC, 0 replies.
- [47/50] [abbrv] flink git commit: [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/30 22:04:58 UTC, 0 replies.
- [48/50] [abbrv] flink git commit: [FLINK-6165] [cep] Implement internal continuity for looping states. - posted by fh...@apache.org on 2017/03/30 22:04:59 UTC, 0 replies.
- [49/50] [abbrv] flink git commit: [FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window. - posted by fh...@apache.org on 2017/03/30 22:05:00 UTC, 0 replies.
- [50/50] [abbrv] flink git commit: [FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/30 22:05:01 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5625] [kinesis] Configurable date format for timestamp-based start position in FlinkKinesisConsumer - posted by tz...@apache.org on 2017/03/31 04:38:30 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-4577] [kinesis] Transparent reshard handling for FlinkKinesisConsumer - posted by tz...@apache.org on 2017/03/31 04:38:31 UTC, 0 replies.
- flink git commit: [FLINK-6205] [FLINK-6069] [cep] Correct watermark/late events in side output. - posted by kk...@apache.org on 2017/03/31 10:30:54 UTC, 0 replies.
- flink git commit: [FLINK-5915] [table] Forward the complete aggregate ArgList to aggregate runtime functions. - posted by fh...@apache.org on 2017/03/31 13:14:53 UTC, 0 replies.
- flink git commit: [FLINK-5903] [yarn] Respect taskmanager.numberOfTaskSlots config value in Yarn mode - posted by tr...@apache.org on 2017/03/31 13:38:15 UTC, 0 replies.
- [1/2] flink git commit: [build system] try other travis infrastructure - posted by rm...@apache.org on 2017/03/31 14:43:33 UTC, 0 replies.
- [2/2] flink git commit: forkcount on travis is 2, so 3GB per parallel test - posted by rm...@apache.org on 2017/03/31 14:43:34 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-2814] [optimizer] DualInputPlanNode cannot be cast to SingleInputPlanNode - posted by gr...@apache.org on 2017/03/31 16:35:24 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-3695] [gelly] ValueArray types - posted by gr...@apache.org on 2017/03/31 16:35:25 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-3695] [gelly] ValueArray types - posted by gr...@apache.org on 2017/03/31 16:35:26 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-5912] [gelly] Inputs for CSV and graph generators - posted by gr...@apache.org on 2017/03/31 16:35:27 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-5913] [gelly] Example drivers - posted by gr...@apache.org on 2017/03/31 16:35:28 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-5913] [gelly] Example drivers - posted by gr...@apache.org on 2017/03/31 16:35:29 UTC, 0 replies.
- flink git commit: [FLINK-5654] [table] Add processing-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. - posted by fh...@apache.org on 2017/03/31 19:52:55 UTC, 0 replies.
- flink git commit: [FLINK-4949] [gelly] Refactor Gelly driver inputs - posted by gr...@apache.org on 2017/03/31 20:34:57 UTC, 0 replies.