[jira] [Created] (FLINK-9402) Kinesis consumer validation incorrectly requires aws.region property

Thomas Weise created FLINK-9402: --- Summary: Kinesis consumer validation incorrectly requires aws.region property Key: FLINK-9402 URL: https://issues.apache.org/jira/browse/FLINK-9402 Project: Flink

[jira] [Created] (FLINK-9415) Remove reference to StreamingMultipleProgramsTestBase in docs

Thomas Weise created FLINK-9415: --- Summary: Remove reference to StreamingMultipleProgramsTestBase in docs Key: FLINK-9415 URL: https://issues.apache.org/jira/browse/FLINK-9415 Project: Flink

[jira] [Created] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

Thomas Weise created FLINK-8516: --- Summary: FlinkKinesisConsumer does not balance shards over subtasks Key: FLINK-8516 URL: https://issues.apache.org/jira/browse/FLINK-8516 Project: Flink Issue

[jira] [Created] (FLINK-8648) Allow for customization of emitRecordAndUpdateState in Kinesis connector

Thomas Weise created FLINK-8648: --- Summary: Allow for customization of emitRecordAndUpdateState in Kinesis connector Key: FLINK-8648 URL: https://issues.apache.org/jira/browse/FLINK-8648 Project: Flink

[jira] [Created] (FLINK-10020) Kinesis Consumer listShards should support more recoverable exceptions

Thomas Weise created FLINK-10020: Summary: Kinesis Consumer listShards should support more recoverable exceptions Key: FLINK-10020 URL: https://issues.apache.org/jira/browse/FLINK-10020 Project:

[jira] [Created] (FLINK-10074) Allowable number of checkpoint failures

Thomas Weise created FLINK-10074: Summary: Allowable number of checkpoint failures Key: FLINK-10074 URL: https://issues.apache.org/jira/browse/FLINK-10074 Project: Flink Issue Type:

[jira] [Created] (FLINK-9926) Allow for ShardConsumer override in Kinesis consumer

Thomas Weise created FLINK-9926: --- Summary: Allow for ShardConsumer override in Kinesis consumer Key: FLINK-9926 URL: https://issues.apache.org/jira/browse/FLINK-9926 Project: Flink Issue Type:

[jira] [Created] (FLINK-9188) Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer

Thomas Weise created FLINK-9188: --- Summary: Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer Key: FLINK-9188 URL: https://issues.apache.org/jira/browse/FLINK-9188 Project:

[jira] [Created] (FLINK-9124) Allow customization of KinesisProxy.getRecords read timeout and retry

Thomas Weise created FLINK-9124: --- Summary: Allow customization of KinesisProxy.getRecords read timeout and retry Key: FLINK-9124 URL: https://issues.apache.org/jira/browse/FLINK-9124 Project: Flink

[jira] [Created] (FLINK-10279) Better clarification for status

Thomas Weise created FLINK-10279: Summary: Better clarification for status Key: FLINK-10279 URL: https://issues.apache.org/jira/browse/FLINK-10279 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-10921) Prioritize shard consumers in Kinesis Consumer by event time

Thomas Weise created FLINK-10921: Summary: Prioritize shard consumers in Kinesis Consumer by event time Key: FLINK-10921 URL: https://issues.apache.org/jira/browse/FLINK-10921 Project: Flink

[jira] [Created] (FLINK-10912) Configurable RocksDBStateBackend options factory

Thomas Weise created FLINK-10912: Summary: Configurable RocksDBStateBackend options factory Key: FLINK-10912 URL: https://issues.apache.org/jira/browse/FLINK-10912 Project: Flink Issue Type:

[jira] [Created] (FLINK-11145) Fix Hadoop version handling in binary release script

Thomas Weise created FLINK-11145: Summary: Fix Hadoop version handling in binary release script Key: FLINK-11145 URL: https://issues.apache.org/jira/browse/FLINK-11145 Project: Flink Issue

[jira] [Created] (FLINK-12675) Event time synchronization in Kafka consumer

Thomas Weise created FLINK-12675: Summary: Event time synchronization in Kafka consumer Key: FLINK-12675 URL: https://issues.apache.org/jira/browse/FLINK-12675 Project: Flink Issue Type:

[jira] [Created] (FLINK-14107) Kinesis consumer record emitter may deadlock under event time alignment

Thomas Weise created FLINK-14107: Summary: Kinesis consumer record emitter may deadlock under event time alignment Key: FLINK-14107 URL: https://issues.apache.org/jira/browse/FLINK-14107 Project:

[jira] [Created] (FLINK-14283) Update Kinesis consumer documentation for watermarks and event time alignment

Thomas Weise created FLINK-14283: Summary: Update Kinesis consumer documentation for watermarks and event time alignment Key: FLINK-14283 URL: https://issues.apache.org/jira/browse/FLINK-14283

