[GitHub] [flink] curcur merged pull request #17173: [FLINK-24155] Sync Chinese version of documentation to configure CheckpointFailureManager

2021-09-08 Thread GitBox
curcur merged pull request #17173: URL: https://github.com/apache/flink/pull/17173 -- 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: issues-unsubscr

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

2021-09-08 Thread GitBox
slinkydeveloper commented on a change in pull request #17204: URL: https://github.com/apache/flink/pull/17204#discussion_r705026970 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java ## @@ -125,4 +12

[jira] [Updated] (FLINK-24225) Define and implement UPSERT INTO semantics

2021-09-08 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-24225: Priority: Minor (was: Major) > Define and implement UPSERT INTO semantics > -

[jira] [Created] (FLINK-24225) Define and implement UPSERT INTO semantics

2021-09-08 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24225: --- Summary: Define and implement UPSERT INTO semantics Key: FLINK-24225 URL: https://issues.apache.org/jira/browse/FLINK-24225 Project: Flink Issu

[jira] [Updated] (FLINK-24225) Define and implement UPSERT INTO semantics

2021-09-08 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-24225: Issue Type: New Feature (was: Bug) > Define and implement UPSERT INTO semantics >

[GitHub] [flink] flinkbot commented on pull request #17210: [FLINK-16346][tests] Remove timeout

2021-09-08 Thread GitBox
flinkbot commented on pull request #17210: URL: https://github.com/apache/flink/pull/17210#issuecomment-915815448 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 pro

[jira] [Commented] (FLINK-23749) Testing Window Join

2021-09-08 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412390#comment-17412390 ] lixiaobao commented on FLINK-23749: --- I will do this on weekends > Testing Window Join

[GitHub] [flink] godfreyhe commented on a change in pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-09-08 Thread GitBox
godfreyhe commented on a change in pull request #14916: URL: https://github.com/apache/flink/pull/14916#discussion_r705020306 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkOptimizeContext.scala ## @@ -30,

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

2021-09-08 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412389#comment-17412389 ] Yangze Guo commented on FLINK-24212: I'll take a look. > kerberos krb5.conf file is

[GitHub] [flink] AHeise commented on a change in pull request #17189: [FLINK-23528][connectors/kinesis] Improving and reenable FlinkKinesisITCase

2021-09-08 Thread GitBox
AHeise commented on a change in pull request #17189: URL: https://github.com/apache/flink/pull/17189#discussion_r705021281 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ## @@

[jira] [Closed] (FLINK-24012) PulsarSourceITCase.testTaskManagerFailure fails due to NoResourceAvailableException

2021-09-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-24012. Resolution: Fixed Thanks [~syhily]. Closing the ticket. > PulsarSourceITCase.testTaskManagerFailu

[jira] [Commented] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

2021-09-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412383#comment-17412383 ] Xintong Song commented on FLINK-24137: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] Airblader commented on a change in pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

2021-09-08 Thread GitBox
Airblader commented on a change in pull request #17204: URL: https://github.com/apache/flink/pull/17204#discussion_r705016537 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java ## @@ -125,4 +126,14 @

[jira] [Updated] (FLINK-24224) Table change to stream for CEP , only event  is ROW  datatype can works on CEP,  but  other POJOs、maps、 JsonObject datatype event  do not work.    Any datatype for even

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-24224: - Description:   1、problem：*Table change to stream for CEP* , only event  is *ROW*  datatype *can works*

[jira] [Updated] (FLINK-24224) Table change to stream for CEP , only the row datatype Stream works on CEP, and other POJOs、maps、 JsonObject datatype streams do not work, but any datatype stream for

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-24224: - Description:   1、problem：*Table change to stream for CEP* , only event  is *ROW*  datatype can works o

[jira] [Updated] (FLINK-24224) Table change to stream for CEP , only event  is ROW  datatype can works on CEP,  but  other POJOs、maps、 JsonObject datatype event  do not work.    Any datatype for even

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-24224: - Summary: Table change to stream for CEP , only event  is ROW  datatype can works on CEP,  but  other POJ

[GitHub] [flink] gaoyunhaii commented on a change in pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

2021-09-08 Thread GitBox
gaoyunhaii commented on a change in pull request #17200: URL: https://github.com/apache/flink/pull/17200#discussion_r705013784 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -529,6 +530,13 @@ protected void proc

[jira] [Reopened] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

