[jira] [Assigned] (FLINK-24058) TaskSlotTableImplTest.testMarkSlotActiveDeactivatesSlotTimeout fails on azure

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24058: Assignee: Chesnay Schepler >

[jira] [Commented] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on azure

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407242#comment-17407242 ] Chesnay Schepler commented on FLINK-15451: -- Looks like a different issue. {code} Aug 31

[jira] [Commented] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-08-31 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407237#comment-17407237 ] Arvid Heise commented on FLINK-24054: - If the external system strictly follows +I key +I key, you

[GitHub] [flink] flinkbot edited a comment on pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-909101643 ## CI report: * 28513efba235e7f4b923bcfd4a111eb3cf241d43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * ac9ad3d39442f0479d1f74d4664c3351fc311a41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17049: [FLINK-23971][tests] fix connector testing framework error when compare records in different splits

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17049: URL: https://github.com/apache/flink/pull/17049#issuecomment-908270735 ## CI report: * Unknown: [CANCELED](TBD) * daad66852e5f50e47b36652f0207a63f3096c125 Azure:

[jira] [Created] (FLINK-24078) Remove brackets around variables

2021-08-31 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24078: Summary: Remove brackets around variables Key: FLINK-24078 URL: https://issues.apache.org/jira/browse/FLINK-24078 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17040: URL: https://github.com/apache/flink/pull/17040#issuecomment-907834154 ## CI report: * Unknown: [CANCELED](TBD) * 752c9db951f0ba3f26695b873b1f81dc6e830cab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17007: [FLINK-17495][metrics] Add additional variables config for metric reporters

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17007: URL: https://github.com/apache/flink/pull/17007#issuecomment-906871869 ## CI report: * ed8cc744f1416145c6dd46dd43edcf90e972fdf7 Azure:

[jira] [Comment Edited] (FLINK-23850) Test Kafka table connector with new runtime provider

2021-08-31 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407235#comment-17407235 ] Matthias edited comment on FLINK-23850 at 8/31/21, 10:42 AM: - Thanks for the

[jira] [Comment Edited] (FLINK-23850) Test Kafka table connector with new runtime provider

2021-08-31 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407235#comment-17407235 ] Matthias edited comment on FLINK-23850 at 8/31/21, 10:41 AM: - Thanks for the

[jira] [Comment Edited] (FLINK-23850) Test Kafka table connector with new runtime provider

2021-08-31 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407235#comment-17407235 ] Matthias edited comment on FLINK-23850 at 8/31/21, 10:41 AM: - Thanks for the

[jira] [Commented] (FLINK-23850) Test Kafka table connector with new runtime provider

2021-08-31 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407235#comment-17407235 ] Matthias commented on FLINK-23850: -- Thanks for the explaination, [~twalthr]. I will give it another

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

2021-08-31 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407234#comment-17407234 ] Xintong Song commented on FLINK-20928: --

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

2021-08-31 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407233#comment-17407233 ] Xintong Song commented on FLINK-23828: --

[jira] [Comment Edited] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407231#comment-17407231 ] Timo Walther edited comment on FLINK-24054 at 8/31/21, 10:39 AM: - In the

[jira] [Updated] (FLINK-24058) TaskSlotTableImplTest.testMarkSlotActiveDeactivatesSlotTimeout fails on azure

2021-08-31 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24058: - Priority: Critical (was: Major) >

[jira] [Commented] (FLINK-24058) TaskSlotTableImplTest.testMarkSlotActiveDeactivatesSlotTimeout fails on azure

2021-08-31 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407232#comment-17407232 ] Xintong Song commented on FLINK-24058: --

[jira] [Created] (FLINK-24077) HBaseConnectorITCase.testTableSink

2021-08-31 Thread Xintong Song (Jira)
Xintong Song created FLINK-24077: Summary: HBaseConnectorITCase.testTableSink Key: FLINK-24077 URL: https://issues.apache.org/jira/browse/FLINK-24077 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407231#comment-17407231 ] Timo Walther commented on FLINK-24054: -- In the first version, the test was failing because I did

[jira] [Commented] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on azure

2021-08-31 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407229#comment-17407229 ] Arvid Heise commented on FLINK-15451: - I got a case now

