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

2021-12-21 Thread qiunan (Jira)
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: Improv

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

2021-12-21 Thread Timo Walther (Jira)
[ 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: 74ed032009aa599c7b69e7205e7a0db3d0

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

2021-12-21 Thread GitBox
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: issues-unsubsc

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

2021-12-21 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463624#comment-17463624 ] Junfan Zhang commented on FLINK-17808: -- I overlooked this, and thanks [~yunta] for

[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

2021-12-21 Thread GitBox
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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

2021-12-21 Thread GitBox
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

2021-12-21 Thread GitBox
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

2021-12-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463622#comment-17463622 ] Yun Tang commented on FLINK-25360: -- [~liufangqi], I think your concerns have two differ

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

2021-12-21 Thread GitBox
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 +185

[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

2021-12-21 Thread GitBox
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 +160

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #17936: URL: https://github.com/apache/flink/pull/17936#issuecomment-980533423 ## CI report: * 819684b71438fea2f38144bc70c23cc6525dee37 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

2021-12-21 Thread GitBox
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 +119

[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

2021-12-21 Thread GitBox
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 +185

[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

2021-12-21 Thread GitBox
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 +119

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #17936: URL: https://github.com/apache/flink/pull/17936#issuecomment-980533423 ## CI report: * 819684b71438fea2f38144bc70c23cc6525dee37 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

2021-12-21 Thread GitBox
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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463612#comment-17463612 ] Caizhi Weng commented on FLINK-24885: - Hi [~wangbaohua] is this issue really fixed?

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Surendra Lalwani (Jira)
[ 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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
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 specif

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463605#comment-17463605 ] Xintong Song commented on FLINK-25328: -- What I had in mind is something similar to

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

2021-12-21 Thread GitBox
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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Surendra Lalwani (Jira)
[ 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 una

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463604#comment-17463604 ] Yun Tang commented on FLINK-17808: -- [~zuston] It seems FileSystem#createRecoverableWrit

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463600#comment-17463600 ] Ada Wong commented on FLINK-25188: -- I have updated numpy version in Apache Beam. we cou

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463599#comment-17463599 ] Yuan Mei edited comment on FLINK-25261 at 12/22/21, 6:40 AM: -

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-999323746 ## CI report: * 20f4eea5c51af444b31a4535e7751af021a9041c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18023: URL: https://github.com/apache/flink/pull/18023#issuecomment-986704278 ## CI report: * 0268004b11d420c07814834ebe4798dfdf7ea5d7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463599#comment-17463599 ] Yuan Mei edited comment on FLINK-25261 at 12/22/21, 6:38 AM: -

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

2021-12-21 Thread GitBox
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 @@ */ in

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

2021-12-21 Thread GitBox
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 testL

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

2021-12-21 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463599#comment-17463599 ] Yuan Mei edited comment on FLINK-25261 at 12/22/21, 6:36 AM: -

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

2021-12-21 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463599#comment-17463599 ] Yuan Mei commented on FLINK-25261: -- Shouldn't truncation happen during checkpoint subsu

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

2021-12-21 Thread GitBox
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 r

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

2021-12-21 Thread GitBox
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 pro

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

2021-12-21 Thread Surendra Lalwani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463598#comment-17463598 ] Surendra Lalwani commented on FLINK-25411: -- [~MartijnVisser82] can you please c

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

2021-12-21 Thread GitBox
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: https://nightli

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

2021-12-21 Thread srujankumar (Jira)
[ 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 afte

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

2021-12-21 Thread srujankumar (Jira)
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

2021-12-21 Thread srujankumar (Jira)
[ 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 afte

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

2021-12-21 Thread GitBox
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 @@ +/* + * L

[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

2021-12-21 Thread wangbaohua (Jira)
[ 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 > workar

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

2021-12-21 Thread wangbaohua (Jira)
[ 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

2021-12-21 Thread wangbaohua (Jira)
[ 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

2021-12-21 Thread GitBox
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 Servic

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

2021-12-21 Thread GitBox
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 and

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

2021-12-21 Thread GitBox
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: issues-unsub

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

2021-12-21 Thread GitBox
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 the

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

2021-12-21 Thread Surendra Lalwani (Jira)
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: Flin

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

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

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

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

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

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

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

2021-12-21 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463590#comment-17463590 ] Shammon commented on FLINK-25328: - Thanks [~xtsong], I think it's interesting about pend

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

2021-12-21 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463588#comment-17463588 ] Junfan Zhang commented on FLINK-25410: -- Could you help check this feature? [~guoyan

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

2021-12-21 Thread Junfan Zhang (Jira)
[ 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 F

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

2021-12-21 Thread Junfan Zhang (Jira)
[ 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 Fl

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

2021-12-21 Thread Junfan Zhang (Jira)
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

2021-12-21 Thread GitBox
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 createJobManag

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

2021-12-21 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463584#comment-17463584 ] Junfan Zhang commented on FLINK-17808: -- [~yunta]  As Stephan mentioned above, i als

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170 ## CI report: * 463b2c0160ba8892fa654a7689f9a58d516583e5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170 ## CI report: * 463b2c0160ba8892fa654a7689f9a58d516583e5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463582#comment-17463582 ] Junfan Zhang commented on FLINK-25398: -- [~Thesharing] Thanks for your advice. Agree

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

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

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

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

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #16571: URL: https://github.com/apache/flink/pull/16571#issuecomment-884882802 ## CI report: * 18b95daab0297d86041683e92112c75b17c17bc8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
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 specif

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 163e826eea7eb58d13e9712562a231bdabae9052 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #16571: URL: https://github.com/apache/flink/pull/16571#issuecomment-884882802 ## CI report: * 18b95daab0297d86041683e92112c75b17c17bc8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463573#comment-17463573 ] Qingsheng Ren commented on FLINK-25286: --- [~monster#12] Thanks for supporting our w

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 163e826eea7eb58d13e9712562a231bdabae9052 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463569#comment-17463569 ] Qingsheng Ren commented on FLINK-25293: --- Thanks for the ticket [~rero] !  Basical

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

2021-12-21 Thread GitBox
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 +92

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * 11c78d1d81896eaea685b7a2e097bdf1124a8e45 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
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 messa

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread GitBox
flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-21 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463562#comment-17463562 ] 刘方奇 commented on FLINK-25360: - Exactly, it can improve state-processor-api. I think it can a

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

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

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

2021-12-21 Thread GitBox
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 ## @@ -54

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

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

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

2021-12-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463557#comment-17463557 ] Yun Tang commented on FLINK-25360: -- [~liufangqi] Any changes to checkpoint persistent c

  1   2   3   4   5   >