2021-09-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22197: -- > UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to > NoSuchFileExcep

[jira] [Commented] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

2021-09-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412378#comment-17412378 ] Xintong Song commented on FLINK-22197: -- Happened again in 1.13. https://dev.azure.c

[jira] [Updated] (FLINK-16346) BlobsCleanupITCase.testBlobServerCleanupCancelledJob fails on Travis

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-16346: - Fix Version/s: 1.12.6 > BlobsCleanupITCase.testBlobServerCleanupCancelledJob fails on Tr

[GitHub] [flink] gaoyunhaii commented on a change in pull request #17200: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints

2021-09-08 Thread GitBox
gaoyunhaii commented on a change in pull request #17200: URL: https://github.com/apache/flink/pull/17200#discussion_r705014169 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -552,6 +560,7 @@ protected void setSyn

[jira] [Updated] (FLINK-24224) Table change to stream for CEP , only the row datatype Stream works on CEP, and other POJOs、maps、 JsonObject datatype streams do not work, but any datatype stream for

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-24224: - Summary: Table change to stream for CEP , only the row datatype Stream works on CEP, and other POJOs、m

[GitHub] [flink] dianfu commented on a change in pull request #17206: [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API

2021-09-08 Thread GitBox
dianfu commented on a change in pull request #17206: URL: https://github.com/apache/flink/pull/17206#discussion_r705009381 ## File path: flink-python/pyflink/datastream/stream_execution_environment.py ## @@ -462,6 +462,23 @@ def get_stream_time_characteristic(self) -> 'TimeCha

[jira] [Commented] (FLINK-23696) RMQSourceTest.testRedeliveredSessionIDsAck fails on azure

2021-09-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412374#comment-17412374 ] Xintong Song commented on FLINK-23696: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-23696) RMQSourceTest.testRedeliveredSessionIDsAck fails on azure

2021-09-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23696: - Affects Version/s: 1.12.5 > RMQSourceTest.testRedeliveredSessionIDsAck fails on azure >

[jira] [Updated] (FLINK-23696) RMQSourceTest.testRedeliveredSessionIDsAck fails on azure

2021-09-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23696: - Fix Version/s: 1.12.6 > RMQSourceTest.testRedeliveredSessionIDsAck fails on azure >

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-09-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412372#comment-17412372 ] Xintong Song commented on FLINK-23493: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-16346) BlobsCleanupITCase.testBlobServerCleanupCancelledJob fails on Travis

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412368#comment-17412368 ] Chesnay Schepler commented on FLINK-16346: -- We seem to be loosing 5 minutes for

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

2021-09-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412367#comment-17412367 ] Xintong Song commented on FLINK-24197: -- https://dev.azure.com/apache-flink/apache-f

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