[GitHub] [flink-training] NicoK commented on a change in pull request #31: [FLINK-23653] exercise and test rework

2021-08-31 Thread GitBox
NicoK commented on a change in pull request #31: URL: https://github.com/apache/flink-training/pull/31#discussion_r699192091 ## File path: rides-and-fares/src/test/java/org/apache/flink/training/exercises/ridesandfares/RidesAndFaresIntegrationTest.java ## @@ -0,0 +1,91 @@ +/*

[GitHub] [flink-training] NicoK commented on a change in pull request #31: [FLINK-23653] exercise and test rework

2021-08-31 Thread GitBox
NicoK commented on a change in pull request #31: URL: https://github.com/apache/flink-training/pull/31#discussion_r699191949 ## File path: rides-and-fares/src/test/java/org/apache/flink/training/exercises/ridesandfares/RidesAndFaresIntegrationTest.java ## @@ -0,0 +1,91 @@ +/*

[jira] [Commented] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

2021-08-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407222#comment-17407222 ] Danny Cranmer commented on FLINK-24041: --- Thanks for the contribution [~CrynetLogistics]. I can

[GitHub] [flink-training] NicoK commented on a change in pull request #31: [FLINK-23653] exercise and test rework

2021-08-31 Thread GitBox
NicoK commented on a change in pull request #31: URL: https://github.com/apache/flink-training/pull/31#discussion_r699187127 ## File path: hourly-tips/src/main/java/org/apache/flink/training/exercises/hourlytips/HourlyTipsExercise.java ## @@ -56,8 +55,8 @@ public

[jira] [Assigned] (FLINK-24041) [FLIP-171] Generic AsyncSinkBase

2021-08-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-24041: - Assignee: Zichen Liu > [FLIP-171] Generic AsyncSinkBase >

[jira] [Commented] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-08-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407218#comment-17407218 ] Kurt Young commented on FLINK-24054: The example you gave is test, whose behavior could be changed &

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * ac9ad3d39442f0479d1f74d4664c3351fc311a41 Azure:

[GitHub] [flink] flinkbot commented on pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
flinkbot commented on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-909101643 ## CI report: * 28513efba235e7f4b923bcfd4a111eb3cf241d43 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17065: [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17065: URL: https://github.com/apache/flink/pull/17065#issuecomment-908917839 ## CI report: * d6889e3f8c9ee40c9dcce7b1691b85001371420a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17058: [FLINK-23664][docs] Add docs for KafkaSink

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17058: URL: https://github.com/apache/flink/pull/17058#issuecomment-908449514 ## CI report: * 6071b8b511f1a462cdf6d22bb45a2a8bf083cf18 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17040: URL: https://github.com/apache/flink/pull/17040#issuecomment-907834154 ## CI report: * Unknown: [CANCELED](TBD) * 752c9db951f0ba3f26695b873b1f81dc6e830cab UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #17022: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17022: URL: https://github.com/apache/flink/pull/17022#issuecomment-907158087 ## CI report: * dd573c4bb1475210822d64e5df8b659f7ecc3546 Azure:

[GitHub] [flink] zentol commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
zentol commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699185725 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed offsets

[GitHub] [flink] AHeise commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
AHeise commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699184559 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed offsets

[GitHub] [flink] zentol commented on pull request #17022: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

2021-08-31 Thread GitBox
zentol commented on pull request #17022: URL: https://github.com/apache/flink/pull/17022#issuecomment-909098111 You need to rebase the branch to fix the libssl issue. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] AHeise commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
AHeise commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699181895 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed offsets

[jira] [Commented] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407214#comment-17407214 ] Timo Walther commented on FLINK-24054: -- It really depends on the use case. For our current Kafka

[GitHub] [flink] AHeise commented on a change in pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

2021-08-31 Thread GitBox
AHeise commented on a change in pull request #17050: URL: https://github.com/apache/flink/pull/17050#discussion_r699178562 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/api/FileReadingWatermarkITCase.java ## @@ -17,130 +17,109 @@ package

[jira] [Closed] (FLINK-24075) Apache Flink 1.13.1 Docker images are published for linux/arm

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24075. Resolution: Fixed All 1.13.1 images have been rebuilt. > Apache Flink 1.13.1 Docker

