[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.1 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129656#comment-17129656 ] Aljoscha Krettek commented on FLINK-15362: -- I downgraded this to 2.4.1 for

[jira] [Updated] (FLINK-15362) Bump Kafka client version to 2.4.1 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15362: - Summary: Bump Kafka client version to 2.4.1 for universal Kafka connector (was: Bump

[jira] [Commented] (FLINK-18174) EventTimeWindowCheckpointingITCase crashes with exit code 127

[ https://issues.apache.org/jira/browse/FLINK-18174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129633#comment-17129633 ] Aljoscha Krettek commented on FLINK-18174: -- Probably, yes. But I didn&#

[jira] [Commented] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129632#comment-17129632 ] Aljoscha Krettek commented on FLINK-18091: -- I see, then this manual

[jira] [Comment Edited] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128272#comment-17128272 ] Aljoscha Krettek edited comment on FLINK-17327 at 6/9/20, 4:4

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129590#comment-17129590 ] Aljoscha Krettek commented on FLINK-17327: -- I was mixing up issues be

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129394#comment-17129394 ] Aljoscha Krettek commented on FLINK-13414: -- There are no concrete plans

[jira] [Updated] (FLINK-17982) Resolve TODO's in concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-17982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17982: - Summary: Resolve TODO's in concepts documentation (was: Remove TODO's from

[jira] [Closed] (FLINK-12587) Add pure-API Watermark class

[ https://issues.apache.org/jira/browse/FLINK-12587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12587. Resolution: Abandoned This has been implemented by now. > Add pure-API Watermark cl

[jira] [Closed] (FLINK-9058) Relax ListState.addAll() and ListState.update() to take Iterable

[ https://issues.apache.org/jira/browse/FLINK-9058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9058. --- Resolution: Abandoned > Relax ListState.addAll() and ListState.update() to take Itera

[jira] [Assigned] (FLINK-13062) Set ScheduleMode based on boundedness of streaming Pipeline

[ https://issues.apache.org/jira/browse/FLINK-13062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-13062: Assignee: (was: Aljoscha Krettek) > Set ScheduleMode based on boundedness

[jira] [Closed] (FLINK-15474) In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand"

[ https://issues.apache.org/jira/browse/FLINK-15474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15474. Fix Version/s: (was: 1.11.0) Resolution: Won't Do

[jira] [Assigned] (FLINK-12461) Flink 1.8 not working with Scala 2.12.8

[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-12461: Assignee: (was: Aljoscha Krettek) > Flink 1.8 not working with Scala 2.1

[jira] [Closed] (FLINK-17815) Change KafkaConnector to give per-partition metric group to WatermarkGenerator

[ https://issues.apache.org/jira/browse/FLINK-17815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17815. Resolution: Won't Fix I think it's ok as it is now. > Change KafkaConnecto

[jira] [Closed] (FLINK-17653) FLIP-126: Unify (and separate) Watermark Assigners

[ https://issues.apache.org/jira/browse/FLINK-17653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17653. Resolution: Fixed All subtasks have been resolved. > FLIP-126: Unify (and separ

[jira] [Reopened] (FLINK-16208) Add introduction to timely stream processing concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-16208: -- Assignee: Aljoscha Krettek (was: David Anderson) Re-opening: I will add a short

[jira] [Reopened] (FLINK-16209) Add Latency and Completeness section in timely stream processing concepts

[ https://issues.apache.org/jira/browse/FLINK-16209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-16209: -- Assignee: Aljoscha Krettek (was: David Anderson) Re-opening: I will add a short

[jira] [Assigned] (FLINK-16214) Describe how state is different for stream/batch programs in concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-16214: Assignee: Aljoscha Krettek > Describe how state is different for stream/ba

[jira] [Reopened] (FLINK-16213) Add "What Is State" section in concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-16213: -- Assignee: Aljoscha Krettek (was: David Anderson) Re-opening: I will add a short

[jira] [Commented] (FLINK-18209) Replace "charged" words in the Flink codebase.

[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129110#comment-17129110 ] Aljoscha Krettek commented on FLINK-18209: -- +1 > Replace "charg

[jira] [Updated] (FLINK-18174) EventTimeWindowCheckpointingITCase crashes with exit code 127

[ https://issues.apache.org/jira/browse/FLINK-18174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18174: - Component/s: (was: API / DataStream) > EventTimeWindowCheckpointingITCase cras

[jira] [Updated] (FLINK-18165) When savingpoint is restored, select the checkpoint directory and stateBackend

[ https://issues.apache.org/jira/browse/FLINK-18165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18165: - Component/s: Runtime / State Backends > When savingpoint is restored, select

[jira] [Updated] (FLINK-18128) CoordinatedSourceITCase.testMultipleSources gets stuck

[ https://issues.apache.org/jira/browse/FLINK-18128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18128: - Component/s: (was: API / DataStream) > CoordinatedSourceITCase.testMultipleSour

[jira] [Updated] (FLINK-18128) CoordinatedSourceITCase.testMultipleSources gets stuck

[ https://issues.apache.org/jira/browse/FLINK-18128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18128: - Component/s: Runtime / Task Runtime / Checkpointing

[jira] [Commented] (FLINK-18095) Custom Execution Environment for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-18095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129088#comment-17129088 ] Aljoscha Krettek commented on FLINK-18095: -- What is the use case for injec

[jira] [Commented] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129083#comment-17129083 ] Aljoscha Krettek commented on FLINK-18091: -- Shouldn't we have an

[jira] [Commented] (FLINK-18054) Environment should provide API to resume from savepoint

[ https://issues.apache.org/jira/browse/FLINK-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129076#comment-17129076 ] Aljoscha Krettek commented on FLINK-18054: -- I agree that this is a pro

[jira] [Updated] (FLINK-18054) Environment should provide API to resume from savepoint

[ https://issues.apache.org/jira/browse/FLINK-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18054: - Component/s: API / DataStream > Environment should provide API to resume from savepo

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128461#comment-17128461 ] Aljoscha Krettek commented on FLINK-17260: -- I pu

[jira] [Comment Edited] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128272#comment-17128272 ] Aljoscha Krettek edited comment on FLINK-17327 at 6/8/20, 1:5

[jira] [Updated] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17327: - Attachment: 0002-Don-t-abort-in-flight-transactions.patch 0001-Change

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128272#comment-17128272 ] Aljoscha Krettek commented on FLINK-17327: -- I managed to find a fix for

[jira] [Commented] (FLINK-16482) Flink Job throw CloseException when call the FlinkKafkaConsumer cancel function

[ https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128033#comment-17128033 ] Aljoscha Krettek commented on FLINK-16482: -- This is not related to FLINK-1

[jira] [Updated] (FLINK-17380) Kafka09ITCase.runAllDeletesTest: "Memory records is not writable"

[ https://issues.apache.org/jira/browse/FLINK-17380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17380: - Summary: Kafka09ITCase.runAllDeletesTest: "Memory records is not writable&qu

[jira] [Updated] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs

[ https://issues.apache.org/jira/browse/FLINK-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16768: - Issue Type: Bug (was: Task

[jira] [Closed] (FLINK-18020) SQLClientKafkaITCase.testKafka is flaky

[ https://issues.apache.org/jira/browse/FLINK-18020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18020. Resolution: Fixed master: - f6bbff40b8bbe6a932afc89039ed2712ecb80e47

[jira] [Closed] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17260. Resolution: Fixed master: - 455fb243486682fded9c136e4e2f4a8551d9a962

[jira] [Updated] (FLINK-18020) SQLClientKafkaITCase.testKafka is flaky

[ https://issues.apache.org/jira/browse/FLINK-18020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18020: - Summary: SQLClientKafkaITCase.testKafka is flaky (was: SQLClientKafkaITCase.testKafka

[jira] [Closed] (FLINK-18120) Don't expand documentation sections by default

[ https://issues.apache.org/jira/browse/FLINK-18120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18120. Fix Version/s: 1.11.0 Resolution: Fixed release-1.11

[jira] [Assigned] (FLINK-18020) SQLClientKafkaITCase.testKafka failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-18020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18020: Assignee: Aljoscha Krettek > SQLClientKafkaITCase.testKafka failed on Tra

[jira] [Updated] (FLINK-18075) Kafka connector does not call open method of (de)serialization schema

[ https://issues.apache.org/jira/browse/FLINK-18075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18075: - Issue Type: Bug (was: Improvement) > Kafka connector does not call open method of

[jira] [Updated] (FLINK-18073) AvroRowDataSerializationSchema is not always serializable

[ https://issues.apache.org/jira/browse/FLINK-18073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18073: - Issue Type: Bug (was: Improvement) > AvroRowDataSerializationSchema is not alw

[jira] [Created] (FLINK-18120) Don't expand documentation sections by default

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

[jira] [Commented] (FLINK-18116) E2E performance test

[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125663#comment-17125663 ] Aljoscha Krettek commented on FLINK-18116: -- Please use a meaningful I

[jira] [Commented] (FLINK-18115) StabilityTest

[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125662#comment-17125662 ] Aljoscha Krettek commented on FLINK-18115: -- Please use a meaningful I

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125629#comment-17125629 ] Aljoscha Krettek commented on FLINK-17260: -- I think this is two sepa

[jira] [Closed] (FLINK-18011) Make WatermarkStrategy/WatermarkStrategies more ergonomic

[ https://issues.apache.org/jira/browse/FLINK-18011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18011. Resolution: Fixed release-1.11: c0eb1e3ad3fceda61e470c584319bddccdf660dd master

[jira] [Closed] (FLINK-17376) Remove deprecated state access methods

[ https://issues.apache.org/jira/browse/FLINK-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17376. Resolution: Fixed release-1.11: 23f0e41604689d271d9e51298294244d7be86c36 > Rem

[jira] [Closed] (FLINK-18032) Remove outdated sections in migration guide

[ https://issues.apache.org/jira/browse/FLINK-18032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18032. Resolution: Fixed release-1.11: 5339a8137fb368789808b9e47a9f97896e89b255 > Rem

[jira] [Updated] (FLINK-11911) KafkaTopicPartition is not a valid POJO

[ https://issues.apache.org/jira/browse/FLINK-11911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11911: - Fix Version/s: (was: 1.10.2) (was: 1.11.0

[jira] [Closed] (FLINK-11911) KafkaTopicPartition is not a valid POJO

[ https://issues.apache.org/jira/browse/FLINK-11911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11911. Resolution: Won't Fix This is now mitigated by FLINK-15904. As others have said, I

[jira] [Commented] (FLINK-18032) Remove outdated sections in migration guide

[ https://issues.apache.org/jira/browse/FLINK-18032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124939#comment-17124939 ] Aljoscha Krettek commented on FLINK-18032: -- ma

[jira] [Commented] (FLINK-17376) Remove deprecated state access methods

[ https://issues.apache.org/jira/browse/FLINK-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124938#comment-17124938 ] Aljoscha Krettek commented on FLINK-17376: -- ma

[jira] [Updated] (FLINK-18032) Remove outdated sections in migration guide

[ https://issues.apache.org/jira/browse/FLINK-18032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18032: - Fix Version/s: 1.11.0 > Remove outdated sections in migration gu

[jira] [Commented] (FLINK-17961) Create an Elasticsearch source

[ https://issues.apache.org/jira/browse/FLINK-17961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124918#comment-17124918 ] Aljoscha Krettek commented on FLINK-17961: -- I think that's a good id

[jira] [Updated] (FLINK-18021) [Umbrella] Manually tests for 1.11 SQL features

[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18021: - Labels: release-testing (was: ) > [Umbrella] Manually tests for 1.11 SQL featu

[jira] [Commented] (FLINK-18036) Chinese documentation build is broken

[ https://issues.apache.org/jira/browse/FLINK-18036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119714#comment-17119714 ] Aljoscha Krettek commented on FLINK-18036: -- Yes, that's the s

[jira] [Updated] (FLINK-18036) Chinese documentation build is broken

[ https://issues.apache.org/jira/browse/FLINK-18036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18036: - Description: Log from one of the builders: https://ci.apache.org/builders/flink-docs

[jira] [Created] (FLINK-18036) Chinese documentation build is broken

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

[jira] [Updated] (FLINK-18036) Chinese documentation build is broken

[ https://issues.apache.org/jira/browse/FLINK-18036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18036: - Issue Type: Bug (was: Task) > Chinese documentation build is bro

[jira] [Commented] (FLINK-18017) have Kafka connector report metrics on null records

[ https://issues.apache.org/jira/browse/FLINK-18017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119435#comment-17119435 ] Aljoscha Krettek commented on FLINK-18017: -- The deserialization schemas

[jira] [Assigned] (FLINK-18032) Remove outdated sections in migration guide

[ https://issues.apache.org/jira/browse/FLINK-18032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18032: Assignee: Aljoscha Krettek > Remove outdated sections in migration gu

[jira] [Created] (FLINK-18032) Remove outdated sections in migration guide

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

[jira] [Assigned] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-16198: Assignee: Zhe Yu > FileUtilsTest fails on Mac

[jira] [Commented] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119391#comment-17119391 ] Aljoscha Krettek commented on FLINK-16198: -- I think we can keep only this

[jira] [Commented] (FLINK-17961) Create an Elasticsearch source

[ https://issues.apache.org/jira/browse/FLINK-17961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118872#comment-17118872 ] Aljoscha Krettek commented on FLINK-17961: -- I think this one is tricky

[jira] [Updated] (FLINK-17987) KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error reading field

[ https://issues.apache.org/jira/browse/FLINK-17987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17987: - Labels: test-stability (was: ) > KafkaITCase.testStartFromGroupOffsets fails w

[jira] [Closed] (FLINK-17956) Add Flink 1.11 MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-17956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17956. Resolution: Fixed master: c03fb573f4258d38fc4c5931afffc6bf6516b2be release-1.11

[jira] [Updated] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17949: - Affects Version/s: 1.11.0 > KafkaShuffleITCase.testSerDeIngestionTime:

[jira] [Commented] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118839#comment-17118839 ] Aljoscha Krettek commented on FLINK-17949: -- If this happens on master it

[jira] [Commented] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118838#comment-17118838 ] Aljoscha Krettek commented on FLINK-16198: -- The test was only recentl

[jira] [Updated] (FLINK-17944) Wrong output in sql client's table mode

[ https://issues.apache.org/jira/browse/FLINK-17944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17944: - Priority: Blocker (was: Major) > Wrong output in sql client's ta

[jira] [Created] (FLINK-18011) Make WatermarkStrategy/WatermarkStrategies more ergonomic

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

[jira] [Commented] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118620#comment-17118620 ] Aljoscha Krettek commented on FLINK-16198: -- I have downgraded to major s

[jira] [Updated] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16198: - Fix Version/s: (was: 1.11.0) > FileUtilsTest fails on Mac

[jira] [Updated] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16198: - Priority: Major (was: Blocker) > FileUtilsTest fails on Mac

[jira] [Updated] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16198: - Affects Version/s: (was: 1.11.0) > FileUtilsTest fails on Mac

[jira] [Closed] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-13632. Resolution: Fixed > Port serializer upgrade tests to TypeSerializerUpgradeTestB

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118607#comment-17118607 ] Aljoscha Krettek commented on FLINK-13632: -- For future reference, I thin

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118604#comment-17118604 ] Aljoscha Krettek commented on FLINK-13632: -- Implemented on mast

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118585#comment-17118585 ] Aljoscha Krettek commented on FLINK-13632: -- Implemented on release-1.1

[jira] [Updated] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13632: - Fix Version/s: (was: 1.10.2) > Port serializer upgrade tests

[jira] [Updated] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13632: - Affects Version/s: (was: 1.10.0) > Port serializer upgrade tests

[jira] [Commented] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117961#comment-17117961 ] Aljoscha Krettek commented on FLINK-16198: -- Something seems to be wrong

[jira] [Closed] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17058. Fix Version/s: 1.12.0 Resolution: Fixed master

[jira] [Created] (FLINK-17956) Add Flink 1.11 MigrationVersion

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

[jira] [Updated] (FLINK-11767) Introduce new TypeSerializerUpgradeTestBase, new PojoSerializerUpgradeTest

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11767: - Fix Version/s: (was: 1.9.3) (was: 1.10.0

[jira] [Closed] (FLINK-17721) AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fails with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17721. Resolution: Fixed release-1.11: 6215e1166aa44ce178ae8c068159eb7efeb53041 master

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

[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115924#comment-17115924 ] Aljoscha Krettek commented on FLINK-12675: -- Sorry for chiming in this late

[jira] [Updated] (FLINK-10740) FLIP-27: Refactor Source Interface

[ https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10740: - Summary: FLIP-27: Refactor Source Interface (was: Refactor Source Interface) > F

[jira] [Closed] (FLINK-17862) The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-17862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17862. Resolution: Not A Problem > The internal class StreamingRuntimeContext is leaked

[jira] [Assigned] (FLINK-17886) Update Chinese documentation for new WatermarkGenerator/WatermarkStrategies

[ https://issues.apache.org/jira/browse/FLINK-17886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17886: Assignee: Yichao Yang > Update Chinese documentation for new WatermarkGenera

[jira] [Updated] (FLINK-17918) Jobs with two input operators are loosing data with unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17918: - Priority: Blocker (was: Critical) > Jobs with two input operators are loosing d

[jira] [Closed] (FLINK-16210) Add section about applications and clusters/session in concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-16210. Fix Version/s: 1.11.0 Resolution: Fixed release-1.11

[jira] [Closed] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

[ https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5479. --- Fix Version/s: 1.11.0 Assignee: Aljoscha Krettek Resolution: Fixed This is

[jira] [Commented] (FLINK-17897) Resolve stability annotations discussion for FLIP-27 in 1.11

[ https://issues.apache.org/jira/browse/FLINK-17897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115817#comment-17115817 ] Aljoscha Krettek commented on FLINK-17897: -- I would downgrade tha

[jira] [Commented] (FLINK-17898) Remove Exceptions from signatures of SourceOutput methods

[ https://issues.apache.org/jira/browse/FLINK-17898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115818#comment-17115818 ] Aljoscha Krettek commented on FLINK-17898: -- I would be in factor of unche

[jira] [Updated] (FLINK-17886) Update Chinese documentation for new WatermarkGenerator/WatermarkStrategies

[ https://issues.apache.org/jira/browse/FLINK-17886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17886: - Summary: Update Chinese documentation for new WatermarkGenerator/WatermarkStrategies

[jira] [Updated] (FLINK-17886) Update Chinese documentation for new WatermarkGenerator/WatermarkStrategies

[ https://issues.apache.org/jira/browse/FLINK-17886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17886: - Issue Type: Task (was: Bug) > Update Chinese documentation for new WatermarkGenera

[jira] [Created] (FLINK-17886) Update documentation for new WatermarkGenerator/WatermarkStrategies

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

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