You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by yanghua <gi...@git.apache.org> on 2018/05/28 05:08:12 UTC
[GitHub] flink pull request #6085: [Flink-9452] Flink 1.5 document version title show...
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6085
[Flink-9452] Flink 1.5 document version title shows snapshot
## What is the purpose of the change
*This pull request fixed flink 1.5 release document version title*
## Brief change log
- *changed version title from 1.5-SNAPSHOT to 1.5*
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (yes / **no**)
- The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (yes / **no**)
- The serializers: (yes / **no** / don't know)
- The runtime per-record code paths (performance sensitive): (yes / **no** / don't know)
- Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: (yes / **no** / don't know)
- The S3 file system connector: (yes / **no** / don't know)
## Documentation
- Does this pull request introduce a new feature? (yes / **no**)
- If yes, how is the feature documented? (not applicable / docs / JavaDocs / **not documented**)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/yanghua/flink FLINK-9452
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/6085.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 #6085
----
commit fec4e4e1fd0002d8f2fcb63f9ee858a6fa13d71a
Author: Nico Kruber <ni...@...>
Date: 2018-04-06T17:36:33Z
[hotfix][network] minor optimisation in LocalBufferPool
commit f7e621d32272140013a25fd39e2a79df5d038eeb
Author: Nico Kruber <ni...@...>
Date: 2018-04-06T17:34:44Z
[FLINK-9144][network] fix SpillableSubpartition causing jobs to hang when spilling
This closes #5842.
commit 01f701ab720bf5c3a87b9a83901e5bd15e96468e
Author: Stefan Richter <s....@...>
Date: 2018-04-18T16:27:00Z
[FLINK-9022][state] Backend disposal in StreamTaskStateInitializer should always be performed in cleanup.
This step should be independent from the fact if the backend is still registered with the closeable registry.
(cherry picked from commit 777cc1a)
commit 63ac68093a104ba01451d5f7f419bf07e2634499
Author: Stefan Richter <s....@...>
Date: 2018-04-18T08:50:24Z
[hotfix][checkpointing] Double check if local state directory exists to avoid problem with concurrent directory creation.
(cherry picked from commit a455d6a)
commit e6659b08889cbed52e2d2a3c5b17c208101e5a20
Author: Stefan Richter <s....@...>
Date: 2018-04-18T16:24:28Z
[hotfix] Generated OperatorSubtaskDescription string should start counting from 1 for index 0
(cherry picked from commit 1bfe87f)
commit 2ccdf07da3ee437bbb889d3fea9b1b9cf4a19637
Author: Stefan Richter <s....@...>
Date: 2018-04-18T16:25:15Z
[hotfix][statebackend] Removed use of rawtype access for generic collection
(cherry picked from commit d1725a9)
commit 5621a1e9fae319aa613c1d60ff752e45eed253ac
Author: Timo Walther <tw...@...>
Date: 2018-04-17T13:12:55Z
[FLINK-9113] [connectors] Use raw local file system for bucketing sink to prevent data loss
This change replaces Hadoop's LocalFileSystem (which is a checksumming filesystem) with the RawFileSystem implementation. For performing checksums the default filesystem only flushes in 512 byte intervals which might lead to data loss during checkpointing. In order to guarantee exact results we skip the checksum computation and perform a raw flush.
Negative effect: Existing checksums are not maintained anymore and thus become invalid.
This closes #5861.
commit 3df5c6685091cea6c50758769c37ad3d6390f94a
Author: Timo Walther <tw...@...>
Date: 2018-03-27T15:44:58Z
[FLINK-8980] [e2e] Add a BucketingSink end-to-end test
This closes #5813.
commit f47c201f80bec5c95eadbbb885638af678d68cc2
Author: zhangminglei <zm...@...>
Date: 2018-04-20T08:42:41Z
[FLINK-9227] [test] Add Bucketing e2e test script to run-nightly-tests.sh
This closes #5884.
commit 537f452d9ae89d55aca6a8907c23494ee553b3ec
Author: Timo Walther <tw...@...>
Date: 2018-04-20T13:02:45Z
[hotfix] [e2e] Update flink-bucketing-sink-test version to 1.5-SNAPSHOT
commit 89d7e9c4e321e514b8a48311df9fa10533677940
Author: Stefan Richter <s....@...>
Date: 2018-04-19T13:10:07Z
[FLINK-8836] Fix duplicate method in KryoSerializer to perform deep copy of default/registered serializer instances.
This method did create deep copies of registered or default serializer instances and
as a result those serializer instances can accidentally be shared across different threads.
This closes #5880.
(cherry picked from commit 7d0bfd5)
commit e2440883e37679d01140291462ff4199a1f00e23
Author: Stephan Ewen <se...@...>
Date: 2018-04-17T15:55:54Z
[hotfix] [core] Small improvements to DataOutputSerializer
commit deba8dc0081c0484932bd27936c9e879c0188f0a
Author: Stephan Ewen <se...@...>
Date: 2018-04-17T16:39:36Z
[hotfix] [core] Fix checkstyle in org.apache.flink.api.common.time
commit c11477adc91adf2cb41ec7268b73de241b109d53
Author: Stephan Ewen <se...@...>
Date: 2018-04-17T16:55:29Z
[hotfix] [core] Cleanup Deadline
Gets rid of unnecessary boxing and multiplications/divisions that Duration does internally.
commit a0ef71b7b6f9815276581931e5fbaa0c374c502d
Author: Stephan Ewen <se...@...>
Date: 2018-04-17T17:17:44Z
[hotfix] [core] Fix checkstyle in org.apache.flink.api.common.typeinfo
commit d9351f458fe29b1365aed4ad112eabb3d57e847f
Author: Stephan Ewen <se...@...>
Date: 2018-04-17T15:44:48Z
[hotfix] [core] Cleanup TypeInformationSerializationSchema
Prevents the class from dropping the TypeInformation, adds a convenience constructor.
commit c202e13bb7c8b9ada24de991ed4f143daa5f490e
Author: Stephan Ewen <se...@...>
Date: 2018-04-17T17:46:08Z
[FLINK-9197] [core] Improve error messages for TypeInformation and TypeHint with generic variables.
commit d6a05a19ec735621090f2cba9b785b6f77a525db
Author: Stephan Ewen <se...@...>
Date: 2018-04-17T18:02:22Z
[hotfix] [core] Drop hijacking of TypeHint by OutputTag. Improve error message for OutputTag.
commit 6de1d1229db65468be60c4ab42f7f2d352c4415d
Author: Stephan Ewen <se...@...>
Date: 2018-04-17T18:04:16Z
[hotfix] [core] Fix OutputTag serialization to not drop TypeInformation
commit e0e94b6afebcb94719dac2510eadf5085fa464e7
Author: Stephan Ewen <se...@...>
Date: 2018-04-17T18:46:26Z
[FLINK-9198] [core] Improve AbstractDeserializationSchema to eagerly extract generic types.
This results in better error messages.
commit 1b3059ec30233dc245ac2eb97deeea6e6294def3
Author: yanghua <ya...@...>
Date: 2018-04-20T06:11:45Z
[FLINK-9223] [tests] bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd
This closes #5882
commit de2eaa45c6af24701d9b13ca12c04d6b82885171
Author: Ken Krugler <ke...@...>
Date: 2018-04-14T19:57:22Z
[hotfix] [docs] Minor cleanup of Java example code for AsyncFunctions
This closes #5848
commit 814d9ea7674cdc4ff32f04807f1c4e8375064425
Author: Nico Kruber <ni...@...>
Date: 2018-03-22T15:48:24Z
[FLINK-9053][runtime] only release outputs under the checkpoint lock
Releasing an operator chain's outputs will call RecordWriter#clearBuffers() and
this may not be run in parallel with RecordWriter#broadcastEvent() which the
asynchronous checkpoint barrier trigger inside Task may run via
StreamTask#triggerCheckpoint(). Now, during the cleanup of StreamTask#invoke(),
StreamTask's asynchronous services are shut down but not those of the Task and
also, operatorChain.releaseOutputs() was not put under the checkpoint lock.
This commit adds the checkpoint lock here and we should be safe to do so since
we already closed all of StreamTask's asynchronous executors and also disposed
the operators and hence nothing should be blocking the cleanup by holding the
checkpoint lock.
This closes #5748
commit bc54ee9da90f61e7b9a2f95d4aad3c4a3f86e432
Author: Stephan Ewen <se...@...>
Date: 2018-04-22T13:12:10Z
[hotfix] [core] Make some fields final in LimitedConnectionsFileSystem
commit d36498f3915c303ec2b1ecd83401b074aceef73b
Author: Nico Kruber <ni...@...>
Date: 2018-03-02T16:26:48Z
[FLINK-8402] [tests] Fix hadoop/presto S3 IT cases for eventually-consistent operations
Also see
https://docs.aws.amazon.com/AmazonS3/latest/dev/Introduction.html#ConsistencyModel
This closes #5624
commit d178e3f98507c0b2b4e3ce2abd0f2490a16d708a
Author: Nico Kruber <ni...@...>
Date: 2018-04-06T09:15:10Z
[FLINK-9076] [network] Reduce minimum number of floating buffers to 0
This closes #5874
commit cb044229e4c480cc22a250130d58dea5d02fbfc8
Author: sihuazhou <su...@...>
Date: 2018-04-12T03:10:48Z
[FLINK-9158] [core] Set default FixedRestartDelayStrategy delay to 0s.
This closes #5839
commit 7ae8e41d80932b49beb58e3bee627765cfe5b4f7
Author: zhangminglei <zm...@...>
Date: 2018-04-16T08:32:28Z
[FLINK-8335] [hbase] Upgrade hbase connector dependency to 1.4.3
This closes #5488
commit 53fb4f737c99e8782f2f7354124855772366ee0a
Author: kkloudas <kk...@...>
Date: 2018-04-23T14:22:38Z
[hotfix] Making arguments in BroadcastProcessFunction final.
commit 1b55747685477bc3b42c200fca9fa148f614885a
Author: zentol <ch...@...>
Date: 2018-04-24T08:07:00Z
[FLINK-9241][metrics][docs] Fix ScalaGauge usage example
----
---
[GitHub] flink pull request #6085: [FLINK-9452] Flink 1.5 document version title show...
Posted by yanghua <gi...@git.apache.org>.
Github user yanghua closed the pull request at:
https://github.com/apache/flink/pull/6085
---