You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by guochuanzhi <gi...@git.apache.org> on 2015/12/16 05:54:34 UTC
[GitHub] flink pull request: Release 0.10
GitHub user guochuanzhi opened a pull request:
https://github.com/apache/flink/pull/1459
Release 0.10
flink test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache/flink release-0.10
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1459.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 #1459
----
commit db19973a4eb1afb381c944f2e37934a0006276dd
Author: vasia <va...@apache.org>
Date: 2015-10-21T14:32:22Z
[FLINK-2887] [gelly] make sendMessageToAllNeighbors respect the EdgeDirection if set in the configuration
This closes #1281
commit e340f839a146e36a24433946612afe460ba11292
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2015-10-22T09:22:03Z
[FLINK-2891] Set KV-State key upon Window Evaluation in General Windows
Before, this was not set, leading to incorrect results if KV-State was
used in the WindowFunction.
This also adds a test.
commit dadb1a8030d8d2e1bd5e6826c1c9632d3d6ddf8b
Author: Fabian Hueske <fh...@apache.org>
Date: 2015-10-22T12:41:11Z
[FLINK-2206] [webui] Fix incorrect counts of finished, canceled, and failed jobs in new web dashboard
This closes #1287
commit 5c3eb8b8f8ff39fafc9d93e42d9f6a924e3d8576
Author: zentol <s....@web.de>
Date: 2015-10-21T13:27:05Z
[FLINK-2668] [DataSet] [api-breaking] Chained Projections are no longer appended
This closes #1279
commit 42b5ead564f1dde16892b85c8fe04fcd2e819cc1
Author: Ulf Karlsson <uk...@spotify.com>
Date: 2015-10-10T22:04:57Z
[FLINK-2874] Fix Avro getter/setter recognition
This closes #1252
commit c72eff4af8ef1f9fc36344f1ff52233bdc15e528
Author: Fabian Hueske <fh...@apache.org>
Date: 2015-10-22T22:06:55Z
[FLINK-2874] Fix recognition of Scala default setters
commit 85b73e0fd255608494fa9ae74a9a505a4989d6ab
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2015-10-23T09:13:37Z
[hotfix] Fix processing time triggering on Window Operator
Before it would only trigger if expectedTime < time. Now it is
expectedTime <= time.
commit c257abf75773b3643692261018b6794debff6001
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2015-10-23T10:48:02Z
Add copy() to Tuple base class.
commit 45ab0eb871de90171bcf5395ca6d2568876a37a8
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2015-10-23T12:38:16Z
[hotfix] Fix broken copy in OperatorChain
Before, the StreamRecords was not copied, now it is.
commit 712c868eb77643ae07542d5a073365e0862a5e97
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2015-10-23T11:08:35Z
[hotfix] Fix Mutable Object window aggregator/Disable Object Copy
This fixes the aggregators to make copies of the objects so that it
works with window operators that are not mutable-object safe.
This also disables object copy in WindowOperator and
NonKeyedWindowOperator.
commit 15d3f10c1a52b2b1cc8fff793648da4a56e72dcc
Author: Greg Hogan <co...@greghogan.com>
Date: 2015-10-22T13:31:09Z
[FLINK-2895] Duplicate immutable object creation
Operators defer object creation when object reuse is disabled.
This closes #1288
commit 8ec828c9444711ab5956904bcffc149a5724e1e6
Author: Ufuk Celebi <uc...@apache.org>
Date: 2015-10-22T10:58:26Z
[FLINK-2893] [runtime] Consistent naming of recovery config parameters
Rename config key prefix from 'ha.zookeeper' to 'recovery.zookeeper'
Rename config key from 'state.backend.fs.dir.recovery' => 'state.backend.fs.recoverydir'
Move ZooKeeper file system state backend configuration keys
This closes #1286
commit c0d7073a5166fdcd6cfbea741ae0bfa132e2bf04
Author: Fabian Hueske <fh...@apache.org>
Date: 2015-10-22T19:10:41Z
[FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests
Rename Match*Test to Join*Test and MapTaskTest to FlatMapTaskTest
This closes #1294
commit bc5b852a29bd76a53975f40909e5259e034c9980
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2015-10-23T09:28:58Z
[hotfix] Add Window Parameter in Trigger.onEventTime/onProcessingTime
Before these trigger methods had no information about the window that
they are responsible for. This information might be required for
implementing more advanced trigger behaviour.
commit 856b27837df97f4341d84e8e0ccaa61de43939b5
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2015-10-23T09:31:13Z
[hotfix] Improve handling of Window Trigger results
This enhances the TriggerResult enum with methods isFire() and isPurge()
that simplify the logic in WindowOperator.processTriggerResult().
Also, the operator now keeps track of the current watermark and fires
immediately if a trigger registers an event-time callback for a
timestamp that lies in the past. For this the TriggerResult now as
method merge() that allows to merge to TriggerResultS.
commit ec1730bf539e055ea95d82ad920a41b686c2f8bc
Author: Maximilian Michels <mx...@apache.org>
Date: 2015-10-23T16:13:13Z
[docs] add information on how to use Kerberos
commit c2811ce975548e18d64a5f3c2b1b397f9e42bc1c
Author: tedyu <yu...@gmail.com>
Date: 2015-10-22T02:40:21Z
[FLINK-2866] [runtime] Eagerly close FSDataInputStream in file state handle
This closes #1282
commit 8e4cb0ae0bdc7f8c60542edabad57e4fa2f0c61e
Author: Stephan Ewen <se...@apache.org>
Date: 2015-10-22T09:24:12Z
[FLINK-2888] [streaming] State backends return copies of the default values
commit 65fcd3abdd4d9ad78c12b95ac7ad0b1e2926609e
Author: Stephan Ewen <se...@apache.org>
Date: 2015-10-22T16:58:29Z
[FLINK-2891] [streaming] Set keys for key/value state in window evaluation of fast-path windows.
commit 16a9edc3e5b3345c7dc8f44d49309d3d98c4a90c
Author: Aljoscha Krettek <al...@gmail.com>
Date: 2015-10-27T12:48:34Z
[hotfix] Fix issue with spaces in Path in start-*-streaming.sh
commit b240a8075c5c66322f6e37ca05b3c4d1c81dd4ec
Author: Till Rohrmann <tr...@apache.org>
Date: 2015-10-21T13:35:02Z
[FLINK-2878] [webmonitor] Fix unexpected leader address pattern
The HandlerRedirectUtils.getRedirectAddress decides whether the retrieved leader address is equal to the local job manager address. The local job manager address is, however, in the form akka.tcp://flink@url/user/jobmanager whereas the leader address can be akka://flink/user/jobmanager if the local job manager is the current leader. Such a case produced a warning which is not correct. This PR checks for the local job manager address and signals that no redirection has to be done if it receives akka://flink/user/jobmanager.
Add test for HandlerRedirectUtils
This closes #1280.
commit 04e25e17bfa85f837fd8a30dc999114720b381ec
Author: Maximilian Michels <mx...@apache.org>
Date: 2015-10-27T14:06:23Z
[docs] remove hard-coded version artifacts
commit 874c500ba305a91873b474fc38eb73726472b0b8
Author: Ufuk Celebi <uc...@apache.org>
Date: 2015-10-26T14:34:58Z
Add org.apache.httpcomponents:(httpcore, httpclient) to dependency management
commit ae19d2ba74c70eacffb9d0deee62ef48829d67d1
Author: Ufuk Celebi <uc...@apache.org>
Date: 2015-10-27T16:40:03Z
[FLINK-2927] [runtime] Provide default required configuration keys in flink-conf of binary distribution
commit 54375b988e2b541025e0276b704765256434b597
Author: Maximilian Michels <mx...@apache.org>
Date: 2015-10-28T16:00:18Z
[scala-shell][docs] add scala sources in earlier phase
Otherwise the javadoc fails to generate..
commit 51ac46e80d140bddd57677afbb70acaa3583fb9b
Author: Maximilian Michels <mx...@apache.org>
Date: 2015-10-28T16:03:08Z
[FLINK-1610][docs] fix javadoc building for aggregate-scaladoc profile
commit fcc1eed3a89f5a8d992ecc67f50d6551f0127852
Author: Sachin Goel <sa...@gmail.com>
Date: 2015-10-24T11:00:23Z
[FLINK-2902][web-dashboard] Sort finished jobs by their end time, running jobs by start time
This closes #1296
commit cdc0dfd18de04e2ae03f6dc0731220d0570523a4
Author: Frederick F. Kautz IV <fk...@alumni.cmu.edu>
Date: 2015-10-28T21:02:47Z
[FLINK-2932] Examples in docs now download shell script using https instead of http
This closes #1309
commit 6a13b9ff54afcdfce6deba6cea47df88f6575bb5
Author: Sachin Goel <sa...@gmail.com>
Date: 2015-10-28T12:30:54Z
[FLINK-2934] Remove placeholder pages for job.statistics, taskmanager.log and taskmanager.stdout
This closes #1307
commit 44b03f20a3cc96a447051e9ab0f2cf04f9829966
Author: Till Rohrmann <tr...@apache.org>
Date: 2015-10-28T17:40:41Z
[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
----
---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request: Release 0.10
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1459
---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request: Release 0.10
Posted by fhueske <gi...@git.apache.org>.
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1459#issuecomment-166340498
I'll close this PR.
---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---
[GitHub] flink pull request: Release 0.10
Posted by fhueske <gi...@git.apache.org>.
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1459#issuecomment-165031211
Hi @guochuanzhi, it looks like your PR does not include any commits of you but just already committed changes. It does also not have a description. Can you please close this PR?
If you would like to contribute to Flink, please have a look at the [contribution guidelines](http://flink.apache.org/how-to-contribute.html).
Thanks, Fabian
---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---