https://github.com/apache/flink

sort by:
Revision Author Date Message Commit Date
3ea8ae3 [FLINK-5575][docs] in old releases, warn users and guide them to the latest stable docs 06 February 2017, 17:08:59 UTC
fd64fac [FLINK-5262][docs] Introduce Gemfile.lock to avoid dependency range conflicts The Gemfile for specifying the Ruby dependencies of our documentation has fixed dependency versions to avoid incompatible changes with different versions of the dependencies. However, Ruby's dependency management allows artifacts to specify ranges for dependencies. This can be problematic. For instance, we use 'jekyll' version 2.5.3 which depends on 'jekyll-gist' ~> 1.0 which means 1.0 >= version < 2.0. This may resolve 'jekyll-gist' 1.4.0 which depends on 'octokit' ~> 4.2 which may be 4.2 >= versions < 5.0. Too bad, 'octokit' starting with 4.4 depends on Ruby version >= 2.0 which is not available on our build servers. Since we already use the improved version of Rubys build system called 'bundler', we can mitigate this problem by checking in a Gemfile.lock file which specifies the exact versions of all dependencies required to build the docs. This closes #2945. 05 December 2016, 17:11:18 UTC
19fec0f [docs] require at least Ruby 1.9.0 for building The json module is bundled with Ruby from 1.9.0 and upwards. This cures dependency problems with different versions of Ruby. 22 August 2016, 08:46:48 UTC
1a1c134 [FLINK-3887] improve dependency management for building docs The Flink documentation build process is currently quite messy. These changes move us to a new build process with proper dependency handling. It assures that we all use the same dependency versions for consistent build output. Also, it eases the automated building process on other systems (like the ASF Buildbot). The goal was to make the documentation build process easier and self-contained. - use Ruby's Bundler Gem to install dependencies - update README - adapt Dockerfile - add additional rules to .gitignore - change default doc output path from /target to /content (default path of the flink-web repository) This closes #2033 31 May 2016, 10:20:28 UTC
19abef4 [FLINK-2800] [kryo] Fix Kryo serialization to clear buffered data The Kryo serializer uses Kryo's Output class to buffer individual write operations before it is written to the underlying output stream. This Output class is flushed by Flink's KryoSerializer upon finishing its serialize call. However, in case of an exception when flushing the Output, the buffered data is kept in the buffer. Since Flink uses EOFExceptions to mark that an underlying buffer is full and has to be spilled, for example, it can happen that the record triggering the spilling is written twice after it is rewritten. The reason is that Kryo's Output buffer still contains the serialization data of the failed attempt which is also flushed to the emptied output stream. This duplication of records can lead to corrupted data which eventually let's the Flink program crash. The problem is solved by clearing Kryo's Output when the flush operation was not successful. This closes #1308 29 October 2015, 13:04:43 UTC
9178a58 [FLINK-1610][docs] fix javadoc building for aggregate-scaladoc profile 28 October 2015, 16:25:00 UTC
2b5f88a [docs] add information on how to use Kerberos 23 October 2015, 16:20:14 UTC
ab694a3 [FLINK-2874] Fix recognition of Scala default setters 23 October 2015, 08:27:59 UTC
4392cf2 [FLINK-2874] Fix Avro getter/setter recognition This closes #1252 23 October 2015, 08:27:51 UTC
9609995 [FLINK-2834] Global round-robin for temporary directories Multiple TaskManager filesystems can be used by configuring multiple temporary directories. This patch changes the process of spilling files from a per-operator round-robin to a global round-robin such that each directory is written to in turn across all operators, reducing unbalanced I/O due to bunching. This closes #1272 21 October 2015, 12:41:08 UTC
b3429ed [FLINK-2885][python] fix path building of Python resources 21 October 2015, 08:46:06 UTC
c2fcf45 [FLINK-2607][quickstart] ignore signature files when creating fat jar This closes #1085. 14 October 2015, 14:12:37 UTC
cf6f87b [FLINK-1610] fix building of java doc for Java 8 This closes #1225. 06 October 2015, 09:18:00 UTC
2b6a837 [docs] fix broken scala shell link 25 September 2015, 11:05:52 UTC
1cac3a4 [FLINK-2751] [docs] Add quickstart menu to the navigation bar of documentation - Improve conditional "active" class for dropdown menu - Fix unclosed A tag This closes #1176. 24 September 2015, 12:07:27 UTC
ca6e224 fix broken link to config page in quickstart 23 September 2015, 16:02:33 UTC
f27219e [hotfix] Use InetAddress.getLocalHost() as first approach when detecting the TMs own ip/hostname 21 September 2015, 14:29:30 UTC
ad09721 [FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator This closes #1130 17 September 2015, 09:58:10 UTC
43e23ba [FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups. This closes #1136 17 September 2015, 09:58:01 UTC
45e2a2a [FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs This closes #1140 17 September 2015, 09:57:50 UTC
c007f72 [FLINK-2656] Fix behavior of FlinkKafkaConsumer for out of range offsets This closes #1117 11 September 2015, 12:27:30 UTC
e5becd4 [hotfix] Add missing import 11 September 2015, 10:54:57 UTC
267376f [FLINK-2639] Add repository for hdp specific jetty to 'vendor-repos' This closes #1113 ----- Closing unresponsive PR: This closes #862 11 September 2015, 09:58:28 UTC
d656fc3 [FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats This closes #1111 10 September 2015, 12:32:51 UTC
ae2b59d [FLINK-2235] fix calculation of free memory for local execution The Java runtime may return Long.MAX_VALUE for a call to the maxMemory() method of the Runtime class. In these cases, we can get hold of the physical memory size of the operating system by using a proprietary Oracle JDK method. Otherwise, we fail with an explanatory exception. The Oracle JVM defines the max memory to be 1/4 of the physical memory if the user has more than 192 Megabytes which is assumed here. This closes #859 03 September 2015, 10:00:47 UTC
18784c9 [build] Revert javakaffee dependency to version 0.27 to play well with ASM shading 27 August 2015, 15:29:46 UTC
f196ca1 [docs] Bump docs to 0.9.1 27 August 2015, 08:21:31 UTC
b8834bc [scripts] Sync release script with master 27 August 2015, 07:40:56 UTC
9f2f6b7 [FLINK-2386] [kafka] Move Kafka connectors to 'org.apache.flink.streaming.connectors.kafka' 26 August 2015, 19:12:51 UTC
940a7c8 [FLINK-2386] [kafka] Add new Kafka Consumer for Flink This closes #1055 26 August 2015, 19:12:43 UTC
3cdbb80 [FLINK-2356] Add shutdown hook to CheckpointCoordinator to prevent resource leaks 26 August 2015, 17:56:45 UTC
eba62a6 [FLINK-2189] [runtime] Fix various issues in hash table - check for memory availability before probing - correctly compute memory required for recursive build fast path - remove all temp files properly 26 August 2015, 17:21:22 UTC
0fe0155 [scripts] resolve base path of symlinked executable - also adapt config.sh to use the same cross-platform compatible mechanism 26 August 2015, 15:38:17 UTC
5869bf9 [FLINK-2555] Properly pass security credentials in the Hadoop Input/Output format wrappers This is needed because the Hadoop IF/OF's are using Hadoop's FileSystem stack, which is using the security credentials passed in the JobConf / Job class in the getSplits() method. Note that access to secured Hadoop 1.x using Hadoop IF/OF's is not possible with this change. This limitation is due to missing methods in the old APIs. - Add some comments & change dependency scope to test This closes #1038. 26 August 2015, 14:30:23 UTC
eb9c75f [FLINK-2394] HadoopOutputFormats use correct OutputCommitters. 26 August 2015, 12:26:03 UTC
d445a33 [hotfix] Add notice about using FLINK_CONF_DIR in Yarn Setup 26 August 2015, 10:39:39 UTC
594f4f7 [hotfix] Allow setting FLINK_CONF_DIR by hand 26 August 2015, 10:39:39 UTC
7e44712 [hotfix] Fixes auto type registration settings in ExecutionConfig 26 August 2015, 10:39:39 UTC
3f2cf5a [FLINK-2270] [docs] Fix typo in docs (enableMonitoring => enableCheckpointing) 26 August 2015, 10:39:38 UTC
11a1cf4 [FLINK-2089] [runtime] Fix illegal state in RecordWriter after partition write failure - Address PR comments 26 August 2015, 10:33:53 UTC
c89851d [FLINK-2460] [runtime] Check parent state in isReleased() check of partition view - Address PR comments 26 August 2015, 10:22:44 UTC
a31f294 [FLINK-2540] [optimizer] [runtime] Propagate union batch exchanges to union inputs The DataExchangeMode of union nodes was not respected when translating an OptimizedPlan to a JobGraph. This could result in deadlocks, when a branched data flow was closed. Union nodes with a batch exchange will propagate their exchange mode to all inputs of their inputs when the JobGraph is generated. 21 August 2015, 15:06:00 UTC
c158317 [FLINK-2286] [streaming] ITCase for ParallelMerge behavior Closes #1014 Adapted for version 0.9 Conflicts: flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/PageRankITCase.java 19 August 2015, 12:07:22 UTC
8711974 [FLINK-2286] [streaming] Wrapped ParallelMerge into stream operator Closes #994 18 August 2015, 13:36:31 UTC
e8802f9 [FLINK-2527] [gelly] Ensure that VertexUpdateFunction.setNewVertexValue is called at most once per updateVertex This closes #1027 17 August 2015, 12:18:14 UTC
827efd0 [hotfix] read from old and new parallelism config key regression of c6358024454cd8225cf27a91db7f64ffa13189ee 12 August 2015, 16:50:33 UTC
bfa11ff [FLINK-2437] handle the case of a non-public default ctor in TypeExtractor.analyzePojo Also changed some prints which printed the word "class" twice, because class.toString also prepends it to the class name. This closes #960. 12 August 2015, 10:30:11 UTC
9219dff [FLINK-1916] [FLINK-2361] [runtime] Fix EOFException and entry loss in CompactingHashTable Also a lot of code cleanups in CompactingHashTable 05 August 2015, 20:09:08 UTC
ec3b983 [FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type 05 August 2015, 14:25:32 UTC
80d3478 [FLINK-2442] [fix] FieldPositionKeys support Pojo fields 04 August 2015, 19:10:19 UTC
8797890 [FLINK-2205] Fix confusing entries in JobManager WebUI JobConfig section. Default display for 'Number of execution retries' is now 'deactivated' and for 'Job parallelism' is 'auto', as suggested in JIRA. 04 August 2015, 19:09:54 UTC
acb6ea8 [FLINK-2422] [web client] Added explicit link in case browser is not redirecting properly 03 August 2015, 22:47:30 UTC
0186a97 Revert API-breaking change: "[FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable)" This reverts commit 3e31ea647c76c85cd2371427b5735cb2d9a84266. 03 August 2015, 10:05:06 UTC
012dd05 [FLINK-2412] [runtime] Check if parent released before querying in-memory buffer in SpillableSubpartitionView 31 July 2015, 09:03:29 UTC
3e31ea6 [FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable) 30 July 2015, 22:38:09 UTC
c756fe8 [FLINK-2424] [core] Close output stream in serialization utility 29 July 2015, 16:40:53 UTC
208c0a1 [FLINK-2384] [runtime] Move blocking I/O call outside of synchronized block Problem: Waiting on asynchronous write requests with the partition lock can result in a deadlock, because all other operations on the same partition are blocked. It is possible that the I/O writer itself needs to access the partition, in which cases the whole program blocks. Solution: Move the wait outside the synchronized block. This was not necessary before, because no operation assumes the spilling to be finished when the finish call has returned. 24 July 2015, 12:00:59 UTC
198406f [FLINK-2381] Stringify cause of ProducerFailedExceptions 24 July 2015, 11:57:00 UTC
d71e65b [FLINK-2400] [tests] Improve error message on unexpected TaskTest message 23 July 2015, 14:47:44 UTC
6332761 [docs] Fix Javadocs of RuntimeContext parallel subtask index 18 July 2015, 09:10:13 UTC
c7e8684 [FLINK-2229] Add equals() and hashCode() to ObjectArrayTypeInfo This closes #842. 15 July 2015, 13:53:43 UTC
451eb82 [FLINK-2280] GenericTypeComparator.compare() respects ascending flag This closes #894 14 July 2015, 09:17:47 UTC
acd4317 [FLINK-2353] Respect JobConfigurable interface in Hadoop mapred wrappers This closes #908 14 July 2015, 09:15:39 UTC
055997e [docs] fix loading of style sheet with protocol relative base URL 13 July 2015, 08:55:16 UTC
7c2a704 [FLINK-2293] [runtime] Fix estimation for the number of hash buckets on recursive builds 08 July 2015, 09:12:07 UTC
0789460 [FLINK-2285] [streaming] Removed duplicate call in close from GroupedActiveDiscretizer 02 July 2015, 14:54:01 UTC
d946599 [FLINK-2298] Add option to pass a custom name for Flink on YARN This closes #876 01 July 2015, 13:26:04 UTC
9835625 [docs] fix broken links in FAQ 25 June 2015, 12:01:35 UTC
69f858e [FLINK-2257] [streaming] Properly forward rich window function calls to wrapped functions Closes #855 25 June 2015, 11:38:56 UTC
d7cfa55 [docs] correct baseurl for 0.9 documentation 24 June 2015, 09:59:30 UTC
b5702c2 [docs] correct yarn command-line example 24 June 2015, 07:50:47 UTC
9f0da5b [FLINK-2262][utils] rename method for default integer value in ParameterTool 24 June 2015, 07:50:44 UTC
61f17f8 [core] Fix typo in DataSinkTask error message 18 June 2015, 09:20:29 UTC
d47405b [streaming] Fix out-of-sync class-level docs of SourceFunction 18 June 2015, 09:20:15 UTC
bbd08f3 Revert "[FLINK-2203] handling null values for RowSerializer" This reverts commit adc3e0e6b1d2013c522e55ee027927488bde09f2. 18 June 2015, 08:20:18 UTC
d6ad294 Revert "[FLINK-2210] Table API support for aggregation on columns with null values" This reverts commit 0914a7d0a8f564c26b6b9c0f37e8685db5d880ed. 18 June 2015, 08:20:10 UTC
0914a7d [FLINK-2210] Table API support for aggregation on columns with null values 16 June 2015, 22:51:17 UTC
adc3e0e [FLINK-2203] handling null values for RowSerializer This closes #831 16 June 2015, 22:51:17 UTC
fa02e5f [FLINK-2174] allow comments in 'slaves' file This closes #796. 16 June 2015, 22:51:16 UTC
44b969e [FLINK-2226][YARN] fail application on failed single-job cluster job Failing jobs executed in the YARN cluster mode leave the application container in the "SUCCEEDED" final state. While for long-running Flink YARN clusters where multiple jobs are run, this is fine, for single jobs it is appropriate to mark the application as failed. This closes #838. 16 June 2015, 22:51:16 UTC
57810b5 [build] merge transitive notice files to shaded notices This closes #837. 16 June 2015, 22:50:55 UTC
57955d9 [FLINK-2120][runtime] rename AbstractJobVertex to JobVertex This closes #840. 16 June 2015, 22:49:35 UTC
6a9782a [legal] Updates LICENSE/NOTICE file of source and binary distribution This closes #830. 16 June 2015, 21:42:39 UTC
d690633 [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems This closes #843. Conflicts: flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java 16 June 2015, 21:42:20 UTC
0a8142a [hotfix] Removed execute() that followed print() in quickstart wordcount jobs 16 June 2015, 20:13:12 UTC
2359b49 [docs] Update obsolate cluster execution guide Closes #835 16 June 2015, 11:07:41 UTC
c2b1e12 [FLINK-2209] [docs] Document linking with jars not in the binary dist 16 June 2015, 11:07:30 UTC
ccaa0b0 [FLINK-2221] [docs] Docs for not using local filesystem on the cluster as state backup This is just a clear documentation of the problem for the 0.9 release. Closes #839 16 June 2015, 11:07:19 UTC
d147c71 [hotfix] Some small fixups in README.md This closes #841. 16 June 2015, 08:38:12 UTC
a300eec [FLINK-2219] [webfrontend] Fix IllegalArgumentException and decrease log level - Pressing the state button in the job history view (like SCHEDULED, FINISHED) sends a "null" (String) as group vertex ID, which results in an IllegalArgumentException. Fixed by check and early return. - The JM log is flooded by INFO-level messages when no GlobalJobParameters are set (common case). Fixed by decreasing the log level of these message to DEBUG. 16 June 2015, 08:34:54 UTC
c4f3f48 [FLINK-2224] Log error cause in JobStatusChange 15 June 2015, 15:22:38 UTC
8232809 [FLINK-2216] Exclude javadoc jar from examples 15 June 2015, 11:05:01 UTC
b342cf7 [readme] Synchronize tagline with intro, fix typos 15 June 2015, 09:58:18 UTC
f5f0709 [FLINK-2194] [type extractor] Excludes Writable type from WritableTypeInformation to be treated as an interface This closes #814. 12 June 2015, 12:28:52 UTC
40e2df5 [FLINK-2072] [ml] Adds quickstart guide This closes #792. 12 June 2015, 12:27:29 UTC
af0fee5 [FLINK-2207] Fix TableAPI conversion documenation and further renamings for consistency. This closes #829 12 June 2015, 12:27:03 UTC
e513be7 [FLINK-2206] Fix incorrect counts of finished, canceled, and failed jobs in webinterface This closes #826 12 June 2015, 12:26:47 UTC
ecfde6d [docs][release] update stable version to 0.9.0 12 June 2015, 11:28:53 UTC
4d8ae1c [docs] remove obsolete YARN link and cleanup download links 12 June 2015, 11:28:53 UTC
f27fc81 [FLINK-2195] Configure Configurable Hadoop InputFormats This closes #828. 12 June 2015, 09:51:48 UTC
back to top