flink-commits mailing list archives: October 2017

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
aljos...@apache.org [1/7] flink git commit: [FLINK-5619] Add numStateEntries() method for all keyed backends Mon, 02 Oct, 08:19
aljos...@apache.org [2/7] flink git commit: [FLINK-7700] Fix RocksDB ListState merging Mon, 02 Oct, 08:19
aljos...@apache.org [3/7] flink git commit: [FLINK-5619] Consolidate ReducingState Tests in StateBackendTestBase Mon, 02 Oct, 08:19
aljos...@apache.org [4/7] flink git commit: [FLINK-7700] Fix RocksDB ReducingState merging Mon, 02 Oct, 08:19
aljos...@apache.org [5/7] flink git commit: [FLINK-5619] Consolidate ListState Tests in StateBackendTestBase Mon, 02 Oct, 08:19
aljos...@apache.org [6/7] flink git commit: [FLINK-7700] Fix RocksDB AggregatingState merging Mon, 02 Oct, 08:19
aljos...@apache.org [7/7] flink git commit: [FLINK-5619] Consolidate AggregatingState Tests in StateBackendTestBase Mon, 02 Oct, 08:19
aljos...@apache.org flink git commit: [FLINK-7721] [DataStream] Only emit new min watermark iff it was aggregated from watermark-aligned inputs Mon, 02 Oct, 09:23
se...@apache.org flink git commit: [FLINK-7662] [build] Remove now obsolete packaged licenses for previously shaded ASM Mon, 02 Oct, 12:38
aljos...@apache.org flink git commit: [FLINK-7721] [DataStream] Only emit new min watermark iff it was aggregated from watermark-aligned inputs Mon, 02 Oct, 14:41
aljos...@apache.org [1/4] flink git commit: [FLINK-7721] Verify StatusWatermarkValve only emits WM iff it has aligned inputs Mon, 02 Oct, 14:46
aljos...@apache.org [2/4] flink git commit: [FLINK-7728] [DataStream] Flush max watermark across all inputs once all become idle Mon, 02 Oct, 14:46
aljos...@apache.org [3/4] flink git commit: [FLINK-7728] [DataStream] Make StatusWatermarkValve unit tests more fine-grained Mon, 02 Oct, 14:46
aljos...@apache.org [4/4] flink git commit: [FLINK-7728] [DataStream] Simplify BufferedValveOutputHandler used in StatusWatermarkValveTest Mon, 02 Oct, 14:46
aljos...@apache.org [1/4] flink git commit: [FLINK-7728] [DataStream] Simplify BufferedValveOutputHandler used in StatusWatermarkValveTest Mon, 02 Oct, 14:54
aljos...@apache.org [2/4] flink git commit: [FLINK-7728] [DataStream] Flush max watermark across all inputs once all become idle Mon, 02 Oct, 14:54
aljos...@apache.org [3/4] flink git commit: [FLINK-7728] [DataStream] Make StatusWatermarkValve unit tests more fine-grained Mon, 02 Oct, 14:54
aljos...@apache.org [4/4] flink git commit: [FLINK-7721] Verify StatusWatermarkValve only emits WM iff it has aligned inputs Mon, 02 Oct, 14:54
trohrm...@apache.org [1/5] flink git commit: [FLINK-7668] Add ExecutionGraphCache for ExecutionGraph based REST handlers Mon, 02 Oct, 20:29
trohrm...@apache.org [2/5] flink git commit: [FLINK-7668] Add ExecutionGraphCache for ExecutionGraph based REST handlers Mon, 02 Oct, 20:29
trohrm...@apache.org [3/5] flink git commit: [FLINK-7695] [flip6] Add JobConfigHandler for new RestServerEndpoint Mon, 02 Oct, 20:29
trohrm...@apache.org [4/5] flink git commit: [FLINK-7708] [flip6] Add CheckpointConfigHandler for new REST endpoint Mon, 02 Oct, 20:29
trohrm...@apache.org [5/5] flink git commit: [FLINK-7710] [flip6] Add CheckpointStatisticsHandler for the new REST endpoint Mon, 02 Oct, 20:29
ches...@apache.org flink git commit: [hotfix] [dispatcher] Remove leftover javadoc from DispatcherGateway Mon, 02 Oct, 20:59
build...@apache.org buildbot failure in on flink-docs-release-1.3 Tue, 03 Oct, 01:06
trohrm...@apache.org flink git commit: [FLINK-7412][network] optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly Wed, 04 Oct, 13:14
trohrm...@apache.org flink git commit: [FLINK-7752] [flip-6] RedirectHandler should execute on the IO thread Wed, 04 Oct, 15:52
se...@apache.org [1/3] flink git commit: [hotfix] [hbase] Set root log level to OFF for flink-hbase tests. Wed, 04 Oct, 19:12
se...@apache.org [2/3] flink git commit: [hotfix] Fix testing log level in flink-runtime Wed, 04 Oct, 19:12
se...@apache.org [3/3] flink git commit: [hotfix] [core] Prevent potential null pointer in MemorySize.equals(...) Wed, 04 Oct, 19:12
fhue...@apache.org flink git commit: [FLINK-7446] [table] Change DefinedRowtimeAttribute to work on existing field. Thu, 05 Oct, 07:09
trohrm...@apache.org flink git commit: [FLINK-7754] [rpc] Complete termination future after actor has been stopped Thu, 05 Oct, 12:53
trohrm...@apache.org [01/14] flink git commit: [FLINK-7057][tests][hotfix] fix test instability of JobManagerCleanupITCase#testBlobServerCleanupCancelledJob Thu, 05 Oct, 14:06
trohrm...@apache.org [02/14] flink git commit: [FLINK-7483][blob] prevent cleanup of re-registered jobs Thu, 05 Oct, 14:06
trohrm...@apache.org [03/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs Thu, 05 Oct, 14:06
trohrm...@apache.org [04/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs Thu, 05 Oct, 14:06
trohrm...@apache.org [05/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs Thu, 05 Oct, 14:06
trohrm...@apache.org [06/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs Thu, 05 Oct, 14:06
trohrm...@apache.org [07/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs Thu, 05 Oct, 14:07
trohrm...@apache.org [08/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs Thu, 05 Oct, 14:07
trohrm...@apache.org [09/14] flink git commit: [FLINK-7261][blob] extend BlobStore#get/put with boolean return values Thu, 05 Oct, 14:07
trohrm...@apache.org [10/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys Thu, 05 Oct, 14:07
trohrm...@apache.org [11/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys Thu, 05 Oct, 14:07
trohrm...@apache.org [12/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys Thu, 05 Oct, 14:07
trohrm...@apache.org [13/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys Thu, 05 Oct, 14:07
trohrm...@apache.org [14/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys Thu, 05 Oct, 14:07
aljos...@apache.org flink git commit: [hotfix] Fix checkstyle problem in StatusWatermarkValve Fri, 06 Oct, 08:17
se...@apache.org [1/4] flink git commit: [FLINK-7643] [core] Drop eager checks for file system support. Fri, 06 Oct, 10:05
se...@apache.org [2/4] flink git commit: [FLINK-7643] [core] Misc. cleanups in FileSystem Fri, 06 Oct, 10:05
se...@apache.org [3/4] flink git commit: [FLINK-7643] [core] Rework FileSystem loading to use factories Fri, 06 Oct, 10:05
se...@apache.org [4/4] flink git commit: [FLINK-7643] [core] Rework FileSystem loading to use factories Fri, 06 Oct, 10:05
se...@apache.org [1/2] flink git commit: [FLINK-7766] [file system sink] Drop obsolete reflective hflush calls Fri, 06 Oct, 16:53
se...@apache.org [2/2] flink git commit: [FLINK-7767] [file system sinks] Avoid loading Hadoop conf dynamically at runtime Fri, 06 Oct, 16:53
se...@apache.org [1/3] flink git commit: [FLINK-7768] [core] Load File Systems via Java Service abstraction Fri, 06 Oct, 17:54
se...@apache.org [2/3] flink git commit: [FLINK-7768] [core] Load File Systems via Java Service abstraction Fri, 06 Oct, 17:54
se...@apache.org [3/3] flink git commit: [FLINK-7768] [core] Load File Systems via Java Service abstraction Fri, 06 Oct, 17:54
build...@apache.org buildbot success in on flink-docs-release-1.3 Sat, 07 Oct, 02:10
se...@apache.org [01/10] flink git commit: [hotfix] [docs] Fix broken links Sun, 08 Oct, 19:38
se...@apache.org [02/10] flink git commit: [FLINK-7772][blob] fix test instability in BlobCacheDeleteTest Sun, 08 Oct, 19:38
se...@apache.org [03/10] flink git commit: [hotfix] [build] Remove no longer needed explicit Hadoop exclusions Sun, 08 Oct, 19:38
se...@apache.org [04/10] flink git commit: [hotfix] [build] Properly exclude flink-python artifact from fat dist jar Sun, 08 Oct, 19:38
se...@apache.org [05/10] flink git commit: [FLINK-7742] [java api] [runtime] Fix array index out of bounds exceptions Sun, 08 Oct, 19:38
se...@apache.org [06/10] flink git commit: [FLINK-7739] [kafka connector] Fix test instabilities Sun, 08 Oct, 19:38
se...@apache.org [07/10] flink git commit: [hotfix] [build] Remove incorrect and ineffective example exclusions Sun, 08 Oct, 19:38
se...@apache.org [08/10] flink git commit: [FLINK-7312] [checkstyle] Enable checkstyle for 'flink/core/memory/*' Sun, 08 Oct, 19:38
se...@apache.org [09/10] flink git commit: [FLINK-7312] [checkstyle] Enable checkstyle for 'flink/core/memory/*' Sun, 08 Oct, 19:38
se...@apache.org [10/10] flink git commit: [FLINK-7310] [core] always use the HybridMemorySegment Sun, 08 Oct, 19:38
se...@apache.org [1/3] flink git commit: [hotfix] [docs] Fix broken links Sun, 08 Oct, 19:42
se...@apache.org [2/3] flink git commit: [FLINK-7742] [java api] [runtime] Fix array index out of bounds exceptions Sun, 08 Oct, 19:42
se...@apache.org [3/3] flink git commit: [FLINK-7739] [kafka connector] Fix test instabilities Sun, 08 Oct, 19:42
build...@apache.org buildbot failure in on flink-docs-release-1.3 Mon, 09 Oct, 01:13
ches...@apache.org flink git commit: [FLINK-7575] [webui] Show "Fetching" instead of 0 when IO metrics are not yet retrieved Mon, 09 Oct, 14:04
ches...@apache.org flink git commit: [FLINK-7761] [examples] Include shaded guava dependency in Twitter example jar Mon, 09 Oct, 16:09
aljos...@apache.org [1/9] flink git commit: [FLINK-6988][kafka] Add Kafka 0.11 tests for scaling down and up again Mon, 09 Oct, 16:59
aljos...@apache.org [2/9] flink git commit: [hotfix][streaming] Fix typo in parameter and unify naming in test harnesses Mon, 09 Oct, 16:59
aljos...@apache.org [3/9] flink git commit: [FLINK-6988] Make TwoPhaseCommitSinkFunction work with Context Mon, 09 Oct, 16:59
aljos...@apache.org [4/9] flink git commit: [FLINK-6988] Add Kafka 0.11 connector maven module Mon, 09 Oct, 16:59
aljos...@apache.org [5/9] flink git commit: [hotfix] Don't use deprecated writeWithTimestamps in Kafka 0.10 tests Mon, 09 Oct, 16:59
aljos...@apache.org [6/9] flink git commit: [FLINK-6988][kafka] Implement our own KafkaProducer class with transactions recovery Mon, 09 Oct, 16:59
aljos...@apache.org [7/9] flink git commit: [FLINK-6988][kafka] Add test for failure before before checkpoint and scaling down Mon, 09 Oct, 16:59
aljos...@apache.org [8/9] flink git commit: [FLINK-6988][kafka] Add flink-connector-kafka-0.11 with exactly-once semantic Mon, 09 Oct, 16:59
aljos...@apache.org [9/9] flink git commit: [FLINK-6988][kafka] Add flink-connector-kafka-0.11 with exactly-once semantic Mon, 09 Oct, 16:59
trohrm...@apache.org [1/3] flink git commit: [hotfix] [REST] Add utility HandlerRequest constructor Mon, 09 Oct, 17:11
trohrm...@apache.org [2/3] flink git commit: [FLINK-7072] [REST] Define protocol for job submit/cancel/stop Mon, 09 Oct, 17:11
trohrm...@apache.org [3/3] flink git commit: [FLINK-7072] [REST] Define protocol for job submit/cancel/stop Mon, 09 Oct, 17:11
Apache Jenkins Server Build failed in Jenkins: flink-snapshot-deployment #615 Tue, 10 Oct, 04:01
ches...@apache.org flink git commit: [FLINK-7744][docs] Add missing top links to documentation Tue, 10 Oct, 12:05
ches...@apache.org flink git commit: [hotfix] [docs] Polish grammar and tone for consistency and clarity Tue, 10 Oct, 12:09
ches...@apache.org flink git commit: [FLINK-7632] [docs] Overhaul Cassandra connector docs Tue, 10 Oct, 12:40
aljos...@apache.org flink git commit: [hotfix] Remove exception stack trace from Emitter shutdown message Tue, 10 Oct, 13:57
ches...@apache.org [1/3] flink git commit: [FLINK-7394][core] Manage exclusive buffers in RemoteInputChannel Tue, 10 Oct, 14:53
ches...@apache.org [2/3] flink git commit: [FLINK-7378][core] Create a fix size (non rebalancing) buffer pool type for the floating buffers Tue, 10 Oct, 14:53
ches...@apache.org [3/3] flink git commit: [FLINK-7699][core] Define the BufferListener interface to replace EventlListener in BufferProvider Tue, 10 Oct, 14:53
ches...@apache.org flink git commit: [FLINK-7790] [REST] Unresolved query params not added to request URL Tue, 10 Oct, 14:56
trohrm...@apache.org [1/3] flink git commit: [FLINK-7709] Add CheckpointStatisticDetailsHandler for new REST endpoint Tue, 10 Oct, 15:35
trohrm...@apache.org [2/3] flink git commit: [FLINK-7709] Add CheckpointStatisticDetailsHandler for new REST endpoint Tue, 10 Oct, 15:35
trohrm...@apache.org [3/3] flink git commit: [FLINK-7709] Add CheckpointStatisticDetailsHandler for new REST endpoint Tue, 10 Oct, 15:35
trohrm...@apache.org flink git commit: [FLINK-7704] [flip6] Add JobPlanHandler for new RestServerEndpoint Tue, 10 Oct, 21:03
fhue...@apache.org [1/5] flink git commit: [FLINK-7410] [table] Use UserDefinedFunction.toString() to display operator names of UDFs. Tue, 10 Oct, 21:09
fhue...@apache.org [2/5] flink git commit: [FLINK-7776] [table] Prevent emission of identical update records in group aggregation. Tue, 10 Oct, 21:09
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
Box list
Oct 2018439
Sep 2018487
Aug 2018448
Jul 2018599
Jun 2018236
May 2018525
Apr 2018365
Mar 2018538
Feb 2018606
Jan 2018405
Dec 2017177
Nov 2017468
Oct 2017356
Sep 2017219
Aug 2017263
Jul 2017462
Jun 2017321
May 2017729
Apr 2017307
Mar 2017394
Feb 2017310
Jan 2017807
Dec 2016417
Nov 2016314
Oct 2016524
Sep 2016371
Aug 2016522
Jul 2016290
Jun 2016252
May 2016217
Apr 2016312
Mar 2016335
Feb 2016514
Jan 2016272
Dec 2015147
Nov 2015352
Oct 2015476
Sep 2015310
Aug 2015328
Jul 2015350
Jun 2015373
May 2015339
Apr 2015399
Mar 2015397
Feb 2015422
Jan 2015334
Dec 2014211
Nov 2014170
Oct 2014186
Sep 2014307
Aug 2014276
Jul 2014291
Jun 2014270