[FLINK-4748] [streaming api] Make timers in Ingestion Time source context
properly cancelable.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dd3416fd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dd3416fd
Diff: ht
[hotfix] [tests] Remove leftover sysout logging code
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/417c5a4b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/417c5a4b
Diff: http://git-wip-us.apache.org/repos/asf/flink/
[hotfix] [streaming api] Remove obsolete and unused InputTypeSerializer from
WindowOperator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1cd8d4f4
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1cd8d4f4
Diff: http:
[FLINK-4718] [docs] Fix figure about parallel watermarks.
This closes #2578
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8000b64a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8000b64a
Diff: http://git-wip-us.apa
[FLINK-4750] [runtime] Cleanly await end of all currently executing processing
time timers when finite streams finish.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8aea8c8f
Tree: http://git-wip-us.apache.org/repos/asf/flin
[hotfix] Various code cleanups around time service and asynchronous exceptions
- DefaultTimeServiceProvider now owns scheduled executor
- Enforce that an asynchronous exception handler is always set
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.o
[FLINK-4709] [core] Fix resource leak in InputStreamFSInputWrapper
This closes #2581
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28b37ef9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28b37ef9
Diff: http://git-w
[hotfix] [streaming api] Cleanup watermark initialization in window operator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9d24d51f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9d24d51f
Diff: http://git-wip-us.apa
[FLINK-4737] [core] Add support for bz2 and xy compression in flink-core.
Adds a dependency on 'commons-compression'.
This closes #2002
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/81aec410
Tree: http://git-wip-us.apache.
[hotfix] [core] Minor code cleanup and correction of javadocs for filesystem
input stream classes.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c62776f0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c62776f0
Diff
[FLINK-4749] [streaming api] Remove redundant processing time timer sets from
window operator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/47e49774
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/47e49774
Diff: htt
http://git-wip-us.apache.org/repos/asf/flink/blob/8ff451be/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/KeyedOneInputStreamOperatorTestHarness.java
--
diff --git
a/flink-streaming-java/src/test/java/org/apach
[FLINK-4700] [tests] Expand and harden TimeServiceProvider test
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4fc54e3e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4fc54e3e
Diff: http://git-wip-us.apache.org/repos
[FLINK-4739] [elasticsearch connector] Adding packaging details for the
Elasticsearch connector
When an uber-jar containing an Elasticsearch sink is executed, an
IllegalArgumentException may occur, which is caused by conflicting files of
Elasticsearch and it's dependencies in META-INF/services.
[FLINK-4329] [streaming api] Fix Streaming File Source Timestamps/Watermarks
Handling
This closes #2546
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ff451be
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8ff451b
Repository: flink
Updated Branches:
refs/heads/master 10a42f951 -> 417c5a4b4
[FLINK-4737] [core] Ensure that Flink and its Hadoop dependency pull the same
version of 'commons-compress'
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/f
[FLINK-4728] [core,optimizer] Replace reference equality with object equality
Some cases of testing Integer equality using == rather than
Integer.equals(Integer), and some additional cleanup.
This closes #2582
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.
Repository: flink
Updated Branches:
refs/heads/master 7c9bc1e51 -> 10a42f951
[FLINK-4744] [streaming api] Introduce usercode class loader to deserialize
partitionable operator state
This closes #2598
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache
[FLINK-4744] [streaming api] Followup: Unify names for operator state access
methods and comments.
Also make JavaSerializer package private, as it is not intended for user as a
proper TypeSerializer
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org
[FLINK-4734] [gelly] Remove use of Tuple setField for fixed position
This closes #2590
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1577e898
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1577e898
Diff: http://git
Repository: flink
Updated Branches:
refs/heads/master 8c7c42f0e -> 7c9bc1e51
http://git-wip-us.apache.org/repos/asf/flink/blob/bb34133e/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphOperationsITCase.java
---
[FLINK-4729] [gelly] Use optional VertexCentric CombineFunction
Passes through the CombineFunction to VertexCentricIteration, and other
code cleanup discovered via IntelliJ's code analyzer.
This closes #2587
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.ap
[FLINK-4740] [tests] Upgrade testing libraries
Upgrades
JUnit from 4.11 to 4.12
Mockito from 1.9.5 to 1.10.19
PowerMock from 1.5.5 to 1.6.5
This closes #2597
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7c9bc1e5
Tre
Repository: flink
Updated Branches:
refs/heads/release-1.1 fddd89bcd -> bab59dfa7
[FLINK-4329] Fix Streaming File Source Timestamps/Watermarks Handling
This closes #2593.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba
Repository: flink
Updated Branches:
refs/heads/release-1.1 a83dbaeb0 -> fddd89bcd
[FLINK-4677] fail if user jar contains no executions
This closes #2548.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fddd89bc
Tree: http
Repository: flink
Updated Branches:
refs/heads/master 825ef3be3 -> 8c7c42f0e
[FLINK-4677] fail if user jar contains no executions
This closes #2548.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8c7c42f0
Tree: http://gi
Repository: flink
Updated Branches:
refs/heads/master efb40cfc5 -> 825ef3be3
[FLINK-3874] Rewrite Kafka JSON Table sink tests
This closes #2430.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/825ef3be
Tree: http://git-wi
Repository: flink
Updated Branches:
refs/heads/release-1.1 a31a22ec7 -> a83dbaeb0
[hotfix] [kafka] Committed offset value set in KafkaTopicPartitionState should
also be incremented by 1.
The broken behaviour was introduced in the last hotfix commit eece0dd0.
Project: http://git-wip-us.apach
Repository: flink
Updated Branches:
refs/heads/master 5a573c6bc -> efb40cfc5
[hotfix] [kafka] Committed offset value set in KafkaTopicPartitionState should
also be incremented by 1.
The broken behaviour was introduced in the last hotfix commit eece0dd0.
Project: http://git-wip-us.apache.org
29 matches
Mail list logo