[jira] [Updated] (FLINK-23895) Upsert materializer is not inserted for all sink providers

2021-08-31 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-23895: Description: The new {{SinkUpsertMaterializer}} is not inserted for

[jira] [Closed] (FLINK-24067) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint

2021-08-31 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24067. --- Resolution: Duplicate > CheckpointBarrierHandler may skip the markAlignmentStart for alignment >

[GitHub] [flink] zentol commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
zentol commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699161962 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed offsets

[GitHub] [flink] zentol commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
zentol commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699161642 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed offsets

[GitHub] [flink] CrynetLogistics commented on pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
CrynetLogistics commented on pull request #17040: URL: https://github.com/apache/flink/pull/17040#issuecomment-909076596 @flinkbot run travis -- 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 the

[GitHub] [flink] CrynetLogistics commented on pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
CrynetLogistics commented on pull request #17040: URL: https://github.com/apache/flink/pull/17040#issuecomment-909076474 @flinkbot run azure -- 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 the

[GitHub] [flink] zentol commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
zentol commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699159076 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed offsets

[GitHub] [flink] zentol commented on a change in pull request #17007: [FLINK-17495][metrics] Add additional variables config for metric reporters

2021-08-31 Thread GitBox
zentol commented on a change in pull request #17007: URL: https://github.com/apache/flink/pull/17007#discussion_r699157999 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/FrontMetricGroup.java ## @@ -72,8 +74,15 @@ public MetricGroup

[jira] [Comment Edited] (FLINK-23544) Window TVF Supports session window

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407205#comment-17407205 ] Timo Walther edited comment on FLINK-23544 at 8/31/21, 9:41 AM: If we

[GitHub] [flink] zentol commented on a change in pull request #17007: [FLINK-17495][metrics] Add additional variables config for metric reporters

2021-08-31 Thread GitBox
zentol commented on a change in pull request #17007: URL: https://github.com/apache/flink/pull/17007#discussion_r699157438 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/FrontMetricGroup.java ## @@ -72,8 +74,15 @@ public MetricGroup

[jira] [Comment Edited] (FLINK-23544) Window TVF Supports session window

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407205#comment-17407205 ] Timo Walther edited comment on FLINK-23544 at 8/31/21, 9:40 AM: If we

[jira] [Commented] (FLINK-23544) Window TVF Supports session window

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407205#comment-17407205 ] Timo Walther commented on FLINK-23544: -- If we want to fix this issue properly we need to wait for

[GitHub] [flink] zentol commented on a change in pull request #17007: [FLINK-17495][metrics] Add additional variables config for metric reporters

2021-08-31 Thread GitBox
zentol commented on a change in pull request #17007: URL: https://github.com/apache/flink/pull/17007#discussion_r699155868 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ReporterSetup.java ## @@ -284,12 +304,19 @@ private static ReporterSetup

[jira] [Updated] (FLINK-24051) Make consumer.group-id optional for KafkaSource

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24051: Affects Version/s: (was: 1.15.0) > Make consumer.group-id optional for KafkaSource >

[jira] [Updated] (FLINK-23875) ReducingUpsertSink can loose records during failover

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-23875: Affects Version/s: (was: 1.15.0) > ReducingUpsertSink can loose records during failover >

[jira] [Updated] (FLINK-24055) Deprecate FlinkKafkaConsumer

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24055: Affects Version/s: (was: 1.15.0) > Deprecate FlinkKafkaConsumer >

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * ac9ad3d39442f0479d1f74d4664c3351fc311a41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17062: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint (1.14)

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17062: URL: https://github.com/apache/flink/pull/17062#issuecomment-908868024 ## CI report: * 5f49d4c824acc8c2170abceeef45bd918f674b2c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17058: [FLINK-23664][docs] Add docs for KafkaSink

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17058: URL: https://github.com/apache/flink/pull/17058#issuecomment-908449514 ## CI report: * 6071b8b511f1a462cdf6d22bb45a2a8bf083cf18 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-893364145 ## CI report: * 1de6e0b83ee64c22c861a9d8e639483aaaba9e7f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[jira] [Commented] (FLINK-24051) Make consumer.group-id optional for KafkaSource