[jira] [Created] (FLINK-14470) Watermark display not working with high parallelism job

Thomas Weise created FLINK-14470: Summary: Watermark display not working with high parallelism job Key: FLINK-14470 URL: https://issues.apache.org/jira/browse/FLINK-14470 Project: Flink

[jira] [Created] (FLINK-16393) Kinesis consumer unnecessarily creates record emitter thread w/o source sync

Thomas Weise created FLINK-16393: Summary: Kinesis consumer unnecessarily creates record emitter thread w/o source sync Key: FLINK-16393 URL: https://issues.apache.org/jira/browse/FLINK-16393

[jira] [Created] (FLINK-15868) Kinesis consumer fails due to jackson-cbor conflict in 1.10 RC1

Thomas Weise created FLINK-15868: Summary: Kinesis consumer fails due to jackson-cbor conflict in 1.10 RC1 Key: FLINK-15868 URL: https://issues.apache.org/jira/browse/FLINK-15868 Project: Flink

[jira] [Created] (FLINK-17496) Performance regression with amazon-kinesis-producer 0.13.1 in Flink 1.10.x

Thomas Weise created FLINK-17496: Summary: Performance regression with amazon-kinesis-producer 0.13.1 in Flink 1.10.x Key: FLINK-17496 URL: https://issues.apache.org/jira/browse/FLINK-17496 Project:

[jira] [Created] (FLINK-21059) KafkaSourceEnumerator does not honor consumer properties

Thomas Weise created FLINK-21059: Summary: KafkaSourceEnumerator does not honor consumer properties Key: FLINK-21059 URL: https://issues.apache.org/jira/browse/FLINK-21059 Project: Flink

[jira] [Created] (FLINK-21169) Kafka flink-connector-base dependency should be scope compile

Thomas Weise created FLINK-21169: Summary: Kafka flink-connector-base dependency should be scope compile Key: FLINK-21169 URL: https://issues.apache.org/jira/browse/FLINK-21169 Project: Flink

[jira] [Created] (FLINK-22668) FLIP-150: Introduce Hybrid Source

Thomas Weise created FLINK-22668: Summary: FLIP-150: Introduce Hybrid Source Key: FLINK-22668 URL: https://issues.apache.org/jira/browse/FLINK-22668 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22670) Initial HybridSource DataStream Implementation

Thomas Weise created FLINK-22670: Summary: Initial HybridSource DataStream Implementation Key: FLINK-22670 URL: https://issues.apache.org/jira/browse/FLINK-22670 Project: Flink Issue Type:

[jira] [Created] (FLINK-22778) Upgrade to JUnit 4.13

Thomas Weise created FLINK-22778: Summary: Upgrade to JUnit 4.13 Key: FLINK-22778 URL: https://issues.apache.org/jira/browse/FLINK-22778 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22791) HybridSource user documentation

Thomas Weise created FLINK-22791: Summary: HybridSource user documentation Key: FLINK-22791 URL: https://issues.apache.org/jira/browse/FLINK-22791 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22790) HybridSource end-to-end test

Thomas Weise created FLINK-22790: Summary: HybridSource end-to-end test Key: FLINK-22790 URL: https://issues.apache.org/jira/browse/FLINK-22790 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24010) HybridSourceReader needs to forward checkpoint notifications

Thomas Weise created FLINK-24010: Summary: HybridSourceReader needs to forward checkpoint notifications Key: FLINK-24010 URL: https://issues.apache.org/jira/browse/FLINK-24010 Project: Flink

[jira] [Created] (FLINK-24064) HybridSource recovery from savepoint fails

Thomas Weise created FLINK-24064: Summary: HybridSource recovery from savepoint fails Key: FLINK-24064 URL: https://issues.apache.org/jira/browse/FLINK-24064 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23633) HybridSource: Support dynamic stop position in FileSource

Thomas Weise created FLINK-23633: Summary: HybridSource: Support dynamic stop position in FileSource Key: FLINK-23633 URL: https://issues.apache.org/jira/browse/FLINK-23633 Project: Flink

[jira] [Created] (FLINK-24687) flink-table uber jar should not include flink-connector-files dependency

Thomas Weise created FLINK-24687: Summary: flink-table uber jar should not include flink-connector-files dependency Key: FLINK-24687 URL: https://issues.apache.org/jira/browse/FLINK-24687 Project:

[jira] [Created] (FLINK-26639) Publish flink-kubernetes-operator maven artifacts

Thomas Weise created FLINK-26639: Summary: Publish flink-kubernetes-operator maven artifacts Key: FLINK-26639 URL: https://issues.apache.org/jira/browse/FLINK-26639 Project: Flink Issue

