[FLINK-3375] [kafka connector] Rework/simplify Kafka Connector and have a
WatermarkExtractor object per partition
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c93103d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tre
http://git-wip-us.apache.org/repos/asf/flink/blob/3c93103d/flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
--
diff --git
a/flink-streaming
[FLINK-3126] [core] Remove accumulator type from "value" in web frontend
This closes #1868
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db85f385
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db85f385
Diff: http:/
[hotfix] [kafka consumer] Increase Kafka test stability by validating written
data before consuming
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d20eda1b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d20eda1b
Dif
[FLINK-3737] [tests] Adding comment about SOCKS proxy server for
WikipediaEditsSourceTest
This closes #1872
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/342db48b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/342
[FLINK-3700] [core] Add 'Preconditions' utility class.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/885d543b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/885d543b
Diff: http://git-wip-us.apache.org/repos/asf/flin
[FLINK-3700] [build] Add 'findbugs' (javax.annotation) annotations as a core
dependency.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/272fd12b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/272fd12b
Diff: http://g
[FLINK-3716] [kafka consumer] Decreasing socket timeout so testFailOnNoBroker()
will pass before JUnit timeout
This closes #1864
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af799883
Tree: http://git-wip-us.apache.org/rep
http://git-wip-us.apache.org/repos/asf/flink/blob/3c93103d/flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/PartitionerWrapper.java
--
diff --git
a/flink-stre
Repository: flink
Updated Branches:
refs/heads/master f315c5700 -> db85f3858
[FLINK-3444] [APIs] Add fromElements method with based class type to avoid the
exception.
This closes #1857
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/
[FLINK-3541] [Kafka Connector] Clean up workaround in FlinkKafkaConsumer09
This closes #1846
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/693d5ab0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/693d5ab0
Diff: http
[FLINK-3375] [kafka connector] Add per-Kafka-partition watermark generation to
the FlinkKafkaConsumer
This closes #1839
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ac1549e
Tree: http://git-wip-us.apache.org/repos/asf/fl
[FLINK-3644] [web monitor] Add new config option to set web monitor tmp dir
This closes #1824
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b188637b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b188637b
Diff: htt
http://git-wip-us.apache.org/repos/asf/flink/blob/3c93103d/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateWithPeriodicWatermarks.java
--
Repository: flink
Updated Branches:
refs/heads/master db85f3858 -> db6528be0
[FLINK-3730] Fix RocksDB Local Directory Initialization
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db6528be
Tree: http://git-wip-us.apache.o
Repository: flink
Updated Branches:
refs/heads/release-1.0 4f9c19808 -> ff38202ba
[FLINK-3730] Fix RocksDB Local Directory Initialization
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ff38202b
Tree: http://git-wip-us.apa
Repository: flink
Updated Branches:
refs/heads/release-1.0 ff38202ba -> ea50ed348
[FLINK-3716] [kafka consumer] Decreasing socket timeout so testFailOnNoBroker()
will pass before JUnit timeout
This closes #1864
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wi
Repository: flink
Updated Branches:
refs/heads/master db6528be0 -> 8e036c38e
[FLINK-3735] Make DataSetUnionRule match only for union-all
This closes #1874
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8e036c38
Tree: htt
Repository: flink
Updated Branches:
refs/heads/master 8e036c38e -> e7d78e63a
[hotfix] [storm] Add proper exception forwarding to FlinkTopology.copyObject
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e7d78e63
Tree: http:
Repository: flink
Updated Branches:
refs/heads/master e7d78e63a -> 6c061684f
[hotfix] [tests] Add cross transformation to OverwriteObjects manual test
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6c061684
Tree: http://g
Repository: flink
Updated Branches:
refs/heads/master 6c061684f -> 5350bc48a
[FLINK-3589] Allow setting Operator parallelism to default value
Adds the public field ExecutionConfig.PARALLELISM_DEFAULT as a flag
value to indicate that the default parallelism should be used.
Adds the public fiel
[FLINK-2909] [gelly] Graph Generators
Initial set of scale-free graph generators:
- Complete graph
- Cycle graph
- Empty graph
- Grid graph
- Hypercube graph
- Path graph
- RMat graph
- Singleton edge graph
- Star graph
This closes #1807
Project: http://git-wip-us.apache.org/repos/asf/flink/rep
Repository: flink
Updated Branches:
refs/heads/master 5350bc48a -> b0a7a1b81
http://git-wip-us.apache.org/repos/asf/flink/blob/b0a7a1b8/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/random/AbstractGeneratorFactory.java
---
[FLINK-3747] Consolidate TimestampAssigner Methods in Kafka Consumer
This closes #1877
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e40e29da
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e40e29da
Diff: http://git
[FLINK-3745] [runtime] Fix early stopping of stream sources
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8570b6dc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8570b6dc
Diff: http://git-wip-us.apache.org/repos/asf
Repository: flink
Updated Branches:
refs/heads/master b0a7a1b81 -> 1a34f2165
[hotfix] [kafka consumer] Increase Kafka test stability
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2728f924
Tree: http://git-wip-us.apache.o
[FLINK-3743] upgrading breeze from 0.11.2 to 0.12
This closes #1876
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1a34f216
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1a34f216
Diff: http://git-wip-us.apache.org/
[FLINK-3375] [Kafka Connector] Add tests for per-kafka-partition watermarks.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2dcd27f4
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2dcd27f4
Diff: http://git-wip-us.apa
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/179
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: lares_ubuntu
Build Reason: The Nigh
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/294
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: lares_ubuntu
Build Reason: The Nightl
30 matches
Mail list logo