2021-08-31 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407202#comment-17407202 ] Arvid Heise commented on FLINK-24051: - Merged into master as

[GitHub] [flink] AHeise merged pull request #17052: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
AHeise merged pull request #17052: URL: https://github.com/apache/flink/pull/17052 -- 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 the specific comment. To unsubscribe, e-mail:

[jira] [Comment Edited] (FLINK-23850) Test Kafka table connector with new runtime provider

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407198#comment-17407198 ] Timo Walther edited comment on FLINK-23850 at 8/31/21, 9:25 AM:

[GitHub] [flink] flinkbot commented on pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
flinkbot commented on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-909061122 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] AHeise commented on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
AHeise commented on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-909060257 > LGTM % do you know if the KafkaSource implements all the listed metrics? Thanks for reminding. I actually found 3 metrics that are currently not supported. -- This is

[jira] [Commented] (FLINK-23850) Test Kafka table connector with new runtime provider

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407198#comment-17407198 ] Timo Walther commented on FLINK-23850: -- [~mapohl] you could implement the same pipeline as in

[jira] [Closed] (FLINK-23895) Upsert materializer is not inserted for all sink providers

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-23895. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] CrynetLogistics opened a new pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
CrynetLogistics opened a new pull request #17068: URL: https://github.com/apache/flink/pull/17068 ## What is the purpose of the change "As a Sink *developer*, I would like to be able to inherit the AbstractAsyncSink class, and implement its abstract method

[GitHub] [flink-web] xintongsong closed pull request #465: announcing the 1.14.0 release candidate

2021-08-31 Thread GitBox
xintongsong closed pull request #465: URL: https://github.com/apache/flink-web/pull/465 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] twalthr closed pull request #17060: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers

2021-08-31 Thread GitBox
twalthr closed pull request #17060: URL: https://github.com/apache/flink/pull/17060 -- 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 the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-24076) Implement Table API walkthrough in flink-playground

2021-08-31 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24076: - Description: Currently, the {{flink-playground}} Table API walkthrough fails due to it only providing

[jira] [Created] (FLINK-24076) Implement Table API walkthrough in flink-playground

2021-08-31 Thread Matthias (Jira)
Matthias created FLINK-24076: Summary: Implement Table API walkthrough in flink-playground Key: FLINK-24076 URL: https://issues.apache.org/jira/browse/FLINK-24076 Project: Flink Issue Type:

[GitHub] [flink-web] xintongsong commented on a change in pull request #465: announcing the 1.14.0 release candidate

2021-08-31 Thread GitBox
xintongsong commented on a change in pull request #465: URL: https://github.com/apache/flink-web/pull/465#discussion_r699131230 ## File path: _posts/2021-08-31-release-1.14.0-rc0.md ## @@ -0,0 +1,39 @@ +--- +layout: post +title: "Help us stabilize Apache Flink 1.14.0 RC0"

[jira] [Comment Edited] (FLINK-23993) Describe eventually-consistency of materializing upserts

2021-08-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407180#comment-17407180 ] Jingsong Lee edited comment on FLINK-23993 at 8/31/21, 9:07 AM: I think

[GitHub] [flink] fapaul commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
fapaul commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699130795 ## File path: docs/content/docs/connectors/datastream/streamfile_sink.md ## @@ -29,6 +29,10 @@ under the License. This connector provides a Sink that

[jira] [Updated] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

2021-08-31 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22889: - Priority: Critical (was: Blocker) > JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure >

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

2021-08-31 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407191#comment-17407191 ] Xintong Song commented on FLINK-22889: -- Reached out to [~roman] offline. We are downgrading this to

[GitHub] [flink] twalthr commented on a change in pull request #17060: [FLINK-23895][table] Upsert materializer is not inserted for all sink providers

2021-08-31 Thread GitBox
twalthr commented on a change in pull request #17060: URL: https://github.com/apache/flink/pull/17060#discussion_r699129141 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -260,76

[jira] [Created] (FLINK-24075) Apache Flink 1.13.1 Docker images are published for linux/arm

