[jira] [Commented] (FLINK-18278) Translate new documenation homepage

2021-06-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-18278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360728#comment-17360728 ] 王博 commented on FLINK-18278: if the duplicate issue of https://issues.apache.org/jira/browse/FLINK-18282

[jira] [Comment Edited] (FLINK-22878) Allow placeholder options in format factories

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360719#comment-17360719 ] Timo Walther edited comment on FLINK-22878 at 6/10/21, 10:26 AM: - We

[jira] [Commented] (FLINK-22878) Allow placeholder options in format factories

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360719#comment-17360719 ] Timo Walther commented on FLINK-22878: -- We found a solution that should solve this problem without

[jira] [Comment Edited] (FLINK-22878) Allow placeholder options in format factories

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360719#comment-17360719 ] Timo Walther edited comment on FLINK-22878 at 6/10/21, 10:24 AM: - We

[GitHub] [flink] flinkbot commented on pull request #16131: [1.12][FLINK-22952][azure] Use Ruby 2.5.9

2021-06-10 Thread GitBox
flinkbot commented on pull request #16131: URL: https://github.com/apache/flink/pull/16131#issuecomment-858503070 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] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * ad96e2d143042a4017628df9b88b4dd79f61dfc5 Azure:

[GitHub] [flink] flinkbot commented on pull request #16130: [FLINK-22952][azure] Remove Ruby usage

2021-06-10 Thread GitBox
flinkbot commented on pull request #16130: URL: https://github.com/apache/flink/pull/16130#issuecomment-858501942 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] zentol opened a new pull request #16131: [FLINK-22952][azure] Use Ruby 2.5.9

2021-06-10 Thread GitBox
zentol opened a new pull request #16131: URL: https://github.com/apache/flink/pull/16131 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c017f9b0b5da8950874bf20a33e2c3adf58daec2 Azure:

[jira] [Updated] (FLINK-22952) docs_404_check fail on azure due to ruby version not available

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

[GitHub] [flink] zentol opened a new pull request #16130: [FLINK-22952][azure] Remove Ruby usage

2021-06-10 Thread GitBox
zentol opened a new pull request #16130: URL: https://github.com/apache/flink/pull/16130 Since the docs have been migrated to hugo we no longer need ruby. -- 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

[jira] [Assigned] (FLINK-22878) Allow placeholder options in format factories

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-22878: Assignee: Timo Walther > Allow placeholder options in format factories >

[jira] [Assigned] (FLINK-22952) docs_404_check fail on azure due to ruby version not available

2021-06-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-22952: Assignee: Chesnay Schepler > docs_404_check fail on azure due to ruby version

[GitHub] [flink] RocMarshal commented on a change in pull request #16126: [FLINK-22934][docs] Add instructions for using the " ' " escape syntax of SQL client

2021-06-10 Thread GitBox
RocMarshal commented on a change in pull request #16126: URL: https://github.com/apache/flink/pull/16126#discussion_r649047706 ## File path: docs/content.zh/docs/dev/table/sql/queries/overview.md ## @@ -393,7 +393,37 @@ Flink SQL uses a lexical policy for identifier (table,

[jira] [Commented] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-06-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360711#comment-17360711 ] Till Rohrmann commented on FLINK-22664: --- Thanks a lot for getting back to us and closing this

[GitHub] [flink] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * ad96e2d143042a4017628df9b88b4dd79f61dfc5 Azure:

[jira] [Closed] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

2021-06-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22312. Resolution: Fixed Fixed via - master (1.14): dd739334d2671e0f262c92dfeecf29979d12f174 -

[GitHub] [flink] xintongsong closed pull request #16127: [FLINK-22312][yarn][test] Fix test instabilities due to expected heartbeat exceptions in log

2021-06-10 Thread GitBox
xintongsong closed pull request #16127: URL: https://github.com/apache/flink/pull/16127 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #16129: [FLINK-22956][table-runtime] Stream Over TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16129: URL: https://github.com/apache/flink/pull/16129#issuecomment-858445627 ## CI report: * 1f330d5d3bf763cdbf580e5e46943e2f874969d2 Azure:

[GitHub] [flink] laughingman7743 commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-06-10 Thread GitBox
laughingman7743 commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-858462749 Is there any progress on this pull request? This pull request has been done very cool. I am hoping that Flink will support the ProtoBuf format. -- This is an

