[GitHub] [flink] vahmed-hamdy commented on a change in pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-09 Thread GitBox
vahmed-hamdy commented on a change in pull request #18669: URL: https://github.com/apache/flink/pull/18669#discussion_r802792404 ## File path: flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java

[jira] [Assigned] (FLINK-24169) Flaky local YARN tests relying on log files

2022-02-09 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-24169: - Assignee: Zsombor Chikán > Flaky local YARN tests relying on log files >

[GitHub] [flink] flinkbot edited a comment on pull request #18665: [FLINK-24440][source] Announce and combine latest watermarks across SourceOperators

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18665: URL: https://github.com/apache/flink/pull/18665#issuecomment-1032724711 ## CI report: * 1157c129cd072947ae7249d4fc220a6bd8e7ba56 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 065c43692477ad54dc906bc6fb0b6afe8082ed0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 56d378844fb46ed0957fb6a96f800a949eb31f11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18573: [FLINK-25841][table] Expose plan via TableEnvironment.compilePlanSql/executePlan

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18573: URL: https://github.com/apache/flink/pull/18573#issuecomment-1025878917 ## CI report: * 11d5bf6f1d0869edf3c190e307a0f6394621bf70 Azure:

[GitHub] [flink] gaborgsomogyi commented on pull request #18687: [FLINK-24169][tests] Add TimeBased rolling policy and delete OnStartupTriggeringPolicy

2022-02-09 Thread GitBox
gaborgsomogyi commented on pull request #18687: URL: https://github.com/apache/flink/pull/18687#issuecomment-1033886192 Thanks for the contribution! A general good habit is to enable the following flag when creating a PR: `Allow edits by maintainers` Please set the following

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * e3c87614bd6772830da3339c3a43e1c35f3eccf1 Azure:

[GitHub] [flink] pnowojski commented on pull request #18665: [FLINK-24440][source] Announce and combine latest watermarks across SourceOperators

2022-02-09 Thread GitBox
pnowojski commented on pull request #18665: URL: https://github.com/apache/flink/pull/18665#issuecomment-1033885036 > Can we merge this PR already? What happens if SourceOperator receives the WatermarkAlignmentEvent? Yes, we could merge it as it is. First and foremost if

[jira] [Closed] (FLINK-26001) Implement ProjectableDecodingFormat for avro bulk format

2022-02-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26001. Assignee: Caizhi Weng Resolution: Fixed master: 479cfb9ea13f9a95419bbe89b26c63127c335483 >

[GitHub] [flink] JingsongLi merged pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

2022-02-09 Thread GitBox
JingsongLi merged pull request #18657: URL: https://github.com/apache/flink/pull/18657 -- 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] [Closed] (FLINK-25696) Introduce metadataConsumer to InitContext in Sink

2022-02-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25696. Resolution: Fixed master: bb1e5040a5271e7c31b7cfbecbb8b3b416c95973 > Introduce metadataConsumer

[GitHub] [flink] RocMarshal commented on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-09 Thread GitBox
RocMarshal commented on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1033880757 @slinkydeveloper Thanks a lot for your review . I made some change. PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] JingsongLi merged pull request #18412: [FLINK-25696][datastream] Introduce metadataConsumer to InitContext in Sink

2022-02-09 Thread GitBox
JingsongLi merged pull request #18412: URL: https://github.com/apache/flink/pull/18412 -- 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 edited a comment on pull request #18687: [FLINK-24169][tests] Add TimeBased rolling policy and delete OnStartupTriggeringPolicy

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18687: URL: https://github.com/apache/flink/pull/18687#issuecomment-1033868741 ## CI report: * ab574e31a308eb750ef411e0e88f04a64b1c9743 UNKNOWN * 277280ca72984935b498a899ad159b7f89f1122b UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * 49ac8e345069f15c61e005f551523e975171d99f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 8fbb6ad775a1fa3e417469a2356cd05f44b51d1c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * 323538b090554997be9ed691e37ebb2da221c7cb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18665: [FLINK-24440][source] Announce and combine latest watermarks across SourceOperators

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18665: URL: https://github.com/apache/flink/pull/18665#issuecomment-1032724711 ## CI report: * 1157c129cd072947ae7249d4fc220a6bd8e7ba56 Azure:

[jira] [Created] (FLINK-26060) Make Python specific exec nodes unsupported

2022-02-09 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-26060: --- Summary: Make Python specific exec nodes unsupported Key: FLINK-26060 URL: https://issues.apache.org/jira/browse/FLINK-26060 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18648: [FLINK-25845][table] Introduce EXECUTE PLAN

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18648: URL: https://github.com/apache/flink/pull/18648#issuecomment-1031569879 ## CI report: * 7fac1d21417d2d779b14e26402a0900e7417eeec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894 ## CI report: * 6408af3118bf294fdb704e36af7568756f3bd1c5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 56d378844fb46ed0957fb6a96f800a949eb31f11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * e3c87614bd6772830da3339c3a43e1c35f3eccf1 Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-09 Thread GitBox
dannycranmer commented on a change in pull request #18669: URL: https://github.com/apache/flink/pull/18669#discussion_r802570306 ## File path: flink-connectors/flink-connector-aws-kinesis-data-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSink.java

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802774901 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/table/Elasticsearch7DynamicSource.java

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802772088 ## File path:

[GitHub] [flink] flinkbot commented on pull request #18687: [FLINK-24169][tests] Add TimeBased rolling policy and delete OnStartupTriggeringPolicy

2022-02-09 Thread GitBox
flinkbot commented on pull request #18687: URL: https://github.com/apache/flink/pull/18687#issuecomment-1033868741 ## CI report: * ab574e31a308eb750ef411e0e88f04a64b1c9743 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * 49ac8e345069f15c61e005f551523e975171d99f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18684: [FLINK-26036] Only respond to TaskExecutor.freeSlot when running

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18684: URL: https://github.com/apache/flink/pull/18684#issuecomment-1033615903 ## CI report: * ca7b71c7558bf699360c74719f3ff932d0ac945b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 8fbb6ad775a1fa3e417469a2356cd05f44b51d1c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18666: [FLINK-25571] Update Elasticsearch Sink to use decomposed interfaces

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18666: URL: https://github.com/apache/flink/pull/18666#issuecomment-1032818588 ## CI report: * 4d4b1fa4851ce8564c319a2976c1cf0f48281b2a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18665: [FLINK-24440][source] Announce and combine latest watermarks across SourceOperators

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18665: URL: https://github.com/apache/flink/pull/18665#issuecomment-1032724711 ## CI report: * 1157c129cd072947ae7249d4fc220a6bd8e7ba56 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 8fa4fa18791e1b15e0e0d45ce624452be2d1ceea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18445: [FLINK-25755][runtime] AdaptiveScheduler: Introduce shared interface…

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18445: URL: https://github.com/apache/flink/pull/18445#issuecomment-1018642854 ## CI report: * c660ed20b710697879e1db386cc4e6ebdfd4b546 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

2022-02-09 Thread GitBox
MartijnVisser commented on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1033866395 @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] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * e3c87614bd6772830da3339c3a43e1c35f3eccf1 Azure:

[GitHub] [flink] flinkbot commented on pull request #18687: [FLINK-24169][tests] Add TimeBased rolling policy and delete OnStartupTriggeringPolicy

2022-02-09 Thread GitBox
flinkbot commented on pull request #18687: URL: https://github.com/apache/flink/pull/18687#issuecomment-1033864419 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] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802765395 ## File path:

[jira] [Commented] (FLINK-25875) "StatsDReporter. FilterCharacters" for special processing of the characters are comprehensive enough

2022-02-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489621#comment-17489621 ] Chesnay Schepler commented on FLINK-25875: -- Do you have a reference for which characters should

[jira] [Updated] (FLINK-24169) Flaky local YARN tests relying on log files

2022-02-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24169: --- Labels: pull-request-available test-stability (was: test-stability) > Flaky local YARN

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * 49ac8e345069f15c61e005f551523e975171d99f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 8fbb6ad775a1fa3e417469a2356cd05f44b51d1c Azure:

[GitHub] [flink] zch93 opened a new pull request #18687: [FLINK-24169][tests] Add TimeBased rolling policy and delete OnStartupTriggeringPolicy

2022-02-09 Thread GitBox
zch93 opened a new pull request #18687: URL: https://github.com/apache/flink/pull/18687 ## What is the purpose of the change *There is a log4j2 related [issue](https://issues.apache.org/jira/browse/LOG4J2-3155), specifically with the OnStartupTriggeringPolicy. The main problem here

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802762536 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/Elasticsearch7SourceBuilder.java

[GitHub] [flink] flinkbot edited a comment on pull request #18666: [FLINK-25571] Update Elasticsearch Sink to use decomposed interfaces

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18666: URL: https://github.com/apache/flink/pull/18666#issuecomment-1032818588 ## CI report: * 4d4b1fa4851ce8564c319a2976c1cf0f48281b2a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18665: [FLINK-24440][source] Announce and combine latest watermarks across SourceOperators

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18665: URL: https://github.com/apache/flink/pull/18665#issuecomment-1032724711 ## CI report: * 1157c129cd072947ae7249d4fc220a6bd8e7ba56 UNKNOWN Bot commands The @flinkbot bot supports the following commands: -

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 8fa4fa18791e1b15e0e0d45ce624452be2d1ceea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18445: [FLINK-25755][runtime] AdaptiveScheduler: Introduce shared interface…

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18445: URL: https://github.com/apache/flink/pull/18445#issuecomment-1018642854 ## CI report: * c660ed20b710697879e1db386cc4e6ebdfd4b546 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * e3c87614bd6772830da3339c3a43e1c35f3eccf1 Azure:

[jira] [Commented] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory

2022-02-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489617#comment-17489617 ] Chesnay Schepler commented on FLINK-26003: -- This is trickier than at first glance because the

[GitHub] [flink] dmvk commented on a change in pull request #18445: [FLINK-25755][runtime] AdaptiveScheduler: Introduce shared interface…

2022-02-09 Thread GitBox
dmvk commented on a change in pull request #18445: URL: https://github.com/apache/flink/pull/18445#discussion_r802743707 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateTransitions.java ## @@ -0,0 +1,149 @@ +/* + * Licensed to the

[jira] [Assigned] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory

2022-02-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-26003: Assignee: (was: Chesnay Schepler) > Use Jackson serialization for persisting

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * 49ac8e345069f15c61e005f551523e975171d99f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 8fbb6ad775a1fa3e417469a2356cd05f44b51d1c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * Unknown: [CANCELED](TBD) * 1354a81b74c87d62d962f07b066b6766eeda8191 Azure:

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802754265 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/Elasticsearch7SourceBuilder.java

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 8fa4fa18791e1b15e0e0d45ce624452be2d1ceea Azure:

[jira] [Assigned] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-02-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-24229: - Assignee: Yuri Gusev (was: Zichen Liu) > [FLIP-171] DynamoDB implementation of Async

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * e3c87614bd6772830da3339c3a43e1c35f3eccf1 Azure:

[jira] [Updated] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-02-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-24229: -- Fix Version/s: (was: 1.15.0) > [FLIP-171] DynamoDB implementation of Async Sink >

[GitHub] [flink] CrynetLogistics commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033848905 -- 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.

[jira] [Created] (FLINK-26059) ResourceProfile#ANY can cause overflow exceptions

2022-02-09 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-26059: Summary: ResourceProfile#ANY can cause overflow exceptions Key: FLINK-26059 URL: https://issues.apache.org/jira/browse/FLINK-26059 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * 49ac8e345069f15c61e005f551523e975171d99f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 8fbb6ad775a1fa3e417469a2356cd05f44b51d1c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * Unknown: [CANCELED](TBD) * 1354a81b74c87d62d962f07b066b6766eeda8191 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #18660: [FLINK-25975][docs] add document about AvroParquet format use cases

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18660: URL: https://github.com/apache/flink/pull/18660#issuecomment-1032465099 ## CI report: * 0e3f1f52759cc30f71495f1a9a254daef3b06fe3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * Unknown: [CANCELED](TBD) * aea6257d81d927242640885759efeaeb53dbd550 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 8fa4fa18791e1b15e0e0d45ce624452be2d1ceea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * e3c87614bd6772830da3339c3a43e1c35f3eccf1 Azure:

[GitHub] [flink] afedulov commented on a change in pull request #18666: [FLINK-25571] Update Elasticsearch Sink to use decomposed interfaces

2022-02-09 Thread GitBox
afedulov commented on a change in pull request #18666: URL: https://github.com/apache/flink/pull/18666#discussion_r802745086 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriterITCase.java

[GitHub] [flink] CrynetLogistics commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-09 Thread GitBox
CrynetLogistics commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1033843145 -- 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.

[GitHub] [flink] CrynetLogistics commented on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-09 Thread GitBox
CrynetLogistics commented on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033843340 @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

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-02-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489602#comment-17489602 ] Danny Cranmer commented on FLINK-24229: --- [~Gusev] unfortunately I will not have the capacity to

[GitHub] [flink] CrynetLogistics commented on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-09 Thread GitBox
CrynetLogistics commented on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033842115 -- 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.

[GitHub] [flink] CrynetLogistics commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-09 Thread GitBox
CrynetLogistics commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1033840554 -- 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.

[GitHub] [flink] flinkbot commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
flinkbot commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * 49ac8e345069f15c61e005f551523e975171d99f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 8fbb6ad775a1fa3e417469a2356cd05f44b51d1c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * Unknown: [CANCELED](TBD) * a0654702899b4a8b6de9a987d765381a154036c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 8fa4fa18791e1b15e0e0d45ce624452be2d1ceea Azure:

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802739776 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/common/ElasticsearchUtil.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * e3c87614bd6772830da3339c3a43e1c35f3eccf1 Azure:

[GitHub] [flink] flinkbot commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
flinkbot commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033835744 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] CrynetLogistics commented on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-09 Thread GitBox
CrynetLogistics commented on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1033834457 -- 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.

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 8fbb6ad775a1fa3e417469a2356cd05f44b51d1c Azure:

[GitHub] [flink] afedulov commented on a change in pull request #18666: [FLINK-25571] Update Elasticsearch Sink to use decomposed interfaces

2022-02-09 Thread GitBox
afedulov commented on a change in pull request #18666: URL: https://github.com/apache/flink/pull/18666#discussion_r802735376 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java

[GitHub] [flink] flinkbot edited a comment on pull request #18660: [FLINK-25975][docs] add document about AvroParquet format use cases

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18660: URL: https://github.com/apache/flink/pull/18660#issuecomment-1032465099 ## CI report: * 4d5b90239be7e5e9fb7dfa3fb85f91a1b1b8081f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * e3c87614bd6772830da3339c3a43e1c35f3eccf1 Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033832751 -- 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.

[jira] [Updated] (FLINK-25977) Close sink client and sink http client for KDS/KDF Sinks

2022-02-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25977: --- Labels: pull-request-available (was: ) > Close sink client and sink http client for

[GitHub] [flink] CrynetLogistics opened a new pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-09 Thread GitBox
CrynetLogistics opened a new pull request #18686: URL: https://github.com/apache/flink/pull/18686 …& ITs ## What is the purpose of the change Bugfix: closes http & sdk clients in KDS Sink. ## Brief change log Bugfix: closes http & sdk clients in KDS Sink.

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802732166 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/split/Elasticsearch7SplitState.java

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802730687 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 8fbb6ad775a1fa3e417469a2356cd05f44b51d1c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * b33d774d6f9739ada14ba3f8c007684898f4c3fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18660: [FLINK-25975][docs] add document about AvroParquet format use cases

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18660: URL: https://github.com/apache/flink/pull/18660#issuecomment-1032465099 ## CI report: * 4d5b90239be7e5e9fb7dfa3fb85f91a1b1b8081f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 2833dba1facd9f745c9c713cb017319947a85f47 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * e3c87614bd6772830da3339c3a43e1c35f3eccf1 Azure:

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-09 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r802727244 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 8fbb6ad775a1fa3e417469a2356cd05f44b51d1c Azure:

<    1   2   3   4   5   6   7   8   9   10   >