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
Issue
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: Sub-ta
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-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-14391:
Summary: Remove FlinkPlan Interface
Key: FLINK-14391
URL: https://issues.apache.org/jira/browse/FLINK-14391
Project: Flink
Issue Type: Sub-task
Aljoscha Krettek created FLINK-14412:
Summary: Rename ML Pipeline to MLPipeline
Key: FLINK-14412
URL: https://issues.apache.org/jira/browse/FLINK-14412
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-14840:
Summary: Use new Executor interface in SQL cli
Key: FLINK-14840
URL: https://issues.apache.org/jira/browse/FLINK-14840
Project: Flink
Issue Type: Sub
Aljoscha Krettek created FLINK-14854:
Summary: Add executeAsync() method to environments
Key: FLINK-14854
URL: https://issues.apache.org/jira/browse/FLINK-14854
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-14968:
Summary: Kerberized YARN on Docker test (custom fs plugin) fails
on Travis
Key: FLINK-14968
URL: https://issues.apache.org/jira/browse/FLINK-14968
Project: Fl
Aljoscha Krettek created FLINK-14992:
Summary: Add job submission listener to execution environments
Key: FLINK-14992
URL: https://issues.apache.org/jira/browse/FLINK-14992
Project: Flink
Aljoscha Krettek created FLINK-15007:
Summary: Flink on YARN does not request required TaskExecutors in
some cases
Key: FLINK-15007
URL: https://issues.apache.org/jira/browse/FLINK-15007
Project:
Aljoscha Krettek created FLINK-15013:
Summary: Flink (on YARN) sometimes needs too many slots
Key: FLINK-15013
URL: https://issues.apache.org/jira/browse/FLINK-15013
Project: Flink
Issue
Aljoscha Krettek created FLINK-15116:
Summary: Make JobClient stateless, remove AutoCloseable
Key: FLINK-15116
URL: https://issues.apache.org/jira/browse/FLINK-15116
Project: Flink
Issue
Aljoscha Krettek created FLINK-15121:
Summary: Add public constructor/getter for execution environments
that takes Configuration
Key: FLINK-15121
URL: https://issues.apache.org/jira/browse/FLINK-15121
Aljoscha Krettek created FLINK-15129:
Summary: Return JobClient instead of JobClient Future from
executeAsync()
Key: FLINK-15129
URL: https://issues.apache.org/jira/browse/FLINK-15129
Project: Fli
Aljoscha Krettek created FLINK-15157:
Summary: Make ScalaShell ensureYarnConfig() and
fetchConnectionInfo() public
Key: FLINK-15157
URL: https://issues.apache.org/jira/browse/FLINK-15157
Project:
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-12019:
Summary:
ZooKeeperHaServicesTest.testCloseAndCleanupAllDataWithUncle is unstable
Key: FLINK-12019
URL: https://issues.apache.org/jira/browse/FLINK-12019
Proje
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-12164:
Summary:
JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable
Key: FLINK-12164
URL: https://issues.apache.org/jira/browse/FLINK-12164
Proj
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-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-12606:
Summary: Move SourceFunction to flink-core
Key: FLINK-12606
URL: https://issues.apache.org/jira/browse/FLINK-12606
Project: Flink
Issue Type: Improve
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: Improveme
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: Flin
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
Iss
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-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-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-13601:
Summary: RegionFailoverITCase is unstable
Key: FLINK-13601
URL: https://issues.apache.org/jira/browse/FLINK-13601
Project: Flink
Issue Type: Improvem
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-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-11539:
Summary: Add TypeSerializerSnapshot for TraversableSerializer
Key: FLINK-11539
URL: https://issues.apache.org/jira/browse/FLINK-11539
Project: Flink
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: Flink
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-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-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-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-11865:
Summary: Code generation in TraversableSerializer is prohibitively
slow
Key: FLINK-11865
URL: https://issues.apache.org/jira/browse/FLINK-11865
Project: Flink
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-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-15251:
Summary: Fabric8FlinkKubeClient doesn't work if ingress has
hostname but no IP
Key: FLINK-15251
URL: https://issues.apache.org/jira/browse/FLINK-15251
Project
Aljoscha Krettek created FLINK-15265:
Summary: Remove "-executor" suffix from executor names
Key: FLINK-15265
URL: https://issues.apache.org/jira/browse/FLINK-15265
Project: Flink
Issue T
Aljoscha Krettek created FLINK-15474:
Summary: In TypeSerializerUpgradeTestBase, create serializer
snapshots "on demand"
Key: FLINK-15474
URL: https://issues.apache.org/jira/browse/FLINK-15474
Pro
Aljoscha Krettek created FLINK-15518:
Summary: Don't hide web frontend side pane automatically
Key: FLINK-15518
URL: https://issues.apache.org/jira/browse/FLINK-15518
Project: Flink
Issue
Aljoscha Krettek created FLINK-15735:
Summary: Too many warnings when running bin/start-cluster.sh
Key: FLINK-15735
URL: https://issues.apache.org/jira/browse/FLINK-15735
Project: Flink
I
Aljoscha Krettek created FLINK-15904:
Summary: Make Kafka Consumer work with activated
"disableGenericTypes()"
Key: FLINK-15904
URL: https://issues.apache.org/jira/browse/FLINK-15904
Project: Flin
Aljoscha Krettek created FLINK-15993:
Summary: Add timeout to 404 documentation redirect, add explanation
Key: FLINK-15993
URL: https://issues.apache.org/jira/browse/FLINK-15993
Project: Flink
Aljoscha Krettek created FLINK-15997:
Summary: Make documentation 404 page look like a documentation page
Key: FLINK-15997
URL: https://issues.apache.org/jira/browse/FLINK-15997
Project: Flink
Aljoscha Krettek created FLINK-15998:
Summary: Revert rename of "Job Cluster" to "Application Cluster"
in documentation
Key: FLINK-15998
URL: https://issues.apache.org/jira/browse/FLINK-15998
Proj
Aljoscha Krettek created FLINK-15999:
Summary: Extract “Concepts” material from API/Library sections and
start proper concepts section
Key: FLINK-15999
URL: https://issues.apache.org/jira/browse/FLINK-15999
Aljoscha Krettek created FLINK-16000:
Summary: Move "Project Build Setup" to "Getting Started" in
documentation
Key: FLINK-16000
URL: https://issues.apache.org/jira/browse/FLINK-16000
Project: Fli
Aljoscha Krettek created FLINK-16041:
Summary: Expand "popular" documentation sections by default
Key: FLINK-16041
URL: https://issues.apache.org/jira/browse/FLINK-16041
Project: Flink
Is
Aljoscha Krettek created FLINK-16045:
Summary: Extract connectors documentation to a top-level section
Key: FLINK-16045
URL: https://issues.apache.org/jira/browse/FLINK-16045
Project: Flink
Aljoscha Krettek created FLINK-16044:
Summary: Extract libraries documentation to a top-level section
Key: FLINK-16044
URL: https://issues.apache.org/jira/browse/FLINK-16044
Project: Flink
Aljoscha Krettek created FLINK-16049:
Summary: Remove outdated "Best Pracatices" section from
Application Development Section
Key: FLINK-16049
URL: https://issues.apache.org/jira/browse/FLINK-16049
Aljoscha Krettek created FLINK-16144:
Summary: Add client.timeout setting and use that for CLI operations
Key: FLINK-16144
URL: https://issues.apache.org/jira/browse/FLINK-16144
Project: Flink
Aljoscha Krettek created FLINK-16207:
Summary: In stream processing concepts section, rework
distribution patterns description
Key: FLINK-16207
URL: https://issues.apache.org/jira/browse/FLINK-16207
Aljoscha Krettek created FLINK-16208:
Summary: Add introduction to timely stream processing concepts
documentation
Key: FLINK-16208
URL: https://issues.apache.org/jira/browse/FLINK-16208
Project:
Aljoscha Krettek created FLINK-16209:
Summary: Add Latency and Completeness section in timely stream
processing concepts
Key: FLINK-16209
URL: https://issues.apache.org/jira/browse/FLINK-16209
Pro
Aljoscha Krettek created FLINK-16210:
Summary: Add section about applications and clusters/session in
concepts documentation
Key: FLINK-16210
URL: https://issues.apache.org/jira/browse/FLINK-16210
Aljoscha Krettek created FLINK-16211:
Summary: Add introduction to stream processing concepts
documentation
Key: FLINK-16211
URL: https://issues.apache.org/jira/browse/FLINK-16211
Project: Flink
Aljoscha Krettek created FLINK-16212:
Summary: Describe how Flink is a unified batch/stream processing
system in concepts documentation
Key: FLINK-16212
URL: https://issues.apache.org/jira/browse/FLINK-16212
Aljoscha Krettek created FLINK-16213:
Summary: Add "What Is State" section in concepts documentation
Key: FLINK-16213
URL: https://issues.apache.org/jira/browse/FLINK-16213
Project: Flink
Aljoscha Krettek created FLINK-16214:
Summary: Describe how state is different for stream/batch programs
in concepts documentation
Key: FLINK-16214
URL: https://issues.apache.org/jira/browse/FLINK-16214
Aljoscha Krettek created FLINK-16216:
Summary: Describe end-to-end exactly once programs in stateful
stream processing concepts documentation
Key: FLINK-16216
URL: https://issues.apache.org/jira/browse/FLINK-1
Aljoscha Krettek created FLINK-16572:
Summary: CheckPubSubEmulatorTest is flaky on Azure
Key: FLINK-16572
URL: https://issues.apache.org/jira/browse/FLINK-16572
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-2891:
---
Summary: Key for Keyed State is not set upon Window Evaluation
Key: FLINK-2891
URL: https://issues.apache.org/jira/browse/FLINK-2891
Project: Flink
Iss
Aljoscha Krettek created FLINK-2922:
---
Summary: Add Queryable Window Operator
Key: FLINK-2922
URL: https://issues.apache.org/jira/browse/FLINK-2922
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-2991:
---
Summary: Extend Window Operators to Allow Efficient Fold Operation
Key: FLINK-2991
URL: https://issues.apache.org/jira/browse/FLINK-2991
Project: Flink
Aljoscha Krettek created FLINK-3024:
---
Summary: TimestampExtractor Does not Work When returning
Long.MIN_VALUE
Key: FLINK-3024
URL: https://issues.apache.org/jira/browse/FLINK-3024
Project: Flink
Aljoscha Krettek created FLINK-3174:
---
Summary: Add merging WindowAssigner
Key: FLINK-3174
URL: https://issues.apache.org/jira/browse/FLINK-3174
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-3177:
---
Summary: Add Stream Operator that Discards Late Elements
Key: FLINK-3177
URL: https://issues.apache.org/jira/browse/FLINK-3177
Project: Flink
Issue Typ
Aljoscha Krettek created FLINK-3178:
---
Summary: Make Closing Behavior of Window Operators Configurable
Key: FLINK-3178
URL: https://issues.apache.org/jira/browse/FLINK-3178
Project: Flink
Is
Aljoscha Krettek created FLINK-3200:
---
Summary: Use Partitioned State Abstraction in WindowOperator
Key: FLINK-3200
URL: https://issues.apache.org/jira/browse/FLINK-3200
Project: Flink
Issue
Aljoscha Krettek created FLINK-3201:
---
Summary: Enhance Partitioned State Interface with State Types
Key: FLINK-3201
URL: https://issues.apache.org/jira/browse/FLINK-3201
Project: Flink
Issu
Aljoscha Krettek created FLINK-3202:
---
Summary: Make Timer/Trigger Service Scoped to Key/Namespace
Key: FLINK-3202
URL: https://issues.apache.org/jira/browse/FLINK-3202
Project: Flink
Issue
Aljoscha Krettek created FLINK-3242:
---
Summary: User-specified StateBackend is not Respected if
Checkpointing is Disabled
Key: FLINK-3242
URL: https://issues.apache.org/jira/browse/FLINK-3242
Project
Aljoscha Krettek created FLINK-3243:
---
Summary: Fix Interplay of TimeCharacteristic and Time Windows
Key: FLINK-3243
URL: https://issues.apache.org/jira/browse/FLINK-3243
Project: Flink
Issu
Aljoscha Krettek created FLINK-3278:
---
Summary: Add Partitioned State Backend Based on RocksDB
Key: FLINK-3278
URL: https://issues.apache.org/jira/browse/FLINK-3278
Project: Flink
Issue Type
Aljoscha Krettek created FLINK-3315:
---
Summary: Fix Slot Sharing in Streaming API
Key: FLINK-3315
URL: https://issues.apache.org/jira/browse/FLINK-3315
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-3336:
---
Summary: Add Semi-Rebalance Data Shipping for DataStream
Key: FLINK-3336
URL: https://issues.apache.org/jira/browse/FLINK-3336
Project: Flink
Issue Typ
Aljoscha Krettek created FLINK-3400:
---
Summary: RocksDB Backend does not work when not in Flink lib folder
Key: FLINK-3400
URL: https://issues.apache.org/jira/browse/FLINK-3400
Project: Flink
Aljoscha Krettek created FLINK-3402:
---
Summary: Refactor Common Parts of Stream/Batch Documentation
Key: FLINK-3402
URL: https://issues.apache.org/jira/browse/FLINK-3402
Project: Flink
Issue
Aljoscha Krettek created FLINK-3403:
---
Summary: Create Section "Working with Time" in Streaming Guide
Key: FLINK-3403
URL: https://issues.apache.org/jira/browse/FLINK-3403
Project: Flink
Iss
Aljoscha Krettek created FLINK-3417:
---
Summary: Add RocksDB StateBackendFactory and integrate with Flink
Config
Key: FLINK-3417
URL: https://issues.apache.org/jira/browse/FLINK-3417
Project: Flink
Aljoscha Krettek created FLINK-3419:
---
Summary: Drop partitionByHash from DataStream
Key: FLINK-3419
URL: https://issues.apache.org/jira/browse/FLINK-3419
Project: Flink
Issue Type: Improvem
Aljoscha Krettek created FLINK-3430:
---
Summary: Remove "no POJO" warning in TypeAnalyzer
Key: FLINK-3430
URL: https://issues.apache.org/jira/browse/FLINK-3430
Project: Flink
Issue Type: Impr
Aljoscha Krettek created FLINK-3436:
---
Summary: Remove ComplexIntegrationITCase
Key: FLINK-3436
URL: https://issues.apache.org/jira/browse/FLINK-3436
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-3439:
---
Summary: Remove final Long.MAX_VALUE Watermark in StreamSource
Key: FLINK-3439
URL: https://issues.apache.org/jira/browse/FLINK-3439
Project: Flink
Iss
Aljoscha Krettek created FLINK-3450:
---
Summary: RocksDB Backed Window Fails with KryoSerializer
Key: FLINK-3450
URL: https://issues.apache.org/jira/browse/FLINK-3450
Project: Flink
Issue Typ
Aljoscha Krettek created FLINK-3512:
---
Summary: Savepoint backend should not revert to "jobmanager"
Key: FLINK-3512
URL: https://issues.apache.org/jira/browse/FLINK-3512
Project: Flink
Issue
Aljoscha Krettek created FLINK-3513:
---
Summary: Fix interplay of automatic Operator UID and Changing name
of WindowOperator
Key: FLINK-3513
URL: https://issues.apache.org/jira/browse/FLINK-3513
Proje
Aljoscha Krettek created FLINK-3521:
---
Summary: Make Iterable part of method signature for WindowFunction
Key: FLINK-3521
URL: https://issues.apache.org/jira/browse/FLINK-3521
Project: Flink
Aljoscha Krettek created FLINK-3527:
---
Summary: Scala DataStream has no transform method
Key: FLINK-3527
URL: https://issues.apache.org/jira/browse/FLINK-3527
Project: Flink
Issue Type: Impr
Aljoscha Krettek created FLINK-3528:
---
Summary: Add Incremental Fold for Non-Keyed Window Operator
Key: FLINK-3528
URL: https://issues.apache.org/jira/browse/FLINK-3528
Project: Flink
Issue
Aljoscha Krettek created FLINK-3548:
---
Summary: Remove unnecessary generic parameter from
SingleOutputStreamOperator
Key: FLINK-3548
URL: https://issues.apache.org/jira/browse/FLINK-3548
Project: Fli
Aljoscha Krettek created FLINK-3565:
---
Summary: FlinkKafkaConsumer does not work with Scala 2.11
Key: FLINK-3565
URL: https://issues.apache.org/jira/browse/FLINK-3565
Project: Flink
Issue T
Aljoscha Krettek created FLINK-3575:
---
Summary: Update Working With State Section in Doc
Key: FLINK-3575
URL: https://issues.apache.org/jira/browse/FLINK-3575
Project: Flink
Issue Type: Impr
Aljoscha Krettek created FLINK-3581:
---
Summary: Add Non-Keyed Window Trigger
Key: FLINK-3581
URL: https://issues.apache.org/jira/browse/FLINK-3581
Project: Flink
Issue Type: Improvement
1 - 100 of 448 matches
Mail list logo