[GitHub] [flink] laughingman7743 commented on a change in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-06-10 Thread GitBox
laughingman7743 commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r649007396 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbFormatUtils.java ## @@ -0,0 +1,146 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #16129: [FLINK-22956][table-runtime] Stream Over TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread GitBox
flinkbot commented on pull request #16129: URL: https://github.com/apache/flink/pull/16129#issuecomment-858445627 ## CI report: * 1f330d5d3bf763cdbf580e5e46943e2f874969d2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16102: URL: https://github.com/apache/flink/pull/16102#issuecomment-856195315 ## CI report: * 918aade90030917ea19c27406395820868ccc0ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16025: [FLINK-22714][table-planner-blink] Simplify window TVF to a simple window assigner if successor node is WindowRank or WindowJoin.

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16025: URL: https://github.com/apache/flink/pull/16025#issuecomment-851164626 ## CI report: * 6a317bf5b3b3b52fc2b8ae354c765113102d5622 Azure:

[jira] [Created] (FLINK-22960) Temporal join TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-22960: Summary: Temporal join TTL should use enableTimeToLive of state instead of timer Key: FLINK-22960 URL: https://issues.apache.org/jira/browse/FLINK-22960 Project:

[GitHub] [flink] AHeise commented on pull request #15725: [FLINK-21389] determine parquet schema from file instead of taking it from user

2021-06-10 Thread GitBox
AHeise commented on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-858434406 > But still, there is a thing I don't get: what is the point of providing a schema in _ParquetInputFormat_ constructor, it is not the one that will be used **at the actual

[jira] [Updated] (FLINK-22959) Keep the job jar files on JobManager

2021-06-10 Thread lukehua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lukehua updated FLINK-22959: Affects Version/s: 1.13.0 > Keep the job jar files on JobManager >

[jira] [Updated] (FLINK-22959) Keep the job jar files on JobManager

2021-06-10 Thread lukehua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lukehua updated FLINK-22959: Fix Version/s: (was: 1.13.1) 1.13.2 > Keep the job jar files on JobManager >

[jira] [Updated] (FLINK-22959) Keep the job jar files on JobManager

2021-06-10 Thread lukehua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lukehua updated FLINK-22959: Component/s: API / Core > Keep the job jar files on JobManager > --

[GitHub] [flink] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * ad96e2d143042a4017628df9b88b4dd79f61dfc5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16102: URL: https://github.com/apache/flink/pull/16102#issuecomment-856195315 ## CI report: * 918aade90030917ea19c27406395820868ccc0ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16025: [FLINK-22714][table-planner-blink] Simplify window TVF to a simple window assigner if successor node is WindowRank or WindowJoin.

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16025: URL: https://github.com/apache/flink/pull/16025#issuecomment-851164626 ## CI report: * 6a317bf5b3b3b52fc2b8ae354c765113102d5622 Azure:

[GitHub] [flink] flinkbot commented on pull request #16129: [FLINK-22956][table-runtime] Stream Over TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread GitBox
flinkbot commented on pull request #16129: URL: https://github.com/apache/flink/pull/16129#issuecomment-858426849 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-22959) Keep the job jar files on JobManager

2021-06-10 Thread lukehua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lukehua updated FLINK-22959: Description: When i use the flink web ui ,i upload the jar files to the Jobmanager, but i can not keep

[jira] [Updated] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22956: --- Labels: pull-request-available (was: ) > Stream Over TTL should use enableTimeToLive of

[GitHub] [flink] JingsongLi opened a new pull request #16129: [FLINK-22956][table-runtime] Stream Over TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread GitBox
JingsongLi opened a new pull request #16129: URL: https://github.com/apache/flink/pull/16129 ## What is the purpose of the change Stream Over TTL should use enableTimeToLive of state instead of timer. We should get rid of `maxIdleStateRetention`. See

[jira] [Assigned] (FLINK-22909) Supports change log inputs for event time operators

2021-06-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22909: Assignee: (was: Jingsong Lee) > Supports change log inputs for event time operators

[jira] [Updated] (FLINK-22959) Keep the job jar files on JobManager

2021-06-10 Thread lukehua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lukehua updated FLINK-22959: Description: When i use the flink web ui ,i upload the jar files to the Jobmanager, but i can not keep

[jira] [Assigned] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22956: Assignee: Jingsong Lee > Stream Over TTL should use enableTimeToLive of state instead of

[jira] [Assigned] (FLINK-22909) Supports change log inputs for event time operators

2021-06-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22909: Assignee: Jingsong Lee > Supports change log inputs for event time operators >

[jira] [Updated] (FLINK-22959) Keep the job jar files on JobManager

2021-06-10 Thread lukehua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lukehua updated FLINK-22959: Description: When i use the flink web ui ,i upload the jar files to the Jobmanager, but i can not keep

[jira] [Updated] (FLINK-22959) Keep the job jar files on JobManager

2021-06-10 Thread lukehua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lukehua updated FLINK-22959: Description: When i use the flink web ui ,i upload the jar files to the Jobmanager, but i can not keep

[jira] [Updated] (FLINK-22959) Keep the job jar files on JobManager