[jira] [Created] (FLINK-26538) Ability to restart deployment w/o spec change

Thomas Weise created FLINK-26538: Summary: Ability to restart deployment w/o spec change Key: FLINK-26538 URL: https://issues.apache.org/jira/browse/FLINK-26538 Project: Flink Issue Type:

[jira] [Created] (FLINK-26554) Clean termination of FlinkDeployment

Thomas Weise created FLINK-26554: Summary: Clean termination of FlinkDeployment Key: FLINK-26554 URL: https://issues.apache.org/jira/browse/FLINK-26554 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26290) Revisit serviceAccount and taskSlots direct fields in CRD

Thomas Weise created FLINK-26290: Summary: Revisit serviceAccount and taskSlots direct fields in CRD Key: FLINK-26290 URL: https://issues.apache.org/jira/browse/FLINK-26290 Project: Flink

[jira] [Created] (FLINK-26261) Reconciliation should try to start job when not already started or move to permanent error

Thomas Weise created FLINK-26261: Summary: Reconciliation should try to start job when not already started or move to permanent error Key: FLINK-26261 URL: https://issues.apache.org/jira/browse/FLINK-26261

[jira] [Created] (FLINK-26811) Document CRD upgrade process

Thomas Weise created FLINK-26811: Summary: Document CRD upgrade process Key: FLINK-26811 URL: https://issues.apache.org/jira/browse/FLINK-26811 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26812) Flink native k8s integration should support owner reference

Thomas Weise created FLINK-26812: Summary: Flink native k8s integration should support owner reference Key: FLINK-26812 URL: https://issues.apache.org/jira/browse/FLINK-26812 Project: Flink

[jira] [Created] (FLINK-25963) FLIP-212: Introduce Flink Kubernetes Operator

Thomas Weise created FLINK-25963: Summary: FLIP-212: Introduce Flink Kubernetes Operator Key: FLINK-25963 URL: https://issues.apache.org/jira/browse/FLINK-25963 Project: Flink Issue Type:

[jira] [Created] (FLINK-27465) AvroRowDeserializationSchema.convertToTimestamp fails with negative nano seconds

Thomas Weise created FLINK-27465: Summary: AvroRowDeserializationSchema.convertToTimestamp fails with negative nano seconds Key: FLINK-27465 URL: https://issues.apache.org/jira/browse/FLINK-27465

[jira] [Created] (FLINK-27435) Kubernetes Operator keeps savepoint history

Thomas Weise created FLINK-27435: Summary: Kubernetes Operator keeps savepoint history Key: FLINK-27435 URL: https://issues.apache.org/jira/browse/FLINK-27435 Project: Flink Issue Type:

[jira] [Created] (FLINK-29100) Deployment with last-state upgrade mode stuck after initial error

Thomas Weise created FLINK-29100: Summary: Deployment with last-state upgrade mode stuck after initial error Key: FLINK-29100 URL: https://issues.apache.org/jira/browse/FLINK-29100 Project: Flink

[jira] [Created] (FLINK-29159) Revisit/harden initial deployment logic

Thomas Weise created FLINK-29159: Summary: Revisit/harden initial deployment logic Key: FLINK-29159 URL: https://issues.apache.org/jira/browse/FLINK-29159 Project: Flink Issue Type:

[jira] [Created] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

Thomas Weise created FLINK-29109: Summary: Checkpoint path conflict with stateless upgrade mode Key: FLINK-29109 URL: https://issues.apache.org/jira/browse/FLINK-29109 Project: Flink Issue

[jira] [Created] (FLINK-29634) Support periodic checkpoint triggering

Thomas Weise created FLINK-29634: Summary: Support periodic checkpoint triggering Key: FLINK-29634 URL: https://issues.apache.org/jira/browse/FLINK-29634 Project: Flink Issue Type: New

[jira] [Created] (FLINK-29497) Provide an option to publish the flink-dist jar file artifact

Thomas Weise created FLINK-29497: Summary: Provide an option to publish the flink-dist jar file artifact Key: FLINK-29497 URL: https://issues.apache.org/jira/browse/FLINK-29497 Project: Flink

[jira] [Created] (FLINK-30004) Cannot resume deployment after suspend with savepoint due to leftover confgmaps

Thomas Weise created FLINK-30004: Summary: Cannot resume deployment after suspend with savepoint due to leftover confgmaps Key: FLINK-30004 URL: https://issues.apache.org/jira/browse/FLINK-30004

[jira] [Created] (FLINK-30858) Kubernetes operator does not update reconciled generation

Thomas Weise created FLINK-30858: Summary: Kubernetes operator does not update reconciled generation Key: FLINK-30858 URL: https://issues.apache.org/jira/browse/FLINK-30858 Project: Flink