flink-commits mailing list archives: October 2015

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
build...@apache.org buildbot failure in ASF Buildbot on flink-docs-release-0.9 Thu, 01 Oct, 01:00
se...@apache.org [1/3] flink git commit: [FLINK-2781] [core] Cleanup NetUtils. Thu, 01 Oct, 07:16
se...@apache.org [2/3] flink git commit: [FLINK-2766] [core] Add proper handling of IPv6 address literals in URLs Thu, 01 Oct, 07:16
se...@apache.org [3/3] flink git commit: [hotfix] [build] Add joda-convert as a non-optional dependency, to fix Scala interoperability Thu, 01 Oct, 07:16
se...@apache.org [1/9] flink git commit: [FLINK-2787] [core] Prevent instantiation of RemoteEnvironment when running a program through the command line. Thu, 01 Oct, 09:54
se...@apache.org [2/9] flink git commit: [streaming] [storm] Clean up instantiation of mini clusters and test environments. Thu, 01 Oct, 09:54
se...@apache.org [3/9] flink git commit: [streaming] [storm] Clean up instantiation of mini clusters and test environments. Thu, 01 Oct, 09:54
se...@apache.org [4/9] flink git commit: [FLINK-2783] Remove "degreeOfParallelism" API calls Thu, 01 Oct, 09:54
se...@apache.org [5/9] flink git commit: [hotfix] Simplify new windowing API Thu, 01 Oct, 09:54
se...@apache.org [6/9] flink git commit: [hotfix] Simplify new windowing API Thu, 01 Oct, 09:54
se...@apache.org [7/9] flink git commit: [FLINK-2561] [gelly] add Scala Gelly docs Thu, 01 Oct, 09:54
se...@apache.org [8/9] flink git commit: [FLINK-2778] Add API for non-parallel non-keyed Windows Thu, 01 Oct, 09:54
se...@apache.org [9/9] flink git commit: [hotfix] [tests] Run IPv6HostnamesITCase with parallel data exchange and less verbose output Thu, 01 Oct, 09:54
mj...@apache.org flink git commit: [doc] fixed typos in "Internals -> Fault Tolerance for Data Streaming" Thu, 01 Oct, 12:08
va...@apache.org flink git commit: [FLINK-2663] [gelly] Updated Gelly library methods to use generic key types Thu, 01 Oct, 19:55
build...@apache.org buildbot success in ASF Buildbot on flink-docs-release-0.9 Fri, 02 Oct, 01:21
mj...@apache.org flink git commit: [FLINK-2525] Add configuration support in Storm-compatibility Fri, 02 Oct, 08:50
m..@apache.org [1/4] flink git commit: [FLINK-2748][jobmanager] accumulator fetch failure leads to duplicate job result response Fri, 02 Oct, 09:56
m..@apache.org [2/4] flink git commit: [FLINK-2776][cli] print job id when submitting a job Fri, 02 Oct, 09:56
m..@apache.org [3/4] flink git commit: [FLINK-1599][docs] TypeComperator with no keys and comparators matches some elements Fri, 02 Oct, 09:56
m..@apache.org [4/4] flink git commit: [FLINK-2762][cli] print execution result only if available Fri, 02 Oct, 09:56
m..@apache.org flink git commit: [FLINK-2796][cli] fix -q flag to suppress log output Fri, 02 Oct, 11:50
se...@apache.org [1/3] flink git commit: [FLINK-2727] [streaming] Add a base class for Message Queue Sources that acknowledge messages by ID. Fri, 02 Oct, 14:50
se...@apache.org [2/3] flink git commit: [hotfix] [streaming] Apply closure cleaner to KeyedWindowFunction Fri, 02 Oct, 14:51
se...@apache.org [3/3] flink git commit: [hotfix] [streaming] Handle rich functions properly in aligned time windows Fri, 02 Oct, 14:51
gyf...@apache.org flink git commit: [FLINK-2802] [streaming] Remove cyclic watermark dependencies for iterations Sun, 04 Oct, 09:02
aljos...@apache.org flink git commit: [FLINK-2666] Add timestamp extraction operator Sun, 04 Oct, 15:10
build...@apache.org buildbot failure in ASF Buildbot on flink-docs-master Mon, 05 Oct, 00:00
rmetz...@apache.org [1/2] flink git commit: [hotfix] Execute YARN integration tests only upon request (by activating the 'include-yarn-tests' profile) Mon, 05 Oct, 01:55
rmetz...@apache.org [2/2] flink git commit: [FLINK-2740] Adding flink-connector-nifi module with NiFiSource and NiFiSink Mon, 05 Oct, 01:55
aljos...@apache.org [01/13] flink git commit: [FLINK-2550] Rename SplitDataStream to SplitStream Mon, 05 Oct, 14:42
aljos...@apache.org [02/13] flink git commit: [hotfix] Use closure cleaner for reduce window Mon, 05 Oct, 14:42
aljos...@apache.org [03/13] flink git commit: Add Scala API for new Windowing Mon, 05 Oct, 14:42
aljos...@apache.org [04/13] flink git commit: [FLINK-2550] Simplify Stream Java API Class Names Mon, 05 Oct, 14:42
aljos...@apache.org [05/13] flink git commit: [FLINK-2550] Simplify Stream Java API Class Names Mon, 05 Oct, 14:42
aljos...@apache.org [06/13] flink git commit: [FLINK-2550] Rename ConnectedDataStream to ConnectedStreams, Remove some operations Mon, 05 Oct, 14:42
aljos...@apache.org [07/13] flink git commit: [FLINK-2550] Rename ConnectedDataStream to ConnectedStreams, Remove some operations Mon, 05 Oct, 14:42
aljos...@apache.org [08/13] flink git commit: Disable tests because operators are not implemented yet Mon, 05 Oct, 14:42
aljos...@apache.org [09/13] flink git commit: [FLINK-2550] Remove groupBy and GroupedDataStream Mon, 05 Oct, 14:42
aljos...@apache.org [10/13] flink git commit: [FLINK-2550] Remove groupBy and GroupedDataStream Mon, 05 Oct, 14:42
aljos...@apache.org [11/13] flink git commit: [FLINK-2550] Change Window API constructs to use Time instead of long Mon, 05 Oct, 14:42
aljos...@apache.org [12/13] flink git commit: [FLINK-2550] Rename IterativeDataStream to IterativeStream Mon, 05 Oct, 14:42
aljos...@apache.org [13/13] flink git commit: [FLINK-2807] Add Javadocs for new windowing semantics/internals Mon, 05 Oct, 14:42
build...@apache.org buildbot success in ASF Buildbot on flink-docs-master Tue, 06 Oct, 00:22
m..@apache.org [1/3] flink git commit: [FLINK-2810] Warn user if bc not installed Tue, 06 Oct, 08:47
m..@apache.org [2/3] flink git commit: [FLINK-2813] document parameter for off-heap memory Tue, 06 Oct, 08:47
m..@apache.org [3/3] flink git commit: [FLINK-1610] fix building of java doc for Java 8 Tue, 06 Oct, 08:47
m..@apache.org flink git commit: [FLINK-1610] fix building of java doc for Java 8 Tue, 06 Oct, 09:18
u..@apache.org [1/3] flink git commit: [FLINK-2811] [web-dashboard] Add job manager configuration overview Tue, 06 Oct, 09:39
u..@apache.org [2/3] flink git commit: [FLINK-2811] [web-dashboard] Add job manager configuration overview Tue, 06 Oct, 09:39
u..@apache.org [3/3] flink git commit: [FLINK-2811] [web-dashboard] Add job manager configuration overview Tue, 06 Oct, 09:39
u..@apache.org flink git commit: [FLINK-2741] Use single log statement in TestLogger Tue, 06 Oct, 09:43
va...@apache.org [1/2] flink git commit: [FLINK-2786] Remove Spargel code and docs; Port Spargel tests to Gelly; Remove Beta badge from Gelly Tue, 06 Oct, 10:14
va...@apache.org [2/2] flink git commit: [FLINK-2786] Remove Spargel code and docs; Port Spargel tests to Gelly; Remove Beta badge from Gelly Tue, 06 Oct, 10:14
mj...@apache.org [01/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [02/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [03/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [04/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [05/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [06/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [07/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [08/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [09/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [10/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [11/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [12/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [13/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * Tue, 06 Oct, 11:31
mj...@apache.org [14/15] flink git commit: [FLINK-2566] FlinkTopologyContext not populated completely - extended FlinkTopologyContext to be populted with all supportable attributes - added JUnit test - updated README.md additionally: module restructuring to get cle Tue, 06 Oct, 11:31
mj...@apache.org [15/15] flink git commit: [FLINK-2566] FlinkTopologyContext not populated completely - extended FlinkTopologyContext to be populted with all supportable attributes - added JUnit test - updated README.md additionally: module restructuring to get cle Tue, 06 Oct, 11:31
mbala...@apache.org flink git commit: [FLINK-2822] [streaming] Remove scala.Serializable imports Tue, 06 Oct, 12:22
twal...@apache.org flink git commit: [FLINK-2642] [table] Scala Table API crashes when executing word count example Tue, 06 Oct, 12:30
mbala...@apache.org [1/5] flink git commit: [FLINK-2283] [streaming] Proper serialization of state in StreamGroupedFold and Reduce Tue, 06 Oct, 15:12
mbala...@apache.org [2/5] flink git commit: [FLINK-2283] [streaming] Test for checkpointing in internal operators Tue, 06 Oct, 15:12
mbala...@apache.org [3/5] flink git commit: [streaming] Removed unused StreamReduce Tue, 06 Oct, 15:12
mbala...@apache.org [4/5] flink git commit: [FLINK-2283] [streaming] grouped reduce and fold operators checkpoint state Tue, 06 Oct, 15:12
mbala...@apache.org [5/5] flink git commit: [FLINK-2812] [streaming] KeySelectorUtil interacts well with type extraction Tue, 06 Oct, 15:12
hsapu...@apache.org [1/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference Tue, 06 Oct, 15:14
hsapu...@apache.org [2/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference Tue, 06 Oct, 15:14
hsapu...@apache.org [3/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference Tue, 06 Oct, 15:14
hsapu...@apache.org [4/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference Tue, 06 Oct, 15:14
hsapu...@apache.org [5/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference Tue, 06 Oct, 15:14
m..@apache.org [1/2] flink git commit: Revert "[FLINK-2203] handling null values for RowSerializer" Tue, 06 Oct, 15:21
m..@apache.org [2/2] flink git commit: Revert "[FLINK-2210] Table API support for aggregation on columns with null values" Tue, 06 Oct, 15:21
aljos...@apache.org flink git commit: Create a deep-copy of the record when changing timestamps. Tue, 06 Oct, 16:22
mj...@apache.org flink git commit: [FLINK-2825] FlinkClient.killTopology fails due to missing leader session ID Tue, 06 Oct, 22:52
fhue...@apache.org [1/2] flink git commit: [FLINK-2066][core] Add configuration of delay between execution retries at job level Wed, 07 Oct, 14:11
fhue...@apache.org [2/2] flink git commit: [FLINK-2767] [scala shell] Add Scala 2.11 support to Scala shell. Update Scala 2.11 version and jline dependency. Wed, 07 Oct, 14:11
chiwanp...@apache.org flink git commit: [FLINK-2806] [scala-api] Add a TypeInformation[Nothing] Wed, 07 Oct, 16:42
va...@apache.org flink git commit: [FLINK-2785] [gelly] implement fromCsvReader for gelly-scala; add tests and docs Wed, 07 Oct, 19:15
aljos...@apache.org [1/8] flink git commit: [FLINK-2674] Add Fold Window Operation for new Windowing API Wed, 07 Oct, 20:33
aljos...@apache.org [2/8] flink git commit: [FLINK-2550] Rework interplay of Window Assigners and TimeCharacteristic Wed, 07 Oct, 20:33
aljos...@apache.org [3/8] flink git commit: [FLINK-2550] Rework interplay of Window Assigners and TimeCharacteristic Wed, 07 Oct, 20:33
aljos...@apache.org [4/8] flink git commit: [FLINK-2819] Add Windowed Join/CoGroup Operator Based on Tagged Union Wed, 07 Oct, 20:33
aljos...@apache.org [5/8] flink git commit: [FLINK-2819] Add Windowed Join/CoGroup Operator Based on Tagged Union Wed, 07 Oct, 20:33
aljos...@apache.org [6/8] flink git commit: [FLINK-2550] Rename reduceWindow to reduce on *WindowedStream, add Lambda Reduce Wed, 07 Oct, 20:33
aljos...@apache.org [7/8] flink git commit: Move CoGroupJoinITCase to windowing package Wed, 07 Oct, 20:33
aljos...@apache.org [8/8] flink git commit: [FLINK-2550] Add Window Aggregations to new Windowing API Wed, 07 Oct, 20:33
va...@apache.org flink git commit: [FLINK-2561] [gelly] add gelly-scala examples: vertex-centric SSSP, GSA SSSP and how to use a library method (connected components). Wed, 07 Oct, 20:37
aljos...@apache.org flink git commit: [hotfix] Add ResultTypeQueryable to Keys in Stream CoGroup/Join Wed, 07 Oct, 21:00
mj...@apache.org flink git commit: [FLINK-2381] [Storm Compatibility] Failing Test: WrapperSetupHelperTest Wed, 07 Oct, 21:07
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
Dec 2021121
Nov 2021414
Oct 2021397
Sep 2021700
Aug 2021786
Jul 2021537
Jun 2021478
May 2021486
Apr 2021844
Mar 2021587
Feb 2021440
Jan 2021464
Dec 2020617
Nov 20201845
Oct 20201078
Sep 2020763
Aug 2020577
Jul 2020671
Jun 20201241
May 20201300
Apr 2020778
Mar 2020671
Feb 2020552
Jan 2020552
Dec 2019699
Nov 2019636
Oct 2019425
Sep 2019378
Aug 2019788
Jul 2019879
Jun 2019559
May 2019549
Apr 2019325
Mar 2019388
Feb 2019612
Jan 2019553
Dec 2018339
Nov 2018690
Oct 2018600
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