[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] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16340564#comment-16340564 ] Thomas Weise commented on FLINK-8516: - Relevant piece of code:

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

[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16341233#comment-16341233 ] Thomas Weise commented on FLINK-8516: - Can a PMC please add me as contributor, thanks! CC:

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357640#comment-16357640 ] Thomas Weise commented on FLINK-5697: - Since shards are immutable wrt their hash key range and records

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

[ https://issues.apache.org/jira/browse/FLINK-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362624#comment-16362624 ] Thomas Weise commented on FLINK-8648: -

[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] [Commented] (FLINK-9967) Snapshot release branches aren't deployed

[ https://issues.apache.org/jira/browse/FLINK-9967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559033#comment-16559033 ] Thomas Weise commented on FLINK-9967: - Good this is fixed. We saw strange build errors with

[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] [Commented] (FLINK-10020) Kinesis Consumer listShards should support more recoverable exceptions

[ https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566010#comment-16566010 ] Thomas Weise commented on FLINK-10020: -- {code:java}

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

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579269#comment-16579269 ] Thomas Weise commented on FLINK-10074: -- I think configuring the behavior as a count of allowable

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

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580624#comment-16580624 ] Thomas Weise commented on FLINK-10074: -- [~till.rohrmann] it is probably unreasonably hard to do for

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

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580624#comment-16580624 ] Thomas Weise edited comment on FLINK-10074 at 8/15/18 4:07 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580624#comment-16580624 ] Thomas Weise edited comment on FLINK-10074 at 8/15/18 4:09 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580699#comment-16580699 ] Thomas Weise commented on FLINK-10074: -- [~yanghua] this is what I meant also, I updated my comment

[jira] [Commented] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis

[ https://issues.apache.org/jira/browse/FLINK-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16570207#comment-16570207 ] Thomas Weise commented on FLINK-9691: - This was fixed, just the JIRA wasn't resolved. > Modify run

[jira] [Updated] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis

[ https://issues.apache.org/jira/browse/FLINK-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9691: Fix Version/s: (was: 1.5.3) 1.5.2 > Modify run loop in Kinesis

[jira] [Resolved] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis

[ https://issues.apache.org/jira/browse/FLINK-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-9691. - Resolution: Fixed > Modify run loop in Kinesis ShardConsumer to not sleep for a fixed >

[jira] [Updated] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis

[ https://issues.apache.org/jira/browse/FLINK-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9691: Fix Version/s: (was: 1.6.1) (was: 1.7.0) 1.6.0 >

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

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571634#comment-16571634 ] Thomas Weise commented on FLINK-10074: -- It could potentially also be specified as maximum time

[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] [Commented] (FLINK-10074) Allowable number of checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16570445#comment-16570445 ] Thomas Weise commented on FLINK-10074: --

[jira] [Commented] (FLINK-10217) use Slack for user support and questions

[ https://issues.apache.org/jira/browse/FLINK-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592615#comment-16592615 ] Thomas Weise commented on FLINK-10217: -- Slack was discussed as an option but there wasn't

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

[ https://issues.apache.org/jira/browse/FLINK-9926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9926: Description: There are various reasons why the user may want to override the consumer. Examples

[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] [Assigned] (FLINK-10279) Better clarification for status

[ https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-10279: Assignee: Thomas Weise > Better clarification for status >

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

[ https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16602886#comment-16602886 ] Thomas Weise commented on FLINK-10279: -- The implication isn't obvious and it can be misleading for

[jira] [Updated] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis

[ https://issues.apache.org/jira/browse/FLINK-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9691: Fix Version/s: 1.6.0 1.5.2 > Modify run loop in Kinesis ShardConsumer to not

[jira] [Commented] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis

[ https://issues.apache.org/jira/browse/FLINK-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540453#comment-16540453 ] Thomas Weise commented on FLINK-9691: - Should this be fixed in 1.4.x and 1.5.x also? > Modify run

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390365#comment-16390365 ] Thomas Weise commented on FLINK-5697: - For idleness detection see:

[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] [Commented] (FLINK-9188) Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-9188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16440391#comment-16440391 ] Thomas Weise commented on FLINK-9188: - [~tzulitai] this is how the proposed generic property support

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

[ https://issues.apache.org/jira/browse/FLINK-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9124: Component/s: Kinesis Connector > Allow customization of KinesisProxy.getRecords read timeout and

[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] [Comment Edited] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16379815#comment-16379815 ] Thomas Weise edited comment on FLINK-5697 at 2/28/18 5:52 AM: -- We have

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16379815#comment-16379815 ] Thomas Weise commented on FLINK-5697: - We have implemented periodic watermark support in a

[jira] [Assigned] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-5697: --- Assignee: Thomas Weise > Add per-shard watermarks for FlinkKinesisConsumer >

[jira] [Commented] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669566#comment-16669566 ] Thomas Weise commented on FLINK-5697: - The latest related discussion:

[jira] [Commented] (FLINK-9007) End-to-end test: Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683198#comment-16683198 ] Thomas Weise commented on FLINK-9007: - Discussion thread: 

[jira] [Assigned] (FLINK-9007) End-to-end test: Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-9007: --- Assignee: Thomas Weise > End-to-end test: Kinesis connector >

[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] [Commented] (FLINK-10912) Configurable RocksDBStateBackend options factory

[ https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689868#comment-16689868 ] Thomas Weise commented on FLINK-10912: -- ML discussion:

[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] [Resolved] (FLINK-11145) Fix Hadoop version handling in binary release script

[ https://issues.apache.org/jira/browse/FLINK-11145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-11145. -- Resolution: Fixed Fix Version/s: 1.7.2 1.8.0 > Fix Hadoop version

[jira] [Updated] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-10251: - Fix Version/s: (was: 1.5.6) > Handle oversized response messages in AkkaRpcActor >

[jira] [Updated] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

[ https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9253: Fix Version/s: (was: 1.5.6) > Make buffer count per InputGate always

[jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6

[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9010: Fix Version/s: (was: 1.5.6) > NoResourceAvailableException with FLIP-6 >

[jira] [Updated] (FLINK-11084) Incorrect ouput after two consecutive split and select

[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-11084: - Fix Version/s: (was: 1.5.6) > Incorrect ouput after two consecutive split and select >

[jira] [Updated] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod

[ https://issues.apache.org/jira/browse/FLINK-7582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-7582: Fix Version/s: (was: 1.5.6) > Rest client may buffer responses indefinitely under heavy laod >

[jira] [Updated] (FLINK-7351) test instability in JobClientActorRecoveryITCase#testJobClientRecovery

[ https://issues.apache.org/jira/browse/FLINK-7351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-7351: Fix Version/s: (was: 1.5.6) > test instability in

[jira] [Updated] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9630: Fix Version/s: (was: 1.5.6) > Kafka09PartitionDiscoverer cause connection leak on >

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9525: Fix Version/s: (was: 1.5.6) > Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs

[jira] [Updated] (FLINK-9360) HA end-to-end nightly test takes more than 15 min in Travis CI

[ https://issues.apache.org/jira/browse/FLINK-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9360: Fix Version/s: (was: 1.5.6) > HA end-to-end nightly test takes more than 15 min in Travis CI >

[jira] [Updated] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restore due to StateBackendTestBase class not register snapshots in some UTs

[ https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9328: Fix Version/s: (was: 1.5.6) > RocksDBStateBackend might use PlaceholderStreamStateHandle to

[jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations

[ https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9457: Fix Version/s: (was: 1.5.6) > Cancel container requests when cancelling pending slot

[jira] [Updated] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-10672: - Fix Version/s: (was: 1.5.6) > Task stuck while writing output to flink >

[jira] [Updated] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures

[ https://issues.apache.org/jira/browse/FLINK-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8803: Fix Version/s: (was: 1.5.6) > Mini Cluster Shutdown with HA unstable, causing test failures >

[jira] [Updated] (FLINK-8418) Kafka08ITCase.testStartFromLatestOffsets() times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8418: Fix Version/s: (was: 1.5.6) > Kafka08ITCase.testStartFromLatestOffsets() times out on Travis >

[jira] [Updated] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

[ https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8046: Fix Version/s: (was: 1.5.6) > ContinuousFileMonitoringFunction wrongly ignores files with

[jira] [Updated] (FLINK-8822) RotateLogFile may not work well when sed version is below 4.2

[ https://issues.apache.org/jira/browse/FLINK-8822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8822: Fix Version/s: (was: 1.5.6) > RotateLogFile may not work well when sed version is below 4.2 >

[jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8899: Fix Version/s: (was: 1.5.6) > Submitting YARN job with FLIP-6 may lead to >

[jira] [Updated] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9900: Fix Version/s: (was: 1.5.6) > Failed to testRestoreBehaviourWithFaultyStateHandles >

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-10241: - Fix Version/s: (was: 1.5.6) > Reduce performance/stability impact of latency metrics >

[jira] [Updated] (FLINK-8247) Support Hadoop-free variant of Flink on Mesos

[ https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8247: Fix Version/s: (was: 1.5.6) > Support Hadoop-free variant of Flink on Mesos >

[jira] [Updated] (FLINK-8724) Add BroadcastState examples with predetermined state transitions for the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-8724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8724: Fix Version/s: (was: 1.5.6) > Add BroadcastState examples with predetermined state transitions

[jira] [Updated] (FLINK-8410) Kafka consumer's commitedOffsets gauge metric is prematurely set

[ https://issues.apache.org/jira/browse/FLINK-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8410: Fix Version/s: (was: 1.5.6) > Kafka consumer's commitedOffsets gauge metric is prematurely set

[jira] [Updated] (FLINK-8722) Refactor BroadcastState examples.

[ https://issues.apache.org/jira/browse/FLINK-8722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8722: Fix Version/s: (was: 1.5.6) > Refactor BroadcastState examples. >

[jira] [Updated] (FLINK-9719) Mesos should use hostname as default jobmanager.rpc.address

[ https://issues.apache.org/jira/browse/FLINK-9719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9719: Fix Version/s: (was: 1.5.6) > Mesos should use hostname as default jobmanager.rpc.address >

[jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests

[ https://issues.apache.org/jira/browse/FLINK-9680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9680: Fix Version/s: (was: 1.5.6) > Reduce heartbeat timeout for E2E tests >

[jira] [Updated] (FLINK-11079) Update LICENSE and NOTICE files for flnk-storm-examples

[ https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-11079: - Fix Version/s: (was: 1.5.6) > Update LICENSE and NOTICE files for flnk-storm-examples >

[jira] [Updated] (FLINK-10317) Configure Metaspace size by default

[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-10317: - Fix Version/s: (was: 1.5.6) > Configure Metaspace size by default >

[jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-10435: - Fix Version/s: (was: 1.5.6) > Client sporadically hangs after Ctrl + C >

[jira] [Updated] (FLINK-8902) Re-scaling job sporadically fails with KeeperException

[ https://issues.apache.org/jira/browse/FLINK-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-8902: Fix Version/s: (was: 1.5.6) > Re-scaling job sporadically fails with KeeperException >

[jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures

[ https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9761: Fix Version/s: (was: 1.5.6) > Potential buffer leak in PartitionRequestClientHandler during

[jira] [Updated] (FLINK-9046) Improve error messages when receiving unexpected messages.

[ https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9046: Fix Version/s: (was: 1.5.6) > Improve error messages when receiving unexpected messages. >

[jira] [Updated] (FLINK-10368) 'Kerberized YARN on Docker test' unstable

[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-10368: - Fix Version/s: (was: 1.5.6) > 'Kerberized YARN on Docker test' unstable >

[jira] [Resolved] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-11048. -- Resolution: Fixed Fix Version/s: 1.8.0 > Ability to programmatically execute streaming

[jira] [Resolved] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

[ https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-4582. - Resolution: Fixed Fix Version/s: 1.8.0 > Allow FlinkKinesisConsumer to adapt for AWS

[jira] [Updated] (FLINK-7991) Cleanup kafka example jar filters

[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-7991: Fix Version/s: (was: 1.5.6) > Cleanup kafka example jar filters >

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706517#comment-16706517 ] Thomas Weise commented on FLINK-11048: -- Related: 

[jira] [Created] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

Thomas Weise created FLINK-11048: Summary: Ability to programmatically execute streaming pipeline with savepoint restore Key: FLINK-11048 URL: https://issues.apache.org/jira/browse/FLINK-11048

[jira] [Resolved] (FLINK-5697) Add per-shard watermarks for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-5697. - Resolution: Implemented Fix Version/s: 1.8.0 > Add per-shard watermarks for

[jira] [Updated] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-11501: - Fix Version/s: (was: 1.9.0) 1.8.0 > Add a ratelimiting feature to the

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776082#comment-16776082 ] Thomas Weise commented on FLINK-10887: -- There is a workaround available; I don't see it as pressing

[jira] [Resolved] (FLINK-11617) Kinesis Connector getRecords() failure logging is misleading

[ https://issues.apache.org/jira/browse/FLINK-11617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-11617. -- Resolution: Fixed Fix Version/s: 1.8.0 > Kinesis Connector getRecords() failure

[jira] [Commented] (FLINK-11617) Kinesis Connector getRecords() failure logging is misleading

[ https://issues.apache.org/jira/browse/FLINK-11617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782230#comment-16782230 ] Thomas Weise commented on FLINK-11617: -- 1.8:  704bc60bdb02681170a74ffcac72bfdab6658548 > Kinesis

[jira] [Resolved] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-11501. -- Resolution: Implemented Fix Version/s: 1.9.0 > Add a ratelimiting feature to the

[jira] [Commented] (FLINK-11826) Kafka09ITCase.testRateLimitedConsumer fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-11826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784686#comment-16784686 ] Thomas Weise commented on FLINK-11826: -- Should we mark the test ignored until flakiness is

[jira] [Commented] (FLINK-9007) End-to-end test: Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799206#comment-16799206 ] Thomas Weise commented on FLINK-9007: - 1.8.x: 11af4523801164539e186d836462f5884b561941   >

[jira] [Updated] (FLINK-9007) End-to-end test: Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9007: Fix Version/s: 1.8.1 > End-to-end test: Kinesis connector > -- > >

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770265#comment-16770265 ] Thomas Weise commented on FLINK-10887: -- For verification, I used a synthetic source with a timer

[jira] [Resolved] (FLINK-10887) Add source watermark tracking to the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-10887. -- Resolution: Implemented > Add source watermark tracking to the JobMaster >

[jira] [Resolved] (FLINK-10422) Follow AWS specs in Kinesis Consumer

[ https://issues.apache.org/jira/browse/FLINK-10422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-10422. -- Resolution: Fixed Fix Version/s: 1.8.0 > Follow AWS specs in Kinesis Consumer >

[jira] [Commented] (FLINK-11547) JsonMappingException in DynamoDBStreamsSchema

[ https://issues.apache.org/jira/browse/FLINK-11547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16764086#comment-16764086 ] Thomas Weise commented on FLINK-11547: -- [~tinder-dthomson] thanks for reporting the issue. Would

[jira] [Updated] (FLINK-10887) Add source watermark tracking to the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-10887: - Fix Version/s: 1.8.0 > Add source watermark tracking to the JobMaster >

[jira] [Commented] (FLINK-4582) Allow FlinkKinesisConsumer to adapt for AWS DynamoDB Streams

[ https://issues.apache.org/jira/browse/FLINK-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16760263#comment-16760263 ] Thomas Weise commented on FLINK-4582: - [~tinder-dthomson] Thanks for the report and yes, please track

[jira] [Resolved] (FLINK-9007) End-to-end test: Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-9007. - Resolution: Implemented Fix Version/s: 1.9.0 > End-to-end test: Kinesis connector >

  1   2   3   4   5   6   >