Aljoscha Krettek created FLINK-14290:
Summary: Decouple plan translation from job execution/ClusterClient
Key: FLINK-14290
URL: https://issues.apache.org/jira/browse/FLINK-14290
Project: Flink
Aljoscha Krettek created FLINK-14250:
Summary: Introduce separate "bin/flink runpy" and remove python
support from "bin/flink run"
Key: FLINK-14250
URL: https://issues.apache.org/jira/browse/FLINK-14250
Aljoscha Krettek created FLINK-14130:
Summary: Remove ClusterClient.run() methods
Key: FLINK-14130
URL: https://issues.apache.org/jira/browse/FLINK-14130
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-14067:
Summary: Decouple PlanExecutor from JSON plan generation
Key: FLINK-14067
URL: https://issues.apache.org/jira/browse/FLINK-14067
Project: Flink
Aljoscha Krettek created FLINK-13601:
Summary: RegionFailoverITCase is unstable
Key: FLINK-13601
URL: https://issues.apache.org/jira/browse/FLINK-13601
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-13397:
Summary: Remove RollingSink
Key: FLINK-13397
URL: https://issues.apache.org/jira/browse/FLINK-13397
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-13396:
Summary: Deprecate BucketingSink
Key: FLINK-13396
URL: https://issues.apache.org/jira/browse/FLINK-13396
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-13062:
Summary: Set ScheduleMode based on boundedness of streaming
Pipeline
Key: FLINK-13062
URL: https://issues.apache.org/jira/browse/FLINK-13062
Project: Flink
Aljoscha Krettek created FLINK-13041:
Summary: Make ScheduleMode configurable on ExecutionConfig
Key: FLINK-13041
URL: https://issues.apache.org/jira/browse/FLINK-13041
Project: Flink
Aljoscha Krettek created FLINK-12832:
Summary: Enhance StreamGraphGenerator/StreamGraph for Blink Table
Runner
Key: FLINK-12832
URL: https://issues.apache.org/jira/browse/FLINK-12832
Project:
Aljoscha Krettek created FLINK-12613:
Summary: Move SinkFunction to flink-core
Key: FLINK-12613
URL: https://issues.apache.org/jira/browse/FLINK-12613
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-12606:
Summary: Move SourceFunction to flink-core
Key: FLINK-12606
URL: https://issues.apache.org/jira/browse/FLINK-12606
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-12587:
Summary: Add pure-API Watermark class
Key: FLINK-12587
URL: https://issues.apache.org/jira/browse/FLINK-12587
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-12501:
Summary: AvroTypeSerializer does not work with types generated by
avrohugger
Key: FLINK-12501
URL: https://issues.apache.org/jira/browse/FLINK-12501
Project:
Aljoscha Krettek created FLINK-12164:
Summary:
JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable
Key: FLINK-12164
URL: https://issues.apache.org/jira/browse/FLINK-12164
Aljoscha Krettek created FLINK-12030:
Summary: KafkaITCase.testMultipleSourcesOnePartition is unstable
Key: FLINK-12030
URL: https://issues.apache.org/jira/browse/FLINK-12030
Project: Flink
Aljoscha Krettek created FLINK-12019:
Summary:
ZooKeeperHaServicesTest.testCloseAndCleanupAllDataWithUncle is unstable
Key: FLINK-12019
URL: https://issues.apache.org/jira/browse/FLINK-12019
Aljoscha Krettek created FLINK-12015:
Summary: TaskManagerRunnerTest is unstable
Key: FLINK-12015
URL: https://issues.apache.org/jira/browse/FLINK-12015
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-12006:
Summary: ZooKeeperHaServicesTest is unstable
Key: FLINK-12006
URL: https://issues.apache.org/jira/browse/FLINK-12006
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-11889:
Summary: Remove "stop" signal along with Stoppable interfaces
Key: FLINK-11889
URL: https://issues.apache.org/jira/browse/FLINK-11889
Project: Flink
Aljoscha Krettek created FLINK-11865:
Summary: Code generation in TraversableSerializer is prohibitively
slow
Key: FLINK-11865
URL: https://issues.apache.org/jira/browse/FLINK-11865
Project:
Aljoscha Krettek created FLINK-11836:
Summary: Update NOTICE-binary and licenses-binary for Flink 1.8.0
Key: FLINK-11836
URL: https://issues.apache.org/jira/browse/FLINK-11836
Project: Flink
Aljoscha Krettek created FLINK-11791:
Summary: Describe how to build Flink with Hadoop in build guide
Key: FLINK-11791
URL: https://issues.apache.org/jira/browse/FLINK-11791
Project: Flink
Aljoscha Krettek created FLINK-11780:
Summary: Change version scheme of Hadoop-based modules to conform
to SNAPSHOT guidelines
Key: FLINK-11780
URL: https://issues.apache.org/jira/browse/FLINK-11780
Aljoscha Krettek created FLINK-11751:
Summary: Extend release notes for Flink 1.8
Key: FLINK-11751
URL: https://issues.apache.org/jira/browse/FLINK-11751
Project: Flink
Issue Type: Task
Aljoscha Krettek created FLINK-11693:
Summary: Add KafkaSerializationSchema that directly uses
ProducerRecord
Key: FLINK-11693
URL: https://issues.apache.org/jira/browse/FLINK-11693
Project:
Aljoscha Krettek created FLINK-11539:
Summary: Add TypeSerializerSnapshot for TraversableSerializer
Key: FLINK-11539
URL: https://issues.apache.org/jira/browse/FLINK-11539
Project: Flink
Aljoscha Krettek created FLINK-10740:
Summary: Refactor Source Interface
Key: FLINK-10740
URL: https://issues.apache.org/jira/browse/FLINK-10740
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-10563:
Summary: Expose shaded Presto S3 filesystem under "s3p" scheme
Key: FLINK-10563
URL: https://issues.apache.org/jira/browse/FLINK-10563
Project: Flink
Aljoscha Krettek created FLINK-10067:
Summary: Add Kafka 1.0.0/1.1.0 connectors
Key: FLINK-10067
URL: https://issues.apache.org/jira/browse/FLINK-10067
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-10016:
Summary: Make YARN/Kerberos end-to-end test stricter
Key: FLINK-10016
URL: https://issues.apache.org/jira/browse/FLINK-10016
Project: Flink
Issue
Aljoscha Krettek created FLINK-10013:
Summary: Fix Kerberos integration for FLIP-6
YarnTaskExecutorRunner
Key: FLINK-10013
URL: https://issues.apache.org/jira/browse/FLINK-10013
Project: Flink
Aljoscha Krettek created FLINK-9983:
---
Summary: Savepoints should count as checkpoints when recovering
Key: FLINK-9983
URL: https://issues.apache.org/jira/browse/FLINK-9983
Project: Flink
Aljoscha Krettek created FLINK-9857:
---
Summary: Processing-time timers fire too early
Key: FLINK-9857
URL: https://issues.apache.org/jira/browse/FLINK-9857
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-9804:
---
Summary: KeyedStateBackend.getKeys() does not work on RocksDB
MapState
Key: FLINK-9804
URL: https://issues.apache.org/jira/browse/FLINK-9804
Project: Flink
Aljoscha Krettek created FLINK-9803:
---
Summary: Drop canEqual() from TypeInformation, TypeSerializer, etc.
Key: FLINK-9803
URL: https://issues.apache.org/jira/browse/FLINK-9803
Project: Flink
Aljoscha Krettek created FLINK-9798:
---
Summary: Drop canEqual() from TypeInformation, TypeSerializer, etc.
Key: FLINK-9798
URL: https://issues.apache.org/jira/browse/FLINK-9798
Project: Flink
Aljoscha Krettek created FLINK-9470:
---
Summary: Allow querying the key in KeyedProcessFunction
Key: FLINK-9470
URL: https://issues.apache.org/jira/browse/FLINK-9470
Project: Flink
Issue
Aljoscha Krettek created FLINK-9353:
---
Summary: End-to-end test: Kubernetes integration
Key: FLINK-9353
URL: https://issues.apache.org/jira/browse/FLINK-9353
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-9306:
---
Summary: Execute YARN IT tests for legacy and new mode
Key: FLINK-9306
URL: https://issues.apache.org/jira/browse/FLINK-9306
Project: Flink
Issue
Aljoscha Krettek created FLINK-9211:
---
Summary: Job submission via REST/dashboard does not work on
Kubernetes
Key: FLINK-9211
URL: https://issues.apache.org/jira/browse/FLINK-9211
Project: Flink
Aljoscha Krettek created FLINK-9205:
---
Summary: Delete non-well-defined SinkFunctions
Key: FLINK-9205
URL: https://issues.apache.org/jira/browse/FLINK-9205
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-9203:
---
Summary: Deprecate non-well-defined SinkFunctions
Key: FLINK-9203
URL: https://issues.apache.org/jira/browse/FLINK-9203
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-9195:
---
Summary: Delete non-well-defined output methods on DataStream
Key: FLINK-9195
URL: https://issues.apache.org/jira/browse/FLINK-9195
Project: Flink
Aljoscha Krettek created FLINK-9193:
---
Summary: Deprecate non-well-defined output methods on DataStream
Key: FLINK-9193
URL: https://issues.apache.org/jira/browse/FLINK-9193
Project: Flink
Aljoscha Krettek created FLINK-9160:
---
Summary: Make subclasses of RuntimeContext internal that should be
internal
Key: FLINK-9160
URL: https://issues.apache.org/jira/browse/FLINK-9160
Project:
Aljoscha Krettek created FLINK-9152:
---
Summary: Harmonize BroadcastProcessFunction Context names
Key: FLINK-9152
URL: https://issues.apache.org/jira/browse/FLINK-9152
Project: Flink
Issue
Aljoscha Krettek created FLINK-9060:
---
Summary: Deleting state using KeyedStateBackend.getKeys() throws
Exception
Key: FLINK-9060
URL: https://issues.apache.org/jira/browse/FLINK-9060
Project: Flink
Aljoscha Krettek created FLINK-8911:
---
Summary: Add separate script for nightly end-to-end tests
Key: FLINK-8911
URL: https://issues.apache.org/jira/browse/FLINK-8911
Project: Flink
Issue
Aljoscha Krettek created FLINK-8890:
---
Summary: Compare checkpoints in order in
CompletedCheckpoint.checkpointsMatch()
Key: FLINK-8890
URL: https://issues.apache.org/jira/browse/FLINK-8890
Project:
Aljoscha Krettek created FLINK-8825:
---
Summary: Disallow new String() without charset in checkstyle
Key: FLINK-8825
URL: https://issues.apache.org/jira/browse/FLINK-8825
Project: Flink
Aljoscha Krettek created FLINK-8810:
---
Summary: Move end-to-end test scripts to end-to-end module
Key: FLINK-8810
URL: https://issues.apache.org/jira/browse/FLINK-8810
Project: Flink
Issue
Aljoscha Krettek created FLINK-8807:
---
Summary: ZookeeperCompleted checkpoint store can get stuck in
infinite loop
Key: FLINK-8807
URL: https://issues.apache.org/jira/browse/FLINK-8807
Project:
Aljoscha Krettek created FLINK-8797:
---
Summary: Port AbstractOperatorRestoreTestBase to
MiniClusterResource
Key: FLINK-8797
URL: https://issues.apache.org/jira/browse/FLINK-8797
Project: Flink
Aljoscha Krettek created FLINK-8778:
---
Summary: Migrate queryable state ITCases to use MiniClusterResource
Key: FLINK-8778
URL: https://issues.apache.org/jira/browse/FLINK-8778
Project: Flink
Aljoscha Krettek created FLINK-8758:
---
Summary: Expose method for non-blocking job submission on
ClusterClient
Key: FLINK-8758
URL: https://issues.apache.org/jira/browse/FLINK-8758
Project: Flink
Aljoscha Krettek created FLINK-8757:
---
Summary: Add MiniClusterResource.getClusterClient()
Key: FLINK-8757
URL: https://issues.apache.org/jira/browse/FLINK-8757
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-8756:
---
Summary: Support ClusterClient.getAccumulators() in
RestClusterClient
Key: FLINK-8756
URL: https://issues.apache.org/jira/browse/FLINK-8756
Project: Flink
Aljoscha Krettek created FLINK-8735:
---
Summary: Add savepoint migration ITCase that covers operator state
Key: FLINK-8735
URL: https://issues.apache.org/jira/browse/FLINK-8735
Project: Flink
Aljoscha Krettek created FLINK-8725:
---
Summary: Separate NFA-state from NFA in CEP library
Key: FLINK-8725
URL: https://issues.apache.org/jira/browse/FLINK-8725
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-8704:
---
Summary: Migrate tests from TestingCluster to MiniClusterResource
Key: FLINK-8704
URL: https://issues.apache.org/jira/browse/FLINK-8704
Project: Flink
Aljoscha Krettek created FLINK-8703:
---
Summary: Migrate tests from LocalFlinkMiniCluster to
MiniClusterResource
Key: FLINK-8703
URL: https://issues.apache.org/jira/browse/FLINK-8703
Project: Flink
Aljoscha Krettek created FLINK-8702:
---
Summary: Migrate tests from FlinkMiniCluster to MiniClusterResource
Key: FLINK-8702
URL: https://issues.apache.org/jira/browse/FLINK-8702
Project: Flink
Aljoscha Krettek created FLINK-8701:
---
Summary: Migrate SavepointMigrationTestBase to MiniClusterResource
Key: FLINK-8701
URL: https://issues.apache.org/jira/browse/FLINK-8701
Project: Flink
Aljoscha Krettek created FLINK-8700:
---
Summary: Port tests from FlinkMiniCluster to MiniClusterResource
Key: FLINK-8700
URL: https://issues.apache.org/jira/browse/FLINK-8700
Project: Flink
Aljoscha Krettek created FLINK-8672:
---
Summary: Support continuous processing in CSV table source
Key: FLINK-8672
URL: https://issues.apache.org/jira/browse/FLINK-8672
Project: Flink
Issue
Aljoscha Krettek created FLINK-8596:
---
Summary: Custom command line code does not correctly catch errors
Key: FLINK-8596
URL: https://issues.apache.org/jira/browse/FLINK-8596
Project: Flink
Aljoscha Krettek created FLINK-8131:
---
Summary: Update to Kafka 0.11.0.2
Key: FLINK-8131
URL: https://issues.apache.org/jira/browse/FLINK-8131
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-8130:
---
Summary: Javadocs link for snapshot release is not correct
Key: FLINK-8130
URL: https://issues.apache.org/jira/browse/FLINK-8130
Project: Flink
Issue
Aljoscha Krettek created FLINK-8099:
---
Summary: Reduce default restart delay to 1 second
Key: FLINK-8099
URL: https://issues.apache.org/jira/browse/FLINK-8099
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-8053:
---
Summary: Default to asynchronous snapshots for FsStateBackend
Key: FLINK-8053
URL: https://issues.apache.org/jira/browse/FLINK-8053
Project: Flink
Aljoscha Krettek created FLINK-8051:
---
Summary: Reactivate Scaladoc aggregation using genjavadoc
Key: FLINK-8051
URL: https://issues.apache.org/jira/browse/FLINK-8051
Project: Flink
Issue
Aljoscha Krettek created FLINK-8023:
---
Summary: User proper AvroSerializer for Avro types
Key: FLINK-8023
URL: https://issues.apache.org/jira/browse/FLINK-8023
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-8001:
---
Summary: Mark Kafka Consumer as idle if it doesn't have partitions
Key: FLINK-8001
URL: https://issues.apache.org/jira/browse/FLINK-8001
Project: Flink
Aljoscha Krettek created FLINK-7944:
---
Summary: Allow configuring Hadoop Classpath
Key: FLINK-7944
URL: https://issues.apache.org/jira/browse/FLINK-7944
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-7931:
---
Summary: FlinkKinesisProducer violates at-least-once guarantees
(1.3 branch)
Key: FLINK-7931
URL: https://issues.apache.org/jira/browse/FLINK-7931
Project:
Aljoscha Krettek created FLINK-7902:
---
Summary: TwoPhaseCommitSinkFunctions should use custom
TypeSerializer
Key: FLINK-7902
URL: https://issues.apache.org/jira/browse/FLINK-7902
Project: Flink
Aljoscha Krettek created FLINK-7864:
---
Summary: Support side-outputs in CoProcessFunction
Key: FLINK-7864
URL: https://issues.apache.org/jira/browse/FLINK-7864
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-7837:
---
Summary: AggregatingFunction does not work with immutable types
Key: FLINK-7837
URL: https://issues.apache.org/jira/browse/FLINK-7837
Project: Flink
Aljoscha Krettek created FLINK-7830:
---
Summary: Problematic interaction of CEP and asynchronous snapshots
Key: FLINK-7830
URL: https://issues.apache.org/jira/browse/FLINK-7830
Project: Flink
Aljoscha Krettek created FLINK-7829:
---
Summary: Remove (or at least deprecate) DataStream.writeToFile/Csv
Key: FLINK-7829
URL: https://issues.apache.org/jira/browse/FLINK-7829
Project: Flink
Aljoscha Krettek created FLINK-7828:
---
Summary: Improve object copying/reuse mode for streaming runtime
Key: FLINK-7828
URL: https://issues.apache.org/jira/browse/FLINK-7828
Project: Flink
Aljoscha Krettek created FLINK-7816:
---
Summary: Support Scala 2.12 closures and Java 8 lambdas in
ClosureCleaner
Key: FLINK-7816
URL: https://issues.apache.org/jira/browse/FLINK-7816
Project: Flink
Aljoscha Krettek created FLINK-7811:
---
Summary: Add support for Scala 2.12
Key: FLINK-7811
URL: https://issues.apache.org/jira/browse/FLINK-7811
Project: Flink
Issue Type: Sub-task
Aljoscha Krettek created FLINK-7810:
---
Summary: Switch from custom Flakka to Akka 2.4.x
Key: FLINK-7810
URL: https://issues.apache.org/jira/browse/FLINK-7810
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-7809:
---
Summary: Drop support for Scala 2.10
Key: FLINK-7809
URL: https://issues.apache.org/jira/browse/FLINK-7809
Project: Flink
Issue Type: Sub-task
Aljoscha Krettek created FLINK-7784:
---
Summary: Don't fail TwoPhaseCommitSinkFunction when failing to
commit
Key: FLINK-7784
URL: https://issues.apache.org/jira/browse/FLINK-7784
Project: Flink
Aljoscha Krettek created FLINK-7783:
---
Summary: Don't always remove checkpoints
ZooKeeperCompletedCheckpointStore#recover()
Key: FLINK-7783
URL: https://issues.apache.org/jira/browse/FLINK-7783
Aljoscha Krettek created FLINK-7763:
---
Summary: TableSinkITCase fails with "object reuse" enabled
Key: FLINK-7763
URL: https://issues.apache.org/jira/browse/FLINK-7763
Project: Flink
Issue
Aljoscha Krettek created FLINK-7762:
---
Summary: Make WikipediaEditsSourceTest a proper test
Key: FLINK-7762
URL: https://issues.apache.org/jira/browse/FLINK-7762
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-7729:
---
Summary: Remove Scala 2.10 support; add Scala 2.12 support
Key: FLINK-7729
URL: https://issues.apache.org/jira/browse/FLINK-7729
Project: Flink
Issue
Aljoscha Krettek created FLINK-7700:
---
Summary: State merging in RocksDB backend leaves old state
Key: FLINK-7700
URL: https://issues.apache.org/jira/browse/FLINK-7700
Project: Flink
Issue
Aljoscha Krettek created FLINK-7623:
---
Summary: Detecting whether an operator is restored doesn't work
with chained state
Key: FLINK-7623
URL: https://issues.apache.org/jira/browse/FLINK-7623
Aljoscha Krettek created FLINK-7586:
---
Summary: Report Watermark metrics in all operators
Key: FLINK-7586
URL: https://issues.apache.org/jira/browse/FLINK-7586
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-7568:
---
Summary: Bring window documentation up-to-date with latest changes
and improve
Key: FLINK-7568
URL: https://issues.apache.org/jira/browse/FLINK-7568
Project:
Aljoscha Krettek created FLINK-7564:
---
Summary: Fix Watermark semantics in Table API
Key: FLINK-7564
URL: https://issues.apache.org/jira/browse/FLINK-7564
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-7563:
---
Summary: Fix watermark semantics in CEP operators
Key: FLINK-7563
URL: https://issues.apache.org/jira/browse/FLINK-7563
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-7553:
---
Summary: Use new SinkFunction interface in FlinkKafkaProducer010
Key: FLINK-7553
URL: https://issues.apache.org/jira/browse/FLINK-7553
Project: Flink
Aljoscha Krettek created FLINK-7552:
---
Summary: Extend SinkFunction interface with SinkContext
Key: FLINK-7552
URL: https://issues.apache.org/jira/browse/FLINK-7552
Project: Flink
Issue
Aljoscha Krettek created FLINK-7480:
---
Summary: Set HADOOP_CONF_DIR to sane default if not set
Key: FLINK-7480
URL: https://issues.apache.org/jira/browse/FLINK-7480
Project: Flink
Issue
101 - 200 of 405 matches
Mail list logo
