[GitHub] [flink] flinkbot edited a comment on pull request #13313: [FLINK-18722][mesos] Migrate MesosResourceManager to the new MesosResourceManagerDriver

flinkbot edited a comment on pull request #13313: URL: https://github.com/apache/flink/pull/13313#issuecomment-686326763 ## CI report: * c5d95b9560a4288f9a8248c66bef45531c685e56 Azure:

[jira] [Closed] (FLINK-17825) HA end-to-end gets killed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17825. -- Fix Version/s: 1.11.3 1.12.0 Resolution: Fixed > HA end-to-end gets

[jira] [Commented] (FLINK-17825) HA end-to-end gets killed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197454#comment-17197454 ] Robert Metzger commented on FLINK-17825:

[jira] [Created] (FLINK-19271) wrong HOP_PROCTIME output when materialize proctime

Leonard Xu created FLINK-19271: -- Summary: wrong HOP_PROCTIME output when materialize proctime Key: FLINK-19271 URL: https://issues.apache.org/jira/browse/FLINK-19271 Project: Flink Issue Type:

[jira] [Closed] (FLINK-19256) Validate Stateful Functions configuration only where necessary

[ https://issues.apache.org/jira/browse/FLINK-19256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-19256. --- Fix Version/s: statefun-2.2.0 Resolution: Fixed statefun-master:

[GitHub] [flink] flinkbot commented on pull request #13405: [FLINK-19270] Extract an inteface from AbstractKeyedStateBackend

flinkbot commented on pull request #13405: URL: https://github.com/apache/flink/pull/13405#issuecomment-694066808 ## CI report: * 835077d91fd63313743cfff3a30e74fd0b44f9af UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197500#comment-17197500 ] Andrey Zagrebin commented on FLINK-19207: - [~lsy] The ListState API in Flink has append-only

[GitHub] [flink] SteNicholas commented on a change in pull request #13275: [FLINK-19064][hbase] HBaseRowDataInputFormat is leaking resources

SteNicholas commented on a change in pull request #13275: URL: https://github.com/apache/flink/pull/13275#discussion_r490071882 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/TableInputSplit.java ## @@ -26,7 +26,7 @@

[jira] [Created] (FLINK-19273) Update parser module for FLIP-107

Timo Walther created FLINK-19273: Summary: Update parser module for FLIP-107 Key: FLINK-19273 URL: https://issues.apache.org/jira/browse/FLINK-19273 Project: Flink Issue Type: Sub-task

[GitHub] [flink] SteNicholas commented on a change in pull request #13275: [FLINK-19064][hbase] HBaseRowDataInputFormat is leaking resources

SteNicholas commented on a change in pull request #13275: URL: https://github.com/apache/flink/pull/13275#discussion_r490073844 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/AbstractTableInputFormat.java ## @@

[jira] [Comment Edited] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192742#comment-17192742 ] Yang Wang edited comment on FLINK-17598 at 9/17/20, 8:46 AM: - Hi

[GitHub] [flink] JingsongLi commented on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

JingsongLi commented on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-694001553 Can you create separate PR for `isTemporary` flag? This is an automated message from the Apache Git Service.

[GitHub] [flink] tzulitai commented on a change in pull request #13102: [FLINK-18515][Kinesis] Adding FanOutRecordPublisher for Kinesis EFO support

tzulitai commented on a change in pull request #13102: URL: https://github.com/apache/flink/pull/13102#discussion_r489964177 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java ## @@

[jira] [Commented] (FLINK-19246) TableSourceITCase.testStreamScanParallelism fails on private Azure accounts

[ https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197441#comment-17197441 ] Dawid Wysakowicz commented on FLINK-19246: --

[jira] [Commented] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts

[ https://issues.apache.org/jira/browse/FLINK-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197446#comment-17197446 ] Robert Metzger commented on FLINK-19069: [~wind_ljy]: do you want to provide a pull request to

[jira] [Created] (FLINK-19270) Extract an inteface from Abstract

Dawid Wysakowicz created FLINK-19270: Summary: Extract an inteface from Abstract Key: FLINK-19270 URL: https://issues.apache.org/jira/browse/FLINK-19270 Project: Flink Issue Type:

[jira] [Closed] (FLINK-19199) Add execution attempt ID to feedback channel keys

[ https://issues.apache.org/jira/browse/FLINK-19199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-19199. --- Fix Version/s: statefun-2.2.0 Resolution: Fixed statefun-master:

[jira] [Created] (FLINK-19272) Add interfaces for FLIP-107

Timo Walther created FLINK-19272: Summary: Add interfaces for FLIP-107 Key: FLINK-19272 URL: https://issues.apache.org/jira/browse/FLINK-19272 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-17825) HA end-to-end gets killed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197523#comment-17197523 ] Dian Fu commented on FLINK-17825: - [~rmetzger] Thanks a lot! > HA end-to-end gets killed due to timeout

[GitHub] [flink] JingsongLi merged pull request #13398: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

JingsongLi merged pull request #13398: URL: https://github.com/apache/flink/pull/13398 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] twalthr commented on pull request #13298: [FLINK-19038][table] It doesn't support to call Table.limit() continuously

twalthr commented on pull request #13298: URL: https://github.com/apache/flink/pull/13298#issuecomment-694023370 Thanks @SteNicholas. I will take a look shortly. This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-19165) Clean up the UnilateralSortMerger

[ https://issues.apache.org/jira/browse/FLINK-19165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-19165: - Parent: FLINK-19268 Issue Type: Sub-task (was: Bug) > Clean up the

[jira] [Updated] (FLINK-19270) Extract an inteface from AbstractKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-19270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19270: --- Labels: pull-request-available (was: ) > Extract an inteface from

[GitHub] [flink] flinkbot commented on pull request #13405: [FLINK-19270] Extract an inteface from AbstractKeyedStateBackend

flinkbot commented on pull request #13405: URL: https://github.com/apache/flink/pull/13405#issuecomment-694050574 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts

[ https://issues.apache.org/jira/browse/FLINK-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197477#comment-17197477 ] Jiayi Liao commented on FLINK-19069: [~rmetzger] Sure. According to the discussion above, I'm going

[jira] [Updated] (FLINK-12884) FLIP-144: Native Kubernetes HA Service

[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-12884: -- Summary: FLIP-144: Native Kubernetes HA Service (was: Implement HighAvailabilityService based on

[GitHub] [flink] SteNicholas commented on a change in pull request #13275: [FLINK-19064][hbase] HBaseRowDataInputFormat is leaking resources

SteNicholas commented on a change in pull request #13275: URL: https://github.com/apache/flink/pull/13275#discussion_r490072665 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/AbstractTableInputFormat.java ## @@ -68,6

[GitHub] [flink] flinkbot edited a comment on pull request #13372: [FLINK-19187][examples-table] Add a new basic Table API example

flinkbot edited a comment on pull request #13372: URL: https://github.com/apache/flink/pull/13372#issuecomment-691076967 ## CI report: * 9ddd54fa12be8d0f43e16b96d01725005d8c145e Azure:

[jira] [Commented] (FLINK-18222) "Avro Confluent Schema Registry nightly end-to-end test" unstable with "Kafka cluster did not start after 120 seconds"

[ https://issues.apache.org/jira/browse/FLINK-18222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197519#comment-17197519 ] Dian Fu commented on FLINK-18222: - [~rmetzger] Thanks a lot! (y) > "Avro Confluent Schema Registry

[GitHub] [flink] flinkbot edited a comment on pull request #13311: [FLINK-18721] Migrate YarnResourceManager to the new YarnResourceManagerDriver

flinkbot edited a comment on pull request #13311: URL: https://github.com/apache/flink/pull/13311#issuecomment-686196434 ## CI report: * b7660009b48d48261b767855d8973c63741ab493 UNKNOWN * f16d78f22d3d66e763f5629a377936bcb20b80c4 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13275: [FLINK-19064][hbase] HBaseRowDataInputFormat is leaking resources

flinkbot edited a comment on pull request #13275: URL: https://github.com/apache/flink/pull/13275#issuecomment-682391096 ## CI report: * 27d9c90c0393f1febaec84f28e850867eed6222d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * 2a006a5c9494d9ff910acb2ebbf135e4adc22029 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * 2a006a5c9494d9ff910acb2ebbf135e4adc22029 Azure:

[jira] [Closed] (FLINK-18604) HBase ConnectorDescriptor can not work in Table API

[ https://issues.apache.org/jira/browse/FLINK-18604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18604. Resolution: Fixed Merged in release-1.11: e69b26242d69df19d90962a1bf472d16bfb58cc1 > HBase

[GitHub] [flink] flinkbot edited a comment on pull request #13371: [FLINK-17879][python] update Python row serializer to support RowKind

flinkbot edited a comment on pull request #13371: URL: https://github.com/apache/flink/pull/13371#issuecomment-690084042 ## CI report: * 1743fdb906cf61fde264a942c0569187edd7b1d6 Azure:

[jira] [Created] (FLINK-19269) Make the PushingAsyncDataInput.DataOutput aware of endOfInput

Dawid Wysakowicz created FLINK-19269: Summary: Make the PushingAsyncDataInput.DataOutput aware of endOfInput Key: FLINK-19269 URL: https://issues.apache.org/jira/browse/FLINK-19269 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

flinkbot edited a comment on pull request #13402: URL: https://github.com/apache/flink/pull/13402#issuecomment-693424540 ## CI report: * 83ff7dd5e54dca0b65e99cbf6409dbf6ae0428a4 Azure:

[jira] [Updated] (FLINK-12884) FLIP-144: Native Kubernetes HA Service

[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-12884: -- Parent: (was: FLINK-17709) Issue Type: New Feature (was: Sub-task) > FLIP-144: Native

[GitHub] [flink] flinkbot edited a comment on pull request #13405: [FLINK-19270] Extract an inteface from AbstractKeyedStateBackend

flinkbot edited a comment on pull request #13405: URL: https://github.com/apache/flink/pull/13405#issuecomment-694066808 ## CI report: * 835077d91fd63313743cfff3a30e74fd0b44f9af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13398: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

flinkbot edited a comment on pull request #13398: URL: https://github.com/apache/flink/pull/13398#issuecomment-693384597 ## CI report: * 09f58aeb9ac653be17d8a9b5b6eaaee02e415ad2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

flinkbot edited a comment on pull request #13402: URL: https://github.com/apache/flink/pull/13402#issuecomment-693424540 ## CI report: * f4a438df036bada30853b6450931e5b116dce9a1 Azure:

[jira] [Commented] (FLINK-17825) HA end-to-end gets killed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-17825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197452#comment-17197452 ] Robert Metzger commented on FLINK-17825: The last failure reported by Dian happened on the

[jira] [Assigned] (FLINK-15869) FLIP-107: Handling of metadata in SQL connectors

[ https://issues.apache.org/jira/browse/FLINK-15869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-15869: Assignee: Timo Walther (was: Dawid Wysakowicz) > FLIP-107: Handling of metadata in SQL

[jira] [Updated] (FLINK-15869) FLIP-107: Handling of metadata in SQL connectors

[ https://issues.apache.org/jira/browse/FLINK-15869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-15869: - Summary: FLIP-107: Handling of metadata in SQL connectors (was: Support to read and write meta

[jira] [Created] (FLINK-19268) Introduce bounded style execution for keyed streams

Dawid Wysakowicz created FLINK-19268: Summary: Introduce bounded style execution for keyed streams Key: FLINK-19268 URL: https://issues.apache.org/jira/browse/FLINK-19268 Project: Flink

[GitHub] [flink] pyscala commented on pull request #13398: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

pyscala commented on pull request #13398: URL: https://github.com/apache/flink/pull/13398#issuecomment-694022644 Hi @JingsongLi,this PR for release-1.11. This is an automated message from the Apache Git Service. To respond

[jira] [Assigned] (FLINK-19270) Extract an inteface from AbstractKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-19270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-19270: Component/s: Runtime / State Backends Fix Version/s: 1.12.0

[GitHub] [flink-statefun] tzulitai closed pull request #153: [FLINK-19256] [core] Move Flink config validation out of StatefulFunctionsConfig

tzulitai closed pull request #153: URL: https://github.com/apache/flink-statefun/pull/153 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] dawidwys opened a new pull request #13405: [FLINK-19270] Extract InternalKeyedStateBackend interface

dawidwys opened a new pull request #13405: URL: https://github.com/apache/flink/pull/13405 ## What is the purpose of the change This commit extracts a minimal interface from AbstractKeyedStateBackend. This interface is returned by StateBackend interface, making it easier to

[jira] [Comment Edited] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197509#comment-17197509 ] Aljoscha Krettek edited comment on FLINK-17295 at 9/17/20, 8:35 AM:

[GitHub] [flink] SteNicholas commented on a change in pull request #13275: [FLINK-19064][hbase] HBaseRowDataInputFormat is leaking resources

SteNicholas commented on a change in pull request #13275: URL: https://github.com/apache/flink/pull/13275#discussion_r490069505 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/AbstractTableInputFormat.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #13372: [FLINK-19187][examples-table] Add a new basic Table API example

flinkbot edited a comment on pull request #13372: URL: https://github.com/apache/flink/pull/13372#issuecomment-691076967 ## CI report: * 9ddd54fa12be8d0f43e16b96d01725005d8c145e Azure:

[jira] [Commented] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197509#comment-17197509 ] Aljoscha Krettek commented on FLINK-17295: -- This is causing FLINK-19264 (thanks [~chesnay] for

[jira] [Updated] (FLINK-15869) FLIP-107: Handling of metadata in SQL connectors

[ https://issues.apache.org/jira/browse/FLINK-15869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-15869: - Description: Besides the main payload, the majority of connectors (and also many formats)

[GitHub] [flink] SteNicholas commented on pull request #13298: [FLINK-19038][table] It doesn't support to call Table.limit() continuously

SteNicholas commented on pull request #13298: URL: https://github.com/apache/flink/pull/13298#issuecomment-694090738 > Thanks @SteNicholas. I will take a look shortly. @twalthr Thanks. This is an automated message

[GitHub] [flink] SteNicholas commented on pull request #13275: [FLINK-19064][hbase] HBaseRowDataInputFormat is leaking resources

SteNicholas commented on pull request #13275: URL: https://github.com/apache/flink/pull/13275#issuecomment-694090343 @rmetzger @wuchong I have already follow up with your comments. Please help to review the changes. Thanks.

[GitHub] [flink] pyscala commented on pull request #13402: [FLINK-19262][API/DataStream] Can not setParallelism for FLIP-27 source

pyscala commented on pull request #13402: URL: https://github.com/apache/flink/pull/13402#issuecomment-694101032 @JingsongLi, please review again. Thanks. This is an automated message from the Apache Git Service. To respond

[jira] [Closed] (FLINK-19056) Investigate multipart upload performance regression

[ https://issues.apache.org/jira/browse/FLINK-19056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-19056. Fix Version/s: (was: 1.12.0) Resolution: Fixed The slowdogn with Netty 4.1.50

[GitHub] [flink] dianfu closed pull request #13371: [FLINK-17879][python] update Python row serializer to support RowKind

dianfu closed pull request #13371: URL: https://github.com/apache/flink/pull/13371 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Comment Edited] (FLINK-19056) Investigate multipart upload performance regression

[ https://issues.apache.org/jira/browse/FLINK-19056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197530#comment-17197530 ] Chesnay Schepler edited comment on FLINK-19056 at 9/17/20, 9:04 AM:

[jira] [Commented] (FLINK-12751) Create file based HA support

[ https://issues.apache.org/jira/browse/FLINK-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197929#comment-17197929 ] Teng Fei Liao commented on FLINK-12751: --- If you replace the deployment with a stateful set for the

[GitHub] [flink] flinkbot edited a comment on pull request #13384: [FLINK-19224][state-processor-api] Support reading window operator state

flinkbot edited a comment on pull request #13384: URL: https://github.com/apache/flink/pull/13384#issuecomment-692330852 ## CI report: * 98b77dffa6ea7b1da3940d9c5cceb5e8d7a73e82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13392: [FLINK-18713][table-planner-blink] Change duration configOption to duration type

flinkbot edited a comment on pull request #13392: URL: https://github.com/apache/flink/pull/13392#issuecomment-692540614 ## CI report: * b4edfc577e0d1d20203de931dbbab1ac4ab2d621 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13412: [FLINK-19069] execute finalizeOnMaster with io executor to avoid hea…

flinkbot edited a comment on pull request #13412: URL: https://github.com/apache/flink/pull/13412#issuecomment-694253946 ## CI report: * 85d80667243bb98025bc5aa52565f4e6b57d468a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13413: [FLINK-19188][examples-table] Add a new streaming SQL example

flinkbot edited a comment on pull request #13413: URL: https://github.com/apache/flink/pull/13413#issuecomment-694306028 ## CI report: * 4ccc07b606b8bc121576b45aa6684c0c71a911f5 Azure:

[jira] [Updated] (FLINK-19283) Allow subclasses to override/extend FlinkKafkaConsumerBase checkpoint methods

[ https://issues.apache.org/jira/browse/FLINK-19283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Kreuziger updated FLINK-19283: - Description: I'm working on a class that extends the FlinkKafkaConsumer to add some

[jira] [Updated] (FLINK-19283) Allow subclasses to override/extend FlinkKafkaConsumerBase checkpoint methods

[ https://issues.apache.org/jira/browse/FLINK-19283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Kreuziger updated FLINK-19283: - Description: I'm working on a class that extends the FlinkKafkaConsumer to add some

[jira] [Created] (FLINK-19283) Allow subclasses to override/extend FlinkKafkaConsumerBase checkpoint methods

Adrian Kreuziger created FLINK-19283: Summary: Allow subclasses to override/extend FlinkKafkaConsumerBase checkpoint methods Key: FLINK-19283 URL: https://issues.apache.org/jira/browse/FLINK-19283

[GitHub] [flink-shaded] zentol opened a new pull request #90: [FLINK-19243][jackson] Bump snakeyaml to 1.27

zentol opened a new pull request #90: URL: https://github.com/apache/flink-shaded/pull/90 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Commented] (FLINK-19141) Flink Job Submitted on Yarn Does not Allocate Task Manager

[ https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197532#comment-17197532 ] Xintong Song commented on FLINK-19141: -- Hi [~yunhui], It is probably a known issue, FLINK-19151.

[jira] [Closed] (FLINK-17879) Update Python row serializer

[ https://issues.apache.org/jira/browse/FLINK-17879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17879. --- Fix Version/s: 1.12.0 Resolution: Fixed Merged to 1.12 via 2f617d028fd96921331047044b683ec854948fd8

[GitHub] [flink] flinkbot edited a comment on pull request #13358: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

flinkbot edited a comment on pull request #13358: URL: https://github.com/apache/flink/pull/13358#issuecomment-689274090 ## CI report: * f6e6e94da73c668aa873d7155aae158418f6bc2f Azure:

[jira] [Commented] (FLINK-19140) Join with Table Function (UDTF) SQL example is incorrect

[ https://issues.apache.org/jira/browse/FLINK-19140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197559#comment-17197559 ] Nicholas Jiang commented on FLINK-19140: [~libenchao]Have you already updated the document? >

[jira] [Created] (FLINK-19277) Introduce BatchArrowPythonGroupWindowAggregateFunctionOperator

Huang Xingbo created FLINK-19277: Summary: Introduce BatchArrowPythonGroupWindowAggregateFunctionOperator Key: FLINK-19277 URL: https://issues.apache.org/jira/browse/FLINK-19277 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * 2a006a5c9494d9ff910acb2ebbf135e4adc22029 Azure:

[GitHub] [flink] wuchong commented on pull request #13294: [FLINK-19002][canal][json] Support to only read changelogs of specific database and table for canal-json format

wuchong commented on pull request #13294: URL: https://github.com/apache/flink/pull/13294#issuecomment-694115988 Hi @leonardBang , I have updated the 'canal-json.database', 'canal-json.table' to 'canal-json.database.include' and 'canal-json.table.include'. Could you have a look again?

[GitHub] [flink] curcur opened a new pull request #13408: [WIP] single task failure recovery --network stack break from serializer

curcur opened a new pull request #13408: URL: https://github.com/apache/flink/pull/13408 Reference Purpose, WIP. ## What is the purpose of the change a prototype of single task failure recovery --network stack break from the serializer

[jira] [Commented] (FLINK-19275) Allow to read and write metadata in Kafka table source/sink

[ https://issues.apache.org/jira/browse/FLINK-19275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197576#comment-17197576 ] Nicholas Jiang commented on FLINK-19275: [~twalthr]I could add `SupportsReadingMetadata` and

[GitHub] [flink] flinkbot edited a comment on pull request #13407: [FLINK-19246][table-planner] Fix TableSourceITCase.testStreamScanParallelism fails on Azure

flinkbot edited a comment on pull request #13407: URL: https://github.com/apache/flink/pull/13407#issuecomment-694117593 ## CI report: * 68e8570c24e5db1b8bba5f2d119e8ac62be15352 Azure:

[GitHub] [flink] dianfu commented on a change in pull request #13388: [FLINK-19184][python] Add Batch Physical Pandas Group Aggregate Rule and RelNode

dianfu commented on a change in pull request #13388: URL: https://github.com/apache/flink/pull/13388#discussion_r490094072 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/BatchExecPythonAggregateRule.java

[GitHub] [flink] wuchong commented on a change in pull request #13332: [FLINK-19128][sql-client] Remove the runtime execution configuration in sql-client-defaults.yaml

wuchong commented on a change in pull request #13332: URL: https://github.com/apache/flink/pull/13332#discussion_r490136576 ## File path: flink-table/flink-sql-client/src/test/resources/test-sql-client-defaults.yaml ## @@ -137,19 +137,10 @@ catalogs: execution: planner:

[GitHub] [flink] StephanEwen commented on pull request #13034: [FLINK-9992][tests] Fix FsStorageLocationReferenceTest#testEncodeAndDecode by adding retries to generate a valid path

StephanEwen commented on pull request #13034: URL: https://github.com/apache/flink/pull/13034#issuecomment-694149461 +1 to merge this This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-19133) User provided kafka partitioners are not initialized correctly

[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197631#comment-17197631 ] CloseRiver commented on FLINK-19133: [~dwysakowicz],yes you are right,i have just verified flink

[GitHub] [flink] rmetzger opened a new pull request #13409: [FLINK-17910][e2e] Fix debug log output to investigate rare test failure

rmetzger opened a new pull request #13409: URL: https://github.com/apache/flink/pull/13409 ## What is the purpose of the change The associated JIRA ticket is actually some test instability, and this change won't fix the instability. But we can not debug a failed Flink job without

[GitHub] [flink] flinkbot edited a comment on pull request #13275: [FLINK-19064][hbase] HBaseRowDataInputFormat is leaking resources

flinkbot edited a comment on pull request #13275: URL: https://github.com/apache/flink/pull/13275#issuecomment-682391096 ## CI report: * 27d9c90c0393f1febaec84f28e850867eed6222d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13397: [FLINK-19178][runtime] Extend managed memory weight/fraction interfaces for various use cases.

flinkbot edited a comment on pull request #13397: URL: https://github.com/apache/flink/pull/13397#issuecomment-693261990 ## CI report: * 7c2c20f97637a965be7c74243592f1157d1ac9f7 Azure:

[jira] [Closed] (FLINK-19251) Avoid confusing queue handling in "SplitReader.handleSplitsChanges()"

[ https://issues.apache.org/jira/browse/FLINK-19251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-19251. > Avoid confusing queue handling in "SplitReader.handleSplitsChanges()" >

[jira] [Resolved] (FLINK-19251) Avoid confusing queue handling in "SplitReader.handleSplitsChanges()"

[ https://issues.apache.org/jira/browse/FLINK-19251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-19251. -- Resolution: Fixed Fixed in 1.12 (master) via ee5c4c211c35c70d28252363bbc8400453609977 >

[GitHub] [flink] zentol commented on a change in pull request #13319: [FLINK-19022][runtime]Register the TerminationFuture of ResourceManager and Dispatcher with DispatcherResourceManagerComponent

zentol commented on a change in pull request #13319: URL: https://github.com/apache/flink/pull/13319#discussion_r490103127 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponent.java ## @@ -74,22 +79,46 @@

[jira] [Commented] (FLINK-19005) Document JDBC drivers as source of Metaspace leaks

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197555#comment-17197555 ] Stephan Ewen commented on FLINK-19005: -- Is there a way to provide a "classloader cleanup hook"

[GitHub] [flink] zentol commented on a change in pull request #13319: [FLINK-19022][runtime]Register the TerminationFuture of ResourceManager and Dispatcher with DispatcherResourceManagerComponent

zentol commented on a change in pull request #13319: URL: https://github.com/apache/flink/pull/13319#discussion_r490102457 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponent.java ## @@ -74,22 +79,46 @@

[jira] [Comment Edited] (FLINK-19246) TableSourceITCase.testStreamScanParallelism fails on private Azure accounts

[ https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197441#comment-17197441 ] Dawid Wysakowicz edited comment on FLINK-19246 at 9/17/20, 9:37 AM:

[jira] [Commented] (FLINK-19264) Identical jobs cannot be run concurrently

[ https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197572#comment-17197572 ] Stephan Ewen commented on FLINK-19264: -- [~kkrugler] Maybe you are running into FLINK-19123 ? >

[GitHub] [flink] flinkbot edited a comment on pull request #13406: [FLINK-19243][elasticsearch] Bump snakeyaml to 1.27

flinkbot edited a comment on pull request #13406: URL: https://github.com/apache/flink/pull/13406#issuecomment-694116951 ## CI report: * 6cc539fc8089fd3b0497fcf3c4af0ed929bcfe0f Azure:

[GitHub] [flink] wuchong commented on a change in pull request #13392: [FLINK-18713][table-planner-blink] Change duration configOption to duration type

wuchong commented on a change in pull request #13392: URL: https://github.com/apache/flink/pull/13392#discussion_r490117998 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowEmitStrategy.scala ## @@ -198,9

[jira] [Created] (FLINK-19278) Bump Scala Macros Version to 2.1.1

Stephan Ewen created FLINK-19278: Summary: Bump Scala Macros Version to 2.1.1 Key: FLINK-19278 URL: https://issues.apache.org/jira/browse/FLINK-19278 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-19228) Avoid accessing FileSystem in client for file system connector

[ https://issues.apache.org/jira/browse/FLINK-19228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19228: Assignee: Nicholas Jiang > Avoid accessing FileSystem in client for file system

[jira] [Commented] (FLINK-19133) User provided kafka partitioners are not initialized correctly

[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197590#comment-17197590 ] Dawid Wysakowicz commented on FLINK-19133: -- I am afraid yes. If you do specify a partitioner

[jira] [Closed] (FLINK-3456) Backpressure Monitoring does not work for Kafka Sources

[ https://issues.apache.org/jira/browse/FLINK-3456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3456. --- Resolution: Not A Problem The Kafka 0.8 connector does not exist any more. > Backpressure

[jira] [Commented] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

[ https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197616#comment-17197616 ] Yun Gao commented on FLINK-18818: - I'll have a look at this issue. >

  1   2   3   4   >