2021-09-08 Thread xmarker (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412349#comment-17412349 ] xmarker edited comment on FLINK-24213 at 9/9/21, 6:29 AM: -- The

[jira] [Commented] (FLINK-24224) Table to stream, only the row datatype Stream works on CEP, and other POJOs, maps and jsonobjects datatype streams do not work, but any datatype stream to CEP can work

2021-09-08 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412366#comment-17412366 ] YUJIANBO commented on FLINK-24224: -- [~dwysakowicz]:              hello, I am very eage

[GitHub] [flink] flinkbot edited a comment on pull request #17209: [FLINK-23378][flink-streaming-java] ContinuousProcessingTimeTrigger can't triger the last fireTimestamp

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17209: URL: https://github.com/apache/flink/pull/17209#issuecomment-915788400 ## CI report: * 23158ac24be163d07459399921135276447f5544 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17206: [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17206: URL: https://github.com/apache/flink/pull/17206#issuecomment-915706736 ## CI report: * 169c8d343e362c0244d2c977bab4db6ac2b47ee1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * 7e524508a999c88c22e981f9ec8a6fcdc6cb07bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 02e870f42aad87379e45b2aaf3fed2e8351fc0a2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN * 6c86314c2f42fd10b0492dd8b570563ba091

[jira] [Created] (FLINK-24224) Table to stream, only the row datatype Stream works on CEP, and other POJOs, maps and jsonobjects datatype streams do not work, but any datatype stream to CEP can work b

2021-09-08 Thread YUJIANBO (Jira)
YUJIANBO created FLINK-24224: Summary: Table to stream, only the row datatype Stream works on CEP, and other POJOs, maps and jsonobjects datatype streams do not work, but any datatype stream to CEP can work by only stream api . Key:

[GitHub] [flink] gaoyunhaii commented on pull request #17120: [FLINK-24065][connector] Upgrade the state of TwoPhaseCommitSink to support empty transaction after finished

2021-09-08 Thread GitBox
gaoyunhaii commented on pull request #17120: URL: https://github.com/apache/flink/pull/17120#issuecomment-915795915 I first removed the start time from the state for the empty transactions~ -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-16346) BlobsCleanupITCase.testBlobServerCleanupCancelledJob fails on Travis

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412353#comment-17412353 ] Chesnay Schepler commented on FLINK-16346: -- You've gotta be kidding me, why is

[jira] [Commented] (FLINK-24013) Add IssueNavigationLink for IDEA

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412351#comment-17412351 ] Chesnay Schepler commented on FLINK-24013: -- I would prefer that, yes. > Add Is

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

2021-09-08 Thread xmarker (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412349#comment-17412349 ] xmarker commented on FLINK-24213: - The dead lock seems occur in following scene: 1.When

[GitHub] [flink] flinkbot commented on pull request #17209: [FLINK-23378][flink-streaming-java] ContinuousProcessingTimeTrigger can't triger the last fireTimestamp

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

[jira] [Created] (FLINK-24223) Client should throw exception to warn users when the configurations set by program options conflict with those set by -D

2021-09-08 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-24223: - Summary: Client should throw exception to warn users when the configurations set by program options conflict with those set by -D Key: FLINK-24223 URL: https://issues.apache.org

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN * 6c86314c2f42fd10b0492dd8b570563ba091

[jira] [Closed] (FLINK-23378) ContinuousProcessingTimeTrigger最后一个定时器无法触发

2021-09-08 Thread frey (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] frey closed FLINK-23378. Fix Version/s: (was: 1.12.3) 1.14.1 Resolution: Fixed > ContinuousProcessingTimeTrig

[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&focusedCommentId=17412340#comment-17412340 ] Chesnay Schepler commented on FLINK-24197: -- I believe this to be an exotic bug

[jira] [Created] (FLINK-24222) Use ContextClassLoaderExtension in ReporterSetupTest

2021-09-08 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24222: Summary: Use ContextClassLoaderExtension in ReporterSetupTest Key: FLINK-24222 URL: https://issues.apache.org/jira/browse/FLINK-24222 Project: Flink

[jira] [Closed] (FLINK-24193) Test service entries cause noise in other tests

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24193. Resolution: Fixed master: Extension added: a5e83afb510aafa05aac31413e2b59704c374aa3 REST t

[GitHub] [flink] zentol merged pull request #17184: [FLINK-24193][tests] Add ClassLoaderExtension

2021-09-08 Thread GitBox
zentol merged pull request #17184: URL: https://github.com/apache/flink/pull/17184 -- 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: issues-unsubscr

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

2021-09-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24209. Resolution: Fixed master/1.14 are not affected. 1.13: c97ddb8181e6ad16510f4e6b558f9441c8f

[GitHub] [flink] flinkbot edited a comment on pull request #17208: [BP-1.14][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17208: URL: https://github.com/apache/flink/pull/17208#issuecomment-915763233 ## CI report: * e677f27ac5d53678debb68648ac7ddc18dc2fb2c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zentol merged pull request #17197: [FLINK-24209][jdbc][build] Add test scope

2021-09-08 Thread GitBox
zentol merged pull request #17197: URL: https://github.com/apache/flink/pull/17197 -- 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: issues-unsubscr

[GitHub] [flink] flinkbot commented on pull request #17209: FLINK-23378

2021-09-08 Thread GitBox
flinkbot commented on pull request #17209: URL: https://github.com/apache/flink/pull/17209#issuecomment-915772622 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 pro

[jira] [Updated] (FLINK-23378) ContinuousProcessingTimeTrigger最后一个定时器无法触发

2021-09-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23378: --- Labels: pull-request-available (was: ) > ContinuousProcessingTimeTrigger最后一个定时器无法触发 > -

[GitHub] [flink] frey66 opened a new pull request #17209: FLINK-23378

2021-09-08 Thread GitBox
frey66 opened a new pull request #17209: URL: https://github.com/apache/flink/pull/17209 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[GitHub] [flink] flinkbot commented on pull request #17208: [BP-1.14][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

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

[GitHub] [flink] flinkbot edited a comment on pull request #17207: [FLINK-22901][table-planner-blink] Introduce getUpsertKeys in FlinkRelMetadataQuery

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17207: URL: https://github.com/apache/flink/pull/17207#issuecomment-915750810 ## CI report: * 4f8b0f5ad64d4fe7c998042ec2b6b1ecec714be5 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN * 6c86314c2f42fd10b0492dd8b570563ba091

[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_r704944200 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/schema/TableSourceTable.scala ## @@ -44,8 +43,8 @@ imp

[jira] [Updated] (FLINK-24149) Make checkpoint self-contained and relocatable

2021-09-08 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24149: Summary: Make checkpoint self-contained and relocatable (was: Make checkpoint relocatable) > Mak

[jira] [Updated] (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:all-tabpanel ] Feifan Wang updated FLINK-24149: Description: h3. 1. Backgroud FLINK-5763 proposal make savepoint relocatable, checkpoint has simi

[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&focusedCommentId=17412326#comment-17412326 ] Feifan Wang commented on FLINK-24149: - Hi [~pnowojski], remove the current distincti

[GitHub] [flink] flinkbot commented on pull request #17207: [FLINK-22901][table-planner-blink] Introduce getUpsertKeys in FlinkRelMetadataQuery

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

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN * e007d566345c353e5f8b068649cd398ba725

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

2021-09-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412322#comment-17412322 ] Piotr Nowojski edited comment on FLINK-24041 at 9/9/21, 4:18 AM: -

[GitHub] [flink] flinkbot commented on pull request #17208: [BP-1.14][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

2021-09-08 Thread GitBox
flinkbot commented on pull request #17208: URL: https://github.com/apache/flink/pull/17208#issuecomment-915749291 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 pro

[GitHub] [flink] PatrickRen opened a new pull request #17208: [BP-1.14][FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

2021-09-08 Thread GitBox
PatrickRen opened a new pull request #17208: URL: https://github.com/apache/flink/pull/17208 Unchanged backport of #16870 on 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 the spec

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

2021-09-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412323#comment-17412323 ] Jingsong Lee commented on FLINK-20370: -- [~jark] I updated cases. I think UpsertMate

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

2021-09-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412322#comment-17412322 ] Piotr Nowojski edited comment on FLINK-24041 at 9/9/21, 3:56 AM: -

[GitHub] [flink] flinkbot commented on pull request #17207: [FLINK-22901][table-planner-blink] Introduce getUpsertKeys in FlinkRelMetadataQuery

2021-09-08 Thread GitBox
flinkbot commented on pull request #17207: URL: https://github.com/apache/flink/pull/17207#issuecomment-915741202 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 pro

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

2021-09-08 Thread GitBox
pnowojski edited a comment on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-915740659 I had to revert this as 1702c9e4f4b because of build failures. Looks like this PR hasn't been rebased and conflicted with another change in the master. https://d

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

2021-09-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412322#comment-17412322 ] Piotr Nowojski edited comment on FLINK-24041 at 9/9/21, 3:54 AM: -

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

2021-09-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412302#comment-17412302 ] Jingsong Lee edited comment on FLINK-20370 at 9/9/21, 3:54 AM: ---

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

2021-09-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-24041: I had to revert this as 1702c9e because of build failures. Looks like this PR hasn't been reb

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

2021-09-08 Thread GitBox
pnowojski commented on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-915740659 I had to revert this as 1702c9e4f4b because of build failures. Looks like this PR hasn't been rebased and conflicted with another change in the master. -- This is an automat

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

2021-09-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412321#comment-17412321 ] Jark Wu commented on FLINK-24214: - >From the stack trace, you should be using Flink vers

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN * 0dcc76878db9d5f613a144f8b13747e541a7

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

2021-09-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412302#comment-17412302 ] Jingsong Lee edited comment on FLINK-20370 at 9/9/21, 3:51 AM: ---

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

2021-09-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412302#comment-17412302 ] Jingsong Lee edited comment on FLINK-20370 at 9/9/21, 3:50 AM: ---

[jira] [Updated] (FLINK-22901) Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

2021-09-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22901: - Fix Version/s: 1.13.3 > Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery >

[jira] [Reopened] (FLINK-22901) Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

2021-09-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-22901: -- re-open for 1.13 > Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery > --

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

2021-09-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412318#comment-17412318 ] Jark Wu commented on FLINK-20370: - [~lzljs3620320] there is 4th case: input is changelog

[GitHub] [flink] JingsongLi opened a new pull request #17207: [FLINK-22901][table] Introduce getUpsertKeys in FlinkRelMetadataQuery

2021-09-08 Thread GitBox
JingsongLi opened a new pull request #17207: URL: https://github.com/apache/flink/pull/17207 Cherry-pick #16096 ## What is the purpose of the change For fix FLINK-20374, we need to resolve streaming computation disorder. we need to introduce a change log upsert keys, this is n

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

2021-09-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412317#comment-17412317 ] Jark Wu commented on FLINK-20370: - [~lzljs3620320] could UpsertMaterialize also solve th

[GitHub] [flink] becketqin commented on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-09-08 Thread GitBox
becketqin commented on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-915734942 Thanks for the patch. LGTM. Merged to master d4c483fadd3df32045fbb2ee117d0a6eeab9276e -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-09-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412313#comment-17412313 ] Jark Wu commented on FLINK-10230: - I'm fine with both SHOW CREATE TABLE and SHOW CREATE

[GitHub] [flink] becketqin merged pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-09-08 Thread GitBox
becketqin merged pull request #17064: URL: https://github.com/apache/flink/pull/17064 -- 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: issues-unsub

[GitHub] [flink] gaoyunhaii commented on a change in pull request #17023: [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'.

2021-09-08 Thread GitBox
gaoyunhaii commented on a change in pull request #17023: URL: https://github.com/apache/flink/pull/17023#discussion_r704923725 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -825,22 +824,9 @@ public void updateAccumulators

[GitHub] [flink] gaoyunhaii commented on a change in pull request #17023: [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'.

2021-09-08 Thread GitBox
gaoyunhaii commented on a change in pull request #17023: URL: https://github.com/apache/flink/pull/17023#discussion_r704923725 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ## @@ -825,22 +824,9 @@ public void updateAccumulators

[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: * Unknown: [CANCELED](TBD) * 02e870f42aad87379e45b2aaf3fed2e8351fc0a2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * b83590dcb652ec96755c63e5ec7c9761fc96d87b UNKNOWN * 0ab16329651532d687f521ce9f6e75885f85d575 UNKNOWN * 0dcc76878db9d5f613a144f8b13747e541a7

[jira] [Commented] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse

2021-09-08 Thread xuyangzhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412307#comment-17412307 ] xuyangzhong commented on FLINK-22455: - Hi, [~tartarus]. I'm trying to solve this iss

[GitHub] [flink] flinkbot edited a comment on pull request #17206: [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API

2021-09-08 Thread GitBox
flinkbot edited a comment on pull request #17206: URL: https://github.com/apache/flink/pull/17206#issuecomment-915706736 ## CI report: * 169c8d343e362c0244d2c977bab4db6ac2b47ee1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * Unknown: [CANCELED](TBD) * 02e870f42aad87379e45b2aaf3fed2e8351fc0a2 UNKNOWN Bot commands The @flinkbot bot supports the fol

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

2021-09-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412302#comment-17412302 ] Jingsong Lee commented on FLINK-20370: -- Yes, it seems that the only solution is sin

[jira] [Closed] (FLINK-24196) Translate "EXPLAIN Statements" page of "SQL" into Chinese

2021-09-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24196. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 125cb70a232b6a6e52c099c6a280414e2f896ad5 >

[GitHub] [flink] wuchong merged pull request #17195: [FLINK-24196][doc]Translate "EXPLAIN Statements" page of "SQL" into C…

2021-09-08 Thread GitBox
wuchong merged pull request #17195: URL: https://github.com/apache/flink/pull/17195 -- 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: issues-unsubsc

[jira] [Comment Edited] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

2021-09-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412293#comment-17412293 ] Jark Wu edited comment on FLINK-24195 at 9/9/21, 2:42 AM: -- Fixe

[jira] [Closed] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

2021-09-08 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24195. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in maste: 7b436773fc8eda6bb5f3c01b917d15d15aa70521 > T

[GitHub] [flink] wuchong merged pull request #17192: [FLINK-24195][doc]Translate "DESCRIBE Statements" page of "SQL" into …

2021-09-08 Thread GitBox
wuchong merged pull request #17192: URL: https://github.com/apache/flink/pull/17192 -- 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: issues-unsubsc

  1   2   3   4   5   >