https://issues.apache.org/jira/browse/FLINK-1388#312
Closed
https://issues.apache.org/jira/browse/FLINK-1388#312
Conversation
PrintSinkFunction now explicitly states threads in output Added printToErr functionality
The current examples show-case the API, more meaningful examples are coming for the 0.9 release.
The performance of data-intensive jobs using Kryo is probably going to be slow. Set correct classloader try to use Kryo.copy() with fallback to serialization copy
… the finished state without all job vertices having properly processed the finalizeOnMaster method.
Excluded the scala example jars Excluded the example source code subdirectories This closes #274
…ction in tumbling window situations. [streaming] Changed TimeEvictionPolicy to keep timestamps in the buffer instead of data-items
Removed Disclaimer file Eliminated unnecessary incubating substrings Bumped version to 0.8-SNAPSHOT
This closes #279
Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
…de simple operators
…nality + DataStream sinks + docs Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WriteAsCsvTest.java flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/WriteAsTextTest.java
Conflicts: flink-scala/src/main/scala/org/apache/flink/api/scala/streaming/DataStream.scala
- Move sling JSON dependency to streaming connectors (prev streaming core)
- Exclude YARN API from transitive mapreduce-core dependencies we use the dependency
only for .mapred and .mapreduce interfaces
- Remove some unnecessary dependencies (junit in java8)
- Manage Kryo dependency
- Cleanup minor POM warnings.
- Add missing entries for dependencies - Remove entries for removed dependencies - Change DEPENDENCIES file to point to src and bin LICENSE and NOTICE file - Add comments in some files to clarify whether the are Flink original, or from which third party file they are adapted - Change some links from incubator to TLP
Before, something like:
def f[T: TypeInformation](data: DataSet[T]) = {
val tpe = createTypeInformation[(T, Seq[T])]
println("Type: " + tpe)
}
f(Seq(1.0f, 2.0f)
would fail because the type extractor could not re-use existing
TypeInformation for nested types.
… in the YARN cluster. Instead of rejecting the session This closes #294
…x broken links Conflicts: README.md docs/internal_job_scheduling.md
Default hadoop version is now hadoop2 Generate specific pom avoids version collisions with dependencies Updated poms for new release scripts
Updated NOTICE files Updated inceptionYear in pom
Contributor
|
Did you do anything besides trying to add all release-0.8 commits to the master? |
…ed with Java 6 (backport)
Contributor
|
This PR seemed to contain some commits that not related to the issue. |
This closes #327.
Contributor
|
This can be closed. "msdevanms wants to merge 78 commits into master from release-0.8", which are both branches from our repo. I also couldn't find a public fork at his account. |
zhijiangW
pushed a commit
to zhijiangW/flink
that referenced
this pull request
Apr 13, 2020
…anges This closes apache#312.
RocMarshal
pushed a commit
to RocMarshal/flink
that referenced
this pull request
May 9, 2024
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
14 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
https://issues.apache.org/jira/browse/FLINK-1388