[jira] [Created] (FLINK-25413) Use append yarn and hadoop config to replace overwrite

qiunan created FLINK-25413: -- Summary: Use append yarn and hadoop config to replace overwrite Key: FLINK-25413 URL: https://issues.apache.org/jira/browse/FLINK-25413 Project: Flink Issue Type:

[jira] [Closed] (FLINK-25365) Remove remaining references to planner from Python

[ https://issues.apache.org/jira/browse/FLINK-25365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25365. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] twalthr closed pull request #18156: [FLINK-25365][python] Remove remaining references to planner from Python

twalthr closed pull request #18156: URL: https://github.com/apache/flink/pull/18156 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463624#comment-17463624 ] Junfan Zhang commented on FLINK-17808: -- I overlooked this, and thanks [~yunta] for pointing it. I

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

TanYuxin-tyx commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r773664257 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java ## @@ -192,6

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

TanYuxin-tyx commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r773663321 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java ## @@ -192,6

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

TanYuxin-tyx commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r773662905 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadSchedulerTest.java ## @@ -192,6

[jira] [Commented] (FLINK-25360) Add State Desc to CheckpointMetadata

[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463622#comment-17463622 ] Yun Tang commented on FLINK-25360: -- [~liufangqi], I think your concerns have two different problems: #

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

TanYuxin-tyx commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r773661934 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java ## @@ -178,6

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

TanYuxin-tyx commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r773661321 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java ## @@ -154,8

[GitHub] [flink] flinkbot edited a comment on pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

flinkbot edited a comment on pull request #17936: URL: https://github.com/apache/flink/pull/17936#issuecomment-980533423 ## CI report: * 819684b71438fea2f38144bc70c23cc6525dee37 Azure:

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

TanYuxin-tyx commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r773659490 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java ## @@ -119,6

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

TanYuxin-tyx commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r773658955 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java ## @@ -178,6

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

TanYuxin-tyx commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r773658627 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java ## @@ -119,6

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

flinkbot edited a comment on pull request #17936: URL: https://github.com/apache/flink/pull/17936#issuecomment-980533423 ## CI report: * 819684b71438fea2f38144bc70c23cc6525dee37 Azure:

[GitHub] [flink] TanYuxin-tyx commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

TanYuxin-tyx commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r773657411 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -456,7 +456,7 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[jira] [Commented] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463612#comment-17463612 ] Caizhi Weng commented on FLINK-24885: - Hi [~wangbaohua] is this issue really fixed? Have you tested

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[jira] [Updated] (FLINK-25411) JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields

[ https://issues.apache.org/jira/browse/FLINK-25411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Surendra Lalwani updated FLINK-25411: - Fix Version/s: 1.13.6 > JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

gaoyunhaii commented on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-999337047 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[jira] [Commented] (FLINK-25328) Improvement of reuse segments for join/agg/sort operators in TaskManager for flink olap queries

[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463605#comment-17463605 ] Xintong Song commented on FLINK-25328: -- What I had in mind is something similar to the idle slot /

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

flinkbot edited a comment on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-984363654 ## CI report: * e7be85162e0b431d518ab1ffe8b59283338d00b7 Azure:

[GitHub] [flink] wuchong commented on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

wuchong commented on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-999330362 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[jira] [Updated] (FLINK-25411) JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields

[ https://issues.apache.org/jira/browse/FLINK-25411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Surendra Lalwani updated FLINK-25411: - Affects Version/s: 1.14.2 1.15.0 > JsonRowSerializationSchema

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463604#comment-17463604 ] Yun Tang commented on FLINK-17808: -- [~zuston] It seems FileSystem#createRecoverableWriter is only

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[jira] [Commented] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463600#comment-17463600 ] Ada Wong commented on FLINK-25188: -- I have updated numpy version in Apache Beam. we could bump to Beam

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[jira] [Comment Edited] (FLINK-25261) Changelog not truncated on materialization

[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463599#comment-17463599 ] Yuan Mei edited comment on FLINK-25261 at 12/22/21, 6:40 AM: - Shouldn't

[GitHub] [flink] flinkbot edited a comment on pull request #18172: [hotfix][doc]update doc variable name reference error

flinkbot edited a comment on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-999323746 ## CI report: * 20f4eea5c51af444b31a4535e7751af021a9041c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure:

[jira] [Comment Edited] (FLINK-25261) Changelog not truncated on materialization

[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463599#comment-17463599 ] Yuan Mei edited comment on FLINK-25261 at 12/22/21, 6:38 AM: - Shouldn't

[GitHub] [flink] wanglijie95 commented on a change in pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

wanglijie95 commented on a change in pull request #18023: URL: https://github.com/apache/flink/pull/18023#discussion_r773634889 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/VertexParallelismInformation.java ## @@ -37,6 +37,14 @@ */

[GitHub] [flink] wanglijie95 commented on a change in pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

wanglijie95 commented on a change in pull request #18023: URL: https://github.com/apache/flink/pull/18023#discussion_r773634628 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertexTest.java ## @@ -93,6 +92,63 @@ public void

[jira] [Comment Edited] (FLINK-25261) Changelog not truncated on materialization

[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463599#comment-17463599 ] Yuan Mei edited comment on FLINK-25261 at 12/22/21, 6:36 AM: - Shouldn't

[jira] [Commented] (FLINK-25261) Changelog not truncated on materialization

[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463599#comment-17463599 ] Yuan Mei commented on FLINK-25261: -- Shouldn't truncation happen during checkpoint subsumption? >

[GitHub] [flink] flinkbot commented on pull request #18172: [hotfix][doc]update doc variable name reference error

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

[GitHub] [flink] flinkbot commented on pull request #18172: [hotfix][doc]update doc variable name reference error

flinkbot commented on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-999323402 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] [Commented] (FLINK-25411) JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields

[ https://issues.apache.org/jira/browse/FLINK-25411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463598#comment-17463598 ] Surendra Lalwani commented on FLINK-25411: -- [~MartijnVisser82] can you please check this >

[GitHub] [flink] h1365930778 opened a new pull request #18172: update doc variable name reference error

h1365930778 opened a new pull request #18172: URL: https://github.com/apache/flink/pull/18172 ## What is the purpose of the change This PR fixes the problem with the Python DataStream API documentation page variable "t_env" being written as "table". On this page:

[jira] [Updated] (FLINK-25412) Upgrade of flink to 1.14.2 is showing internal server errors in the UI

[ https://issues.apache.org/jira/browse/FLINK-25412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] srujankumar updated FLINK-25412: Description: Hi  We have recently upgraded the flink from {{1.13.3}} to {{1.14.2}} and then

[jira] [Created] (FLINK-25412) Upgrade of flink to 1.14.2 is showing internal server errors in the UI

srujankumar created FLINK-25412: --- Summary: Upgrade of flink to 1.14.2 is showing internal server errors in the UI Key: FLINK-25412 URL: https://issues.apache.org/jira/browse/FLINK-25412 Project: Flink

[jira] [Updated] (FLINK-25412) Upgrade of flink to 1.14.2 is showing internal server errors in the UI

[ https://issues.apache.org/jira/browse/FLINK-25412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] srujankumar updated FLINK-25412: Description: Hi  We have recently upgraded the flink from {{1.13.3}} to {{1.14.2}} and then

[GitHub] [flink] yangjunhan commented on a change in pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

yangjunhan commented on a change in pull request #18148: URL: https://github.com/apache/flink/pull/18148#discussion_r773623624 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job-manager/thread-dump/job-manager-thread-dump.component.ts ## @@ -0,0 +1,72 @@ +/* + *

[jira] [Closed] (FLINK-24952) Rowtime attributes must not be in the input rows of a regular join. As a workaround you can cast the time attributes of input tables to TIMESTAMP before

[ https://issues.apache.org/jira/browse/FLINK-24952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua closed FLINK-24952. -- Resolution: Fixed > Rowtime attributes must not be in the input rows of a regular join. As a >

[jira] [Closed] (FLINK-25103) KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A

[ https://issues.apache.org/jira/browse/FLINK-25103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua closed FLINK-25103. -- Resolution: Fixed > KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A >

[jira] [Closed] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua closed FLINK-24885. -- Resolution: Fixed > ProcessElement Interface parameter Collector : java.lang.NullPointerException >

[GitHub] [flink] jelly-1203 commented on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

jelly-1203 commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-999311507 Hi, @godfreyhe Please have time to do the final check. If there is any deficiency, I will continue to improve -- This is an automated message from the Apache Git

[GitHub] [flink] becketqin commented on pull request #17991: [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deserializer

becketqin commented on pull request #17991: URL: https://github.com/apache/flink/pull/17991#issuecomment-999305905 Merged to master: 2b1a9dea74a334adb1fe890f024f4153ad11a985 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] becketqin merged pull request #17991: [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deserializer

becketqin merged pull request #17991: URL: https://github.com/apache/flink/pull/17991 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] becketqin commented on pull request #17991: [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deserializer

becketqin commented on pull request #17991: URL: https://github.com/apache/flink/pull/17991#issuecomment-999305583 Thanks for the patch. LGTM. -- 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] [Created] (FLINK-25411) JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields

Surendra Lalwani created FLINK-25411: Summary: JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields Key: FLINK-25411 URL: https://issues.apache.org/jira/browse/FLINK-25411 Project:

[jira] [Comment Edited] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463588#comment-17463588 ] Junfan Zhang edited comment on FLINK-25410 at 12/22/21, 5:47 AM: - Could

[jira] [Comment Edited] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463588#comment-17463588 ] Junfan Zhang edited comment on FLINK-25410 at 12/22/21, 5:43 AM: - Could

[jira] [Comment Edited] (FLINK-25328) Improvement of reuse segments for join/agg/sort operators in TaskManager for flink olap queries

[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463590#comment-17463590 ] Shammon edited comment on FLINK-25328 at 12/22/21, 5:42 AM: Thanks

[jira] [Commented] (FLINK-25328) Improvement of reuse segments for join/agg/sort operators in TaskManager for flink olap queries

[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463590#comment-17463590 ] Shammon commented on FLINK-25328: - Thanks [~xtsong], I think it's interesting about pending requests. I

[jira] [Commented] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463588#comment-17463588 ] Junfan Zhang commented on FLINK-25410: -- Could you help check this feature? [~guoyangze]  

[jira] [Updated] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25410: - Description: h2. Why In our internal streaming platform, we will use flink-cli tool to submit

[jira] [Updated] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25410: - Description: h2. Why In our internal streaming platform, we will use flink-cli tool to submit

[jira] [Created] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

Junfan Zhang created FLINK-25410: Summary: Flink CLI should exit when app is accepted with detach mode on Yarn Key: FLINK-25410 URL: https://issues.apache.org/jira/browse/FLINK-25410 Project: Flink

[GitHub] [flink] xintongsong commented on a change in pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

xintongsong commented on a change in pull request #18148: URL: https://github.com/apache/flink/pull/18148#discussion_r773568386 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -693,6 +696,21 @@ JobManagerRunner

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463584#comment-17463584 ] Junfan Zhang commented on FLINK-17808: -- [~yunta]  As Stephan mentioned above, i also think the

[GitHub] [flink] flinkbot edited a comment on pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

flinkbot edited a comment on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170 ## CI report: * 463b2c0160ba8892fa654a7689f9a58d516583e5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

flinkbot edited a comment on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170 ## CI report: * 463b2c0160ba8892fa654a7689f9a58d516583e5 Azure:

[jira] [Commented] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463582#comment-17463582 ] Junfan Zhang commented on FLINK-25398: -- [~Thesharing] Thanks for your advice. Agree with u, i will

[GitHub] [flink] flinkbot edited a comment on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

flinkbot edited a comment on pull request #18114: URL: https://github.com/apache/flink/pull/18114#issuecomment-994556266 ## CI report: * ad59747459a1ff9ff00e772282f8f02a955fafdd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

flinkbot edited a comment on pull request #18114: URL: https://github.com/apache/flink/pull/18114#issuecomment-994556266 ## CI report: * ad59747459a1ff9ff00e772282f8f02a955fafdd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16571: [hotfix][connector/kafka] fix missing nullable annotion

flinkbot edited a comment on pull request #16571: URL: https://github.com/apache/flink/pull/16571#issuecomment-884882802 ## CI report: * 18b95daab0297d86041683e92112c75b17c17bc8 Azure:

[GitHub] [flink] JingsongLi commented on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

JingsongLi commented on pull request #18114: URL: https://github.com/apache/flink/pull/18114#issuecomment-999271045 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 163e826eea7eb58d13e9712562a231bdabae9052 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16571: [hotfix][connector/kafka] fix missing nullable annotion

flinkbot edited a comment on pull request #16571: URL: https://github.com/apache/flink/pull/16571#issuecomment-884882802 ## CI report: * 18b95daab0297d86041683e92112c75b17c17bc8 Azure:

[jira] [Commented] (FLINK-25286) Improve connector testing framework to support more scenarios

[ https://issues.apache.org/jira/browse/FLINK-25286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463573#comment-17463573 ] Qingsheng Ren commented on FLINK-25286: --- [~monster#12] Thanks for supporting our work on connector

[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 163e826eea7eb58d13e9712562a231bdabae9052 Azure:

[jira] [Commented] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463569#comment-17463569 ] Qingsheng Ren commented on FLINK-25293: --- Thanks for the ticket [~rero] !  Basically Flink doesn't

[GitHub] [flink] JingsongLi commented on a change in pull request #18135: [FLINK-24809][table-common][table-planner] Fix precision for aggs on DECIMAL types

JingsongLi commented on a change in pull request #18135: URL: https://github.com/apache/flink/pull/18135#discussion_r773580701 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala ## @@ -831,34

[GitHub] [flink] flinkbot edited a comment on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * 11c78d1d81896eaea685b7a2e097bdf1124a8e45 Azure:

[GitHub] [flink] wangyang0918 commented on pull request #17819: [FLINK-15816][k8s] Limit kubernetes.cluster-id to a maximum of 40 characters

wangyang0918 commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-999262358 It is a good idea to introduce such a `enum`. And I do not think we will have the prefix and suffix for the K8s resource names or labels. +1 -- This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure:

[jira] [Commented] (FLINK-25360) Add State Desc to CheckpointMetadata

[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463562#comment-17463562 ] 刘方奇 commented on FLINK-25360: - Exactly, it can improve state-processor-api. I think it can also help the

[jira] [Commented] (FLINK-25360) Add State Desc to CheckpointMetadata

[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463561#comment-17463561 ] 刘方奇 commented on FLINK-25360: - [~yunta] THX for your reply.  We use state-processor-api to transform state

[GitHub] [flink] PatrickRen commented on a change in pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

PatrickRen commented on a change in pull request #18014: URL: https://github.com/apache/flink/pull/18014#discussion_r773571166 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java ## @@

[jira] [Comment Edited] (FLINK-25409) Add cache metric to LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463553#comment-17463553 ] Yuan Zhu edited comment on FLINK-25409 at 12/22/21, 3:06 AM: - In 1.14.2,

[jira] [Commented] (FLINK-25360) Add State Desc to CheckpointMetadata

[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463557#comment-17463557 ] Yun Tang commented on FLINK-25360: -- [~liufangqi] Any changes to checkpoint persistent content requires

  1   2   3   4   5   >