[jira] [Created] (FLINK-21505) Enforce common savepoint format at the operator level

Aljoscha Krettek created FLINK-21505: Summary: Enforce common savepoint format at the operator level Key: FLINK-21505 URL: https://issues.apache.org/jira/browse/FLINK-21505 Project: Flink

[jira] [Assigned] (FLINK-20976) Unify Binary format for Keyed State savepoints

[ https://issues.apache.org/jira/browse/FLINK-20976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20976: Assignee: Dawid Wysakowicz > Unify Binary format for Keyed State savepoints >

[jira] [Commented] (FLINK-20918) Avoid excessive flush of Hadoop output stream

[ https://issues.apache.org/jira/browse/FLINK-20918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278767#comment-17278767 ] Aljoscha Krettek commented on FLINK-20918: -- Is there an observed real-world impact of this? I

[jira] [Closed] (FLINK-21151) Extract common full-snapshot writer from RocksDB full-snapshot strategy

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

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17274459#comment-17274459 ] Aljoscha Krettek commented on FLINK-21132: -- I'll try and expand on what I wrote earlier. The

[jira] [Closed] (FLINK-12461) Document binary compatibility situation with Scala beyond 2.12.8

[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12461. Resolution: Workaround The workaround is compiling manually for the specific Scala

[jira] [Assigned] (FLINK-12461) Document binary compatibility situation with Scala beyond 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: Aljoscha Krettek > Document binary compatibility situation with Scala

[jira] [Updated] (FLINK-12461) Document binary compatibility situation with Scala beyond 2.12.8

[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-12461: - Summary: Document binary compatibility situation with Scala beyond 2.12.8 (was: Flink

[jira] [Updated] (FLINK-12461) Document binary compatibility situation with Scala beyond 2.12.8

[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-12461: - Fix Version/s: 1.12.2 1.13.0 > Document binary compatibility

[jira] [Commented] (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:comment-tabpanel=17273629#comment-17273629 ] Aljoscha Krettek commented on FLINK-12461: -- I added an explanation of the situation to the

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272921#comment-17272921 ] Aljoscha Krettek commented on FLINK-21132: -- It seems to me we just need to make sure that 

[jira] [Commented] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272732#comment-17272732 ] Aljoscha Krettek commented on FLINK-21106: -- Agreed! > google-java-format Intellij Plugin

[jira] [Commented] (FLINK-21153) yarn-per-job deployment target ignores yarn options

[ https://issues.apache.org/jira/browse/FLINK-21153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272731#comment-17272731 ] Aljoscha Krettek commented on FLINK-21153: -- I agree with [~fly_in_gis], the behaviour of the

[jira] [Created] (FLINK-21151) Extract common full-snapshot writer from RocksDB full-snapshot strategy

Aljoscha Krettek created FLINK-21151: Summary: Extract common full-snapshot writer from RocksDB full-snapshot strategy Key: FLINK-21151 URL: https://issues.apache.org/jira/browse/FLINK-21151

[jira] [Commented] (FLINK-21106) google-java-format Intellij Plugin 1.7.0.5 causes UnsupportedOperationException in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271520#comment-17271520 ] Aljoscha Krettek commented on FLINK-21106: -- Side note: I'm just using the most recent IntelliJ

[jira] [Updated] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-21133: - Component/s: Runtime / Checkpointing > FLIP-27 Source does not work with synchronous

[jira] [Updated] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-21133: - Component/s: API / Core > FLIP-27 Source does not work with synchronous savepoint >

[jira] [Commented] (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:comment-tabpanel=17270046#comment-17270046 ] Aljoscha Krettek commented on FLINK-12461: -- This should be related to my first comment. The

[jira] [Updated] (FLINK-21060) Could not create the DispatcherResourceManagerComponent

[ https://issues.apache.org/jira/browse/FLINK-21060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-21060: - Component/s: (was: API / Core) Table SQL / Ecosystem > Could not

[jira] [Commented] (FLINK-20517) Support mixed keyed/non-keyed operations in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267327#comment-17267327 ] Aljoscha Krettek commented on FLINK-20517: -- release-1.12:

[jira] [Updated] (FLINK-20517) Support mixed keyed/non-keyed operations in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20517: - Fix Version/s: 1.12.2 > Support mixed keyed/non-keyed operations in BATCH execution

[jira] [Updated] (FLINK-20491) Support Broadcast Operation in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20491: - Fix Version/s: 1.12.2 > Support Broadcast Operation in BATCH execution mode >

[jira] [Commented] (FLINK-20491) Support Broadcast Operation in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267326#comment-17267326 ] Aljoscha Krettek commented on FLINK-20491: -- release-1.12:

[jira] [Commented] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing

[ https://issues.apache.org/jira/browse/FLINK-17011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265875#comment-17265875 ] Aljoscha Krettek commented on FLINK-17011: -- I think introducing a builder pattern here is good.

[jira] [Commented] (FLINK-20969) Update Scala 2.12 version to 2.12.13

[ https://issues.apache.org/jira/browse/FLINK-20969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264743#comment-17264743 ] Aljoscha Krettek commented on FLINK-20969: -- [~eloisant] Please continue on FLINK-12461. This

[jira] [Updated] (FLINK-20959) How to close Apache Flink REST API

[ https://issues.apache.org/jira/browse/FLINK-20959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20959: - Component/s: (was: API / Core) Runtime / REST > How to close

[jira] [Commented] (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:comment-tabpanel=17260480#comment-17260480 ] Aljoscha Krettek commented on FLINK-20888: -- Nice debugging! I think that in general operators

[jira] [Closed] (FLINK-20491) Support Broadcast Operation in BATCH execution mode

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

[jira] [Closed] (FLINK-20517) Support mixed keyed/non-keyed operations in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20517. Fix Version/s: (was: 1.12.1) 1.13.0 Resolution: Implemented

[jira] [Commented] (FLINK-20870) FlinkKafkaSink

[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260342#comment-17260342 ] Aljoscha Krettek commented on FLINK-20870: -- Could you maybe show the program code you're using?

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

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

[jira] [Commented] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17259803#comment-17259803 ] Aljoscha Krettek commented on FLINK-19589: -- I don't really have an opinion on this. As long as

[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=17259550#comment-17259550 ] Aljoscha Krettek commented on FLINK-13414: -- For sure, banning our internal Scala use into its

[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=17258789#comment-17258789 ] Aljoscha Krettek commented on FLINK-13414: -- [~NickBurkard] or [~bobanahalf]: if you're keen you

[jira] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258785#comment-17258785 ] Aljoscha Krettek commented on FLINK-20309: -- Another one:

[jira] [Assigned] (FLINK-20845) Drop support for Scala 2.11

[ https://issues.apache.org/jira/browse/FLINK-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20845: Assignee: Nick Burkard > Drop support for Scala 2.11 >

[jira] [Assigned] (FLINK-20517) Support mixed keyed/non-keyed operations in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20517: Assignee: Aljoscha Krettek (was: Dawid Wysakowicz) > Support mixed

[jira] [Updated] (FLINK-20517) Support mixed keyed/non-keyed operations in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20517: - Description: Using the batch state backend requires that the inputs are sorted by a

[jira] [Updated] (FLINK-20517) Support mixed keyed/non-keyed operations in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20517: - Summary: Support mixed keyed/non-keyed operations in BATCH execution mode (was:

[jira] [Updated] (FLINK-20517) Support mixed keyed/non-keyed operations in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20517: - Issue Type: Improvement (was: Bug) > Support mixed keyed/non-keyed operations in BATCH

[jira] [Commented] (FLINK-16764) Allow custom Kafka topic discovery logic

[ https://issues.apache.org/jira/browse/FLINK-16764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258193#comment-17258193 ] Aljoscha Krettek commented on FLINK-16764: -- I'm afraid no-one worked on this so far. Do you

[jira] [Created] (FLINK-20843) UnalignedCheckpointITCase is unstable

Aljoscha Krettek created FLINK-20843: Summary: UnalignedCheckpointITCase is unstable Key: FLINK-20843 URL: https://issues.apache.org/jira/browse/FLINK-20843 Project: Flink Issue Type:

[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=17258133#comment-17258133 ] Aljoscha Krettek commented on FLINK-13414: -- For reference: - Thread about dropping Scala 2.11,

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255509#comment-17255509 ] Aljoscha Krettek commented on FLINK-20628: -- Ok, that sounds good! > Port RabbitMQ Sources to

[jira] [Commented] (FLINK-20625) Refactor Google Cloud PubSub Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255508#comment-17255508 ] Aljoscha Krettek commented on FLINK-20625: -- Thanks, that looks good! And yes, we don't need to

[jira] [Commented] (FLINK-17691) FlinkKafkaProducer transactional.id too long when using Semantic.EXACTLY_ONCE

[ https://issues.apache.org/jira/browse/FLINK-17691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255506#comment-17255506 ] Aljoscha Krettek commented on FLINK-17691: -- Regarding Issues #1 and #2, these were proposed as

[jira] [Updated] (FLINK-20764) BatchGroupedReduceOperator does not emit results for singleton inputs

[ https://issues.apache.org/jira/browse/FLINK-20764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20764: - Issue Type: Bug (was: Improvement) > BatchGroupedReduceOperator does not emit results

[jira] [Created] (FLINK-20764) BatchGroupedReduceOperator does not emit results for singleton inputs

Aljoscha Krettek created FLINK-20764: Summary: BatchGroupedReduceOperator does not emit results for singleton inputs Key: FLINK-20764 URL: https://issues.apache.org/jira/browse/FLINK-20764

[jira] [Closed] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20476. Resolution: Not A Problem Closing this for now since it wasn't actually a problem with

[jira] [Created] (FLINK-20651) Use Spotless/google-java-format for code formatting/enforcement

Aljoscha Krettek created FLINK-20651: Summary: Use Spotless/google-java-format for code formatting/enforcement Key: FLINK-20651 URL: https://issues.apache.org/jira/browse/FLINK-20651 Project:

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250968#comment-17250968 ] Aljoscha Krettek commented on FLINK-20476: -- Something must have changed if there is suddenly

[jira] [Commented] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250953#comment-17250953 ] Aljoscha Krettek commented on FLINK-20646: -- I think the windowless {{reduce()}} is not a common

[jira] [Commented] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250942#comment-17250942 ] Aljoscha Krettek commented on FLINK-20646: -- A very quick fix for this is to just call {code}

[jira] [Commented] (FLINK-20625) Refactor Google Cloud PubSub Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250898#comment-17250898 ] Aljoscha Krettek commented on FLINK-20625: -- Does our current PubSub source also only support

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250896#comment-17250896 ] Aljoscha Krettek commented on FLINK-20628: -- So in this case splits would not contain a "real"

[jira] [Updated] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20618: - Component/s: (was: API / Core) Runtime / Network > Some of the

[jira] [Commented] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode

[ https://issues.apache.org/jira/browse/FLINK-20617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250216#comment-17250216 ] Aljoscha Krettek commented on FLINK-20617: -- I think this is because of a dependency mismatch.

[jira] [Updated] (FLINK-20541) ClusterID is not used in the method!

[ https://issues.apache.org/jira/browse/FLINK-20541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20541: - Fix Version/s: (was: 1.11.3) > ClusterID is not used in the method! >

[jira] [Updated] (FLINK-20491) Support Broadcast Operation in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20491: - Summary: Support Broadcast Operation in BATCH execution mode (was: Support Broadcast

[jira] [Commented] (FLINK-20491) Support Broadcast State in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247268#comment-17247268 ] Aljoscha Krettek commented on FLINK-20491: -- I extended my work-in-progress PR:

[jira] [Commented] (FLINK-20491) Support Broadcast State in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246439#comment-17246439 ] Aljoscha Krettek commented on FLINK-20491: -- Thanks, those are very thoughtful comments! I'll

[jira] [Commented] (FLINK-20491) Support Broadcast State in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246380#comment-17246380 ] Aljoscha Krettek commented on FLINK-20491: -- I posted a first PoC as a PR. Right now, what I'm

[jira] [Created] (FLINK-20491) Support Broadcast State in BATCH execution mode

Aljoscha Krettek created FLINK-20491: Summary: Support Broadcast State in BATCH execution mode Key: FLINK-20491 URL: https://issues.apache.org/jira/browse/FLINK-20491 Project: Flink

[jira] [Commented] (FLINK-20098) Don't add flink-connector-files to flink-dist, make dependencies explicit

[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243207#comment-17243207 ] Aljoscha Krettek commented on FLINK-20098: -- The final solution shouldn't have a regression. The

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19984: - Affects Version/s: (was: 1.12.0) > Add TypeSerializerTestCoverageTest to check

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19984: - Fix Version/s: 1.12.0 > Add TypeSerializerTestCoverageTest to check whether tests based

[jira] [Closed] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

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

[jira] [Commented] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242385#comment-17242385 ] Aljoscha Krettek commented on FLINK-20443: -- This is the same as FLINK-5149 so I think it's good

[jira] [Updated] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20443: - Summary: ContinuousProcessingTimeTrigger doesn't fire at the end of the window (was:

[jira] [Updated] (FLINK-20438) SystemProcessingTimeServiceTest fails due to missing output

[ https://issues.apache.org/jira/browse/FLINK-20438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20438: - Summary: SystemProcessingTimeServiceTest fails due to missing output (was:

[jira] [Closed] (FLINK-20337) Allow stateful migration from StreamingFileSink to FileSink

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20337. Resolution: Implemented release-1.12: d0757e95c3c33d4f13377f2c14c179076b3795b2 (and

[jira] [Commented] (FLINK-20337) Allow stateful migration from StreamingFileSink to FileSink

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240799#comment-17240799 ] Aljoscha Krettek commented on FLINK-20337: -- master: da1ad03d68e6c57a95d7375259247053aa8fc24e

[jira] [Updated] (FLINK-20337) Allow stateful migration from StreamingFileSink to FileSink

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20337: - Summary: Allow stateful migration from StreamingFileSink to FileSink (was: Make

[jira] [Deleted] (FLINK-20338) Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek deleted FLINK-20338: - > Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state. >

[jira] [Deleted] (FLINK-20339) `FileWriter` support to load StreamingFileSink's state.

[ https://issues.apache.org/jira/browse/FLINK-20339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek deleted FLINK-20339: - > `FileWriter` support to load StreamingFileSink's state. >

[jira] [Commented] (FLINK-20339) `FileWriter` support to load StreamingFileSink's state.

[ https://issues.apache.org/jira/browse/FLINK-20339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239700#comment-17239700 ] Aljoscha Krettek commented on FLINK-20339: -- Just for anyone wondering, this was closed because

[jira] [Updated] (FLINK-20338) Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20338: - Fix Version/s: (was: 1.12.0) > Make the `StatefulSinkWriterOperator` load

[jira] [Commented] (FLINK-20338) Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239699#comment-17239699 ] Aljoscha Krettek commented on FLINK-20338: -- Just for anyone wondering, this was closed because

[jira] [Updated] (FLINK-20339) `FileWriter` support to load StreamingFileSink's state.

[ https://issues.apache.org/jira/browse/FLINK-20339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20339: - Fix Version/s: (was: 1.12.0) > `FileWriter` support to load StreamingFileSink's

[jira] [Assigned] (FLINK-20339) `FileWriter` support to load StreamingFileSink's state.

[ https://issues.apache.org/jira/browse/FLINK-20339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20339: Assignee: Yun Gao > `FileWriter` support to load StreamingFileSink's state. >

[jira] [Assigned] (FLINK-20338) Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20338: Assignee: Guowei Ma > Make the `StatefulSinkWriterOperator` load

[jira] [Closed] (FLINK-20360) AbstractFetcherWatermarksTest$PeriodicWatermarksSuite.testPeriodicWatermarks is unstable

[ https://issues.apache.org/jira/browse/FLINK-20360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20360. Fix Version/s: (was: 1.12.0) Resolution: Not A Problem The change is not

[jira] [Comment Edited] (FLINK-20360) AbstractFetcherWatermarksTest$PeriodicWatermarksSuite.testPeriodicWatermarks is unstable

[ https://issues.apache.org/jira/browse/FLINK-20360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239665#comment-17239665 ] Aljoscha Krettek edited comment on FLINK-20360 at 11/27/20, 12:53 PM:

[jira] [Commented] (FLINK-20360) AbstractFetcherWatermarksTest$PeriodicWatermarksSuite.testPeriodicWatermarks is unstable

[ https://issues.apache.org/jira/browse/FLINK-20360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239656#comment-17239656 ] Aljoscha Krettek commented on FLINK-20360: -- I'm taking a look.  >

[jira] [Assigned] (FLINK-20360) AbstractFetcherWatermarksTest$PeriodicWatermarksSuite.testPeriodicWatermarks is unstable

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

[jira] [Commented] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239655#comment-17239655 ] Aljoscha Krettek commented on FLINK-20190: -- I can probably comment once I understand your use

[jira] [Closed] (FLINK-20302) Recommend DataStream API with BATCH execution mode in DataSet docs

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

[jira] [Updated] (FLINK-20302) Recommend DataStream API with BATCH execution mode in DataSet docs

[ https://issues.apache.org/jira/browse/FLINK-20302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20302: - Summary: Recommend DataStream API with BATCH execution mode in DataSet docs (was:

[jira] [Closed] (FLINK-19316) FLIP-134: Batch execution for the DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19316. Resolution: Done All subtasks have been resolved. > FLIP-134: Batch execution for the

[jira] [Closed] (FLINK-20153) Add documentation for BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20153. Resolution: Done master: d222ce46b33ab686c503906bf4789c78107608c7 > Add documentation

[jira] [Updated] (FLINK-20343) Add overview / reference architecture documentation page

[ https://issues.apache.org/jira/browse/FLINK-20343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20343: - Summary: Add overview / reference architecture documentation page (was: Add overview /

[jira] [Updated] (FLINK-20342) Revisit page structure in documentation

[ https://issues.apache.org/jira/browse/FLINK-20342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20342: - Summary: Revisit page structure in documentation (was: Revisit page structure) >

[jira] [Commented] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238729#comment-17238729 ] Aljoscha Krettek commented on FLINK-20337: -- It's not incomplete, it's just that existing users

[jira] [Assigned] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20337: Assignee: Guowei Ma > Make migrate `StreamingFileSink` to `FileSink` possible >

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238628#comment-17238628 ] Aljoscha Krettek commented on FLINK-20329: -- Probably related to FLINK-20279. It seems using

[jira] [Closed] (FLINK-19510) FLIP-143: Introduce a new unified sink api

[ https://issues.apache.org/jira/browse/FLINK-19510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19510. Resolution: Implemented All subtasks have been implemented > FLIP-143: Introduce a new

[jira] [Assigned] (FLINK-20304) Fail hard when trying to run job with broadcast state in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20304: Assignee: Kostas Kloudas > Fail hard when trying to run job with broadcast state

[jira] [Commented] (FLINK-20304) Fail hard when trying to run job with broadcast state in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238018#comment-17238018 ] Aljoscha Krettek commented on FLINK-20304: -- I think it's not a blocker but still nice to have.

[jira] [Updated] (FLINK-19697) Make the Sink API committer retry-able

[ https://issues.apache.org/jira/browse/FLINK-19697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19697: - Parent: (was: FLINK-19510) Issue Type: New Feature (was: Sub-task) > Make

[jira] [Closed] (FLINK-17691) FlinkKafkaProducer transactional.id too long when using Semantic.EXACTLY_ONCE

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

  1   2   3   4   5   6   7   8   9   10   >