[jira] [Updated] (FLINK-17737) KeyedStateCheckpointingITCase fails in UlignedCheckpoint mode

[ https://issues.apache.org/jira/browse/FLINK-17737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17737: --- Summary: KeyedStateCheckpointingITCase fails in UlignedCheckpoint mode (was:

[jira] [Updated] (FLINK-17737) KeyedStateCheckpointingITCase fails in UnalignedCheckpoint mode

[ https://issues.apache.org/jira/browse/FLINK-17737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17737: --- Summary: KeyedStateCheckpointingITCase fails in UnalignedCheckpoint mode (was:

[GitHub] [flink] pnowojski commented on pull request #12183: [FLINK-17737][task] Fix AlternatingCheckpointBarrierHandler

pnowojski commented on pull request #12183: URL: https://github.com/apache/flink/pull/12183#issuecomment-629602498 Great, thanks for the info. I was waiting for my private build of this PR as well, but it would take couple of hours.

[GitHub] [flink] pnowojski merged pull request #12183: [FLINK-17737][task] Fix AlternatingCheckpointBarrierHandler

pnowojski merged pull request #12183: URL: https://github.com/apache/flink/pull/12183 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] pnowojski commented on a change in pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

pnowojski commented on a change in pull request #12186: URL: https://github.com/apache/flink/pull/12186#discussion_r426128101 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -279,16 +281,18

[GitHub] [flink] rkhachatryan commented on pull request #12183: [FLINK-17737][task] Fix AlternatingCheckpointBarrierHandler

rkhachatryan commented on pull request #12183: URL: https://github.com/apache/flink/pull/12183#issuecomment-629601871 [Build](https://dev.azure.com/khachatryanroman/flink/_build/results?buildId=6=results) failed in my private azure account because of unrelated issues:

[GitHub] [flink] AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

AHeise commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r426127832 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaShuffleFetcher.java ## @@

[jira] [Updated] (FLINK-17750) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint failed on azure

[ https://issues.apache.org/jira/browse/FLINK-17750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-17750: -- Description:

[jira] [Created] (FLINK-17750) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint failed on azure

Roman Khachatryan created FLINK-17750: - Summary: YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint failed on azure Key: FLINK-17750 URL: https://issues.apache.org/jira/browse/FLINK-17750

[GitHub] [flink] pnowojski commented on a change in pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

pnowojski commented on a change in pull request #12186: URL: https://github.com/apache/flink/pull/12186#discussion_r426127568 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -174,7 +174,9 @@

[GitHub] [flink] AHeise commented on a change in pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

AHeise commented on a change in pull request #12186: URL: https://github.com/apache/flink/pull/12186#discussion_r426127346 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -279,16 +281,18 @@

[GitHub] [flink] AHeise commented on a change in pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

AHeise commented on a change in pull request #12186: URL: https://github.com/apache/flink/pull/12186#discussion_r426127286 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -174,7 +174,9 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 6d7ff00d684de2f19cce74d766824613fb86dc86 Azure:

[jira] [Commented] (FLINK-17737) KeyedStateCheckpointingITCase fails in UC mode

[ https://issues.apache.org/jira/browse/FLINK-17737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108892#comment-17108892 ] Roman Khachatryan commented on FLINK-17737: --- Thanks for offering your help [~complone]! There

[GitHub] [flink] flinkbot edited a comment on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

flinkbot edited a comment on pull request #12188: URL: https://github.com/apache/flink/pull/12188#issuecomment-629595773 ## CI report: * 7111bcfcc655d8d6b0ee5f9ff66e80e732f7272e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 6d7ff00d684de2f19cce74d766824613fb86dc86 Azure:

[GitHub] [flink] KurtYoung commented on a change in pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

KurtYoung commented on a change in pull request #12145: URL: https://github.com/apache/flink/pull/12145#discussion_r426120399 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala ## @@ -60,7

[GitHub] [flink] wuchong commented on a change in pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

wuchong commented on a change in pull request #12133: URL: https://github.com/apache/flink/pull/12133#discussion_r426125279 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRowDataDeSerializationSchemaTest.java ## @@ -0,0 +1,155 @@ +/* +

[GitHub] [flink] wuchong commented on a change in pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

wuchong commented on a change in pull request #12133: URL: https://github.com/apache/flink/pull/12133#discussion_r426125279 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRowDataDeSerializationSchemaTest.java ## @@ -0,0 +1,155 @@ +/* +

[GitHub] [flink] godfreyhe commented on a change in pull request #12171: [FLINK-17715][sql client] Supports function DDLs in SQL-CLI

godfreyhe commented on a change in pull request #12171: URL: https://github.com/apache/flink/pull/12171#discussion_r426125201 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/Executor.java ## @@ -133,6 +133,21 @@ */

[GitHub] [flink] wuchong commented on a change in pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

wuchong commented on a change in pull request #12133: URL: https://github.com/apache/flink/pull/12133#discussion_r426121118 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -157,4 +166,118 @@ private

[GitHub] [flink] curcur edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-629595539 Resolved 3. the last one. remove getTypeSerializer() from TypeInformationSerializationSchema; Done

[GitHub] [flink] flinkbot edited a comment on pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

flinkbot edited a comment on pull request #12178: URL: https://github.com/apache/flink/pull/12178#issuecomment-629283346 ## CI report: * 5634098665a7f8ed379d7c48a36146145fa58067 Azure:

[GitHub] [flink] flinkbot commented on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

flinkbot commented on pull request #12188: URL: https://github.com/apache/flink/pull/12188#issuecomment-629595773 ## CI report: * 7111bcfcc655d8d6b0ee5f9ff66e80e732f7272e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * ba9ee6228cf9eea60df403e37b41b907fef21a28 Azure:

[jira] [Closed] (FLINK-17587) Filesystem streaming sink support partition commit (success file)

[ https://issues.apache.org/jira/browse/FLINK-17587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17587. Resolution: Implemented master: 25279ed0a3cf7c5fa8d1ad1b3b44990782924362

[GitHub] [flink] curcur commented on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-629595539 Resolved 3. the last one. remove getTypeSerializer() from TypeInformationSerializationSchema This is an

[GitHub] [flink] JingsongLi merged pull request #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

JingsongLi merged pull request #12062: URL: https://github.com/apache/flink/pull/12062 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] flinkbot commented on pull request #12188: [FLINK-17728] [sql-client] sql client supports parser statements via sql parser

flinkbot commented on pull request #12188: URL: https://github.com/apache/flink/pull/12188#issuecomment-629594206 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

[GitHub] [flink] pnowojski commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

pnowojski commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r426121598 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[]

<    1   2   3   4   5   6