2021-06-10 Thread lukehua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lukehua updated FLINK-22959: Description: When i use the flink web ui ,i upload the jar files to the Jobmanager, but i can not keep

[jira] [Created] (FLINK-22959) Keep the job jar files on JobManager

2021-06-10 Thread lukehua (Jira)
lukehua created FLINK-22959: --- Summary: Keep the job jar files on JobManager Key: FLINK-22959 URL: https://issues.apache.org/jira/browse/FLINK-22959 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-22955) lookup join filter push down result to mismatch function signature

2021-06-10 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360650#comment-17360650 ] JING ZHANG commented on FLINK-22955: [~gsavl] Thanks for firing the issue, add the mailist url here 

[GitHub] [flink] akalash commented on a change in pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

2021-06-10 Thread GitBox
akalash commented on a change in pull request #16102: URL: https://github.com/apache/flink/pull/16102#discussion_r648958362 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/IgnoreInFlightDataITCase.java ## @@ -107,17 +111,27 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #16128: [FLINK-22957][table-runtime] Rank TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16128: URL: https://github.com/apache/flink/pull/16128#issuecomment-858396590 ## CI report: * c1496ae5f3e3f74ac121791bdf3b1f82bede643a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * 3e7547f7f3ef663536bf763e0306c717f4cf45ec Azure:

[jira] [Issue Comment Deleted] (FLINK-20873) Upgrade Calcite version to 1.27

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-20873: - Comment: was deleted (was: This issue was labeled "stale-major" 7 ago and has not received any

[jira] [Issue Comment Deleted] (FLINK-20873) Upgrade Calcite version to 1.27

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-20873: - Comment: was deleted (was: This major issue is unassigned and itself and all of its Sub-Tasks

[jira] [Issue Comment Deleted] (FLINK-21239) Upgrade Calcite version to 1.28

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21239: - Comment: was deleted (was: This major issue is unassigned and itself and all of its Sub-Tasks

[jira] [Updated] (FLINK-21239) Upgrade Calcite version to 1.28

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21239: - Labels: (was: auto-deprioritized-major) > Upgrade Calcite version to 1.28 >

[jira] [Updated] (FLINK-21239) Upgrade Calcite version to 1.28

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21239: - Priority: Major (was: Minor) > Upgrade Calcite version to 1.28 >

[jira] [Issue Comment Deleted] (FLINK-21239) Upgrade Calcite version to 1.28

2021-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21239: - Comment: was deleted (was: This issue was labeled "stale-major" 7 ago and has not received any

[GitHub] [flink] flinkbot commented on pull request #16128: [FLINK-22957][table-runtime] Rank TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread GitBox
flinkbot commented on pull request #16128: URL: https://github.com/apache/flink/pull/16128#issuecomment-858396590 ## CI report: * c1496ae5f3e3f74ac121791bdf3b1f82bede643a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16037: [FLINK-22812][hive] Fix HiveConf, HiveMetaStoreClient and upgrade avr…

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16037: URL: https://github.com/apache/flink/pull/16037#issuecomment-851863905 ## CI report: * 104bc233bc2003180da19e9096c842141383066a UNKNOWN * 32210f42d0d60d3ee843a2a926bdc8b423dd29ef Azure:

[jira] [Commented] (FLINK-22530) RuntimeException after subsequent windowed grouping in TableAPI

2021-06-10 Thread Christopher Rost (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360630#comment-17360630 ] Christopher Rost commented on FLINK-22530: -- Hi, I still really looking forward to a fix of this

[jira] [Commented] (FLINK-22678) Hide ChangelogStateBackend From Users

2021-06-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360623#comment-17360623 ] Yuan Mei commented on FLINK-22678: -- [~nicholasjiang] It is not that simple, please check the google doc

[jira] [Commented] (FLINK-22678) Hide ChangelogStateBackend From Users

2021-06-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360621#comment-17360621 ] Yuan Mei commented on FLINK-22678: -- [~Zakelly] Please go ahead. > Hide ChangelogStateBackend From

[jira] [Updated] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22956: - Component/s: Table SQL / Runtime > Stream Over TTL should use enableTimeToLive of state instead

[jira] [Updated] (FLINK-22957) Rank TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22957: - Component/s: Table SQL / Runtime > Rank TTL should use enableTimeToLive of state instead of

[jira] [Assigned] (FLINK-22957) Rank TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22957: Assignee: Jingsong Lee > Rank TTL should use enableTimeToLive of state instead of timer

[GitHub] [flink] flinkbot edited a comment on pull request #16037: [FLINK-22812][hive] Fix HiveConf, HiveMetaStoreClient and upgrade avr…

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16037: URL: https://github.com/apache/flink/pull/16037#issuecomment-851863905 ## CI report: * 104bc233bc2003180da19e9096c842141383066a UNKNOWN * 32210f42d0d60d3ee843a2a926bdc8b423dd29ef Azure:

[GitHub] [flink] flinkbot commented on pull request #16128: [FLINK-22957][table-runtime] Rank TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread GitBox
flinkbot commented on pull request #16128: URL: https://github.com/apache/flink/pull/16128#issuecomment-858375694 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] qingdao81 commented on pull request #15808: [FLINK-21229] add confluent schema registry ssl support

2021-06-10 Thread GitBox
qingdao81 commented on pull request #15808: URL: https://github.com/apache/flink/pull/15808#issuecomment-858375407 @twalthr Sounds good to me. Let me know in case you need any further support. -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-22957) Rank TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22957: --- Labels: pull-request-available (was: ) > Rank TTL should use enableTimeToLive of state

[GitHub] [flink] JingsongLi opened a new pull request #16128: [FLINK-22957][table-runtime] Rank TTL should use enableTimeToLive of state instead of timer

2021-06-10 Thread GitBox
JingsongLi opened a new pull request #16128: URL: https://github.com/apache/flink/pull/16128 ## What is the purpose of the change Rank TTL should use enableTimeToLive of state instead of timer. We should get rid of `maxIdleStateRetention`. See

[GitHub] [flink] Airblader commented on a change in pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

2021-06-10 Thread GitBox
Airblader commented on a change in pull request #16046: URL: https://github.com/apache/flink/pull/16046#discussion_r648905113 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CurrentWatermarkInputTypeStrategy.java ##

[GitHub] [flink] Airblader commented on a change in pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

2021-06-10 Thread GitBox
Airblader commented on a change in pull request #16046: URL: https://github.com/apache/flink/pull/16046#discussion_r648903537 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CurrentWatermarkInputTypeStrategy.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #16126: [FLINK-22934][docs] Add instructions for using the " ' " escape syntax of SQL client

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16126: URL: https://github.com/apache/flink/pull/16126#issuecomment-858225387 ## CI report: * 7e5a79a9b48f69dce3349c18afb8f266182748b4 Azure:

[jira] [Commented] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

2021-06-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360602#comment-17360602 ] Jark Wu commented on FLINK-22954: - Another way can be refactoring the join operator to build the right

[GitHub] [flink] Airblader commented on a change in pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

2021-06-10 Thread GitBox
Airblader commented on a change in pull request #16046: URL: https://github.com/apache/flink/pull/16046#discussion_r648889963 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinition.java ## @@ -53,19 +53,23 @@

[jira] [Commented] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

2021-06-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360591#comment-17360591 ] godfrey he commented on FLINK-22954: [~jark] If we do not apply

[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

2021-06-10 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360588#comment-17360588 ] Ada Wong commented on FLINK-14902: -- I want to contribute this ticket. I want to use VertX to support

[jira] [Created] (FLINK-22958) Reused content in docs causes confusing navigation jumps

2021-06-10 Thread Jira
Ingo Bürk created FLINK-22958: - Summary: Reused content in docs causes confusing navigation jumps Key: FLINK-22958 URL: https://issues.apache.org/jira/browse/FLINK-22958 Project: Flink Issue

[jira] [Commented] (FLINK-22928) Unexpected exception happens in RecordWriter when stopping-with-savepoint

2021-06-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360583#comment-17360583 ] Yun Gao commented on FLINK-22928: - Yes, indeed, it also looks to me to be the same issue, very thanks~

[GitHub] [flink] flinkbot edited a comment on pull request #16127: [FLINK-22312][yarn][test] Fix test instabilities due to expected heartbeat exceptions in log

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #16127: URL: https://github.com/apache/flink/pull/16127#issuecomment-858327979 ## CI report: * 86b0b047914fe80e33a3b869594a07b0a8d8347f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-06-10 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * d1b81032b6f735cb72fc862b35512b9126b83915 Azure:

[GitHub] [flink] wangyang0918 commented on pull request #16127: [FLINK-22312][yarn][test] Fix test instabilities due to expected heartbeat exceptions in log

2021-06-10 Thread GitBox
wangyang0918 commented on pull request #16127: URL: https://github.com/apache/flink/pull/16127#issuecomment-85821 +1 for merging. We could simply ignore the "Exception on heartbeat" and `java.io.InterruptedIOException: Call interrupted` if all other verification passed. It

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

2021-06-10 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360575#comment-17360575 ] Qingsheng Ren commented on FLINK-22457: --- [~xintongsong] Sure, trying to reproduce locally >

[jira] [Updated] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

2021-06-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22954: Component/s: (was: Table SQL / API) Table SQL / Planner > Don't support consuming

<    1   2   3   4