Stephan Ewen created FLINK-10033:
Summary: Let Task release reference to Invokable on shutdown
Key: FLINK-10033
URL: https://issues.apache.org/jira/browse/FLINK-10033
Project: Flink
Issue
Stephan Ewen created FLINK-9865:
---
Summary: flink-hadoop-compatibility should assume Hadoop as
provided
Key: FLINK-9865
URL: https://issues.apache.org/jira/browse/FLINK-9865
Project: Flink
Stephan Ewen created FLINK-9809:
---
Summary: Support setting CoLocation constraints on the DataStream
Transformations
Key: FLINK-9809
URL: https://issues.apache.org/jira/browse/FLINK-9809
Project: Flink
Stephan Ewen created FLINK-9776:
---
Summary: Interrupt TaskThread only while in User/Operator code
Key: FLINK-9776
URL: https://issues.apache.org/jira/browse/FLINK-9776
Project: Flink
Issue
Stephan Ewen created FLINK-9753:
---
Summary: Support ORC/Parquet for StreamingFileSink
Key: FLINK-9753
URL: https://issues.apache.org/jira/browse/FLINK-9753
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-9752:
---
Summary: Add an S3 RecoverableWriter
Key: FLINK-9752
URL: https://issues.apache.org/jira/browse/FLINK-9752
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-9751:
---
Summary: Add a RecoverableWriter to the FileSystem abstraction
Key: FLINK-9751
URL: https://issues.apache.org/jira/browse/FLINK-9751
Project: Flink
Issue
Stephan Ewen created FLINK-9750:
---
Summary: Create new StreamingFileSink that works on Flink's
FileSystem abstraction
Key: FLINK-9750
URL: https://issues.apache.org/jira/browse/FLINK-9750
Project: Flink
Stephan Ewen created FLINK-9749:
---
Summary: Rework Bucketing Sink
Key: FLINK-9749
URL: https://issues.apache.org/jira/browse/FLINK-9749
Project: Flink
Issue Type: New Feature
Stephan Ewen created FLINK-9428:
---
Summary: Allow operators to flush data on checkpoint pre-barrier
Key: FLINK-9428
URL: https://issues.apache.org/jira/browse/FLINK-9428
Project: Flink
Issue
Stephan Ewen created FLINK-9392:
---
Summary: Add @FunctionalInterface annotations to all core
functional interfaces
Key: FLINK-9392
URL: https://issues.apache.org/jira/browse/FLINK-9392
Project: Flink
Stephan Ewen created FLINK-9314:
---
Summary: Enable SSL mutual authentication for Netty / TaskManagers
Key: FLINK-9314
URL: https://issues.apache.org/jira/browse/FLINK-9314
Project: Flink
Issue
Stephan Ewen created FLINK-9313:
---
Summary: Enable mutual authentication for RPC (akka)
Key: FLINK-9313
URL: https://issues.apache.org/jira/browse/FLINK-9313
Project: Flink
Issue Type:
Stephan Ewen created FLINK-9310:
---
Summary: Update default cyphersuites
Key: FLINK-9310
URL: https://issues.apache.org/jira/browse/FLINK-9310
Project: Flink
Issue Type: Task
Stephan Ewen created FLINK-9292:
---
Summary: Remove TypeInfoParser
Key: FLINK-9292
URL: https://issues.apache.org/jira/browse/FLINK-9292
Project: Flink
Issue Type: Task
Components:
Stephan Ewen created FLINK-9279:
---
Summary: PythonPlanBinderTest flakey
Key: FLINK-9279
URL: https://issues.apache.org/jira/browse/FLINK-9279
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-9277:
---
Summary: Reduce noisiness of SlotPool logging
Key: FLINK-9277
URL: https://issues.apache.org/jira/browse/FLINK-9277
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-9276:
---
Summary: Improve error message when TaskManager fails
Key: FLINK-9276
URL: https://issues.apache.org/jira/browse/FLINK-9276
Project: Flink
Issue Type:
Stephan Ewen created FLINK-9198:
---
Summary: Improve error messages in AbstractDeserializationSchema
for type extraction
Key: FLINK-9198
URL: https://issues.apache.org/jira/browse/FLINK-9198
Project:
Stephan Ewen created FLINK-9197:
---
Summary: Improve error message for TypyInformation and TypeHint
with generics
Key: FLINK-9197
URL: https://issues.apache.org/jira/browse/FLINK-9197
Project: Flink
Stephan Ewen created FLINK-9192:
---
Summary: Undo parameterization of StateMachine Example
Key: FLINK-9192
URL: https://issues.apache.org/jira/browse/FLINK-9192
Project: Flink
Issue Type:
Stephan Ewen created FLINK-9189:
---
Summary: Add a SBT and Gradle Quickstarts
Key: FLINK-9189
URL: https://issues.apache.org/jira/browse/FLINK-9189
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-9098:
---
Summary: ClassLoaderITCase unstable
Key: FLINK-9098
URL: https://issues.apache.org/jira/browse/FLINK-9098
Project: Flink
Issue Type: Bug
Components:
Stephan Ewen created FLINK-9045:
---
Summary: LocalEnvironment with web UI does not work with flip-6
Key: FLINK-9045
URL: https://issues.apache.org/jira/browse/FLINK-9045
Project: Flink
Issue
Stephan Ewen created FLINK-9037:
---
Summary: Test flake Kafka09ITCase#testCancelingEmptyTopic
Key: FLINK-9037
URL: https://issues.apache.org/jira/browse/FLINK-9037
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-9036:
---
Summary: Add default value via suppliers
Key: FLINK-9036
URL: https://issues.apache.org/jira/browse/FLINK-9036
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-9035:
---
Summary: State Descriptors have broken hashCode() and equals()
Key: FLINK-9035
URL: https://issues.apache.org/jira/browse/FLINK-9035
Project: Flink
Issue
Stephan Ewen created FLINK-9034:
---
Summary: State Descriptors drop TypeInformation on serialization
Key: FLINK-9034
URL: https://issues.apache.org/jira/browse/FLINK-9034
Project: Flink
Issue
Stephan Ewen created FLINK-8885:
---
Summary: The DispatcherThreadFactory should register uncaught
exception handlers
Key: FLINK-8885
URL: https://issues.apache.org/jira/browse/FLINK-8885
Project: Flink
Stephan Ewen created FLINK-8884:
---
Summary: The DispatcherThreadFactory should register uncaught
exception handlers
Key: FLINK-8884
URL: https://issues.apache.org/jira/browse/FLINK-8884
Project: Flink
Stephan Ewen created FLINK-8883:
---
Summary: ExceptionUtils.rethrowIfFatalError should tread
ThreadDeath as fatal.
Key: FLINK-8883
URL: https://issues.apache.org/jira/browse/FLINK-8883
Project: Flink
Stephan Ewen created FLINK-8879:
---
Summary: Add concurrent access check to AvroSerializer
Key: FLINK-8879
URL: https://issues.apache.org/jira/browse/FLINK-8879
Project: Flink
Issue Type:
Stephan Ewen created FLINK-8878:
---
Summary: Check for concurrent access to Kryo Serializer
Key: FLINK-8878
URL: https://issues.apache.org/jira/browse/FLINK-8878
Project: Flink
Issue Type:
Stephan Ewen created FLINK-8877:
---
Summary: Configure Kryo's log level based on Flink's log level
Key: FLINK-8877
URL: https://issues.apache.org/jira/browse/FLINK-8877
Project: Flink
Issue
Stephan Ewen created FLINK-8876:
---
Summary: Improve concurrent access handling in stateful serializers
Key: FLINK-8876
URL: https://issues.apache.org/jira/browse/FLINK-8876
Project: Flink
Issue
Stephan Ewen created FLINK-8856:
---
Summary: Move all interrupt() calls to TaskCanceler
Key: FLINK-8856
URL: https://issues.apache.org/jira/browse/FLINK-8856
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8837:
---
Summary: Move DataStreamUtils to package 'experimental'.
Key: FLINK-8837
URL: https://issues.apache.org/jira/browse/FLINK-8837
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8835:
---
Summary: Fix TaskManager config keys
Key: FLINK-8835
URL: https://issues.apache.org/jira/browse/FLINK-8835
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8824:
---
Summary: In Kafka Consumers, replace 'getCanonicalClassName()'
with 'getClassName()'
Key: FLINK-8824
URL: https://issues.apache.org/jira/browse/FLINK-8824
Project:
Stephan Ewen created FLINK-8806:
---
Summary: Failure in UnionInputGate getNextBufferOrEvent()
Key: FLINK-8806
URL: https://issues.apache.org/jira/browse/FLINK-8806
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8803:
---
Summary: Mini Cluster Shutdown with HA unstable, causing test
failures
Key: FLINK-8803
URL: https://issues.apache.org/jira/browse/FLINK-8803
Project: Flink
Stephan Ewen created FLINK-8800:
---
Summary: Set Logging to TRACE for
org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler
Key: FLINK-8800
URL: https://issues.apache.org/jira/browse/FLINK-8800
Stephan Ewen created FLINK-8798:
---
Summary: Make commons-logging a parent-first pattern
Key: FLINK-8798
URL: https://issues.apache.org/jira/browse/FLINK-8798
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8791:
---
Summary: Fix documentation on how to link dependencies
Key: FLINK-8791
URL: https://issues.apache.org/jira/browse/FLINK-8791
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8767:
---
Summary: Set the maven.compiler.source and .target properties for
Java Quickstart
Key: FLINK-8767
URL: https://issues.apache.org/jira/browse/FLINK-8767
Project: Flink
Stephan Ewen created FLINK-8765:
---
Summary: Simplify quickstart properties
Key: FLINK-8765
URL: https://issues.apache.org/jira/browse/FLINK-8765
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-8766:
---
Summary: Pin scala runtime version for Java Quickstart
Key: FLINK-8766
URL: https://issues.apache.org/jira/browse/FLINK-8766
Project: Flink
Issue Type:
Stephan Ewen created FLINK-8764:
---
Summary: Make quickstarts work out of the box for IDE and JAR
packaging
Key: FLINK-8764
URL: https://issues.apache.org/jira/browse/FLINK-8764
Project: Flink
Stephan Ewen created FLINK-8762:
---
Summary: Remove unnecessary examples and make "StreamingJob" the
default
Key: FLINK-8762
URL: https://issues.apache.org/jira/browse/FLINK-8762
Project: Flink
Stephan Ewen created FLINK-8763:
---
Summary: Remove obsolete Dummy.java classes from quickstart
projects.
Key: FLINK-8763
URL: https://issues.apache.org/jira/browse/FLINK-8763
Project: Flink
Stephan Ewen created FLINK-8761:
---
Summary: Various improvements to the Quickstarts
Key: FLINK-8761
URL: https://issues.apache.org/jira/browse/FLINK-8761
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-8738:
---
Summary: Converge runtime dependency versions for 'scala-lang' and
for 'com.typesafe:config'
Key: FLINK-8738
URL: https://issues.apache.org/jira/browse/FLINK-8738
Stephan Ewen created FLINK-8729:
---
Summary: Migrate JSONGenerator from Slink to Jackson
Key: FLINK-8729
URL: https://issues.apache.org/jira/browse/FLINK-8729
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8727:
---
Summary: Test instability in
SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager
Key: FLINK-8727
URL: https://issues.apache.org/jira/browse/FLINK-8727
Stephan Ewen created FLINK-8696:
---
Summary: Remove JobManager local mode from the Unix Shell Scripts
Key: FLINK-8696
URL: https://issues.apache.org/jira/browse/FLINK-8696
Project: Flink
Issue
Stephan Ewen created FLINK-8695:
---
Summary: Move RocksDB State Backend from 'flink-contrib' to
'flink-state-backends'
Key: FLINK-8695
URL: https://issues.apache.org/jira/browse/FLINK-8695
Project: Flink
Stephan Ewen created FLINK-8682:
---
Summary: Make start/stop cluster scripts work without SSH for
local HA setups
Key: FLINK-8682
URL: https://issues.apache.org/jira/browse/FLINK-8682
Project: Flink
Stephan Ewen created FLINK-8681:
---
Summary: Remove planVisualizer.html move notice
Key: FLINK-8681
URL: https://issues.apache.org/jira/browse/FLINK-8681
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-8680:
---
Summary: Name printing sinks by default.
Key: FLINK-8680
URL: https://issues.apache.org/jira/browse/FLINK-8680
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-8549:
---
Summary: Move TimerServiceOptions to TaskManagerOptions
Key: FLINK-8549
URL: https://issues.apache.org/jira/browse/FLINK-8549
Project: Flink
Issue Type:
Stephan Ewen created FLINK-8548:
---
Summary: Add Streaming State Machine Example
Key: FLINK-8548
URL: https://issues.apache.org/jira/browse/FLINK-8548
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-8540:
---
Summary: FileStateHandles must not attempt to delete their parent
directory.
Key: FLINK-8540
URL: https://issues.apache.org/jira/browse/FLINK-8540
Project: Flink
Stephan Ewen created FLINK-8539:
---
Summary: Introduce "CompletedCheckpointStorageLocation" to
explicitly handle disposal of checkpoint storage locations
Key: FLINK-8539
URL:
Stephan Ewen created FLINK-8531:
---
Summary: Support separation of "Exclusive", "Shared" and "Task
owned" state
Key: FLINK-8531
URL: https://issues.apache.org/jira/browse/FLINK-8531
Project: Flink
Stephan Ewen created FLINK-8499:
---
Summary: Kryo must not be child-first loaded
Key: FLINK-8499
URL: https://issues.apache.org/jira/browse/FLINK-8499
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8461:
---
Summary: Wrong logger configurations for shaded Netty
Key: FLINK-8461
URL: https://issues.apache.org/jira/browse/FLINK-8461
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8374:
---
Summary: Unstable Yarn tests due to Akka Shutdown Exception Logging
Key: FLINK-8374
URL: https://issues.apache.org/jira/browse/FLINK-8374
Project: Flink
Issue
Stephan Ewen created FLINK-8373:
---
Summary: Inconsistencies in some FileSystem directory functions
Key: FLINK-8373
URL: https://issues.apache.org/jira/browse/FLINK-8373
Project: Flink
Issue
Stephan Ewen created FLINK-8268:
---
Summary: Test instability for 'TwoPhaseCommitSinkFunctionTest'
Key: FLINK-8268
URL: https://issues.apache.org/jira/browse/FLINK-8268
Project: Flink
Issue
Stephan Ewen created FLINK-8264:
---
Summary: Add Scala to the parent-first loading patterns
Key: FLINK-8264
URL: https://issues.apache.org/jira/browse/FLINK-8264
Project: Flink
Issue Type:
Stephan Ewen created FLINK-8263:
---
Summary: Wrong packaging of flink-core in scala quickstarty
Key: FLINK-8263
URL: https://issues.apache.org/jira/browse/FLINK-8263
Project: Flink
Issue Type:
Stephan Ewen created FLINK-8261:
---
Summary: Typos in the shading exclusion for jsr305 in the
quickstarts
Key: FLINK-8261
URL: https://issues.apache.org/jira/browse/FLINK-8261
Project: Flink
Stephan Ewen created FLINK-8196:
---
Summary: Fix Hadoop Servled Dependency Exclusion
Key: FLINK-8196
URL: https://issues.apache.org/jira/browse/FLINK-8196
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-8125:
---
Summary: Support limiting the number of open FileSystem connections
Key: FLINK-8125
URL: https://issues.apache.org/jira/browse/FLINK-8125
Project: Flink
Issue
Stephan Ewen created FLINK-7997:
---
Summary: Avro should be always in the user code
Key: FLINK-7997
URL: https://issues.apache.org/jira/browse/FLINK-7997
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-7973:
---
Summary: Fix service shading relocation for S3 file systems
Key: FLINK-7973
URL: https://issues.apache.org/jira/browse/FLINK-7973
Project: Flink
Issue Type:
Stephan Ewen created FLINK-7972:
---
Summary: Move SerializationSchema to flink-core
Key: FLINK-7972
URL: https://issues.apache.org/jira/browse/FLINK-7972
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-7968:
---
Summary: Deduplicate serializer classes between runtime and
queryable state
Key: FLINK-7968
URL: https://issues.apache.org/jira/browse/FLINK-7968
Project: Flink
Stephan Ewen created FLINK-7925:
---
Summary: Add CheckpointingOptions
Key: FLINK-7925
URL: https://issues.apache.org/jira/browse/FLINK-7925
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-7924:
---
Summary: Fix incorrect names of checkpoint options
Key: FLINK-7924
URL: https://issues.apache.org/jira/browse/FLINK-7924
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-7842:
---
Summary: Shade jackson (org.codehouse.jackson) in
flink-shaded-hadoop2
Key: FLINK-7842
URL: https://issues.apache.org/jira/browse/FLINK-7842
Project: Flink
Stephan Ewen created FLINK-7841:
---
Summary: Add docs for Flink's S3 support
Key: FLINK-7841
URL: https://issues.apache.org/jira/browse/FLINK-7841
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-7840:
---
Summary: Shade Akka's Netty Dependency
Key: FLINK-7840
URL: https://issues.apache.org/jira/browse/FLINK-7840
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-7768:
---
Summary: Load File Systems via Java Service abstraction
Key: FLINK-7768
URL: https://issues.apache.org/jira/browse/FLINK-7768
Project: Flink
Issue Type:
Stephan Ewen created FLINK-7767:
---
Summary: Avoid loading Hadoop conf dynamically at runtime
Key: FLINK-7767
URL: https://issues.apache.org/jira/browse/FLINK-7767
Project: Flink
Issue Type:
Stephan Ewen created FLINK-7766:
---
Summary: Remove obsolete reflection for hflush on HDFS
Key: FLINK-7766
URL: https://issues.apache.org/jira/browse/FLINK-7766
Project: Flink
Issue Type:
Stephan Ewen created FLINK-7662:
---
Summary: Remove unnecessary packaged licenses
Key: FLINK-7662
URL: https://issues.apache.org/jira/browse/FLINK-7662
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-7419:
---
Summary: Shade jackson dependency in flink-avro
Key: FLINK-7419
URL: https://issues.apache.org/jira/browse/FLINK-7419
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-7417:
---
Summary: Create flink-shaded-jackson
Key: FLINK-7417
URL: https://issues.apache.org/jira/browse/FLINK-7417
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-7418:
---
Summary: Replace all uses of jackson with flink-shaded-jackson
Key: FLINK-7418
URL: https://issues.apache.org/jira/browse/FLINK-7418
Project: Flink
Issue
Stephan Ewen created FLINK-7266:
---
Summary: Don't attempt to delete parent directory on S3
Key: FLINK-7266
URL: https://issues.apache.org/jira/browse/FLINK-7266
Project: Flink
Issue Type: Bug
Stephan Ewen created FLINK-7265:
---
Summary: FileSystems should describe their kind and consistency
level
Key: FLINK-7265
URL: https://issues.apache.org/jira/browse/FLINK-7265
Project: Flink
Stephan Ewen created FLINK-7263:
---
Summary: Improve Pull Request Template
Key: FLINK-7263
URL: https://issues.apache.org/jira/browse/FLINK-7263
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-7253:
---
Summary: Remove all 'assume Java 8' code in tests
Key: FLINK-7253
URL: https://issues.apache.org/jira/browse/FLINK-7253
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-7251:
---
Summary: Merge the flink-java8 project into flink-core
Key: FLINK-7251
URL: https://issues.apache.org/jira/browse/FLINK-7251
Project: Flink
Issue Type:
Stephan Ewen created FLINK-7252:
---
Summary: Remove Flink Futures or back them by CompletableFutures
Key: FLINK-7252
URL: https://issues.apache.org/jira/browse/FLINK-7252
Project: Flink
Issue
Stephan Ewen created FLINK-7249:
---
Summary: Bump Java version in build plugind
Key: FLINK-7249
URL: https://issues.apache.org/jira/browse/FLINK-7249
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-7250:
---
Summary: Drop the jdk8 build profile
Key: FLINK-7250
URL: https://issues.apache.org/jira/browse/FLINK-7250
Project: Flink
Issue Type: Sub-task
Stephan Ewen created FLINK-7231:
---
Summary: SlotSharingGroups are not always released in time for new
restarts
Key: FLINK-7231
URL: https://issues.apache.org/jira/browse/FLINK-7231
Project: Flink
Stephan Ewen created FLINK-7216:
---
Summary: ExecutionGraph can perform concurrent global restarts to
scheduling
Key: FLINK-7216
URL: https://issues.apache.org/jira/browse/FLINK-7216
Project: Flink
201 - 300 of 711 matches
Mail list logo
