[jira] [Closed] (FLINK-17773) Update documentation for new WatermarkGenerator/WatermarkStrategies

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

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

[ https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113997#comment-17113997 ] Aljoscha Krettek commented on FLINK-17721: -- Yes, I think option 3) is the

[jira] [Commented] (FLINK-17775) Cannot set batch job name when using collect

[ https://issues.apache.org/jira/browse/FLINK-17775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113996#comment-17113996 ] Aljoscha Krettek commented on FLINK-17775: -- Indeed, there is currently no

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17113990#comment-17113990 ] Aljoscha Krettek commented on FLINK-17862: -- How is it leaked in the oper

[jira] [Assigned] (FLINK-12855) Stagger panes on partitions to distribute workload.

[ https://issues.apache.org/jira/browse/FLINK-12855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-12855: Assignee: Teng Hu > Stagger panes on partitions to distribute workl

[jira] [Closed] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence

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

[jira] [Commented] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence

[ https://issues.apache.org/jira/browse/FLINK-16911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113914#comment-17113914 ] Aljoscha Krettek commented on FLINK-16911: -- I believe this is a tim

[jira] [Assigned] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence

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

[jira] [Closed] (FLINK-17361) Support creating of a JDBC table using a custom query

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

[jira] [Assigned] (FLINK-17361) Support creating of a JDBC table using a custom query

[ https://issues.apache.org/jira/browse/FLINK-17361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17361: Assignee: Flavio Pompermaier > Support creating of a JDBC table using a cus

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

Aljoscha Krettek created FLINK-17815: Summary: Change KafkaConnector to give per-partition metric group to WatermarkGenerator Key: FLINK-17815 URL: https://issues.apache.org/jira/browse/FLINK-17815

[jira] [Updated] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

[ https://issues.apache.org/jira/browse/FLINK-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15557: - Fix Version/s: 1.12.0 > Cannot connect to Azure Event Hub/Kafka since Jan 5th 2

[jira] [Updated] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

[ https://issues.apache.org/jira/browse/FLINK-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15557: - Priority: Critical (was: Blocker) > Cannot connect to Azure Event Hub/Kafka since

[jira] [Closed] (FLINK-17593) Support arbitrary recovery mechanism for PartFileWriter

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

[jira] [Reopened] (FLINK-17593) Support arbitrary recovery mechanism for PartFileWriter

[ https://issues.apache.org/jira/browse/FLINK-17593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-17593: -- > Support arbitrary recovery mechanism for PartFileWri

[jira] [Commented] (FLINK-17775) Cannot set batch job name when using collect

[ https://issues.apache.org/jira/browse/FLINK-17775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110243#comment-17110243 ] Aljoscha Krettek commented on FLINK-17775: -- How are you executing the job

[jira] [Commented] (FLINK-17775) Cannot set batch job name when using collect

[ https://issues.apache.org/jira/browse/FLINK-17775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110173#comment-17110173 ] Aljoscha Krettek commented on FLINK-17775: -- This is a different i

[jira] [Closed] (FLINK-17615) flink batch job name doesn't show as defined in program

[ https://issues.apache.org/jira/browse/FLINK-17615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17615. Resolution: Not A Problem This was fixed by recent changes, {{OptimizerPlanEnvironment

[jira] [Updated] (FLINK-17705) Add rat license checks for flink-benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17705: - Summary: Add rat license checks for flink-benchmarks (was: Add rat license checks

[jira] [Updated] (FLINK-17706) Clarify licensing situation for flink-benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17706: - Summary: Clarify licensing situation for flink-benchmarks (was: Clarify licensing

[jira] [Closed] (FLINK-17676) Is there some way to rollback the .out file of TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17676. Resolution: Won't Do I think we can't fix that from the Flink side, printing

[jira] [Closed] (FLINK-17378) KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable

[ https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17378. Resolution: Duplicate > KafkaProducerExactlyOnceITC

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110113#comment-17110113 ] Aljoscha Krettek commented on FLINK-17730: -- That's a very long runtim

[jira] [Commented] (FLINK-17619) Only set offset commit if group id is configured for Kafka Table source

[ https://issues.apache.org/jira/browse/FLINK-17619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110096#comment-17110096 ] Aljoscha Krettek commented on FLINK-17619: -- Sounds legit, yes. > O

[jira] [Closed] (FLINK-17602) Documentation for broadcast state correction

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

[jira] [Commented] (FLINK-17584) disableAutoTypeRegistration option does not work with Streaming API, only with Batch

[ https://issues.apache.org/jira/browse/FLINK-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110091#comment-17110091 ] Aljoscha Krettek commented on FLINK-17584: -- I think you shouldn't

[jira] [Closed] (FLINK-17348) Expose metric group to ascendingTimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-17348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17348. Fix Version/s: 1.11.0 Resolution: Fixed This was added in the new interfaces of

[jira] [Assigned] (FLINK-17348) Expose metric group to ascendingTimestampExtractor

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

[jira] [Closed] (FLINK-17669) Use new WatermarkStrategy/WatermarkGenerator in Kafka connector

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

[jira] [Closed] (FLINK-17661) Add APIs for using new WatermarkStrategy/WatermarkGenerator

[ https://issues.apache.org/jira/browse/FLINK-17661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17661. Resolution: Fixed master: d755e1b4e7252f968e0a66836353f30b2e4f64bd > Add APIs for us

[jira] [Closed] (FLINK-17766) Use checkpoint lock instead of fine-grained locking in Kafka AbstractFetcher

[ https://issues.apache.org/jira/browse/FLINK-17766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17766. Resolution: Fixed master: 59714b9d6addb1dbf2171cab937a0e3fec52f2b1 > Use checkpoint l

[jira] [Closed] (FLINK-17658) Add new TimestampAssigner and WatermarkGenerator interfaces

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

[jira] [Closed] (FLINK-17659) Add common watermark strategies and WatermarkStrategies helper

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

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

Aljoscha Krettek created FLINK-17773: Summary: Update documentation for new WatermarkGenerator/WatermarkStrategies Key: FLINK-17773 URL: https://issues.apache.org/jira/browse/FLINK-17773 Project

[jira] [Created] (FLINK-17766) Use checkpoint lock instead of fine-grained locking in Kafka AbstractFetcher

Aljoscha Krettek created FLINK-17766: Summary: Use checkpoint lock instead of fine-grained locking in Kafka AbstractFetcher Key: FLINK-17766 URL: https://issues.apache.org/jira/browse/FLINK-17766

[jira] [Commented] (FLINK-17544) NPE JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108194#comment-17108194 ] Aljoscha Krettek commented on FLINK-17544: -- Ah sorry, nevermind.   Btw,

[jira] [Updated] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

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

[jira] [Assigned] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

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

[jira] [Commented] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108084#comment-17108084 ] Aljoscha Krettek commented on FLINK-16383: -- This is an extract of the rele

[jira] [Closed] (FLINK-17578) Union of 2 SideOutputs behaviour incorrect

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

[jira] [Closed] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-16383. Assignee: Aljoscha Krettek Resolution: Fixed I added a potential fix on master in

[jira] [Commented] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107288#comment-17107288 ] Aljoscha Krettek commented on FLINK-17469: -- I agree on all of this, it w

[jira] [Commented] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107225#comment-17107225 ] Aljoscha Krettek commented on FLINK-16383: -- I doubt it's FLINK-1730

[jira] [Commented] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107219#comment-17107219 ] Aljoscha Krettek commented on FLINK-16383: -- I started looking into this

[jira] [Commented] (FLINK-17545) Resource leak JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107082#comment-17107082 ] Aljoscha Krettek commented on FLINK-17545: -- Did you by chance also try

[jira] [Commented] (FLINK-17544) NPE JDBCUpsertOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107071#comment-17107071 ] Aljoscha Krettek commented on FLINK-17544: -- hi [~johnlon] do you maybe wan

[jira] [Updated] (FLINK-17559) Backpressure seems to be broken when not going through network

[ https://issues.apache.org/jira/browse/FLINK-17559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17559: - Component/s: (was: API / Core) > Backpressure seems to be broken when not go

[jira] [Updated] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17560: - Component/s: Runtime / Coordination > No Slots available exception in Apache Flink

[jira] [Closed] (FLINK-17654) Move Clock classes to flink-core to make them usable outside runtime

[ https://issues.apache.org/jira/browse/FLINK-17654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17654. Resolution: Fixed master: dcbd665f35bf40210d2dfe654a40a6cd5faba253 > Move Clock clas

[jira] [Closed] (FLINK-17655) Remove old and long deprecated TimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-17655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17655. Release Note: The long-deprecated `TimestampExtractor` was removed along with API methods

[jira] [Commented] (FLINK-17578) Union of 2 SideOutputs behaviour incorrect

[ https://issues.apache.org/jira/browse/FLINK-17578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106431#comment-17106431 ] Aljoscha Krettek commented on FLINK-17578: -- [~damjad] do you want to open

[jira] [Assigned] (FLINK-17578) Union of 2 SideOutputs behaviour incorrect

[ https://issues.apache.org/jira/browse/FLINK-17578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17578: Assignee: Danish Amjad > Union of 2 SideOutputs behaviour incorr

[jira] [Created] (FLINK-17669) Use new WatermarkStrategy/WatermarkGenerator in Kafka connector

Aljoscha Krettek created FLINK-17669: Summary: Use new WatermarkStrategy/WatermarkGenerator in Kafka connector Key: FLINK-17669 URL: https://issues.apache.org/jira/browse/FLINK-17669 Project

[jira] [Created] (FLINK-17661) Add APIs for using new WatermarkStrategy/WatermarkGenerator

Aljoscha Krettek created FLINK-17661: Summary: Add APIs for using new WatermarkStrategy/WatermarkGenerator Key: FLINK-17661 URL: https://issues.apache.org/jira/browse/FLINK-17661 Project: Flink

[jira] [Created] (FLINK-17659) Add common watermark strategies and WatermarkStrategies helper

Aljoscha Krettek created FLINK-17659: Summary: Add common watermark strategies and WatermarkStrategies helper Key: FLINK-17659 URL: https://issues.apache.org/jira/browse/FLINK-17659 Project

[jira] [Created] (FLINK-17658) Add new TimestampAssigner and WatermarkGenerator interfaces

Aljoscha Krettek created FLINK-17658: Summary: Add new TimestampAssigner and WatermarkGenerator interfaces Key: FLINK-17658 URL: https://issues.apache.org/jira/browse/FLINK-17658 Project: Flink

[jira] [Created] (FLINK-17655) Remove old and long deprecated TimestampExtractor

Aljoscha Krettek created FLINK-17655: Summary: Remove old and long deprecated TimestampExtractor Key: FLINK-17655 URL: https://issues.apache.org/jira/browse/FLINK-17655 Project: Flink

[jira] [Created] (FLINK-17654) Move Clock classes to flink-core to make them usable outside runtime

Aljoscha Krettek created FLINK-17654: Summary: Move Clock classes to flink-core to make them usable outside runtime Key: FLINK-17654 URL: https://issues.apache.org/jira/browse/FLINK-17654 Project

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

Aljoscha Krettek created FLINK-17653: Summary: FLIP-126: Unify (and separate) Watermark Assigners Key: FLINK-17653 URL: https://issues.apache.org/jira/browse/FLINK-17653 Project: Flink

[jira] [Updated] (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 updated FLINK-17653: - Issue Type: New Feature (was: Bug) > FLIP-126: Unify (and separate) Waterm

[jira] [Commented] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106005#comment-17106005 ] Aljoscha Krettek commented on FLINK-7267: - But options sound good to me!

[jira] [Commented] (FLINK-17530) Fix illegal reflective access by ClosureCleaner

[ https://issues.apache.org/jira/browse/FLINK-17530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106002#comment-17106002 ] Aljoscha Krettek commented on FLINK-17530: -- I think A) is not an option

[jira] [Commented] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105999#comment-17105999 ] Aljoscha Krettek commented on FLINK-17529: -- No worries! If you think we m

[jira] [Closed] (FLINK-15841) TimeWindow.intersects return true for consecutive windows

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

[jira] [Closed] (FLINK-16521) Remove unused FileUtils#isClassFile

[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-16521. Resolution: Fixed master: 0a34e4a0288172f3b81f6b2f7480adde764cd1cb > Remove unu

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17105478#comment-17105478 ] Aljoscha Krettek commented on FLINK-5479: - We're currently voting on

[jira] [Commented] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python

[ https://issues.apache.org/jira/browse/FLINK-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105480#comment-17105480 ] Aljoscha Krettek commented on FLINK-17394: -- Yes, they should be deprecated

[jira] [Commented] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105445#comment-17105445 ] Aljoscha Krettek commented on FLINK-17469: -- [~johnlon] any update on

[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: - Priority: Critical (was: Major) > Kafka unavailability could cause Flink TM shutd

[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: - Fix Version/s: 1.10.2 1.11.0 > Kafka unavailability could ca

[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=17104242#comment-17104242 ] Aljoscha Krettek commented on FLINK-17327: -- Btw, this can be reproduced

[jira] [Commented] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104145#comment-17104145 ] Aljoscha Krettek commented on FLINK-17529: -- [~austince] do you want to try

[jira] [Commented] (FLINK-17192) java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: The record exceeds the maximum size of

[ https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17101753#comment-17101753 ] Aljoscha Krettek commented on FLINK-17192: -- Yes, I'm afraid that i

[jira] [Commented] (FLINK-17204) The RMQSource and RMQSink of the RabbitMQ connector have inconsistent default value of durable ​​when declaring the queue.

[ https://issues.apache.org/jira/browse/FLINK-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100939#comment-17100939 ] Aljoscha Krettek commented on FLINK-17204: -- I'm reviewing the PR.

[jira] [Commented] (FLINK-17514) TaskCancelerWatchdog does not kill TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100932#comment-17100932 ] Aljoscha Krettek commented on FLINK-17514: -- Maybe a bit late, but no,

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099793#comment-17099793 ] Aljoscha Krettek commented on FLINK-17447: -- [~pnowojski] Could you maybe

[jira] [Updated] (FLINK-17447) Flink CEPOperator StateException

[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17447: - Component/s: (was: Library / CEP) Runtime / Network > Fl

[jira] [Commented] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099785#comment-17099785 ] Aljoscha Krettek commented on FLINK-17453: -- Maybe [~jark] or someone from

[jira] [Updated] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17453: - Component/s: (was: API / Type Serialization System) > KyroSerializer thr

[jira] [Commented] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099784#comment-17099784 ] Aljoscha Krettek commented on FLINK-17453: -- I don't actually see how

[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=17099777#comment-17099777 ] Aljoscha Krettek commented on FLINK-17327: -- I think the Kafka code doe

[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=17099775#comment-17099775 ] Aljoscha Krettek commented on FLINK-17327: -- For testing I tried this aga

[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=17099751#comment-17099751 ] Aljoscha Krettek commented on FLINK-17327: -- This is another fix we need: h

[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=17099653#comment-17099653 ] Aljoscha Krettek commented on FLINK-17376: -- Is there a link to th

[jira] [Commented] (FLINK-17514) TaskCancelerWatchdog does not kill TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099642#comment-17099642 ] Aljoscha Krettek commented on FLINK-17514: -- Btw, FLINK-16225 is not marke

[jira] [Commented] (FLINK-17514) TaskCancelerWatchdog does not kill TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099637#comment-17099637 ] Aljoscha Krettek commented on FLINK-17514: -- Typo, dammit..

[jira] [Updated] (FLINK-17514) TaskCancelerWatchdog does not kill TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17514: - Description: The watchdog reports a fatal error using {{taskManager.notifyFatalError

[jira] [Updated] (FLINK-17515) Move YARN staging functionality to a separate class

[ https://issues.apache.org/jira/browse/FLINK-17515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17515: - Summary: Move YARN staging functionality to a separate class (was: Move file uploading

[jira] [Commented] (FLINK-17502) Give RMQ deserialization schema access to more RMQ information

[ https://issues.apache.org/jira/browse/FLINK-17502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099624#comment-17099624 ] Aljoscha Krettek commented on FLINK-17502: -- We should also close FLINK-

[jira] [Updated] (FLINK-17502) Give RMQ deserialization schema access to more RMQ information

[ https://issues.apache.org/jira/browse/FLINK-17502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17502: - Summary: Give RMQ deserialization schema access to more RMQ information (was: More

[jira] [Assigned] (FLINK-17502) More granular source parsing

[ https://issues.apache.org/jira/browse/FLINK-17502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17502: Assignee: Karim Mansour > More granular source pars

[jira] [Assigned] (FLINK-17204) The RMQSource and RMQSink of the RabbitMQ connector have inconsistent default value of durable ​​when declaring the queue.

[ https://issues.apache.org/jira/browse/FLINK-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17204: Assignee: Austin Cawley-Edwards > The RMQSource and RMQSink of the Rabbi

[jira] [Created] (FLINK-17514) TaskCancelerWatchdog does not kill TaskManager

Aljoscha Krettek created FLINK-17514: Summary: TaskCancelerWatchdog does not kill TaskManager Key: FLINK-17514 URL: https://issues.apache.org/jira/browse/FLINK-17514 Project: Flink Issue

[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=17099608#comment-17099608 ] Aljoscha Krettek commented on FLINK-17327: -- The fix I mentioned is

[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=17099045#comment-17099045 ] Aljoscha Krettek commented on FLINK-17327: -- I believe

[jira] [Reopened] (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 reopened FLINK-17327: -- I'm re-opening for now since I think the KafkaConsumer is working as designed,

[jira] [Commented] (FLINK-17192) java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: The record exceeds the maximum size of

[ https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098801#comment-17098801 ] Aljoscha Krettek commented on FLINK-17192: -- Did you try set

[jira] [Closed] (FLINK-11186) Event-time balancing for multiple Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-11186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11186. Resolution: Duplicate > Event-time balancing for multiple Kafka partiti

[jira] [Closed] (FLINK-17494) Possible direct memory leak in cassandra sink

[ https://issues.apache.org/jira/browse/FLINK-17494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17494. Resolution: Duplicate > Possible direct memory leak in cassandra s

[jira] [Updated] (FLINK-17498) MapCancelingITCase.testMapCancelling fails with timeout

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

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