[jira] [Assigned] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21104: --- Assignee: Arvid Heise > UnalignedCheckpointITCase.execute failed with

[jira] [Commented] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271313#comment-17271313 ] Arvid Heise commented on FLINK-21104: - Merged as 1257d15fb362442dfbb39cf681161beb92b20a88 into

[jira] [Resolved] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21104. - Resolution: Fixed > UnalignedCheckpointITCase.execute failed with "IllegalStateException" >

[jira] [Updated] (FLINK-20955) Refactor HBase Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20955: Fix Version/s: (was: 1.12.0) 1.13.0 > Refactor HBase Source in accordance

[jira] [Assigned] (FLINK-20955) Refactor HBase Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20955: --- Assignee: Moritz Manner > Refactor HBase Source in accordance with FLIP-27 >

[jira] [Commented] (FLINK-21213) Elasticsearch (v5.3.3) sink end-to-end test' failed

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276306#comment-17276306 ] Arvid Heise commented on FLINK-21213: - The sanity check at the end of the e2e fails as the log

[jira] [Assigned] (FLINK-21213) Elasticsearch (v5.3.3) sink end-to-end test' failed

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21213: --- Assignee: Arvid Heise > Elasticsearch (v5.3.3) sink end-to-end test' failed >

[jira] [Assigned] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21213: --- Assignee: Yun Tang (was: Arvid Heise) > e2e test fail with 'As task is already not

[jira] [Commented] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276365#comment-17276365 ] Arvid Heise commented on FLINK-21213: - This issue is caused by a new warning added in FLINK-20675.

