flink git commit: [hotfix] [streaming api] Re-register timers in open() instead of restore()
Repository: flink
Updated Branches:
refs/heads/master 6efb7c266 -> 97c71675a
[hotfix] [streaming api] Re-register timers in open() instead of restore()
This makes sure timers cannot fire prior to the operator being opened.
This closes #2602
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/97c71675
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/97c71675
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/97c71675
Branch: refs/heads/master
Commit: 97c71675ad9e2b50b818362f92faef9eb44da627
Parents: 6efb7c2
Author: kl0u
Authored: Thu Oct 6 10:44:58 2016 +0200
Committer: Stephan Ewen
Committed: Fri Oct 7 11:01:49 2016 +0200
--
.../runtime/operators/windowing/WindowOperator.java | 9 +
1 file changed, 5 insertions(+), 4 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/flink/blob/97c71675/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
--
diff --git
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
index c5f1ca2..4d8f655 100644
---
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
+++
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
@@ -230,6 +230,11 @@ public class WindowOperator
if (windowAssigner instanceof MergingWindowAssigner) {
mergingWindowsByKey = new HashMap<>();
}
+
+ // re-register the restored timers (if any)
+ if (processingTimeTimersQueue.size() > 0) {
+ nextTimer =
getTimerService().registerTimer(processingTimeTimersQueue.peek().timestamp,
this);
+ }
}
@Override
@@ -881,10 +886,6 @@ public class WindowOperator
processingTimeTimersQueue.add(timer);
processingTimeTimers.add(timer);
}
-
- if (numProcessingTimeTimers > 0) {
- nextTimer =
getTimerService().registerTimer(processingTimeTimersQueue.peek().timestamp,
this);
- }
}
private void snapshotTimers(DataOutputView out) throws IOException {
buildbot success in on flink-docs-master
The Buildbot has detected a restored build on builder flink-docs-master while building . Full details are available at: https://ci.apache.org/builders/flink-docs-master/builds/482 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave3_ubuntu Build Reason: forced: by IRC user on channel #flink-testing: rebuilding after fix Build Source Stamp: HEAD Blamelist: Build succeeded! Sincerely, -The Buildbot
flink git commit: [FLINK-4731] Fix HeapKeyedStateBackend Scale-In
Repository: flink
Updated Branches:
refs/heads/master 97c71675a -> 8d953bf26
[FLINK-4731] Fix HeapKeyedStateBackend Scale-In
Adds additional tests in RescalingITCase for scale-in
This closes #2584.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8d953bf2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8d953bf2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8d953bf2
Branch: refs/heads/master
Commit: 8d953bf2626012e3e497334641962bd8f96098de
Parents: 97c7167
Author: Stefan Richter
Authored: Sun Oct 2 16:56:41 2016 +0200
Committer: Ufuk Celebi
Committed: Fri Oct 7 14:14:27 2016 +0200
--
.../savepoint/SavepointV1Serializer.java| 4 +-
.../filesystem/FsCheckpointStreamFactory.java | 11 +-
.../state/heap/HeapKeyedStateBackend.java | 164 ++--
.../state/memory/ByteStreamStateHandle.java | 79 +++---
.../memory/MemCheckpointStreamFactory.java | 3 +-
.../checkpoint/CheckpointCoordinatorTest.java | 20 +-
.../checkpoint/savepoint/SavepointV1Test.java | 9 +-
.../jobmanager/JobManagerHARecoveryTest.java| 4 +-
.../ZooKeeperSubmittedJobGraphsStoreITCase.java | 7 +-
.../runtime/testutils/CommonTestUtils.java | 23 ++
.../TestByteStreamStateHandleDeepCompare.java | 54
.../test/checkpointing/RescalingITCase.java | 253 ---
12 files changed, 465 insertions(+), 166 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/flink/blob/8d953bf2/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java
index f120e1d..666176b 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java
@@ -290,6 +290,7 @@ class SavepointV1Serializer implements
SavepointSerializer {
} else if (stateHandle instanceof ByteStreamStateHandle) {
dos.writeByte(BYTE_STREAM_STATE_HANDLE);
ByteStreamStateHandle byteStreamStateHandle =
(ByteStreamStateHandle) stateHandle;
+ dos.writeUTF(byteStreamStateHandle.getHandleName());
byte[] internalData = byteStreamStateHandle.getData();
dos.writeInt(internalData.length);
dos.write(byteStreamStateHandle.getData());
@@ -310,10 +311,11 @@ class SavepointV1Serializer implements
SavepointSerializer {
String pathString = dis.readUTF();
return new FileStateHandle(new Path(pathString), size);
} else if (BYTE_STREAM_STATE_HANDLE == type) {
+ String handleName = dis.readUTF();
int numBytes = dis.readInt();
byte[] data = new byte[numBytes];
dis.readFully(data);
- return new ByteStreamStateHandle(data);
+ return new ByteStreamStateHandle(handleName, data);
} else {
throw new IOException("Unknown implementation of
StreamStateHandle, code: " + type);
}
http://git-wip-us.apache.org/repos/asf/flink/blob/8d953bf2/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java
--
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java
index e4f7eba..fcc97b3 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java
@@ -177,7 +177,6 @@ public class FsCheckpointStreamFactory implements
CheckpointStreamFactory {
this.localStateThreshold = localStateThreshold;
}
-
@Override
public void write(int b) throws IOException {
if (pos >= writeBuffer.length) {
@@ -219,7 +218,7 @@ public class FsCheckpointStreamFactory implements
CheckpointStreamFactory {
@Override
public long getPos() throws IOException {
- return outStream == null ? pos : outSt
buildbot failure in on flink-docs-master
The Buildbot has detected a new failure on builder flink-docs-master while building . Full details are available at: https://ci.apache.org/builders/flink-docs-master/builds/483 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: forced: by IRC user on channel #flink-testing: rebuilding after fix Build Source Stamp: HEAD Blamelist: BUILD FAILED: failed Flink docs Sincerely, -The Buildbot
buildbot success in on flink-docs-master
The Buildbot has detected a restored build on builder flink-docs-master while building . Full details are available at: https://ci.apache.org/builders/flink-docs-master/builds/484 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave1_ubuntu Build Reason: forced: by IRC user on channel #flink-testing: rebuilding after fix Build Source Stamp: HEAD Blamelist: Build succeeded! Sincerely, -The Buildbot
[2/2] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager
[FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager Instead of relying on a full synchronization of all slots information on every heartbeat, the SlotManager is now responsible for updating its state. It initially syncs all slots upon registration of the TaskExecutor. After that, it only receives notifications from the TaskExecutor when slots become available again. This simplifies the logic of the SlotManager and makes the slot allocation more predictable in case of message loss. Additional changes: - Move the slot registration and allocation report to the registration of the TaskExecutor - Let the TaskExecutor immediately notify the ResourceManager once a slot becomes free. The ResourceManager has to confirm this notification. Otherwise, the slot will be blocked because the ResourceManager's state is not in sync. - Integrate with handleSlotRequestFailedAtTaskManager and introduce fencing to protect against TaskExecutors which are not registered anymore. - introduce RPC call to notify ResourceManager about free slots - ignore out-of-date slot requests from ResourceManager at TaskExecutor - let the ResourceManager update its state instead of relying on heartbeats - provide ResourceManagerServices to SlotManager - introduce factory for SlotManager - keep task gateways and worker information in ResourceManager and inform SlotManager - add TaskExecutor test to ensure that a free slot which hasn't been confirmed by the task executor is correctly blacklisted as long as the ResourceManager has not confirmed the allocation removal. - adapt tests - update javadocs This closes #2571. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0518af03 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0518af03 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0518af03 Branch: refs/heads/flip-6 Commit: 0518af03a8931ed9b2da013c5ed4da7065156ee0 Parents: 85424c1 Author: Maximilian Michels Authored: Thu Sep 29 15:08:32 2016 +0200 Committer: Maximilian Michels Committed: Fri Oct 7 15:51:14 2016 +0200 -- .../clusterframework/types/ResourceSlot.java| 12 +- .../resourcemanager/ResourceManager.java| 115 +-- .../resourcemanager/ResourceManagerGateway.java | 31 +- .../ResourceManagerServices.java| 2 +- .../resourcemanager/SlotRequestRegistered.java | 33 -- .../resourcemanager/SlotRequestRejected.java| 34 -- .../resourcemanager/SlotRequestReply.java | 41 --- .../StandaloneResourceManager.java | 8 +- .../jobmanager/RMSlotRequestRegistered.java | 33 ++ .../jobmanager/RMSlotRequestRejected.java | 34 ++ .../messages/jobmanager/RMSlotRequestReply.java | 41 +++ .../taskexecutor/SlotAvailableReply.java| 47 +++ .../taskexecutor/TMSlotRequestRegistered.java | 35 ++ .../taskexecutor/TMSlotRequestRejected.java | 35 ++ .../taskexecutor/TMSlotRequestReply.java| 58 .../registration/TaskExecutorRegistration.java | 12 +- .../registration/WorkerRegistration.java| 42 +++ .../slotmanager/SimpleSlotManager.java | 53 --- .../slotmanager/SlotManager.java| 326 +++ .../slotmanager/SlotManagerFactory.java | 31 ++ .../flink/runtime/taskexecutor/SlotReport.java | 19 +- .../runtime/taskexecutor/TaskExecutor.java | 37 ++- .../taskexecutor/TaskExecutorGateway.java | 7 +- ...TaskExecutorToResourceManagerConnection.java | 2 +- .../resourcemanager/ResourceManagerHATest.java | 12 +- .../ResourceManagerJobMasterTest.java | 4 +- .../ResourceManagerTaskExecutorTest.java| 53 +-- .../resourcemanager/TestingResourceManager.java | 53 +++ .../resourcemanager/TestingSlotManager.java | 78 + .../slotmanager/SlotManagerTest.java| 239 ++ .../slotmanager/SlotProtocolTest.java | 92 -- .../runtime/taskexecutor/TaskExecutorTest.java | 96 +- 32 files changed, 1087 insertions(+), 628 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink/blob/0518af03/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java index 4a91a79..0b9367d 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceSlot.java @@ -18,7 +18,7 @@ package org.apache.flink.runtime.clusterfr
[1/2] flink git commit: [FLINK-4347][FLINK-4348] simplify SlotManager and integrate it with ResourceManager
Repository: flink
Updated Branches:
refs/heads/flip-6 85424c135 -> 0518af03a
http://git-wip-us.apache.org/repos/asf/flink/blob/0518af03/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerJobMasterTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerJobMasterTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerJobMasterTest.java
index 8f09152..14afd0e 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerJobMasterTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerJobMasterTest.java
@@ -25,10 +25,8 @@ import org.apache.flink.runtime.jobmaster.JobMasterGateway;
import org.apache.flink.runtime.jobmaster.JobMasterRegistrationSuccess;
import org.apache.flink.runtime.leaderelection.TestingLeaderElectionService;
import org.apache.flink.runtime.leaderelection.TestingLeaderRetrievalService;
-import org.apache.flink.runtime.resourcemanager.slotmanager.SimpleSlotManager;
import org.apache.flink.runtime.rpc.TestingSerialRpcService;
import org.apache.flink.runtime.registration.RegistrationResponse;
-import org.apache.flink.runtime.rpc.exceptions.LeaderSessionIDException;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
@@ -160,7 +158,7 @@ public class ResourceManagerJobMasterTest {
TestingHighAvailabilityServices highAvailabilityServices = new
TestingHighAvailabilityServices();
highAvailabilityServices.setResourceManagerLeaderElectionService(resourceManagerLeaderElectionService);
highAvailabilityServices.setJobMasterLeaderRetriever(jobID,
jobMasterLeaderRetrievalService);
- ResourceManager resourceManager = new
StandaloneResourceManager(rpcService, highAvailabilityServices, new
SimpleSlotManager());
+ ResourceManager resourceManager = new
TestingResourceManager(rpcService, highAvailabilityServices);
resourceManager.start();
return resourceManager;
}
http://git-wip-us.apache.org/repos/asf/flink/blob/0518af03/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTaskExecutorTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTaskExecutorTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTaskExecutorTest.java
index e6d1ed5..a577c26 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTaskExecutorTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTaskExecutorTest.java
@@ -22,10 +22,9 @@ import
org.apache.flink.runtime.clusterframework.types.ResourceID;
import org.apache.flink.runtime.concurrent.Future;
import
org.apache.flink.runtime.highavailability.TestingHighAvailabilityServices;
import org.apache.flink.runtime.leaderelection.TestingLeaderElectionService;
-import org.apache.flink.runtime.resourcemanager.slotmanager.SimpleSlotManager;
import org.apache.flink.runtime.rpc.TestingSerialRpcService;
import org.apache.flink.runtime.registration.RegistrationResponse;
-import org.apache.flink.runtime.rpc.exceptions.LeaderSessionIDException;
+import org.apache.flink.runtime.taskexecutor.SlotReport;
import org.apache.flink.runtime.taskexecutor.TaskExecutorGateway;
import org.apache.flink.runtime.taskexecutor.TaskExecutorRegistrationSuccess;
import org.junit.After;
@@ -44,9 +43,24 @@ public class ResourceManagerTaskExecutorTest {
private TestingSerialRpcService rpcService;
+ private SlotReport slotReport = new SlotReport();
+
+ private static String taskExecutorAddress = "/taskExecutor1";
+
+ private ResourceID taskExecutorResourceID;
+
+ private StandaloneResourceManager resourceManager;
+
+ private UUID leaderSessionId;
+
@Before
public void setup() throws Exception {
rpcService = new TestingSerialRpcService();
+
+ taskExecutorResourceID = mockTaskExecutor(taskExecutorAddress);
+ TestingLeaderElectionService rmLeaderElectionService = new
TestingLeaderElectionService();
+ resourceManager =
createAndStartResourceManager(rmLeaderElectionService);
+ leaderSessionId = grantLeadership(rmLeaderElectionService);
}
@After
@@ -59,19 +73,15 @@ public class ResourceManagerTaskExecutorTest {
*/
@Test
public void testRegisterTaskExecutor() throws Exception {
- String taskExecutorAddress = "/taskExecutor1";
- ResourceID taskExecutorResourceID =
mockTaskExecutor(taskExecutorAddress);
-
flink git commit: [FLINK-4318][docs] change default version in config
Repository: flink Updated Branches: refs/heads/master 8d953bf26 -> 706dc131c [FLINK-4318][docs] change default version in config Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/706dc131 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/706dc131 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/706dc131 Branch: refs/heads/master Commit: 706dc131cfdce0b75d6a5fa237a96fe723a1b22e Parents: 8d953bf Author: Maximilian Michels Authored: Fri Oct 7 16:03:13 2016 +0200 Committer: Maximilian Michels Committed: Fri Oct 7 16:04:14 2016 +0200 -- docs/_config.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/flink/blob/706dc131/docs/_config.yml -- diff --git a/docs/_config.yml b/docs/_config.yml index 700d289..1f9f157 100644 --- a/docs/_config.yml +++ b/docs/_config.yml @@ -80,4 +80,4 @@ kramdown: host: 0.0.0.0 # please use a protocol relative URL here -baseurl: //ci.apache.org/projects/flink/flink-docs-master +baseurl: //ci.apache.org/projects/flink/flink-docs-release-1.2
[1/3] flink-web git commit: [FLINK-4318][docs] change default version in config
Repository: flink-web Updated Branches: refs/heads/asf-site 799a6cdcf -> aaf1263c9 [FLINK-4318][docs] change default version in config Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/d758d51a Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/d758d51a Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/d758d51a Branch: refs/heads/asf-site Commit: d758d51a08c69f1900c358546b156e77e36a043d Parents: 799a6cd Author: Maximilian Michels Authored: Wed Oct 5 16:06:44 2016 +0200 Committer: Maximilian Michels Committed: Fri Oct 7 16:11:23 2016 +0200 -- _config.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/d758d51a/_config.yml -- diff --git a/_config.yml b/_config.yml index 1c008aa..c0dc495 100644 --- a/_config.yml +++ b/_config.yml @@ -47,7 +47,7 @@ stable: "1.1" snapshot: "1.2" docs-stable: "http://ci.apache.org/projects/flink/flink-docs-release-1.1"; -docs-snapshot: "http://ci.apache.org/projects/flink/flink-docs-master"; +docs-snapshot: "http://ci.apache.org/projects/flink/flink-docs-release-1.2"; # Used by the gh_link plugin jira: "https://issues.apache.org/jira/browse/FLINK";
[3/3] flink-web git commit: update website
update website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/aaf1263c Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/aaf1263c Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/aaf1263c Branch: refs/heads/asf-site Commit: aaf1263c9279b0247500b06a7da2d1691e0abdcd Parents: d758d51 Author: Maximilian Michels Authored: Thu Oct 6 16:06:44 2016 +0200 Committer: Maximilian Michels Committed: Fri Oct 7 16:11:26 2016 +0200 -- content/blog/index.html | 6 ++--- content/blog/page2/index.html | 6 ++--- content/blog/page3/index.html | 6 ++--- content/blog/page4/index.html | 6 ++--- .../release_1.0.0-changelog_known_issues.html | 6 ++--- content/blog/release_1.1.0-changelog.html | 6 ++--- content/community.html | 6 ++--- content/community.md.orig | 6 ++--- content/contribute-code.html| 6 ++--- content/contribute-documentation.html | 6 ++--- content/downloads.html | 6 ++--- content/faq.html| 26 ++-- content/features.html | 6 ++--- content/how-to-contribute.html | 6 ++--- content/improve-website.html| 6 ++--- content/index.html | 24 +- content/material.html | 6 ++--- content/news/2014/08/26/release-0.6.html| 6 ++--- content/news/2014/09/26/release-0.6.1.html | 6 ++--- content/news/2014/10/03/upcoming_events.html| 6 ++--- content/news/2014/11/04/release-0.7.0.html | 6 ++--- .../news/2014/11/18/hadoop-compatibility.html | 6 ++--- content/news/2015/01/06/december-in-flink.html | 6 ++--- content/news/2015/01/21/release-0.8.html| 6 ++--- content/news/2015/02/04/january-in-flink.html | 6 ++--- content/news/2015/02/09/streaming-example.html | 6 ++--- .../news/2015/03/02/february-2015-in-flink.html | 6 ++--- .../peeking-into-Apache-Flinks-Engine-Room.html | 6 ++--- content/news/2015/04/07/march-in-flink.html | 6 ++--- .../2015/04/13/release-0.9.0-milestone1.html| 6 ++--- .../05/11/Juggling-with-Bits-and-Bytes.html | 6 ++--- .../news/2015/05/14/Community-update-April.html | 6 ++--- .../announcing-apache-flink-0.9.0-release.html | 6 ++--- .../2015/08/24/introducing-flink-gelly.html | 6 ++--- content/news/2015/09/01/release-0.9.1.html | 6 ++--- content/news/2015/09/03/flink-forward.html | 6 ++--- content/news/2015/09/16/off-heap-memory.html| 6 ++--- content/news/2015/11/16/release-0.10.0.html | 6 ++--- content/news/2015/11/27/release-0.10.1.html | 6 ++--- .../news/2015/12/04/Introducing-windows.html| 6 ++--- .../news/2015/12/11/storm-compatibility.html| 6 ++--- content/news/2015/12/18/a-year-in-review.html | 6 ++--- content/news/2016/02/11/release-0.10.2.html | 6 ++--- content/news/2016/03/08/release-1.0.0.html | 6 ++--- content/news/2016/04/06/cep-monitoring.html | 6 ++--- content/news/2016/04/06/release-1.0.1.html | 6 ++--- .../news/2016/04/14/flink-forward-announce.html | 6 ++--- content/news/2016/04/22/release-1.0.2.html | 6 ++--- content/news/2016/05/11/release-1.0.3.html | 6 ++--- content/news/2016/05/24/stream-sql.html | 6 ++--- content/news/2016/08/08/release-1.1.0.html | 6 ++--- content/news/2016/08/11/release-1.1.1.html | 6 ++--- content/news/2016/09/05/release-1.1.2.html | 6 ++--- content/poweredby.html | 6 ++--- content/privacy-policy.html | 6 ++--- content/project.html| 6 ++--- content/slides.html | 8 +++--- 57 files changed, 191 insertions(+), 191 deletions(-) -- http://git-wip-us.apache.org/repos/asf/flink-web/blob/aaf1263c/content/blog/index.html -- diff --git a/content/blog/index.html b/content/blog/index.html index a7ea912..916238c 100644 --- a/content/blog/index.html +++ b/content/blog/index.html @@ -89,9 +89,9 @@ Snapshot (Development) -http://ci.apache.org/projects/flink/flink-docs-master";>1.2 Documentation -http://ci.apache.org/projects/flink/flink-docs-master/api/java"; class="active">1.2 Javadocs -http://ci.apache.org/projects/flink/flink-docs-master/api/scala/index.html"; class="active">1.2 ScalaDocs +http://ci.apache.org/projects/flink/flink-docs-release-1.2";>1.2 Documenta
[2/3] flink-web git commit: update website
http://git-wip-us.apache.org/repos/asf/flink-web/blob/aaf1263c/content/news/2016/08/08/release-1.1.0.html -- diff --git a/content/news/2016/08/08/release-1.1.0.html b/content/news/2016/08/08/release-1.1.0.html index 4f5b30b..3eefa68 100644 --- a/content/news/2016/08/08/release-1.1.0.html +++ b/content/news/2016/08/08/release-1.1.0.html @@ -89,9 +89,9 @@ Snapshot (Development) -http://ci.apache.org/projects/flink/flink-docs-master";>1.2 Documentation -http://ci.apache.org/projects/flink/flink-docs-master/api/java"; class="active">1.2 Javadocs -http://ci.apache.org/projects/flink/flink-docs-master/api/scala/index.html"; class="active">1.2 ScalaDocs +http://ci.apache.org/projects/flink/flink-docs-release-1.2";>1.2 Documentation +http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/java"; class="active">1.2 Javadocs +http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/scala/index.html"; class="active">1.2 ScalaDocs http://git-wip-us.apache.org/repos/asf/flink-web/blob/aaf1263c/content/news/2016/08/11/release-1.1.1.html -- diff --git a/content/news/2016/08/11/release-1.1.1.html b/content/news/2016/08/11/release-1.1.1.html index 9a243a1..7df29c5 100644 --- a/content/news/2016/08/11/release-1.1.1.html +++ b/content/news/2016/08/11/release-1.1.1.html @@ -89,9 +89,9 @@ Snapshot (Development) -http://ci.apache.org/projects/flink/flink-docs-master";>1.2 Documentation -http://ci.apache.org/projects/flink/flink-docs-master/api/java"; class="active">1.2 Javadocs -http://ci.apache.org/projects/flink/flink-docs-master/api/scala/index.html"; class="active">1.2 ScalaDocs +http://ci.apache.org/projects/flink/flink-docs-release-1.2";>1.2 Documentation +http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/java"; class="active">1.2 Javadocs +http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/scala/index.html"; class="active">1.2 ScalaDocs http://git-wip-us.apache.org/repos/asf/flink-web/blob/aaf1263c/content/news/2016/09/05/release-1.1.2.html -- diff --git a/content/news/2016/09/05/release-1.1.2.html b/content/news/2016/09/05/release-1.1.2.html index 0abf585..b4207c7 100644 --- a/content/news/2016/09/05/release-1.1.2.html +++ b/content/news/2016/09/05/release-1.1.2.html @@ -89,9 +89,9 @@ Snapshot (Development) -http://ci.apache.org/projects/flink/flink-docs-master";>1.2 Documentation -http://ci.apache.org/projects/flink/flink-docs-master/api/java"; class="active">1.2 Javadocs -http://ci.apache.org/projects/flink/flink-docs-master/api/scala/index.html"; class="active">1.2 ScalaDocs +http://ci.apache.org/projects/flink/flink-docs-release-1.2";>1.2 Documentation +http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/java"; class="active">1.2 Javadocs +http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/scala/index.html"; class="active">1.2 ScalaDocs http://git-wip-us.apache.org/repos/asf/flink-web/blob/aaf1263c/content/poweredby.html -- diff --git a/content/poweredby.html b/content/poweredby.html index 0bf90c1..fc302a2 100644 --- a/content/poweredby.html +++ b/content/poweredby.html @@ -89,9 +89,9 @@ Snapshot (Development) -http://ci.apache.org/projects/flink/flink-docs-master";>1.2 Documentation -http://ci.apache.org/projects/flink/flink-docs-master/api/java"; class="active">1.2 Javadocs -http://ci.apache.org/projects/flink/flink-docs-master/api/scala/index.html"; class="active">1.2 ScalaDocs +http://ci.apache.org/projects/flink/flink-docs-release-1.2";>1.2 Documentation +http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/java"; class="active">1.2 Javadocs +http://ci.apache.org/projects/flink/flink-docs-release-1.2/api/scala/index.html"; class="active">1.2 ScalaDocs http://git-wip-us.apache.org/repos/asf/flink-web/blob/aaf1263c/content/privacy-policy.html -- diff --git a/content/privacy-policy.html b/content/privacy-policy.html index 332e84e..213c5d5 100644 -
buildbot success in on flink-docs-release-1.1
The Buildbot has detected a restored build on builder flink-docs-release-1.1 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.1/builds/70 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave1_ubuntu Build Reason: forced: by IRC user on channel #flink-testing: rebuilding after fix Build Source Stamp: HEAD Blamelist: Build succeeded! Sincerely, -The Buildbot
buildbot failure in on flink-docs-release-0.10
The Buildbot has detected a new failure on builder flink-docs-release-0.10 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-0.10/builds/354 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The Nightly scheduler named 'flink-nightly-docs-release-0.10' triggered this build Build Source Stamp: [branch release-0.10] HEAD Blamelist: BUILD FAILED: failed Flink docs Sincerely, -The Buildbot
buildbot success in on flink-docs-release-0.9
The Buildbot has detected a restored build on builder flink-docs-release-0.9 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-0.9/builds/469 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave3_ubuntu Build Reason: The Nightly scheduler named 'flink-nightly-docs-release-0.9' triggered this build Build Source Stamp: [branch release-0.9] HEAD Blamelist: Build succeeded! Sincerely, -The Buildbot
