Aljoscha Krettek created FLINK-21505:
Summary: Enforce common savepoint format at the operator level
Key: FLINK-21505
URL: https://issues.apache.org/jira/browse/FLINK-21505
Project: Flink
Aljoscha Krettek created FLINK-21151:
Summary: Extract common full-snapshot writer from RocksDB
full-snapshot strategy
Key: FLINK-21151
URL: https://issues.apache.org/jira/browse/FLINK-21151
Aljoscha Krettek created FLINK-20843:
Summary: UnalignedCheckpointITCase is unstable
Key: FLINK-20843
URL: https://issues.apache.org/jira/browse/FLINK-20843
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-20651:
Summary: Use Spotless/google-java-format for code
formatting/enforcement
Key: FLINK-20651
URL: https://issues.apache.org/jira/browse/FLINK-20651
Project:
Aljoscha Krettek created FLINK-20491:
Summary: Support Broadcast State in BATCH execution mode
Key: FLINK-20491
URL: https://issues.apache.org/jira/browse/FLINK-20491
Project: Flink
Aljoscha Krettek created FLINK-20302:
Summary: Suggest DataStream API with BATCH execution mode in
DataSet docs
Key: FLINK-20302
URL: https://issues.apache.org/jira/browse/FLINK-20302
Project:
Aljoscha Krettek created FLINK-20153:
Summary: Add documentation for BATCH execution mode
Key: FLINK-20153
URL: https://issues.apache.org/jira/browse/FLINK-20153
Project: Flink
Issue
Aljoscha Krettek created FLINK-20098:
Summary: Don't add flink-connector-files to flink-dist
Key: FLINK-20098
URL: https://issues.apache.org/jira/browse/FLINK-20098
Project: Flink
Issue
Aljoscha Krettek created FLINK-20001:
Summary: Don't use setAllVerticesInSameSlotSharingGroupByDefault
in StreamGraphGenerator
Key: FLINK-20001
URL: https://issues.apache.org/jira/browse/FLINK-20001
Aljoscha Krettek created FLINK-19932:
Summary: Add integration test for BATCH execution on DataStream API
Key: FLINK-19932
URL: https://issues.apache.org/jira/browse/FLINK-19932
Project: Flink
Aljoscha Krettek created FLINK-19837:
Summary: Don't emit intermediate watermarks watermark operators in
BATCH execution mode
Key: FLINK-19837
URL: https://issues.apache.org/jira/browse/FLINK-19837
Aljoscha Krettek created FLINK-19835:
Summary: Don't emit intermediate watermarks in BATCH execution mode
Key: FLINK-19835
URL: https://issues.apache.org/jira/browse/FLINK-19835
Project: Flink
Aljoscha Krettek created FLINK-19833:
Summary: Rename Sink API Writer interface to SinkWriter
Key: FLINK-19833
URL: https://issues.apache.org/jira/browse/FLINK-19833
Project: Flink
Issue
Aljoscha Krettek created FLINK-19671:
Summary: Update EditorConfig file to be useful
Key: FLINK-19671
URL: https://issues.apache.org/jira/browse/FLINK-19671
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-19521:
Summary: Support dynamic properties on DefaultCLI
Key: FLINK-19521
URL: https://issues.apache.org/jira/browse/FLINK-19521
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-19508:
Summary: Add collect() operation on DataStream
Key: FLINK-19508
URL: https://issues.apache.org/jira/browse/FLINK-19508
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-19493:
Summary: In CliFrontend, make flow of Configuration more obvious
Key: FLINK-19493
URL: https://issues.apache.org/jira/browse/FLINK-19493
Project: Flink
Aljoscha Krettek created FLINK-19479:
Summary: Allow explicitly configuring time behaviour on
KeyedStream.intervalJoin()
Key: FLINK-19479
URL: https://issues.apache.org/jira/browse/FLINK-19479
Aljoscha Krettek created FLINK-19377:
Summary: Task can swallow test exceptions which hides test failures
Key: FLINK-19377
URL: https://issues.apache.org/jira/browse/FLINK-19377
Project: Flink
Aljoscha Krettek created FLINK-19326:
Summary: Allow explicitly configuring time behaviour on CEP
PatternStream
Key: FLINK-19326
URL: https://issues.apache.org/jira/browse/FLINK-19326
Project:
Aljoscha Krettek created FLINK-19319:
Summary: Deprecate
StreamExecutionEnvironment.setStreamTimeCharacteristic()
Key: FLINK-19319
URL: https://issues.apache.org/jira/browse/FLINK-19319
Project:
Aljoscha Krettek created FLINK-19318:
Summary: Deprecate timeWindow() operations in DataStream API
Key: FLINK-19318
URL: https://issues.apache.org/jira/browse/FLINK-19318
Project: Flink
Aljoscha Krettek created FLINK-19317:
Summary: Make EventTime the default StreamTimeCharacteristic
Key: FLINK-19317
URL: https://issues.apache.org/jira/browse/FLINK-19317
Project: Flink
Aljoscha Krettek created FLINK-19316:
Summary: FLIP-134: Batch execution for the DataStream API
Key: FLINK-19316
URL: https://issues.apache.org/jira/browse/FLINK-19316
Project: Flink
Aljoscha Krettek created FLINK-19264:
Summary: MiniCluster is flaky with concurrent job execution
Key: FLINK-19264
URL: https://issues.apache.org/jira/browse/FLINK-19264
Project: Flink
Aljoscha Krettek created FLINK-19247:
Summary: Update Chinese documentation after removal of Kafka 0.10
and 0.11
Key: FLINK-19247
URL: https://issues.apache.org/jira/browse/FLINK-19247
Project:
Aljoscha Krettek created FLINK-19193:
Summary: Upgrade migration guidelines to use stop-with-savepoint
Key: FLINK-19193
URL: https://issues.apache.org/jira/browse/FLINK-19193
Project: Flink
Aljoscha Krettek created FLINK-19155:
Summary: ResultPartitionTest is unstable
Key: FLINK-19155
URL: https://issues.apache.org/jira/browse/FLINK-19155
Project: Flink
Issue Type: New
Aljoscha Krettek created FLINK-19153:
Summary: FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs
(and deprecate the DataSet API)
Key: FLINK-19153
URL: https://issues.apache.org/jira/browse/FLINK-19153
Aljoscha Krettek created FLINK-19152:
Summary: Remove Kafka 0.10.x and 0.11.x connectors
Key: FLINK-19152
URL: https://issues.apache.org/jira/browse/FLINK-19152
Project: Flink
Issue
Aljoscha Krettek created FLINK-19135:
Summary: (Stream)ExecutionEnvironment.execute() should not throw
ExecutionException
Key: FLINK-19135
URL: https://issues.apache.org/jira/browse/FLINK-19135
Aljoscha Krettek created FLINK-19123:
Summary: TestStreamEnvironment does not use shared MiniCluster for
executeAsync()
Key: FLINK-19123
URL: https://issues.apache.org/jira/browse/FLINK-19123
Aljoscha Krettek created FLINK-18693:
Summary: AvroSerializationSchema does not work with types
generated by avrohugger
Key: FLINK-18693
URL: https://issues.apache.org/jira/browse/FLINK-18693
Aljoscha Krettek created FLINK-18692:
Summary: AvroSerializationSchema does not work with types
generated by avrohugger
Key: FLINK-18692
URL: https://issues.apache.org/jira/browse/FLINK-18692
Aljoscha Krettek created FLINK-18569:
Summary: Add Table.limit() which is the equivalent of SQL LIMIT
Key: FLINK-18569
URL: https://issues.apache.org/jira/browse/FLINK-18569
Project: Flink
Aljoscha Krettek created FLINK-18478:
Summary: AvroDeserializationSchema does not work with types
generated by avrohugger
Key: FLINK-18478
URL: https://issues.apache.org/jira/browse/FLINK-18478
Aljoscha Krettek created FLINK-18381:
Summary: Update Jekyll to 4.0.1
Key: FLINK-18381
URL: https://issues.apache.org/jira/browse/FLINK-18381
Project: Flink
Issue Type: Bug
Aljoscha Krettek created FLINK-18377:
Summary: Rename "Flink Master" back to JobManager in documentation
Key: FLINK-18377
URL: https://issues.apache.org/jira/browse/FLINK-18377
Project: Flink
Aljoscha Krettek created FLINK-18120:
Summary: Don't expand documentation sections by default
Key: FLINK-18120
URL: https://issues.apache.org/jira/browse/FLINK-18120
Project: Flink
Issue
Aljoscha Krettek created FLINK-18036:
Summary: Chinese documentation build is broken
Key: FLINK-18036
URL: https://issues.apache.org/jira/browse/FLINK-18036
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-18032:
Summary: Remove outdated sections in migration guide
Key: FLINK-18032
URL: https://issues.apache.org/jira/browse/FLINK-18032
Project: Flink
Issue
Aljoscha Krettek created FLINK-18011:
Summary: Make WatermarkStrategy/WatermarkStrategies more ergonomic
Key: FLINK-18011
URL: https://issues.apache.org/jira/browse/FLINK-18011
Project: Flink
Aljoscha Krettek created FLINK-17956:
Summary: Add Flink 1.11 MigrationVersion
Key: FLINK-17956
URL: https://issues.apache.org/jira/browse/FLINK-17956
Project: Flink
Issue Type: Task
Aljoscha Krettek created FLINK-17886:
Summary: Update documentation for new
WatermarkGenerator/WatermarkStrategies
Key: FLINK-17886
URL: https://issues.apache.org/jira/browse/FLINK-17886
Project:
Aljoscha Krettek created FLINK-17815:
Summary: Change KafkaConnector to give per-partition metric group
to WatermarkGenerator
Key: FLINK-17815
URL: https://issues.apache.org/jira/browse/FLINK-17815
Aljoscha Krettek created FLINK-17773:
Summary: Update documentation for new
WatermarkGenerator/WatermarkStrategies
Key: FLINK-17773
URL: https://issues.apache.org/jira/browse/FLINK-17773
Project:
Aljoscha Krettek created FLINK-17766:
Summary: Use checkpoint lock instead of fine-grained locking in
Kafka AbstractFetcher
Key: FLINK-17766
URL: https://issues.apache.org/jira/browse/FLINK-17766
Aljoscha Krettek created FLINK-17669:
Summary: Use new WatermarkStrategy/WatermarkGenerator in Kafka
connector
Key: FLINK-17669
URL: https://issues.apache.org/jira/browse/FLINK-17669
Project:
Aljoscha Krettek created FLINK-17661:
Summary: Add APIs for using new
WatermarkStrategy/WatermarkGenerator
Key: FLINK-17661
URL: https://issues.apache.org/jira/browse/FLINK-17661
Project: Flink
Aljoscha Krettek created FLINK-17659:
Summary: Add common watermark strategies and WatermarkStrategies
helper
Key: FLINK-17659
URL: https://issues.apache.org/jira/browse/FLINK-17659
Project:
Aljoscha Krettek created FLINK-17658:
Summary: Add new TimestampAssigner and WatermarkGenerator
interfaces
Key: FLINK-17658
URL: https://issues.apache.org/jira/browse/FLINK-17658
Project: Flink
Aljoscha Krettek created FLINK-17655:
Summary: Remove old and long deprecated TimestampExtractor
Key: FLINK-17655
URL: https://issues.apache.org/jira/browse/FLINK-17655
Project: Flink
Aljoscha Krettek created FLINK-17654:
Summary: Move Clock classes to flink-core to make them usable
outside runtime
Key: FLINK-17654
URL: https://issues.apache.org/jira/browse/FLINK-17654
Aljoscha Krettek created FLINK-17653:
Summary: FLIP-126: Unify (and separate) Watermark Assigners
Key: FLINK-17653
URL: https://issues.apache.org/jira/browse/FLINK-17653
Project: Flink
Aljoscha Krettek created FLINK-17514:
Summary: TaskCancelerWatchdog does not kill TaskManager
Key: FLINK-17514
URL: https://issues.apache.org/jira/browse/FLINK-17514
Project: Flink
Issue
Aljoscha Krettek created FLINK-17415:
Summary: Fold API-agnostic documentation into DataStream
documentation (chinese)
Key: FLINK-17415
URL: https://issues.apache.org/jira/browse/FLINK-17415
Aljoscha Krettek created FLINK-17349:
Summary: Reduce runtime of LocalExecutorITCase
Key: FLINK-17349
URL: https://issues.apache.org/jira/browse/FLINK-17349
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-17217:
Summary: Download links for central.maven.org in doc don't work
Key: FLINK-17217
URL: https://issues.apache.org/jira/browse/FLINK-17217
Project: Flink
Aljoscha Krettek created FLINK-17136:
Summary: Rename toplevel DataSet/DataStream section titles
Key: FLINK-17136
URL: https://issues.apache.org/jira/browse/FLINK-17136
Project: Flink
Aljoscha Krettek created FLINK-17074:
Summary: Deprecate DataStream.keyBy() that use tuple/expression
keys
Key: FLINK-17074
URL: https://issues.apache.org/jira/browse/FLINK-17074
Project: Flink
Aljoscha Krettek created FLINK-17009:
Summary: Fold API-agnostic documentation into DataStream
documentation
Key: FLINK-17009
URL: https://issues.apache.org/jira/browse/FLINK-17009
Project: Flink
Aljoscha Krettek created FLINK-16976:
Summary: Update chinese documentation for ListCheckpointed
deprecation
Key: FLINK-16976
URL: https://issues.apache.org/jira/browse/FLINK-16976
Project: Flink
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
Aljoscha Krettek created FLINK-16216:
Summary: Describe end-to-end exactly once programs in stateful
stream processing concepts documentation
Key: FLINK-16216
URL:
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-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-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-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-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-16209:
Summary: Add Latency and Completeness section in timely stream
processing concepts
Key: FLINK-16209
URL: https://issues.apache.org/jira/browse/FLINK-16209
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-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-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-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-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-16041:
Summary: Expand "popular" documentation sections by default
Key: FLINK-16041
URL: https://issues.apache.org/jira/browse/FLINK-16041
Project: Flink
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:
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-15998:
Summary: Revert rename of "Job Cluster" to "Application Cluster"
in documentation
Key: FLINK-15998
URL: https://issues.apache.org/jira/browse/FLINK-15998
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-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-15904:
Summary: Make Kafka Consumer work with activated
"disableGenericTypes()"
Key: FLINK-15904
URL: https://issues.apache.org/jira/browse/FLINK-15904
Project:
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
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
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
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
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
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-15129:
Summary: Return JobClient instead of JobClient Future from
executeAsync()
Key: FLINK-15129
URL: https://issues.apache.org/jira/browse/FLINK-15129
Project:
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-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-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-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-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-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:
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
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:
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-14391:
Summary: Remove FlinkPlan Interface
Key: FLINK-14391
URL: https://issues.apache.org/jira/browse/FLINK-14391
Project: Flink
Issue Type: Sub-task
1 - 100 of 405 matches
Mail list logo
