[GitHub] [flink] flinkbot commented on pull request #15226: [FLINK-20977][sql-client] Fix USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped

flinkbot commented on pull request #15226: URL: https://github.com/apache/flink/pull/15226#issuecomment-799974052 ## CI report: * 174d3bffbdc765f2eafe5c5295fe90554f4db6f7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15214: [FLINK-21793][k8s] Use RM generated JVM memory options.

flinkbot edited a comment on pull request #15214: URL: https://github.com/apache/flink/pull/15214#issuecomment-799249041 ## CI report: * abf3a6ff6c11d774b842af456a1c356a5292463a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15206: [FLINK-21673] Add extension points to snapshot reading/wr…

flinkbot edited a comment on pull request #15206: URL: https://github.com/apache/flink/pull/15206#issuecomment-798969998 ## CI report: * e78660dd022b3beface3ea8307e8f89292127c03 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

flinkbot edited a comment on pull request #15205: URL: https://github.com/apache/flink/pull/15205#issuecomment-798969965 ## CI report: * 8087d8f7d23911e311e212464badff6c89945e1d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * c9e2228fabe711bfa14d967084f2580cf51bdf4f Azure:

[GitHub] [flink] flinkbot commented on pull request #15227: [hotfix][checkpoint] Incorrect calculation of timeInQueue

flinkbot commented on pull request #15227: URL: https://github.com/apache/flink/pull/15227#issuecomment-799972353 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] pengkangjing opened a new pull request #15227: [hotfix][checkpoint] Incorrect calculation of timeInQueue

pengkangjing opened a new pull request #15227: URL: https://github.com/apache/flink/pull/15227 ## What is the purpose of the change **the correct timeInQueue is subtract request.timestamp from currentTimeMillis()** ## Brief change log **the correct timeInQueue is

[jira] [Created] (FLINK-21808) Support DQL in HiveParser

Rui Li created FLINK-21808: -- Summary: Support DQL in HiveParser Key: FLINK-21808 URL: https://issues.apache.org/jira/browse/FLINK-21808 Project: Flink Issue Type: Sub-task Components:

[GitHub] [flink] flinkbot edited a comment on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

flinkbot edited a comment on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799901815 ## CI report: * a61ff8f4fa887ca43d9e7e0b938b8519aab032c8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15214: [FLINK-21793][k8s] Use RM generated JVM memory options.

flinkbot edited a comment on pull request #15214: URL: https://github.com/apache/flink/pull/15214#issuecomment-799249041 ## CI report: * 5e9149267553ea5925bf4f59fe875bd7bfc324cd Azure:

[GitHub] [flink] flinkbot commented on pull request #15226: [FLINK-20977][sql-client] Fix USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped

flinkbot commented on pull request #15226: URL: https://github.com/apache/flink/pull/15226#issuecomment-799960289 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] wuchong opened a new pull request #15226: [FLINK-20977][sql-client] Fix USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped

wuchong opened a new pull request #15226: URL: https://github.com/apache/flink/pull/15226 ## What is the purpose of the change Fix USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in SQL Client. ## Brief change log

[jira] [Created] (FLINK-21807) Make ApplicationDeployer interface public

Yang Wang created FLINK-21807: - Summary: Make ApplicationDeployer interface public Key: FLINK-21807 URL: https://issues.apache.org/jira/browse/FLINK-21807 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

flinkbot edited a comment on pull request #15225: URL: https://github.com/apache/flink/pull/15225#issuecomment-799908523 ## CI report: * a112ca39e0b124df96e5c143ac37a263c0340671 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

flinkbot edited a comment on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799901815 ## CI report: * a61ff8f4fa887ca43d9e7e0b938b8519aab032c8 Azure:

[jira] [Created] (FLINK-21806) ContinuousEventTimeTrigger should register its first timer base on current watermark

Kezhu Wang created FLINK-21806: -- Summary: ContinuousEventTimeTrigger should register its first timer base on current watermark Key: FLINK-21806 URL: https://issues.apache.org/jira/browse/FLINK-21806

[GitHub] [flink] flinkbot edited a comment on pull request #15214: [FLINK-21793][k8s] Use RM generated JVM memory options.