[jira] [Updated] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21213: Summary: e2e test fail with 'As task is already not running, no longer decline checkpoint' (was:

[jira] [Commented] (FLINK-21175) OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but was:<-9223372036854775808>

[ https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278670#comment-17278670 ] Arvid Heise commented on FLINK-21175: - I will check how easy it is to backport it. If it turns out

[jira] [Commented] (FLINK-21217) Resuming Savepoint (rocks, scale up, rocks timers) end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-21217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278681#comment-17278681 ] Arvid Heise commented on FLINK-21217: - Extracted exceptions   {noformat} 2021-01-29 15:20:41,001

[jira] [Assigned] (FLINK-21175) OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but was:<-9223372036854775808>

[ https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21175: --- Assignee: Arvid Heise > OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but

[jira] [Resolved] (FLINK-21175) OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but was:<-9223372036854775808>

[ https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21175. - Resolution: Resolved > OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but >

[jira] [Commented] (FLINK-21175) OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but was:<-9223372036854775808>

[ https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278850#comment-17278850 ] Arvid Heise commented on FLINK-21175: - Backported into releases-1.11 as

[jira] [Closed] (FLINK-21175) OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but was:<-9223372036854775808>

[ https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-21175. --- > OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but > was:<-9223372036854775808> >

[jira] [Created] (FLINK-21181) Buffer pool is destroyed error when outputting data over a timer after cancellation.

Arvid Heise created FLINK-21181: --- Summary: Buffer pool is destroyed error when outputting data over a timer after cancellation. Key: FLINK-21181 URL: https://issues.apache.org/jira/browse/FLINK-21181

[jira] [Created] (FLINK-21186) RecordWriterOutput swallows interrupt state when interrupted.

Arvid Heise created FLINK-21186: --- Summary: RecordWriterOutput swallows interrupt state when interrupted. Key: FLINK-21186 URL: https://issues.apache.org/jira/browse/FLINK-21186 Project: Flink

[jira] [Commented] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277092#comment-17277092 ] Arvid Heise commented on FLINK-21213: - On INFO, it probably still triggers e2e failure, cf.

[jira] [Commented] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

[ https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363389#comment-17363389 ] Arvid Heise commented on FLINK-21389: - Merged into 1.13 as 4780b5d98e53c7a1cbabf2092b38d4e84fed3b32.

[jira] [Closed] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

[ https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-21389. --- Fix Version/s: 1.13.2 Resolution: Resolved > ParquetInputFormat should not need parquet

[jira] [Commented] (FLINK-22830) DataSet API to allow to collect and do the bulk upload in DB

[ https://issues.apache.org/jira/browse/FLINK-22830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358565#comment-17358565 ] Arvid Heise commented on FLINK-22830: - I'm responding on stackoverflow. Such question are best asked

[jira] [Closed] (FLINK-22830) DataSet API to allow to collect and do the bulk upload in DB

[ https://issues.apache.org/jira/browse/FLINK-22830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-22830. --- Resolution: Not A Problem > DataSet API to allow to collect and do the bulk upload in DB >

[jira] [Created] (FLINK-22902) Port KafkaSink to FLIP-143

Arvid Heise created FLINK-22902: --- Summary: Port KafkaSink to FLIP-143 Key: FLINK-22902 URL: https://issues.apache.org/jira/browse/FLINK-22902 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-22608) Flink Kryo deserialize read wrong bytes

[ https://issues.apache.org/jira/browse/FLINK-22608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-22608. --- Resolution: Invalid Hi [~Autumn], Please check [Supported data types for schema

[jira] [Closed] (FLINK-22876) Adding SharedObjects junit rule to ease test development

[ https://issues.apache.org/jira/browse/FLINK-22876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-22876. --- Resolution: Fixed > Adding SharedObjects junit rule to ease test development >

[jira] [Updated] (FLINK-22964) Connector-base exposes dependency to flink-core.

[ https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22964: Labels: classloading (was: ) > Connector-base exposes dependency to flink-core. >

[jira] [Updated] (FLINK-22964) Connector-base exposes dependency to flink-core.

[ https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22964: Component/s: Connectors / Common > Connector-base exposes dependency to flink-core. >

[jira] [Updated] (FLINK-22964) Connector-base exposes dependency to flink-core.

[ https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22964: Description: Connectors get shaded into the user jar and as such should contain no unnecessary

[jira] [Created] (FLINK-22964) Connector-base exposes dependency to flink-core.

Arvid Heise created FLINK-22964: --- Summary: Connector-base exposes dependency to flink-core. Key: FLINK-22964 URL: https://issues.apache.org/jira/browse/FLINK-22964 Project: Flink Issue Type:

[jira] [Created] (FLINK-23024) RPC result TaskManagerInfoWithSlots not serializable

Arvid Heise created FLINK-23024: --- Summary: RPC result TaskManagerInfoWithSlots not serializable Key: FLINK-23024 URL: https://issues.apache.org/jira/browse/FLINK-23024 Project: Flink Issue

[jira] [Commented] (FLINK-23024) RPC result TaskManagerInfoWithSlots not serializable

[ https://issues.apache.org/jira/browse/FLINK-23024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364965#comment-17364965 ] Arvid Heise commented on FLINK-23024: - CC [~karmagyz] > RPC result TaskManagerInfoWithSlots not

[jira] [Assigned] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close()

[ https://issues.apache.org/jira/browse/FLINK-20888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20888: --- Assignee: Arvid Heise > ContinuousFileReaderOperator should not close the output on

[jira] [Comment Edited] (FLINK-23022) Plugin classloader settings do not work as described

[ https://issues.apache.org/jira/browse/FLINK-23022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368252#comment-17368252 ] Arvid Heise edited comment on FLINK-23022 at 6/23/21, 2:52 PM: --- Imho is

[jira] [Commented] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368244#comment-17368244 ] Arvid Heise commented on FLINK-23011: - Re 1b) I agree that we already have it for static

[jira] [Comment Edited] (FLINK-23022) Plugin classloader settings do not work as described

[ https://issues.apache.org/jira/browse/FLINK-23022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368252#comment-17368252 ] Arvid Heise edited comment on FLINK-23022 at 6/23/21, 2:51 PM: --- Imho is

[jira] [Commented] (FLINK-23022) Plugin classloader settings do not work as described

[ https://issues.apache.org/jira/browse/FLINK-23022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368252#comment-17368252 ] Arvid Heise commented on FLINK-23022: - Imho is the ticket correct and we should fix documentation or

[jira] [Commented] (FLINK-23022) Plugin classloader settings do not work as described

[ https://issues.apache.org/jira/browse/FLINK-23022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368278#comment-17368278 ] Arvid Heise commented on FLINK-23022: - Sorry you are right, it definitively loads from flink cl

[jira] [Commented] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368014#comment-17368014 ] Arvid Heise commented on FLINK-23011: - Thanks for sharing your thoughts. I agree with 1(a) but I'm

[jira] [Resolved] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22698. - Fix Version/s: 1.13.2 1.12.5 1.14.0 Resolution:

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367250#comment-17367250 ] Arvid Heise commented on FLINK-22698: - Merged into master as

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369251#comment-17369251 ] Arvid Heise commented on FLINK-23147: - Hi Chesnay, I'm lacking a bit of knowledge to contribute to

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369374#comment-17369374 ] Arvid Heise commented on FLINK-23147: - > ehhh; a plugin interface with this signature

[jira] [Comment Edited] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369374#comment-17369374 ] Arvid Heise edited comment on FLINK-23147 at 6/25/21, 10:15 AM: >

[jira] [Commented] (FLINK-22257) Clarify Flink ConfigOptions Usage

[ https://issues.apache.org/jira/browse/FLINK-22257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369320#comment-17369320 ] Arvid Heise commented on FLINK-22257: - :+1: to Robert's idea. Could some config have more than one

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369348#comment-17369348 ] Arvid Heise commented on FLINK-23147: - Just to repeat what I have stated at other places: the intent

[jira] [Commented] (FLINK-22876) Adding SharedObjects junit rule to ease test development

[ https://issues.apache.org/jira/browse/FLINK-22876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359288#comment-17359288 ] Arvid Heise commented on FLINK-22876: - Merged into master as

[jira] [Assigned] (FLINK-22792) Limit size of already processed files in File Source SplitEnumerator

[ https://issues.apache.org/jira/browse/FLINK-22792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22792: --- Assignee: Tianxin Zhao > Limit size of already processed files in File Source

[jira] [Updated] (FLINK-22682) Checkpoint interval too large for higher DOP

[ https://issues.apache.org/jira/browse/FLINK-22682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22682: Description: When running a job on EMR with DOP of 160, checkpoints are not triggered at the set

[jira] [Created] (FLINK-22682) Checkpoint interval too large for higher DOP

Arvid Heise created FLINK-22682: --- Summary: Checkpoint interval too large for higher DOP Key: FLINK-22682 URL: https://issues.apache.org/jira/browse/FLINK-22682 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341570#comment-17341570 ] Arvid Heise commented on FLINK-17170: - Merged into master as

[jira] [Resolved] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-17170. - Fix Version/s: 1.12.4 1.13.1 1.14.0 Resolution:

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20431: Fix Version/s: (was: 1.12.4) 1.12.5 >

[jira] [Updated] (FLINK-19743) Add Source metrics definitions

[ https://issues.apache.org/jira/browse/FLINK-19743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19743: Fix Version/s: (was: 1.12.4) 1.12.5 > Add Source metrics definitions >

[jira] [Updated] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20777: Fix Version/s: (was: 1.12.4) 1.12.5 > Default value of property

[jira] [Updated] (FLINK-20114) Fix a few KafkaSource-related bugs

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20114: Summary: Fix a few KafkaSource-related bugs (was: Test Kafka Source based on the new Source API 

[jira] [Updated] (FLINK-20114) Fix a few KafkaSource-related bugs

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20114: Parent: (was: FLINK-20112) Issue Type: Bug (was: Sub-task) > Fix a few

[jira] [Updated] (FLINK-20379) Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20379: Fix Version/s: (was: 1.12.4) 1.12.5 > Update

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20576: Fix Version/s: (was: 1.12.4) 1.12.5 > Flink Temporal Join Hive Dim Error >

[jira] [Updated] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19925: Fix Version/s: (was: 1.12.4) 1.12.5 > Errors$NativeIoException:

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22282: Fix Version/s: (was: 1.12.4) 1.12.5 > Move creation of SplitEnumerator to

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20656: Fix Version/s: (was: 1.12.4) 1.12.5 > Update docs for new KafkaSource

[jira] [Updated] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20849: Fix Version/s: (was: 1.12.4) 1.12.5 > Improve JavaDoc and logging of new

[jira] [Updated] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21445: Fix Version/s: (was: 1.12.4) 1.12.5 > Application mode does not set the

[jira] [Updated] (FLINK-21589) Document Table/SQL API limitations regarding upgrades with savepoints

[ https://issues.apache.org/jira/browse/FLINK-21589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21589: Fix Version/s: (was: 1.12.4) 1.12.5 > Document Table/SQL API limitations

[jira] [Updated] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20655: Fix Version/s: (was: 1.12.4) 1.12.5 > Add E2E tests to the new KafkaSource

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20457: Fix Version/s: (was: 1.12.4) 1.12.5 > Fix the handling of timestamp in

[jira] [Updated] (FLINK-22494) Avoid discarding checkpoints in case of failure

[ https://issues.apache.org/jira/browse/FLINK-22494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22494: Fix Version/s: (was: 1.12.4) 1.12.5 > Avoid discarding checkpoints in case

[jira] [Updated] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

[ https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22040: Fix Version/s: (was: 1.12.4) 1.12.5 > Maven: Entry has not been leased

[jira] [Updated] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store

[ https://issues.apache.org/jira/browse/FLINK-22434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22434: Fix Version/s: (was: 1.12.4) 1.12.5 > Dispatcher does not store suspended

[jira] [Updated] (FLINK-22564) Kubernetes-related ITCases do not fail even in case of failure

[ https://issues.apache.org/jira/browse/FLINK-22564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22564: Fix Version/s: (was: 1.12.4) 1.12.5 > Kubernetes-related ITCases do not

[jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message

[ https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20687: Fix Version/s: (was: 1.12.4) 1.12.5 > Missing 'yarn-application' target in

[jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21711: Fix Version/s: (was: 1.12.4) 1.12.5 > DataStreamSink doesn't allow setting

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21876: Fix Version/s: (was: 1.12.4) 1.12.5 > Handle it properly when the returned

[jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync

[ https://issues.apache.org/jira/browse/FLINK-21693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21693: Fix Version/s: (was: 1.12.4) 1.12.5 > TestStreamEnvironment does not

[jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22479: Fix Version/s: 1.13.1 > [Kinesis][Consumer] Potential lock-up under error condition >

[jira] [Resolved] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22479. - Resolution: Fixed > [Kinesis][Consumer] Potential lock-up under error condition >

[jira] [Updated] (FLINK-22502) DefaultCompletedCheckpointStore drops unrecoverable checkpoints silently

[ https://issues.apache.org/jira/browse/FLINK-22502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22502: Fix Version/s: (was: 1.12.4) 1.12.5 > DefaultCompletedCheckpointStore

[jira] [Updated] (FLINK-18952) Add 10 minutes to DataStream API documentation

[ https://issues.apache.org/jira/browse/FLINK-18952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18952: Parent: (was: FLINK-18761) Issue Type: Improvement (was: Sub-task) > Add 10 minutes

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340890#comment-17340890 ] Arvid Heise commented on FLINK-17170: - Merged into 1.13 as

[jira] [Commented] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339861#comment-17339861 ] Arvid Heise commented on FLINK-22573: - Merged the fix into master as

[jira] [Commented] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340014#comment-17340014 ] Arvid Heise commented on FLINK-22573: - Merged into 1.12 as 41dc5871d76e913bad9be59d65e2bb26d67fec15

[jira] [Updated] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22573: Fix Version/s: 1.12.4 1.13.1 1.14.0 > AsyncIO can timeout

[jira] [Resolved] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22573. - Resolution: Fixed > AsyncIO can timeout elements after completion >

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340239#comment-17340239 ] Arvid Heise commented on FLINK-17170: - Merged into 1.12 as 1de3d6345a4132dda4b31f66275fb732afe3ef30.

[jira] [Commented] (FLINK-22566) Running Kerberized YARN application on Docker test (default input) fails with no resources

[ https://issues.apache.org/jira/browse/FLINK-22566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340237#comment-17340237 ] Arvid Heise commented on FLINK-22566: - I disabled the tests in 1.12 with

[jira] [Created] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

Arvid Heise created FLINK-22686: --- Summary: Incompatible subtask mappings while resuming from unaligned checkpoints Key: FLINK-22686 URL: https://issues.apache.org/jira/browse/FLINK-22686 Project: Flink

[jira] [Updated] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22686: Fix Version/s: 1.13.1 > Incompatible subtask mappings while resuming from unaligned checkpoints >

[jira] [Resolved] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22613. - Resolution: Resolved > FlinkKinesisITCase.testStopWithSavepoint fails >

[jira] [Updated] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22613: Fix Version/s: 1.13.2 1.12.5 1.14.0 >

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351836#comment-17351836 ] Arvid Heise commented on FLINK-22613: - Merged into master as

[jira] [Assigned] (FLINK-21393) Implement ParquetAvroInputFormat

[ https://issues.apache.org/jira/browse/FLINK-21393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21393: --- Assignee: Etienne Chauchot > Implement ParquetAvroInputFormat >

[jira] [Resolved] (FLINK-21393) Implement ParquetAvroInputFormat

[ https://issues.apache.org/jira/browse/FLINK-21393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21393. - Fix Version/s: (was: 1.14.0) 1.13.2 Resolution: Fixed > Implement

[jira] [Created] (FLINK-22828) Allow using a custom AWS credentials provider for the Kinesis Connector

Arvid Heise created FLINK-22828: --- Summary: Allow using a custom AWS credentials provider for the Kinesis Connector Key: FLINK-22828 URL: https://issues.apache.org/jira/browse/FLINK-22828 Project: Flink

[jira] [Assigned] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22613: --- Assignee: Arvid Heise > FlinkKinesisITCase.testStopWithSavepoint fails >

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349810#comment-17349810 ] Arvid Heise commented on FLINK-22613: - I'll take a look. > FlinkKinesisITCase.testStopWithSavepoint

[jira] [Created] (FLINK-22876) Adding SharedObjects junit rule to ease test development

Arvid Heise created FLINK-22876: --- Summary: Adding SharedObjects junit rule to ease test development Key: FLINK-22876 URL: https://issues.apache.org/jira/browse/FLINK-22876 Project: Flink Issue

[jira] [Updated] (FLINK-22876) Adding SharedObjects junit rule to ease test development

[ https://issues.apache.org/jira/browse/FLINK-22876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22876: Description: Most test rely on static variables to sync between test code and UDFs to avoid

[jira] [Commented] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368643#comment-17368643 ] Arvid Heise commented on FLINK-23011: - I think we a have a large agreement here. I'd open a FLIP but

[jira] [Updated] (FLINK-23127) Can't use plugins for GCS filesystem

[ https://issues.apache.org/jira/browse/FLINK-23127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23127: Component/s: FileSystems > Can't use plugins for GCS filesystem >

<    1   2   3   4   5   6   7   8   9   10   >