[GitHub] [flink] AHeise merged pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on the unified sink (FLIP-143)

2021-10-07 Thread GitBox
AHeise merged pull request #17363: URL: https://github.com/apache/flink/pull/17363 -- 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] [Commented] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure

2021-10-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425382#comment-17425382 ] Arvid Heise commented on FLINK-24405: - Merged into 1.14 as

[jira] [Resolved] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure

2021-10-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24405. - Fix Version/s: 1.14.1 Resolution: Fixed > KafkaWriterITCase.testLingeringTransaction

[GitHub] [flink] AHeise merged pull request #17421: [FLINK-24405][tests] Introduce util to reliably drain all messages from a kafka topic

2021-10-07 Thread GitBox
AHeise merged pull request #17421: URL: https://github.com/apache/flink/pull/17421 -- 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] flinkbot commented on pull request #17423: [FLINK-24443][table-runtime] Reenable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs

2021-10-07 Thread GitBox
flinkbot commented on pull request #17423: URL: https://github.com/apache/flink/pull/17423#issuecomment-937528000 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] [Updated] (FLINK-24443) IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs fail with output mismatch

2021-10-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24443: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] slinkydeveloper opened a new pull request #17423: [FLINK-24443][table-runtime] Reenable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs

2021-10-07 Thread GitBox
slinkydeveloper opened a new pull request #17423: URL: https://github.com/apache/flink/pull/17423 ## What is the purpose of the change Fixed and reenabled `IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs` ## Brief change log - Fixed and reenabled

[jira] [Created] (FLINK-24466) Interval Join late events handling behaviour is not consistent

2021-10-07 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24466: --- Summary: Interval Join late events handling behaviour is not consistent Key: FLINK-24466 URL: https://issues.apache.org/jira/browse/FLINK-24466

[jira] [Updated] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure

2021-10-07 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24405: Affects Version/s: 1.14.0 > KafkaWriterITCase.testLingeringTransaction fails on azure >

[jira] [Updated] (FLINK-24465) Wrong javadoc and documentation for buffer timeout

2021-10-07 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24465: - Description: The javadoc for {{setBufferTimeout}} and similarly the documentation for

[jira] [Assigned] (FLINK-24409) Kafka topics with periods in their names generate a constant stream of errors

2021-10-07 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Preuss reassigned FLINK-24409: Assignee: Qingsheng Ren (was: Alexander Preuss) > Kafka topics with periods in

[GitHub] [flink] fapaul commented on a change in pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-07 Thread GitBox
fapaul commented on a change in pull request #17374: URL: https://github.com/apache/flink/pull/17374#discussion_r723896941 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractor.java

[jira] [Updated] (FLINK-24465) Wrong javadoc and documentation for buffer timeout

2021-10-07 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24465: - Description: The javadoc for {{setBufferTimeout}} and similarly the documentation for

[jira] [Updated] (FLINK-24465) Wrong javadoc and documentation for buffer timeout

2021-10-07 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24465: - Description: The javadoc for {{setBufferTimeout}} and similarly the documentation for

[jira] [Created] (FLINK-24465) Wrong javadoc and documentation for buffer timeout

2021-10-07 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24465: Summary: Wrong javadoc and documentation for buffer timeout Key: FLINK-24465 URL: https://issues.apache.org/jira/browse/FLINK-24465 Project: Flink

[jira] [Resolved] (FLINK-24382) RecordsOut metric for sinks is inaccurate

2021-10-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24382. - Fix Version/s: 1.14.1 1.15.0 Assignee: Fabian Paul

[jira] [Commented] (FLINK-24382) RecordsOut metric for sinks is inaccurate

2021-10-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425370#comment-17425370 ] Arvid Heise commented on FLINK-24382: - Merged into 1.14 as d5f0d492334e54e005fe39b9d2a623ebe6c2f99b.

[GitHub] [flink] AHeise merged pull request #17420: [BP-1.14][FLINK-24382][metrics] Do not compute recordsOut metric in SinkOperat…

2021-10-07 Thread GitBox
AHeise merged pull request #17420: URL: https://github.com/apache/flink/pull/17420 -- 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] AHeise commented on pull request #17235: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release

2021-10-07 Thread GitBox
AHeise commented on pull request #17235: URL: https://github.com/apache/flink/pull/17235#issuecomment-937503443 @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 specific

[GitHub] [flink] AHeise commented on pull request #17401: [FLINK-24409][connectors] Fix metrics errors with topics names with periods

2021-10-07 Thread GitBox
AHeise commented on pull request #17401: URL: https://github.com/apache/flink/pull/17401#issuecomment-937502238 @PatrickRen could you PTAL? I think we should have a test case for record lag metric as well. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] AHeise commented on pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

2021-10-07 Thread GitBox
AHeise commented on pull request #17358: URL: https://github.com/apache/flink/pull/17358#issuecomment-937497529 Also merged into release-1.14. -- 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

[GitHub] [flink] AHeise merged pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

2021-10-07 Thread GitBox
AHeise merged pull request #17358: URL: https://github.com/apache/flink/pull/17358 -- 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] AHeise commented on pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

2021-10-07 Thread GitBox
AHeise commented on pull request #17358: URL: https://github.com/apache/flink/pull/17358#issuecomment-937485519 Thanks. I'm merging. -- 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

<    1   2   3