flinkbot edited a comment on pull request #15214: URL: https://github.com/apache/flink/pull/15214#issuecomment-799249041 ## CI report: * 5e9149267553ea5925bf4f59fe875bd7bfc324cd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15200: [FLINK-21355] Send changes to the state changelog

flinkbot edited a comment on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-798902665 ## CI report: * 5e1342d9916f5c4356c622a40bc27bcbdacde9d7 UNKNOWN * ece208b9da559a725362de3d5c4e39e05de5d35e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 7c1b2b19a27ad6411875c2cd49e4d0bdfac5d174 Azure:

[jira] [Commented] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302213#comment-17302213 ] Yang Wang commented on FLINK-21685: --- [~petrizhang] After submitting more jobs in the session cluster,

[jira] [Comment Edited] (FLINK-20130) Add ZStandard format to inputs

[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302212#comment-17302212 ] Xintong Song edited comment on FLINK-20130 at 3/16/21, 4:50 AM: I have

[jira] [Reopened] (FLINK-20130) Add ZStandard format to inputs

[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-20130: -- I have reverted the changes (f220277c907852c028150a26fb5aff55dcff9d57), because it breaks the

[GitHub] [flink] flinkbot edited a comment on pull request #15223: [hotfix][javadocs] Expand JavaDoc for AccumulatorHelper

flinkbot edited a comment on pull request #15223: URL: https://github.com/apache/flink/pull/15223#issuecomment-799779491 ## CI report: * f12a1ac3afc264fe3b4b2cd81e6a9b01dae8bef2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15204: [FLINK-21783] Allow extension of HeapBackend SnapshotStrategy

flinkbot edited a comment on pull request #15204: URL: https://github.com/apache/flink/pull/15204#issuecomment-798969920 ## CI report: * de733f40a33045acef6ef9b6a4e17d767c55d9b9 UNKNOWN * 251bdef8c5a4425debdc1068a62f60537b7f78b0 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 7c1b2b19a27ad6411875c2cd49e4d0bdfac5d174 Azure:

[GitHub] [flink] KurtYoung commented on pull request #14054: [FLINK-20130][core] Add ZStandard to FileInputFormat

KurtYoung commented on pull request #14054: URL: https://github.com/apache/flink/pull/14054#issuecomment-799937333 Looks like this PR will break the tests. This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] kezhuw commented on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

kezhuw commented on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799937144 Hi @xintongsong, I have pushed a fixup commit according to you review comments. Please checkout and verify whether it meet your expectation. Thanks.

[jira] [Commented] (FLINK-21190) Expose extended exception history through REST handler and adapt UI accordingly

[ https://issues.apache.org/jira/browse/FLINK-21190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302203#comment-17302203 ] John Phelan commented on FLINK-21190: - hi [~mapohl] would you mind doing a call to talk about the

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * 6b317a312546abfb536c1358a331f1878e65e5d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 7c1b2b19a27ad6411875c2cd49e4d0bdfac5d174 Azure:

[GitHub] [flink] xintongsong commented on a change in pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

xintongsong commented on a change in pull request #15224: URL: https://github.com/apache/flink/pull/15224#discussion_r594840818 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/UnsafeMemoryBudget.java ## @@ -213,4 +213,16 @@ void

[GitHub] [flink] xintongsong commented on a change in pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

xintongsong commented on a change in pull request #15224: URL: https://github.com/apache/flink/pull/15224#discussion_r594842999 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/memory/MemoryManagerTest.java ## @@ -351,4 +352,27 @@ private void

[GitHub] [flink] zjuwangg commented on a change in pull request #15215: [FLINK-21785][blink-table-planner] Support json ser/de for StreamExecCorrelate

zjuwangg commented on a change in pull request #15215: URL: https://github.com/apache/flink/pull/15215#discussion_r594845347 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecCorrelate.java ## @@

[GitHub] [flink] wenlong88 commented on a change in pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

wenlong88 commented on a change in pull request #15219: URL: https://github.com/apache/flink/pull/15219#discussion_r594841777 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/LogicalTypeSerdeTest.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * 6b317a312546abfb536c1358a331f1878e65e5d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

flinkbot edited a comment on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * faff60c6e9ec1eedd27c3f1d221d7fc2de8f99c7 Azure:

[jira] [Commented] (FLINK-21727) Support DDL in HiveParser

[ https://issues.apache.org/jira/browse/FLINK-21727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302199#comment-17302199 ] Jark Wu commented on FLINK-21727: - Fixed in master: 95d6278e522d3716d1932cbb97993b56ab382eed

[jira] [Closed] (FLINK-21727) Support DDL in HiveParser

[ https://issues.apache.org/jira/browse/FLINK-21727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21727. --- Assignee: Rui Li Resolution: Fixed > Support DDL in HiveParser > - > >

[GitHub] [flink] wuchong merged pull request #15151: [FLINK-21727][hive] Support DDL in HiveParser

wuchong merged pull request #15151: URL: https://github.com/apache/flink/pull/15151 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

[jira] [Updated] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21803: Component/s: (was: API / Core) Table SQL / API > Tumbling / Sliding windows are

[jira] [Commented] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302196#comment-17302196 ] Jark Wu commented on FLINK-21803: - I think maybe FLINK-20387 can fix this problem. We will support

[GitHub] [flink] lindong28 commented on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

lindong28 commented on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-799917097 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

flinkbot edited a comment on pull request #15225: URL: https://github.com/apache/flink/pull/15225#issuecomment-799908523 ## CI report: * a112ca39e0b124df96e5c143ac37a263c0340671 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

flinkbot edited a comment on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * faff60c6e9ec1eedd27c3f1d221d7fc2de8f99c7 Azure:

[GitHub] [flink] fsk119 commented on a change in pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

fsk119 commented on a change in pull request #15197: URL: https://github.com/apache/flink/pull/15197#discussion_r594834406 ## File path: flink-table/flink-sql-client/src/test/resources/sql/set.q ## @@ -42,20 +42,11 @@ CREATE TABLE hive_table ( [INFO] Table has been created.

[GitHub] [flink] fsk119 commented on a change in pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

fsk119 commented on a change in pull request #15197: URL: https://github.com/apache/flink/pull/15197#discussion_r594834367 ## File path: flink-table/flink-sql-client/src/test/resources/sql/set.q ## @@ -42,20 +42,11 @@ CREATE TABLE hive_table ( [INFO] Table has been created.

[GitHub] [flink] xintongsong commented on a change in pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

xintongsong commented on a change in pull request #15112: URL: https://github.com/apache/flink/pull/15112#discussion_r594812450 ## File path: flink-core/src/main/java/org/apache/flink/api/common/resources/Resource.java ## @@ -30,7 +30,8 @@ /** Base class for resources one

[GitHub] [flink] fsk119 commented on a change in pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

fsk119 commented on a change in pull request #15197: URL: https://github.com/apache/flink/pull/15197#discussion_r594830451 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/LocalExecutorITCase.java ## @@ -444,6 +444,7 @@

[GitHub] [flink] flinkbot commented on pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

flinkbot commented on pull request #15225: URL: https://github.com/apache/flink/pull/15225#issuecomment-799908523 ## CI report: * a112ca39e0b124df96e5c143ac37a263c0340671 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

flinkbot edited a comment on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799901815 ## CI report: * a61ff8f4fa887ca43d9e7e0b938b8519aab032c8 Azure:

[GitHub] [flink] leonardBang commented on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

leonardBang commented on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-799908446 rebase and fix last comment This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15215: [FLINK-21785][blink-table-planner] Support json ser/de for StreamExecCorrelate

flinkbot edited a comment on pull request #15215: URL: https://github.com/apache/flink/pull/15215#issuecomment-799415392 ## CI report: * 1afde0cb4e55f09d68c42afaa709c645b992784a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

flinkbot edited a comment on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978 ## CI report: * e82fe2aac9edd6def8c5ef83ccafe5846c1ac7e4 Azure:

[jira] [Commented] (FLINK-11408) ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge

[ https://issues.apache.org/jira/browse/FLINK-11408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302181#comment-17302181 ] Kezhu Wang commented on FLINK-11408: I think it is same as FLINK-5717 and similar to event time

[jira] [Commented] (FLINK-21634) ALTER TABLE statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302180#comment-17302180 ] Zheng Hu commented on FLINK-21634: -- Thanks for the update, Looks good to me (from iceberg

[GitHub] [flink] flinkbot commented on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

flinkbot commented on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799901815 ## CI report: * a61ff8f4fa887ca43d9e7e0b938b8519aab032c8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15214: [FLINK-21793][k8s] Use RM generated JVM memory options.

flinkbot edited a comment on pull request #15214: URL: https://github.com/apache/flink/pull/15214#issuecomment-799249041 ## CI report: * 5e9149267553ea5925bf4f59fe875bd7bfc324cd Azure:

[GitHub] [flink] flinkbot commented on pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

flinkbot commented on pull request #15225: URL: https://github.com/apache/flink/pull/15225#issuecomment-799901617 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 #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

flinkbot edited a comment on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978 ## CI report: * e82fe2aac9edd6def8c5ef83ccafe5846c1ac7e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15215: [FLINK-21785][blink-table-planner] Support json ser/de for StreamExecCorrelate

flinkbot edited a comment on pull request #15215: URL: https://github.com/apache/flink/pull/15215#issuecomment-799415392 ## CI report: * 1afde0cb4e55f09d68c42afaa709c645b992784a Azure:

[GitHub] [flink] paul8263 opened a new pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

paul8263 opened a new pull request #15225: URL: https://github.com/apache/flink/pull/15225 [hotfix][docs] Add missing semicolons and remove unnecessary semicolons for learn-flink documents. ## What is the purpose of the change Fix several typos in Flink doc: learning-flink,

[jira] [Created] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit Json ser/de

Wenlong Lyu created FLINK-21805: --- Summary: Support StreamExecRank and StreamExecSortLimit Json ser/de Key: FLINK-21805 URL: https://issues.apache.org/jira/browse/FLINK-21805 Project: Flink

[GitHub] [flink] PatrickRen commented on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

PatrickRen commented on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-799897177 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] wuchong commented on pull request #14725: [FLINK-20977] Fix use the "USE DATABASE" command bug

wuchong commented on pull request #14725: URL: https://github.com/apache/flink/pull/14725#issuecomment-799895287 Has been fixed by FLINK-21614. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] wuchong closed pull request #14725: [FLINK-20977] Fix use the "USE DATABASE" command bug

wuchong closed pull request #14725: URL: https://github.com/apache/flink/pull/14725 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

[jira] [Updated] (FLINK-21753) Cycle references between memory manager and gc cleaner action

[ https://issues.apache.org/jira/browse/FLINK-21753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21753: --- Labels: pull-request-available (was: ) > Cycle references between memory manager and gc

[GitHub] [flink] flinkbot edited a comment on pull request #14395: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

flinkbot edited a comment on pull request #14395: URL: https://github.com/apache/flink/pull/14395#issuecomment-745744218 ## CI report: * 07407367ad601c684d652677ed8844bf8e28158b Azure:

[jira] [Commented] (FLINK-20977) USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in Flink SQL client

[ https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302163#comment-17302163 ] Jark Wu commented on FLINK-20977: - This has been fixed in master when working on FLINK-21614. I will

[jira] [Updated] (FLINK-20977) USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in Flink SQL client

[ https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20977: Fix Version/s: (was: 1.13.0) > USE DATABASE & USE CATALOG fails with quoted identifiers containing >

[GitHub] [flink] flinkbot commented on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

flinkbot commented on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799892253 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] kezhuw opened a new pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

kezhuw opened a new pull request #15224: URL: https://github.com/apache/flink/pull/15224 ## What is the purpose of the change Break cycle reference between memory manager and gc cleaner action in the first place. ## Brief change log * Creates an runnable that does not

[jira] [Closed] (FLINK-21704) Support StreamExecChangelogNormalize and StreamExecDropUpdateBefore json serde

[ https://issues.apache.org/jira/browse/FLINK-21704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21704. -- Resolution: Fixed Fixed in 1.13.0: e2b7256c19b5ddbcdbc44f8822cc50127711fe7e > Support

[GitHub] [flink] godfreyhe merged pull request #15210: [FLINK-21704][table-planner-blink] Support json ser/de for ChangelogSource

godfreyhe merged pull request #15210: URL: https://github.com/apache/flink/pull/15210 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

[GitHub] [flink] flinkbot edited a comment on pull request #15214: [FLINK-21793][k8s] Use RM generated JVM memory options.

flinkbot edited a comment on pull request #15214: URL: https://github.com/apache/flink/pull/15214#issuecomment-799249041 ## CI report: * 5e9149267553ea5925bf4f59fe875bd7bfc324cd Azure:

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r594810045 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ## @@ -213,9 +213,9 @@ public static void setTokensFor( Collection>

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r594810045 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ## @@ -213,9 +213,9 @@ public static void setTokensFor( Collection>

[GitHub] [flink] KurtYoung commented on a change in pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

KurtYoung commented on a change in pull request #15136: URL: https://github.com/apache/flink/pull/15136#discussion_r594809220 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/utils/ExpressionTestBase.scala ## @@

[GitHub] [flink] zentol commented on a change in pull request #15159: [FLINK-21136] Adjust timeouts for reactive mode

zentol commented on a change in pull request #15159: URL: https://github.com/apache/flink/pull/15159#discussion_r594806790 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -411,6 +411,35 @@

[jira] [Commented] (FLINK-21603) SQLClientKafkaITCase failed due to unexpected end of file

[ https://issues.apache.org/jira/browse/FLINK-21603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302148#comment-17302148 ] Xintong Song commented on FLINK-21603: --

[GitHub] [flink] zuston commented on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-799882439 > Hi @zuston and thanks for your contribution. > I'm wondering whether we can test that Flink is behaving in the right way when disabling the newly introduced flag. Right now,

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r594804847 ## File path: docs/layouts/shortcodes/generated/yarn_config_configuration.html ## @@ -140,6 +140,12 @@ ListString A

[GitHub] [flink] flinkbot edited a comment on pull request #14395: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

flinkbot edited a comment on pull request #14395: URL: https://github.com/apache/flink/pull/14395#issuecomment-745744218 ## CI report: * c49e4e668d1ff384073fd39e10af994b19c27018 Azure:

[jira] [Commented] (FLINK-19938) Implement shuffle data read scheduling for sort-merge blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-19938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302144#comment-17302144 ] junbiao chen commented on FLINK-19938: -- [~kevin.cyj] Thanks for answering my doubts.BTW，when will 

[GitHub] [flink] haydenzhourepo commented on pull request #15143: [FLINK-20938] Flink cos fs hadoop feature

haydenzhourepo commented on pull request #15143: URL: https://github.com/apache/flink/pull/15143#issuecomment-799873990 @yanghua can you have a review, ths This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #14395: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

flinkbot edited a comment on pull request #14395: URL: https://github.com/apache/flink/pull/14395#issuecomment-745744218 ## CI report: * c49e4e668d1ff384073fd39e10af994b19c27018 Azure:

[jira] [Updated] (FLINK-16542) Nothing on the HistoryServer

[ https://issues.apache.org/jira/browse/FLINK-16542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-16542: --- Attachment: (was: HistoryServer.JPG) > Nothing on the HistoryServer >

[jira] [Updated] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-19067: --- Description: When run examples/batch/WordCount.jar，it will fail with the exception: {code:java}

[jira] [Issue Comment Deleted] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-19067: --- Comment: was deleted (was: [~rmetzger] I find the same exception on original version It seems that

[jira] [Issue Comment Deleted] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-19067: --- Comment: was deleted (was: I delete some logs contain custom information It is a custom build, but

[jira] [Issue Comment Deleted] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-19067: --- Comment: was deleted (was: The log in JobManager is the same as CLI

[jira] [Issue Comment Deleted] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-19067: --- Comment: was deleted (was: [~rmetzger] After testing again, this should have nothing to do with

[jira] [Updated] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-19067: --- Attachment: (was: flink-jobmanager-deployer-hejiefang02.log) > resource_manager and dispatcher

[jira] [Updated] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-19067: --- Attachment: (was: flink-taskmanager-deployer-hejiefang02.log) > resource_manager and dispatcher

[jira] [Updated] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-19067: --- Attachment: (was: flink-jobmanager-deployer-hejiefang01.log) > resource_manager and dispatcher

[jira] [Updated] (FLINK-19067) resource_manager and dispatcher register on different nodes in HA mode will cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-19067: --- Attachment: (was: flink-taskmanager-deployer-hejiefang01.log) > resource_manager and dispatcher

  1   2   3   4   5   6   >