The Buildbot has detected a build exception 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/374
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave3_ubuntu
Build Reason: The N
The Buildbot has detected a build exception 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/259
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave3_ubuntu
Build Reason: The
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/382
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: tethys_ubuntu
Build Reason: The Nightly scheduler
Repository: flink
Updated Branches:
refs/heads/master 17dfd68d0 -> 49ce6f7b8
[hotfix] [core][gelly] Fix license formatting
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/49ce6f7b
Tree: http://git-wip-us.apache.org/repos/a
http://git-wip-us.apache.org/repos/asf/flink/blob/17dfd68d/flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java
--
diff --git
a/flink-streamin
Repository: flink
Updated Branches:
refs/heads/master 424c08267 -> 17dfd68d0
http://git-wip-us.apache.org/repos/asf/flink/blob/17dfd68d/flink-streaming-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/testutils/TestableFlinkKinesisConsumer.java
[FLINK-3231] FlinkKinesisConsumer rework to handle Kinesis resharding
This also fixes FLINK-4020: remove shard list querying from Kinesis consumer
constructor
This closes #2131
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commi
http://git-wip-us.apache.org/repos/asf/flink/blob/17dfd68d/flink-streaming-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcherTest.java
--
diff --git
a/flink-
Repository: flink
Updated Branches:
refs/heads/master 0c8092855 -> 424c08267
[FLINK-4146] Fix YARN test failure
This closes #2200
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/424c0826
Tree: http://git-wip-us.apache.org
Repository: flink
Updated Branches:
refs/heads/master 8a2c03e1a -> 0c8092855
[FLINK-4133] Reflect streaming file source changes in documentation
This closes #2198
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0c809285
T
http://git-wip-us.apache.org/repos/asf/flink/blob/4b71e0e7/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
--
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.ja
Repository: flink
Updated Branches:
refs/heads/master 5c0c7e36e -> 8a2c03e1a
http://git-wip-us.apache.org/repos/asf/flink/blob/4b71e0e7/flink-test-utils/src/test/java/org/apache/flink/test/util/TestBaseUtils.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/b9f42e91/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorTest.java
--
diff --git
a/flink-streaming-java/src/test/java/org/apache/flink/s
[FLINK-3995] [build] Properly structure test scopes and dependencies
Makes the JUnit test utils (TestLogger, retry rules, ...) properly available to
other projects without the 'flink-core' test-jar, via the
'flink-test-utils-junit' project.
Makes the ForkableMiniCluster, TestEnvironment, and ot
http://git-wip-us.apache.org/repos/asf/flink/blob/b9f42e91/flink-streaming-java/src/test/java/org/apache/flink/streaming/timestamp/TimestampITCase.java
--
diff --git
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/
[FLINK-3995] [build] Fix failing tests and add missing dependencies
This closes #2148
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8a2c03e1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8a2c03e1
Diff: http://git-
http://git-wip-us.apache.org/repos/asf/flink/blob/b9f42e91/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/CoGroupJoinITCase.java
--
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/
[FLINK-3995] [build] flink-test-utils also contains the streaming test
utilities.
Test utilities include the StreamingMultipleProgramsTestBase and
StreamingTestEnvironment.
This moves the ITCases for streaming into 'flink-tests' to achieve that.
This closes #2092
Project: http://git-wip-us.a
http://git-wip-us.apache.org/repos/asf/flink/blob/4b71e0e7/flink-runtime/src/main/scala/org/apache/flink/runtime/testingUtils/TestingJobManagerMessages.scala
--
diff --git
a/flink-runtime/src/main/scala/org/apache/flink/runtime/te
http://git-wip-us.apache.org/repos/asf/flink/blob/4b71e0e7/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
--
diff --git
a/flink-test-utils-parent/flink-test-utils/src/main/java
http://git-wip-us.apache.org/repos/asf/flink/blob/4b71e0e7/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskAsyncCheckpointTest.java
--
diff --git
a/flink-streaming-java/src/test/java/org/apach
http://git-wip-us.apache.org/repos/asf/flink/blob/b9f42e91/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/StreamTaskTimerITCase.java
--
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/streaming/runt
http://git-wip-us.apache.org/repos/asf/flink/blob/4b71e0e7/flink-test-utils/src/test/java/org/apache/flink/test/testdata/WebLogAnalysisData.java
--
diff --git
a/flink-test-utils/src/test/java/org/apache/flink/test/testdata/WebLogA
http://git-wip-us.apache.org/repos/asf/flink/blob/4b71e0e7/flink-java/src/test/java/org/apache/flink/api/common/io/SequentialFormatTestBase.java
--
diff --git
a/flink-java/src/test/java/org/apache/flink/api/common/io/SequentialFor
http://git-wip-us.apache.org/repos/asf/flink/blob/4b71e0e7/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/testdata/WebLogAnalysisData.java
--
diff --git
a/flink-test-utils-parent/flink-test-utils/src/
[FLINK-4115] Skip filesystem checks for filesystems with no built-in support
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a3d1a174
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a3d1a174
Diff: http://git-wip-us.apa
Change Validation Exception to LOG.warn() in FsStateBackend
Before, job would fail with an exception if the checkpoint filesystem
was not accessible from the client. This is preventing some correct jobs
from running.
Now, only print a warning.
This closes #2157
Project: http://git-wip-us.apach
Repository: flink
Updated Branches:
refs/heads/master 647b4c577 -> 5c0c7e36e
[FLINK-4115] Remove filesystem initialisation from FsStateBackend constructor
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/989c67a1
Tree: http
Repository: flink
Updated Branches:
refs/heads/master 18995c8c7 -> 647b4c577
[FLINK-4145] Harden JMX tests
Use distinct non-default port ranges for all tests.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/647b4c57
Tree:
29 matches
Mail list logo