2021-08-31 Thread Matthias (Jira)
Matthias created FLINK-24075: Summary: Apache Flink 1.13.1 Docker images are published for linux/arm Key: FLINK-24075 URL: https://issues.apache.org/jira/browse/FLINK-24075 Project: Flink Issue

[jira] [Assigned] (FLINK-24075) Apache Flink 1.13.1 Docker images are published for linux/arm

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24075: Assignee: Chesnay Schepler > Apache Flink 1.13.1 Docker images are published for

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * ac9ad3d39442f0479d1f74d4664c3351fc311a41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-908893945 ## CI report: * 167a600021ec50d0fa82e8806593391fe57a545a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17049: [FLINK-23971][tests] fix connector testing framework error when compare records in different splits

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17049: URL: https://github.com/apache/flink/pull/17049#issuecomment-908270735 ## CI report: * Unknown: [CANCELED](TBD) * 8e565dae5256ed75289f4ad53c11840889fdc5e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * ed7683ef12ccef4aa05782a762ff5c4a61535053 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-893364145 ## CI report: * 1de6e0b83ee64c22c861a9d8e639483aaaba9e7f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[jira] [Created] (FLINK-24074) Check 1.14 licensing

2021-08-31 Thread Xintong Song (Jira)
Xintong Song created FLINK-24074: Summary: Check 1.14 licensing Key: FLINK-24074 URL: https://issues.apache.org/jira/browse/FLINK-24074 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-24073) Statefun 2.2 documentation build fails on buildbot

2021-08-31 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24073: Summary: Statefun 2.2 documentation build fails on buildbot Key: FLINK-24073 URL: https://issues.apache.org/jira/browse/FLINK-24073 Project: Flink

[jira] [Commented] (FLINK-23993) Describe eventually-consistency of materializing upserts

2021-08-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407180#comment-17407180 ] Jingsong Lee commented on FLINK-23993: -- I think we can not finish this in 1.14 release. Actually,

[jira] [Updated] (FLINK-24071) Flink 1.12 HDFS sink have a problem,reported as OOM

2021-08-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24071: Component/s: Connectors / FileSystem > Flink 1.12 HDFS sink have a problem,reported as OOM >

[jira] [Updated] (FLINK-24071) Flink 1.12 HDFS sink have a problem,reported as OOM

2021-08-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24071: Description: {code} org.apache.flink.runtime.JobException: Recovery is suppressed by

[jira] [Closed] (FLINK-23663) Reduce state size in ChangelogNormalize through filter push down

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-23663. Fix Version/s: 1.15.0 1.14.0 Resolution: Fixed Fixed in master: commit

[GitHub] [flink] pnowojski commented on a change in pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

2021-08-31 Thread GitBox
pnowojski commented on a change in pull request #16988: URL: https://github.com/apache/flink/pull/16988#discussion_r699022660 ## File path: docs/content/docs/deployment/network_buffer.md ## @@ -0,0 +1,125 @@ +--- +title: "Network Tuning" +weight: 100 +type: docs +aliases: + -

[jira] [Commented] (FLINK-23544) Window TVF Supports session window

2021-08-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407174#comment-17407174 ] Jark Wu commented on FLINK-23544: - I guess the reason maybe PARTITIONED BY clause of TVF syntax is not

[GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-08-31 Thread GitBox
Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699104914 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] flinkbot edited a comment on pull request #17058: [FLINK-23664][docs] Add docs for KafkaSink

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17058: URL: https://github.com/apache/flink/pull/17058#issuecomment-908449514 ## CI report: * 6071b8b511f1a462cdf6d22bb45a2a8bf083cf18 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * ac9ad3d39442f0479d1f74d4664c3351fc311a41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17049: [FLINK-23971][tests] fix connector testing framework error when compare records in different splits

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17049: URL: https://github.com/apache/flink/pull/17049#issuecomment-908270735 ## CI report: * Unknown: [CANCELED](TBD) * 8e565dae5256ed75289f4ad53c11840889fdc5e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17025: URL: https://github.com/apache/flink/pull/17025#issuecomment-907189639 ## CI report: * 20abcd8ee08baa3acb52d606bf1db76df6e9769e Azure:

<    2   3   4   5   6   7   8   >