The Buildbot has detected a restored build 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/325
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave1_ubuntu
Build Reason: The
The Buildbot has detected a new failure 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/41
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave2_ubuntu
Build Reason: The
[FLINK-4571] [gelly] Configurable little parallelism in Gelly drivers
This closes #2475
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bdd3c0d9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bdd3c0d9
Diff:
Repository: flink
Updated Branches:
refs/heads/master 0735b5b93 -> bdd3c0d94
[FLINK-4522] [docs] Gelly link broken in homepage
The Gelly documentation was recently split into multiple pages in
FLINK-4104 but was missing a redirect. This commit updates the Gelly
redirect to point to the old
[FLINK-4257] [gelly] Handle delegating algorithm change of class
Replaces Delegate with NoOpOperator.
This closes #2474
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8210ff46
Tree:
Repository: flink
Updated Branches:
refs/heads/flip-6 1f3256b59 -> 17b83f11b
[hotfix] [taskmanager] Fixes TaskManager component creation at startup
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17b83f11
Tree:
http://git-wip-us.apache.org/repos/asf/flink/blob/02b852e3/flink-tests/src/test/java/org/apache/flink/test/runtime/leaderelection/ZooKeeperLeaderElectionITCase.java
--
diff --git
[FLINK-4451] [rpc] Throw RpcConnectionException when rpc endpoint is not
reachable
This PR introduces a RpcConnectionException which is thrown if the rpc endpoint
is not reachable when calling RpcService.connect.
This closes #2405.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
[FLINK-4559][kinesis-connector] Fix AWSUtil.getCredentialsProvider() to not
return null
Return a DefaultAWSCredentialsProviderChain instead of null when
AWS_CREDENTIALS_PROVIDER config is set to "AUTO"
This closes #2470
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-4265] [dataset api] Add a NoOpOperator
Adds a NoOpOperator which is unwound in OperatorTranslation.translate.
This will be first used by Gelly as a placeholder to support implicit
operator reuse.
This closes #2294
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-4459] [distributed runtime] Introduce SlotProvider for Scheduler
This closes #2424
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6e40f590
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6e40f590
Diff:
[FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters
Adapt related components to the changes in HighAvailabilityServices
Add comments for getJobMasterElectionService in HighAvailabilityServices
This closes #2377.
Project:
[FLINK-4414] [cluster] Add getAddress method to RpcGateway
The RpcGateway.getAddress method allows to retrieve the fully qualified address
of the
associated RpcEndpoint.
This closes #2392.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-4383] [rpc] Eagerly serialize remote rpc invocation messages
This PR introduces an eager serialization for remote rpc invocation messages.
That way it is possible to check whether the message is serializable and
whether it exceeds the maximum allowed akka frame size. If either of these
[FLINK-4373] [cluster management] Introduce SlotID, AllocationID,
ResourceProfile
[FLINK-4373] [cluster management] address comments
This closes #2370.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e966f821
Tree:
http://git-wip-us.apache.org/repos/asf/flink/blob/72468d14/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
--
diff --git
[FLINK-4516] leader election of resourcemanager
- add serial rpc service
- add a special rpcService implementation which directly executes the
asynchronous calls serially one by one, it is just for testcase
- Change ResourceManagerLeaderContender code and TestingSerialRpcService code
- override
[FLINK-4392] [rpc] Make RPC Service thread-safe
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/518fb681
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/518fb681
Diff:
[FLINK-3580] [table] Add current time point functions
This closes #2441.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e376c003
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e376c003
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/72468d14/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
--
diff --git
[FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out of
the rpc package
The TaskExecutor, the JobMaster and the ResourceManager were still contained in
the rpc
package. With this commit, they will be moved out of this package. Now they are
contained
in dedicated packages
http://git-wip-us.apache.org/repos/asf/flink/blob/02b852e3/flink-streaming-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/manualtests/ManualExactlyOnceWithStreamReshardingTest.java
[FLINK-4347][cluster management] Implement SlotManager core
This closes #2388
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/108f43f7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/108f43f7
Diff:
[FLINK-4443] [rpc] Add support for rpc gateway and rpc endpoint inheritance
This commit extends the RpcCompletenessTest such that it can now check for
inherited
remote procedure calls. All methods defined at the RpcGateway are considered
native.
This means that they need no RpcEndpoint
[hotfix] Add self rpc gateway registration to TestingSerialRpcService
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/562b2937
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/562b2937
Diff:
[FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies
This PR introduces a generic AkkaRpcActor which receives rpc calls as a
RpcInvocation message. The RpcInvocation message is generated by the
AkkaInvocationHandler which gets them from automatically generated Java Proxies.
Add
http://git-wip-us.apache.org/repos/asf/flink/blob/67e6f574/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java
--
diff --git
[FLINK-4363] Implement TaskManager basic startup of all components in java
This closes #2400
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/73de8427
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/73de8427
Diff:
[FLINK-4403] [rpc] Use relative classloader for proxies, rather than system
class loader.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a7e3579b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a7e3579b
Diff:
[FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as
protected
Give main thread execution context into the
TaskExecutorToResourceManagerConnection
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
http://git-wip-us.apache.org/repos/asf/flink/blob/6e40f590/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/SchedulerSlotSharingTest.java
--
diff --git
[FLINK-4355] [cluster management] Implement TaskManager side of registration at
ResourceManager.
This closes #2353
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f94ae532
Tree:
[hotfix] [clustermgnt] Set pending registration properly in
TaskExecutorToResourceManagerConnection
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20fefaae
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/20fefaae
http://git-wip-us.apache.org/repos/asf/flink/blob/02b852e3/flink-runtime/src/main/scala/org/apache/flink/runtime/testingUtils/TestingTaskManagerLike.scala
--
diff --git
[hotfix] Remove RecoveryMode from JobMaster
The recovery mode is not used any more by the latest CheckpointCoordinator.
All difference in recovery logic between high-availability and
non-high-availability
is encapsulated in the HighAvailabilityServices.
Project:
http://git-wip-us.apache.org/repos/asf/flink/blob/0f36fb7f/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerGateway.java
--
diff --git
[FLINK-4073] remove unstable testing code in TaskManagerFailure test
Yarn reports null or (1, maxVcores) depending on its internal logic. The
test only worked in the past because it summed up the used vcores of the
RM and the TM containers. We have checks in place to ensure the vcores
config
[FLINK-4073] fix stability of TaskManagerFailure test
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2f87f61d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2f87f61d
Diff:
[FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokensFor()
This closes #2402
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7e07bde8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7e07bde8
Diff:
[FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster
Rename _configuration to originalConfiguration
Remove testing classes from main scope in flink-runtime
Previously, the ForkableFlinkMiniCluster which resided in flink-test-utils
required
these files to be in the main scope
[FLINK-4368] [distributed runtime] Eagerly initialize the RPC endpoint members
This closes #2351
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/506aac07
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/506aac07
Diff:
[FLINK-4456] Replace Akka specific types by interfaces in Task
Introduce TaskExecutionStateListener for Task
Replace JobManagerGateway in Task by InputSplitProvider and CheckpointNotifier
Replace the TaskManager ActorGateway by TaskManagerConnection in Task
Rename
Repository: flink
Updated Branches:
refs/heads/flip-6 0cf2a822b -> 1f3256b59 (forced update)
[FLINK-4566] [network runtime] Properly preserve exception causes for
ProducerFailedException
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-4570] remove conflicting Unicode character
This caused Scalastyle to fail, presumably depending on the locale
used. After a bit of debugging on the Scalastyle plugin I found out that
the number in the error is the byte position.
"Expected identifier, but got Token(COMMA,,,1772,,)"
head
[FLINK-4382] [rpc] Buffer rpc calls until the RpcEndpoint has been started
This PR allows the AkkaRpcActor to stash messages until the corresponding
RcpEndpoint
has been started. When receiving a Processing.START message, the AkkaRpcActor
unstashes all messages and starts processing rpcs. When
[FLINK-4346] [rpc] Add new RPC abstraction
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0f36fb7f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0f36fb7f
Diff:
[FLINK-4567] [runtime] Enhance SerializedThrowable to properly mimic Exception
causes
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/761d0a02
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/761d0a02
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/72468d14/flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/SlotManagerTest.java
--
diff --git
[FLINK-4355] [cluster management] Add tests for the TaskManager ->
ResourceManager registration.
This closes #2395.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/223eb6f5
Tree:
[FLINK-4386] [rpc] Add a utility to verify calls happen in the Rpc Endpoint's
main thread
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2963e6c1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2963e6c1
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/72468d14/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/72468d14/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/SlotManagerTest.java
--
diff --git
[FLINK-4434] [rpc] Add a testing RPC service.
This closes #2394.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b540c718
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b540c718
Diff:
Repository: flink
Updated Branches:
refs/heads/master 02b852e35 -> 0735b5b93
[FLINK-4456] Replace Akka specific types by interfaces in Task
Introduce TaskExecutionStateListener for Task
Replace JobManagerGateway in Task by InputSplitProvider and CheckpointNotifier
Replace the TaskManager
http://git-wip-us.apache.org/repos/asf/flink/blob/02b852e3/flink-runtime/src/main/scala/org/apache/flink/runtime/testingUtils/TestingTaskManagerLike.scala
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master 920cda408 -> 02b852e35
http://git-wip-us.apache.org/repos/asf/flink/blob/02b852e3/flink-tests/src/test/java/org/apache/flink/test/runtime/leaderelection/ZooKeeperLeaderElectionITCase.java
http://git-wip-us.apache.org/repos/asf/flink/blob/02b852e3/flink-streaming-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/manualtests/ManualExactlyOnceWithStreamReshardingTest.java
Repository: flink
Updated Branches:
refs/heads/master 66d4b8724 -> 920cda408
[FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokensFor()
This closes #2402
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7e07bde8
Tree:
[FLINK-4595] Close FileOutputStream in ParameterTool
This closes #2478
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/920cda40
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/920cda40
Diff:
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/799a6cdc
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/799a6cdc
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/799a6cdc
Repository: flink-web
Updated Branches:
refs/heads/asf-site 190b3d610 -> 799a6cdcf
add guideline about merge commits
This closes #33
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/6cf93263
Tree:
Repository: flink
Updated Tags: refs/tags/release-1.1.2 [created] 7294b82bf
62 matches
Mail list logo
