GitHub user chakravarthyvp opened a pull request:
https://github.com/apache/flink/pull/2596
Release 1.1
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the items into account, feel free to open your
pull request. For more information and/or questions please refer to the [How To
Contribute guide](http://flink.apache.org/how-to-contribute.html).
In addition to going through the list, please provide a meaningful
description of your changes.
- [ ] General
- The pull request references the related JIRA issue ("[FLINK-XXX] Jira
title text")
- The pull request addresses only one issue
- Each commit in the PR has a meaningful commit message (including the
JIRA id)
- [ ] Documentation
- Documentation has been added for new functionality
- Old documentation affected by the pull request has been updated
- JavaDoc for public methods has been added
- [ ] Tests & Build
- Functionality added by the pull request is covered by tests
- `mvn clean verify` has been executed successfully locally or a Travis
build has passed
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache/flink release-1.1
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2596.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2596
----
commit 67036d8bece36cf4d4bdf39f459859aa64227eef
Author: Maximilian Michels <m...@apache.org>
Date: 2016-07-28T12:56:21Z
[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.
commit 383a1ccaac215d91fc8aeeae4e2154aff344d3e4
Author: Ufuk Celebi <u...@apache.org>
Date: 2016-08-01T09:13:27Z
[FLINK-4289] Unset -x flag for .java files
Some source files had the -x flag set:
Before this change:
```
$ find . -perm +111 -type f | grep "\.java"
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/places/Attributes.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/places/BoundingBox.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/places/Places.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/Contributors.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/Coordinates.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/CurrentUserRetweet.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/Entities.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/HashTags.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/Media.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/Size.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/Symbol.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/URL.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/entities/UserMention.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/tweet/Tweet.java
./flink-contrib/flink-tweet-inputformat/src/main/java/org/apache/flink/contrib/tweetinputformat/model/User/Users.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/ApplyFunction.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherFunction.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/Neighbor.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/SumFunction.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSAConnectedComponents.java
./flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/GSASingleSourceShortestPaths.java
./flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/GSASingleSourceShortestPaths.java
./flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/test/GatherSumApplyITCase.java
./flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
```
After this change:
```
$ find . -perm +111 -type f | grep "\.java"
```
commit ac7028e7a341973e045dff6d02214e9546de5ed2
Author: Ufuk Celebi <u...@apache.org>
Date: 2016-08-01T15:57:18Z
Revert "[FLINK-4154] [core] Correction of murmur hash breaks backwards
compatibility"
This reverts commit 81cf2296683a473db4061dd3bed0aeb249e05058.
We had an incorrent implementation of Murmur hash in Flink 1.0. This
was fixed in 641a0d4 for Flink 1.1. Then we thought that we need to
revert this in order to ensure backwards compatability between Flink
1.0 and 1.1 savepoints (81cf22). Turns out, savepoint backwards
compatability is broken for other reasons, too. Therefore, we revert
81cf22 here, ending up with a correct implementation of Murmur hash
again.
commit c71a0c73448f82e20cdc87bcc7e94220a472e586
Author: Stephan Ewen <se...@apache.org>
Date: 2016-08-02T16:09:14Z
[FLINK-4307] [streaming API] Restore ListState behavior for user-facing
ListStates
commit a4d9f57153d4ff84395e56b68d8453384437254f
Author: philippgrulich <philippgrul...@hotmail.de>
Date: 2016-07-21T20:31:24Z
[FLINK-4251] [Rabbit MQ] Allow users to override queue setup in order to
customize queue config
This closes #2281
commit 49e66bec911b43de5fc1f6ea68581d4d45c6cca9
Author: Stephan Ewen <se...@apache.org>
Date: 2016-08-01T08:01:35Z
[hotfix] [docs] Remove obsolete file 'plotPoints.py'
commit a1926799d30aae33ca14580fcd494286797e1297
Author: Stephan Ewen <se...@apache.org>
Date: 2016-08-01T09:22:27Z
[FLINK-4285] [docs] Update the setup quickstart guide with the new
SocketWindowWordCount example
commit 60b10851294e1829786ac54abe9232188d24653d
Author: Stephan Ewen <se...@apache.org>
Date: 2016-08-01T10:03:33Z
[FLINK-4292] [batch connectors] Fix setup of HCatalog project by adding
Scala SDK dependency
commit 24951845131c6b191a04fa569c22e2e8cbc71fa8
Author: Till Rohrmann <trohrm...@apache.org>
Date: 2016-08-01T16:05:14Z
[FLINK-4296] Fixes failure reporting of consumer task scheduling when
producer has already finished
This PR changes the failure behaviour such that the consumer task is failed
instead of the
producer task. The latter is problematic, since a finsihed producer task
will simply swallow
scheduling exception originating from scheduling the consumer task.
This closes #2321.
commit e09a45436961eb1214a96b5a5144f2ea919af77e
Author: Maximilian Michels <m...@apache.org>
Date: 2016-08-01T16:15:56Z
[FLINK-4299] show loss of job manager in Client
This prints a message when the leading JobManager changes after first
connecting to a JobManager. Further, it prints a message when a connection
to a JobManager has been established.
This closes #2322.
commit 2ea4dd89348ab5ea07edfa40bb791d9a84864f37
Author: Stephan Ewen <se...@apache.org>
Date: 2016-08-01T10:17:35Z
[hotfix] Remove various '.hidden' files that seem to have been accidentally
committed
commit 34eefa32fb59782170df5c7fbc462d4fa085a148
Author: Stephan Ewen <se...@apache.org>
Date: 2016-08-01T12:15:40Z
[hotfix] [build] Update LICENSE file with new URL of simplejmx dependency
commit 7768bb2defe48afb6e77c072e97526856538f6e9
Author: Stephan Ewen <se...@apache.org>
Date: 2016-08-01T14:55:02Z
[FLINK-4290] [Cassandra Connector] Skip CassandraConnectorTest on Java 7
builds
Cassandra needs Java 8 to run reliably.
commit 5363e7ad7f83bcba9be5830639f3fbc940a8bc54
Author: Greg Hogan <c...@greghogan.com>
Date: 2016-07-14T17:40:35Z
[FLINK-4219] [scripts] Quote PDSH opts in start-cluster.sh
This prevents word splitting if the user configures multiple SSH
options.
This closes #2253.
commit 5184d0bb4941cdbe09a5288a9a3cc21bbd116c43
Author: Ufuk Celebi <u...@apache.org>
Date: 2016-08-05T09:49:42Z
[FLINK-4314] [tests] Fix test instability in
JobManagerHAJobGraphRecoveryITCase
The test was relying on the JobManager shutting down before the
TaskManager, which is not necessarily the case. If the TaskManager
shuts down before the JobManager, the JobGraph could reach the final
state FAILED, in which case all HA state is removed.
To circumvent this, we add a restart strategy.
commit e4f62d3b38ccb93e45c50ee97dae9157a0493e47
Author: Maximilian Michels <m...@apache.org>
Date: 2016-08-01T13:19:15Z
[FLINK-4297] [yarn] Decode URL encoded fat jar path
This solves problems with spaces and special characters in the
automatically determined fat jar path which is returned URL encoded.
This closes #2320
commit b054da46ea00e958b1c055f6e4f8b5dd51d3a390
Author: Robert Metzger <rmetz...@apache.org>
Date: 2016-08-08T10:19:03Z
[hotfix][kinesis] Fix build instructions
commit 19de8ec01a9ec2b3ac0fdf0052b780f970b9bcd1
Author: Stephan Ewen <se...@apache.org>
Date: 2016-08-08T17:16:23Z
[FLINK-4332] [checkpoints] Fix SavepointV1Serializer read() / readFully()
commit fc5b58d29486d9a7e0053a508274a46de97c73aa
Author: Shannon Carey <rehevk...@gmail.com>
Date: 2016-08-08T20:04:23Z
[FLINK-4334] [quickstarts] Correctly exclude hadoop1 in quickstart POMs
This closes #2341
commit a09f87c5c48cdac8eeadd90d4975ad04d795f51f
Author: Robert Metzger <rmetz...@apache.org>
Date: 2016-08-09T11:52:34Z
[hotfix][build] Fix release script
commit 68c1a907003a2317716e017d4776f331def64ba2
Author: Ufuk Celebi <u...@apache.org>
Date: 2016-08-11T07:51:45Z
[docs] Remove deprecated variables
commit 58c810aeaa42f66b70d3364efdfed3f296023ac8
Author: Ufuk Celebi <u...@apache.org>
Date: 2016-08-11T07:55:22Z
[docs] Update quickstart version to 1.1.1
commit f67cb89d4934d8ebb2d04d3a2c020c9702b99934
Author: Maximilian Michels <m...@apache.org>
Date: 2016-08-10T10:08:23Z
[FLINK-4236] fix error handling for jar files with no main method
This change shows only entry classes with a valid main method. It
ignores classes which contain no main method.
This closes #2347
commit c2906c0216e5139de9d3928a49a501cb29796ebd
Author: Sunny T <sunny@sunnys-macbook-pro-3.local>
Date: 2016-08-14T22:50:08Z
[FLINK-4309] Fix potential NPE in DelegatingConfiguration
This closes #2371.
commit aa50e226c318f6f52ffdfad3bab4bd8b926ba410
Author: zentol <ches...@apache.org>
Date: 2016-08-17T10:15:37Z
[FLINK-4411] [py] Properly propagate chained dual input children
commit 445eaa986dca59b12458254c31624474b3bac632
Author: zentol <ches...@apache.org>
Date: 2016-08-17T11:47:30Z
[FLINK-4412] [py] Chaining properly handles broadcast variables
commit cbce10d100a19247476035ed53ea8196d19051f5
Author: zentol <ches...@apache.org>
Date: 2016-08-10T14:23:54Z
[FLINK-4302] [metrics] Add documentation to MetricConfig
commit 54cccb852f2d4d9f46f6ed8eb635662d6a122a99
Author: Stephan Ewen <se...@apache.org>
Date: 2016-08-17T09:53:57Z
[FLINK-4409] [build] Exclude JSR 305 from Hadoop dependencies
commit e352ce4be8e8bc1cb75b40682aa8b9b4c99fb63e
Author: Ivan Mushketyk <ivan.mushke...@gmail.com>
Date: 2016-07-23T09:39:24Z
[FLINK-3866] StringArraySerializer does not treat type as immutable.
commit 70b818b1ba27e5e7d4758c438801681cbf5aee81
Author: Maximilian Michels <m...@apache.org>
Date: 2016-08-22T16:11:45Z
[FLINK-4454] always display JobManager address using LeaderRetrievalService
This closes #2406
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
