[jira] [Commented] (FLINK-17506) SavepointEnvironment does not honour 'io.tmp.dirs' property

2021-09-08 Thread David Causse (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411983#comment-17411983 ] David Causse commented on FLINK-17506: -- I'm seeing a _similar_ problem (with 1.12.1, 1.13.2 and

[jira] [Commented] (FLINK-24214) A submit job failure crashes the sql client

2021-09-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411981#comment-17411981 ] Timo Walther commented on FLINK-24214: -- Seems the latest refactorings of the SQL Client in 1.13

[jira] [Updated] (FLINK-24161) Can not stop the job with savepoint while a task is finishing

2021-09-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24161: --- Labels: pull-request-available (was: ) > Can not stop the job with savepoint while a task

[GitHub] [flink] dawidwys opened a new pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

2021-09-08 Thread GitBox
dawidwys opened a new pull request #17200: URL: https://github.com/apache/flink/pull/17200 ## What is the purpose of the change * In endData() if there is an pending savepoint without drain, we fail the task by throw an exception. * When triggering stop-with-savepoint without drain,

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

2021-09-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411971#comment-17411971 ] Timo Walther commented on FLINK-20370: -- [~lzljs3620320] [~jark] What is the current status of this

[jira] [Assigned] (FLINK-22942) Disable upsert into syntax in Flink SQL

2021-09-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-22942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-22942: - Assignee: Francesco Guardiani > Disable upsert into syntax in Flink SQL >

[jira] [Assigned] (FLINK-22942) Disable upsert into syntax in Flink SQL

2021-09-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-22942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-22942: - Assignee: (was: Francesco) > Disable upsert into syntax in Flink SQL >

[jira] [Assigned] (FLINK-22942) Disable upsert into syntax in Flink SQL

2021-09-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-22942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-22942: - Assignee: Francesco > Disable upsert into syntax in Flink SQL >

[GitHub] [flink] flinkbot commented on pull request #17199: [FLINK-23848][connector/pulsar] Fix the consumer not found error in test. [1.14]

2021-09-08 Thread GitBox
flinkbot commented on pull request #17199: URL: https://github.com/apache/flink/pull/17199#issuecomment-915288286 ## CI report: * 852571fd2ee436ef97c309efd01e4a054abf4426 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17189: URL: https://github.com/apache/flink/pull/17189#issuecomment-914637509 ## CI report: * 93a633abd0aa205e32de24ded4c5b1e9aa9d4c64 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17185: [BP-1.14][FLINK-24160][tests] Use FS checkpoint storage in PartiallyFinishedSourcesITCase

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17185: URL: https://github.com/apache/flink/pull/17185#issuecomment-914350232 ## CI report: * b8e22a6a23b7173f2744f0cf9b565aa5014b2311 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17151: [FLINK-23180] Do not initialize checkpoint base locations when checkp…

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17151: URL: https://github.com/apache/flink/pull/17151#issuecomment-913110826 ## CI report: * 4b431b9e8b67caf75739a39180715e0fcc23279e UNKNOWN * d57aa64c5010aca1d5e481e0eb68dbc090963ac1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17118: URL: https://github.com/apache/flink/pull/17118#issuecomment-911539514 ## CI report: * 0714a5578052a2e0ff1cddf70ac55ac8285f39ba Azure:

[jira] [Closed] (FLINK-24034) Upgrade commons-compress to 1.21

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24034. Fix Version/s: (was: 1.14.1) (was: 1.15.0)

[jira] [Updated] (FLINK-18996) Avoid disorder for time interval join

2021-09-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-18996: - Priority: Critical (was: Minor) > Avoid disorder for time interval join >

[jira] [Updated] (FLINK-24191) Adjusting number of buffers besides buffer size

2021-09-08 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24191: -- Description: "Buffer debloat" adjusts only the buffer size but it also makes sense to

[GitHub] [flink] flinkbot commented on pull request #17199: [FLINK-23848][connector/pulsar] Fix the consumer not found error in test. [1.14]

2021-09-08 Thread GitBox
flinkbot commented on pull request #17199: URL: https://github.com/apache/flink/pull/17199#issuecomment-915277656 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-22113) UniqueKey constraint is lost with multiple sources join in SQL

2021-09-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22113: - Priority: Critical (was: Major) > UniqueKey constraint is lost with multiple sources join in

[GitHub] [flink] syhily opened a new pull request #17199: [FLINK-23848][connector/pulsar] Fix the consumer not found error in test.

2021-09-08 Thread GitBox
syhily opened a new pull request #17199: URL: https://github.com/apache/flink/pull/17199 ## What is the purpose of the change Pulsar would disconnect the existed consumer when we perform a seek operation on a topic partition. If we have multiple consumers with the same

[jira] [Updated] (FLINK-24190) Handling large record with buffer debloat

2021-09-08 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24190: -- Description: If the buffer size will be too small(less than record size) due to

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

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

[GitHub] [flink] flinkbot edited a comment on pull request #17190: (1.14) [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17190: URL: https://github.com/apache/flink/pull/17190#issuecomment-914893423 ## CI report: * 312d3fdff5268054063007839731ff74f8ed7d71 Azure:

[GitHub] [flink] AHeise merged pull request #17119: [FLINK-23848][connector/pulsar] Fix the consumer not found error in test.

2021-09-08 Thread GitBox
AHeise merged pull request #17119: URL: https://github.com/apache/flink/pull/17119 -- 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 a change in pull request #17119: [FLINK-23848][connector/pulsar] Fix the consumer not found error in test.

2021-09-08 Thread GitBox
AHeise commented on a change in pull request #17119: URL: https://github.com/apache/flink/pull/17119#discussion_r704447651 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java ## @@

[GitHub] [flink] AHeise commented on a change in pull request #17119: [FLINK-23848][connector/pulsar] Fix the consumer not found error in test.

2021-09-08 Thread GitBox
AHeise commented on a change in pull request #17119: URL: https://github.com/apache/flink/pull/17119#discussion_r704447651 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java ## @@

[jira] [Resolved] (FLINK-23807) Use RestClient to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover

2021-09-08 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23807. - Resolution: Fixed Merged into master as ef082c9d091846a1659277aa313b1cc6f79eba94. Merged into

[jira] [Resolved] (FLINK-24126) Use increment of bytes-consumed-total for updating numBytesIn in KafkaSource

2021-09-08 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24126. - Resolution: Fixed Merged into 1.14 as b434f0acd65d1cb654f080bf091f6585eeba7e16. > Use

[GitHub] [flink] AHeise merged pull request #17178: [BP-1.14][FLINK-23807][connector/testing-framework] Use RestClient to detect TaskManager failure in test environments

2021-09-08 Thread GitBox
AHeise merged pull request #17178: URL: https://github.com/apache/flink/pull/17178 -- 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 merged pull request #17191: [BP-1.14][FLINK-24126][connector/kafka] Use increment of bytes consumed/produced for updating numBytesIn/Out in Kafka connector

2021-09-08 Thread GitBox
AHeise merged pull request #17191: URL: https://github.com/apache/flink/pull/17191 -- 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-24189) Buffer debloating for multiply gates

2021-09-08 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24189: -- Description: Right now, the buffer debloat suppose that it works with

[GitHub] [flink] AHeise commented on a change in pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

2021-09-08 Thread GitBox
AHeise commented on a change in pull request #16940: URL: https://github.com/apache/flink/pull/16940#discussion_r704437448 ## File path: flink-test-utils-parent/flink-connector-testing/src/test/java/org/apache/flink/connectors/test/common/utils/TestDataMatchersTest.java ## @@

[jira] [Updated] (FLINK-24214) A submit job failure crashes the sql client

2021-09-08 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-24214: Description: I've noticed that when executing a valid query, in case there is a

[jira] [Created] (FLINK-24214) A submit job failure crashes the sql client

2021-09-08 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24214: --- Summary: A submit job failure crashes the sql client Key: FLINK-24214 URL: https://issues.apache.org/jira/browse/FLINK-24214 Project: Flink

[jira] [Commented] (FLINK-24149) Make checkpoint relocatable

2021-09-08 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411934#comment-17411934 ] Feifan Wang commented on FLINK-24149: - [~yunta] I did think about this issue too simplistically at

[GitHub] [flink] flinkbot edited a comment on pull request #17198: [FLINK-24212][kerbernets] fix the problem that kerberos krb5.conf file is mounted as empty directory, not a expected file

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17198: URL: https://github.com/apache/flink/pull/17198#issuecomment-915217186 ## CI report: * 0cf21ddabc21af46f66d74bdc86e4dd971f53f7f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-914384307 ## CI report: * 9a740a5445fc0dbf1799c5388525b58721da4a62 UNKNOWN * f9b4ae5381c9fb11cdb1de5a50eff89cc231effc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17195: [FLINK-24196][doc]Translate "EXPLAIN Statements" page of "SQL" into C…

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17195: URL: https://github.com/apache/flink/pull/17195#issuecomment-915027502 ## CI report: * b491ca621d1960372157222fe844020aed00dacf UNKNOWN * 915076797894330a6caab7b8c78e02a9fc76a2a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17187: [FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17187: URL: https://github.com/apache/flink/pull/17187#issuecomment-914504554 ## CI report: * d7bfc754def9778e7b35ebb8a555a8e713117355 Azure:

[jira] [Updated] (FLINK-23974) Lower throughput for buffer debloat in case of different load profile

2021-09-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23974: --- Summary: Lower throughput for buffer debloat in case of different load profile (was: Low

[jira] [Commented] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2021-09-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411912#comment-17411912 ] Dawid Wysakowicz commented on FLINK-23047: --

[GitHub] [flink] flinkbot commented on pull request #17198: [FLINK-24212][kerbernets] fix the problem that kerberos krb5.conf file is mounted as empty directory, not a expected file

2021-09-08 Thread GitBox
flinkbot commented on pull request #17198: URL: https://github.com/apache/flink/pull/17198#issuecomment-915217186 ## CI report: * 0cf21ddabc21af46f66d74bdc86e4dd971f53f7f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17192: [FLINK-24195][doc]Translate "DESCRIBE Statements" page of "SQL" into …

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17192: URL: https://github.com/apache/flink/pull/17192#issuecomment-914985462 ## CI report: * 7a707d9f9a5a6eb1d23e41d5d8a352a055abd55e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17187: [FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17187: URL: https://github.com/apache/flink/pull/17187#issuecomment-914504554 ## CI report: * d7bfc754def9778e7b35ebb8a555a8e713117355 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-914384307 ## CI report: * 9a740a5445fc0dbf1799c5388525b58721da4a62 UNKNOWN * f9b4ae5381c9fb11cdb1de5a50eff89cc231effc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17135: [FLINK-24098] Document FLIP-147 capabiliites and limitations

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17135: URL: https://github.com/apache/flink/pull/17135#issuecomment-912443975 ## CI report: * 6976c1e0ff29913256425672b5173806e3ce691e Azure:

[jira] [Assigned] (FLINK-23313) Reintroduce temporal table function documentation

2021-09-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-23313: -- Assignee: Leonard Xu > Reintroduce temporal table function documentation >

[jira] [Created] (FLINK-24213) Java deadlock in QueryableState ClientTest

2021-09-08 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24213: Summary: Java deadlock in QueryableState ClientTest Key: FLINK-24213 URL: https://issues.apache.org/jira/browse/FLINK-24213 Project: Flink Issue

[jira] [Commented] (FLINK-23313) Reintroduce temporal table function documentation

2021-09-08 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411906#comment-17411906 ] Leonard Xu commented on FLINK-23313: [~MartijnVisser] Sure, please assign this to me. > Reintroduce

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2021-09-08 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411900#comment-17411900 ] Arvid Heise commented on FLINK-23391: - cc [~renqs] > KafkaSourceReaderTest.testKafkaSourceMetrics

[jira] [Updated] (FLINK-23974) Low throughput for buffer debloat in case of different load profile

2021-09-08 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-23974: -- Description: According to task https://issues.apache.org/jira/browse/FLINK-23456, we

[GitHub] [flink] AHeise merged pull request #17168: [hotfix][docs] Fix sentence by adding one word:

2021-09-08 Thread GitBox
AHeise merged pull request #17168: URL: https://github.com/apache/flink/pull/17168 -- 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-24212) kerberos krb5.conf file is mounted as empty directory, not the expected file

2021-09-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24212: --- Labels: pull-request-available (was: ) > kerberos krb5.conf file is mounted as empty

[GitHub] [flink] flinkbot commented on pull request #17198: [FLINK-24212][kerbernets] fix the problem that kerberos krb5.conf file is mounted as empty directory, not a expected file

2021-09-08 Thread GitBox
flinkbot commented on pull request #17198: URL: https://github.com/apache/flink/pull/17198#issuecomment-915195449 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] curcur commented on pull request #17120: [FLINK-24065][connector] Upgrade the state of TwoPhaseCommitSink to support empty transaction after finished

2021-09-08 Thread GitBox
curcur commented on pull request #17120: URL: https://github.com/apache/flink/pull/17120#issuecomment-915194368 Hey @dawidwys , I am fine with either way. The only concern is as mentioned above, the code has an implicit assumption that `currentTransactionHolder != null` in

[jira] [Commented] (FLINK-23313) Reintroduce temporal table function documentation

2021-09-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411896#comment-17411896 ] Martijn Visser commented on FLINK-23313: [~Leonard Xu] Should I still assign this ticket to you?

[GitHub] [flink] lzshlzsh opened a new pull request #17198: fix the problem that kerberos krb5.conf file is mounted as empty dire…

2021-09-08 Thread GitBox
lzshlzsh opened a new pull request #17198: URL: https://github.com/apache/flink/pull/17198 …ctory, not the expected file ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC.

[GitHub] [flink] flinkbot edited a comment on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-914384307 ## CI report: * 9a740a5445fc0dbf1799c5388525b58721da4a62 UNKNOWN * f9b4ae5381c9fb11cdb1de5a50eff89cc231effc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17165: [FLINK-24160][tests] Use FS checkpoint storage in PartiallyFinishedSourcesITCase

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17165: URL: https://github.com/apache/flink/pull/17165#issuecomment-913856367 ## CI report: * 19a0d7d7e48d3d007fc2721e6b32ac461d3b40c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17135: [FLINK-24098] Document FLIP-147 capabiliites and limitations

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17135: URL: https://github.com/apache/flink/pull/17135#issuecomment-912443975 ## CI report: * 6976c1e0ff29913256425672b5173806e3ce691e Azure:

[jira] [Commented] (FLINK-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]"

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411894#comment-17411894 ] Chesnay Schepler commented on FLINK-24197: -- I was finally able to reproduce it. It seems depend

[jira] [Assigned] (FLINK-24161) Can not stop the job with savepoint while a task is finishing

2021-09-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-24161: Assignee: Dawid Wysakowicz > Can not stop the job with savepoint while a task is

[GitHub] [flink] dawidwys commented on a change in pull request #17135: [FLINK-24098] Document FLIP-147 capabiliites and limitations

2021-09-08 Thread GitBox
dawidwys commented on a change in pull request #17135: URL: https://github.com/apache/flink/pull/17135#discussion_r704346332 ## File path: docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md ## @@ -211,4 +223,41 @@ Flink currently only provides processing

[GitHub] [flink] flinkbot edited a comment on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-914384307 ## CI report: * 9a740a5445fc0dbf1799c5388525b58721da4a62 UNKNOWN * f9b4ae5381c9fb11cdb1de5a50eff89cc231effc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17184: [FLINK-24193][tests] Add ClassLoaderExtension

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17184: URL: https://github.com/apache/flink/pull/17184#issuecomment-914328876 ## CI report: * 39e7b6d0a0eb8f68fa58b66856694470919491d0 UNKNOWN * 3a13e28adc79b35215d30950d9c342d97d938acf Azure:

[jira] [Updated] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory, not the expected file

2021-09-08 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-24212: -- Description: >From FLINK-18971,we can mount kerberos krb5 conf file to pod with path

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

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

[GitHub] [flink] dawidwys commented on a change in pull request #17135: [FLINK-24098] Document FLIP-147 capabiliites and limitations

2021-09-08 Thread GitBox
dawidwys commented on a change in pull request #17135: URL: https://github.com/apache/flink/pull/17135#discussion_r704343221 ## File path: docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md ## @@ -211,4 +223,45 @@ Flink currently only provides processing

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

2021-09-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411879#comment-17411879 ] Dawid Wysakowicz commented on FLINK-24074: -- I checked the diff between release-1.13 and

[GitHub] [flink] zentol merged pull request #17194: [FLINK-24034] Upgrade commons-compress to 1.21 and other apache.commons updates

2021-09-08 Thread GitBox
zentol merged pull request #17194: URL: https://github.com/apache/flink/pull/17194 -- 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-24212) kerberos krb5.conf file is mounted as empty directory, not the expected file

2021-09-08 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-24212: -- Priority: Minor (was: Major) > kerberos krb5.conf file is mounted as empty directory, not the

[jira] [Updated] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory, not the expected file

2021-09-08 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiuZeshan updated FLINK-24212: -- Summary: kerberos krb5.conf file is mounted as empty directory, not the expected file (was: kerberos

[GitHub] [flink] flinkbot edited a comment on pull request #17197: [FLINK-24209][jdbc][build] Add test scope

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17197: URL: https://github.com/apache/flink/pull/17197#issuecomment-915130715 ## CI report: * b9fb4c7469502e42eee91075a87a3880de0e8d8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17184: [FLINK-24193][tests] Add ClassLoaderExtension

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17184: URL: https://github.com/apache/flink/pull/17184#issuecomment-914328876 ## CI report: * 39e7b6d0a0eb8f68fa58b66856694470919491d0 UNKNOWN * c652a8a01a0ad750621845d63b91cadd5ba36807 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-914384307 ## CI report: * 9a740a5445fc0dbf1799c5388525b58721da4a62 UNKNOWN * a4f150371b2297ae49e64c149dd164b7bef370eb Azure:

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

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

[jira] [Commented] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory for customer file name

2021-09-08 Thread LiuZeshan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411864#comment-17411864 ] LiuZeshan commented on FLINK-24212: --- Could you [~karmagyz] [~xtsong] have a look at this. Assign to

[jira] [Closed] (FLINK-24203) AbstractServerTest fails due to port conflict

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24203. Resolution: Fixed master: 7c65adb8f028e90350b766c630d7434c8b999a27 > AbstractServerTest

[GitHub] [flink] zentol merged pull request #17193: [FLINK-24203][runtime][tests] Resolve AbstractServerTest fails due to port conflict

2021-09-08 Thread GitBox
zentol merged pull request #17193: URL: https://github.com/apache/flink/pull/17193 -- 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] [Created] (FLINK-24212) kerberos krb5.conf file is mounted as empty directory for customer file name

2021-09-08 Thread LiuZeshan (Jira)
LiuZeshan created FLINK-24212: - Summary: kerberos krb5.conf file is mounted as empty directory for customer file name Key: FLINK-24212 URL: https://issues.apache.org/jira/browse/FLINK-24212 Project:

[jira] [Assigned] (FLINK-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]"

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24197: Assignee: Chesnay Schepler > Streaming File Sink end-to-end test fails with :

[GitHub] [flink] flinkbot commented on pull request #17197: [FLINK-24209][jdbc][build] Add test scope

2021-09-08 Thread GitBox
flinkbot commented on pull request #17197: URL: https://github.com/apache/flink/pull/17197#issuecomment-915130715 ## CI report: * b9fb4c7469502e42eee91075a87a3880de0e8d8f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17193: [FLINK-24203][runtime][tests] Resolve AbstractServerTest fails due to port conflict

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17193: URL: https://github.com/apache/flink/pull/17193#issuecomment-914985560 ## CI report: * 431885c512aa376be12ffc08bd042c1aab33a3e3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-914384307 ## CI report: * 9a740a5445fc0dbf1799c5388525b58721da4a62 UNKNOWN * a4f150371b2297ae49e64c149dd164b7bef370eb Azure:

[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-09-08 Thread GitBox
RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-913970522 > @wuchong @twalthr Thank you for your suggestions. I'll simplify the related documentation in this PR. > Looking forward to the refactoring next. @wuchong

[jira] [Closed] (FLINK-24211) flink-sql-connector-kinesis does not list transitive dependencies from flink-connector-kinesis

2021-09-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24211. Resolution: Not A Problem > flink-sql-connector-kinesis does not list transitive

[jira] [Commented] (FLINK-24211) flink-sql-connector-kinesis does not list transitive dependencies from flink-connector-kinesis

2021-09-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411845#comment-17411845 ] Dawid Wysakowicz commented on FLINK-24211: -- Yes, you're right. My bad. I've just checked the

[jira] [Commented] (FLINK-24211) flink-sql-connector-kinesis does not list transitive dependencies from flink-connector-kinesis

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411840#comment-17411840 ] Chesnay Schepler commented on FLINK-24211: -- Isn't that fine because the NOTICE files are

[GitHub] [flink] godfreyhe commented on a change in pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

2021-09-08 Thread GitBox
godfreyhe commented on a change in pull request #17118: URL: https://github.com/apache/flink/pull/17118#discussion_r704247305 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/common/CommonPhysicalJoin.scala ## @@

[jira] [Created] (FLINK-24211) flink-sql-connector-kinesis does not list transitive dependencies from flink-connector-kinesis

2021-09-08 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24211: Summary: flink-sql-connector-kinesis does not list transitive dependencies from flink-connector-kinesis Key: FLINK-24211 URL:

[jira] [Updated] (FLINK-24211) flink-sql-connector-kinesis does not list transitive dependencies from flink-connector-kinesis

2021-09-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24211: - Parent: (was: FLINK-24074) Issue Type: Bug (was: Sub-task) >

[jira] [Assigned] (FLINK-24203) AbstractServerTest fails due to port conflict

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24203: Assignee: xmarker > AbstractServerTest fails due to port conflict >

[jira] [Updated] (FLINK-24209) Jdbc connector uses postgres testcontainers in compile scope

2021-09-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24209: --- Labels: pull-request-available (was: ) > Jdbc connector uses postgres testcontainers in

[GitHub] [flink] flinkbot commented on pull request #17197: [FLINK-24209][jdbc][build] Add test scope

2021-09-08 Thread GitBox
flinkbot commented on pull request #17197: URL: https://github.com/apache/flink/pull/17197#issuecomment-915101387 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] [Assigned] (FLINK-24156) BlobServer crashes due to SocketTimeoutException in Java 11

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24156: Assignee: Ryan Scudellari > BlobServer crashes due to SocketTimeoutException in

[GitHub] [flink] flinkbot edited a comment on pull request #17196: [HOTFIX][docs] fix sentence to make the description more clear.

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17196: URL: https://github.com/apache/flink/pull/17196#issuecomment-915073209 ## CI report: * 928d8dcbd3b60d2fe1c37603f26298ad269f86b1 Azure:

[jira] [Assigned] (FLINK-24210) Window related serailizer should not return 0 as its serialized length

2021-09-08 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24210: Assignee: Jinzhong Li > Window related serailizer should not return 0 as its serialized length >

[GitHub] [flink] flinkbot edited a comment on pull request #17192: [FLINK-24195][doc]Translate "DESCRIBE Statements" page of "SQL" into …

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17192: URL: https://github.com/apache/flink/pull/17192#issuecomment-914985462 ## CI report: * a5cb09d36ca9a5e91a896532e83500aa02b4ca4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17184: [FLINK-24193][tests] Add ClassLoaderExtension

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17184: URL: https://github.com/apache/flink/pull/17184#issuecomment-914328876 ## CI report: * 39e7b6d0a0eb8f68fa58b66856694470919491d0 UNKNOWN * c652a8a01a0ad750621845d63b91cadd5ba36807 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17151: [FLINK-23180] Do not initialize checkpoint base locations when checkp…

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17151: URL: https://github.com/apache/flink/pull/17151#issuecomment-913110826 ## CI report: * 4b431b9e8b67caf75739a39180715e0fcc23279e UNKNOWN * Unknown: [CANCELED](TBD) * d57aa64c5010aca1d5e481e0eb68dbc090963ac1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17118: [FLINK-22603][table-planner]The digest can be produced by SourceAbilitySpec.

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17118: URL: https://github.com/apache/flink/pull/17118#issuecomment-911539514 ## CI report: * 74370f1b06d5c8cbd90ac63c4320c66bf488e8a6 Azure:

<    1   2   3   4   5   >