[jira] [Closed] (FLINK-28265) Inconsistency in Kubernetes HA service: broken state handle

2022-08-26 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-28265. - Fix Version/s: 1.16.0 1.15.3 Resolution: Fixed Fixed via: master(1.16): aae96

[GitHub] [flink] wangyang0918 merged pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-26 Thread GitBox
wangyang0918 merged PR #20673: URL: https://github.com/apache/flink/pull/20673 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.

[GitHub] [flink] wangyang0918 commented on pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-26 Thread GitBox
wangyang0918 commented on PR #20673: URL: https://github.com/apache/flink/pull/20673#issuecomment-1229137353 Merging now. -- 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

[GitHub] [flink] wangyang0918 commented on pull request #20684: [FLINK-29105][k8s] Fix the unstable k8s test 'testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents'

2022-08-26 Thread GitBox
wangyang0918 commented on PR #20684: URL: https://github.com/apache/flink/pull/20684#issuecomment-1229137197 @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 comme

[jira] [Updated] (FLINK-29124) Redundant checkNotNull in cli Package

2022-08-26 Thread ivan Qing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ivan Qing updated FLINK-29124: -- Description: Redundant NotNull checks in function cli/CliFrontend. {*}getEffectiveConfiguration{*}():

[jira] [Updated] (FLINK-29124) Redundant checkNotNull in cli Package

2022-08-26 Thread ivan Qing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ivan Qing updated FLINK-29124: -- Description: Redundant NotNull checks in function cli/CliFrontend. {*}getEffectiveConfiguration{*}():

[jira] [Created] (FLINK-29124) Redundant checkNotNull in cli Package

2022-08-26 Thread ivan Qing (Jira)
ivan Qing created FLINK-29124: - Summary: Redundant checkNotNull in cli Package Key: FLINK-29124 URL: https://issues.apache.org/jira/browse/FLINK-29124 Project: Flink Issue Type: Improvement

[GitHub] [flink] SwimSweet commented on a diff in pull request #20671: [FLINK-28915] Flink Native k8s mode jar localtion support s3 schema.

2022-08-26 Thread GitBox
SwimSweet commented on code in PR #20671: URL: https://github.com/apache/flink/pull/20671#discussion_r956250930 ## docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md: ## @@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar $FLINK_HOME/usrlib/my-flink-job.jar

[GitHub] [flink] liuzhuang2017 commented on a diff in pull request #20660: [FLINK-28998] Translate'Fine-Grained Resource Management' page into Chinese

2022-08-26 Thread GitBox
liuzhuang2017 commented on code in PR #20660: URL: https://github.com/apache/flink/pull/20660#discussion_r952051966 ## docs/content.zh/docs/deployment/finegrained_resource.md: ## @@ -23,97 +23,86 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] xintongsong commented on a diff in pull request #20622: [FLINK-28974][sql-gateway]Add doc for the API and Option of sql gateway

2022-08-26 Thread GitBox
xintongsong commented on code in PR #20622: URL: https://github.com/apache/flink/pull/20622#discussion_r956517011 ## flink-docs/pom.xml: ## @@ -173,6 +173,19 @@ under the License. ${project.version} + + org.apache.fli

[jira] [Updated] (FLINK-23633) HybridSource: Support dynamic stop position in FileSource

2022-08-26 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23633: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[GitHub] [flink] flinkbot commented on pull request #20691: [hotfix][Tests] Replace deprecated AbstractThrowableAssert#getRootCause with AbstractThrowableAssert#rootCause

2022-08-26 Thread GitBox
flinkbot commented on PR #20691: URL: https://github.com/apache/flink/pull/20691#issuecomment-1228967801 ## CI report: * cff97f48587863eed84c38b694acb8845c4fd44b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] snuyanzin opened a new pull request, #20691: [hotfix][Tests] Replace deprecated AbstractThrowableAssert#getRootCause with AbstractThrowableAssert#rootCause

2022-08-26 Thread GitBox
snuyanzin opened a new pull request, #20691: URL: https://github.com/apache/flink/pull/20691 ## What is the purpose of the change This a trivial PR replacing deprecated `AbstractThrowableAssert#getRootCause` with `AbstractThrowableAssert#rootCause` ## Verifying this change

[GitHub] [flink] snuyanzin commented on pull request #20663: [FLINK-29067][Table SQL/API] Replace deprecated SqlParser#configBuilder with SqlParser#config

2022-08-26 Thread GitBox
snuyanzin commented on PR #20663: URL: https://github.com/apache/flink/pull/20663#issuecomment-1228763271 @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 comment.

[GitHub] [flink] SwimSweet commented on a diff in pull request #20671: [FLINK-28915] Flink Native k8s mode jar localtion support s3 schema.

2022-08-26 Thread GitBox
SwimSweet commented on code in PR #20671: URL: https://github.com/apache/flink/pull/20671#discussion_r956250930 ## docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md: ## @@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar $FLINK_HOME/usrlib/my-flink-job.jar

[GitHub] [flink] SwimSweet commented on a diff in pull request #20671: [FLINK-28915] Flink Native k8s mode jar localtion support s3 schema.

2022-08-26 Thread GitBox
SwimSweet commented on code in PR #20671: URL: https://github.com/apache/flink/pull/20671#discussion_r956250930 ## docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md: ## @@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar $FLINK_HOME/usrlib/my-flink-job.jar

[GitHub] [flink-kubernetes-operator] tedhtchang commented on pull request #313: [FLINK-27852][docs] OLM installation and development documentation

2022-08-26 Thread GitBox
tedhtchang commented on PR #313: URL: https://github.com/apache/flink-kubernetes-operator/pull/313#issuecomment-1228733052 @shalberd Yes, I had considered to put it in the [redhat marketplace community-operators](https://github.com/redhat-openshift-ecosystem/community-operators-prod/tree/ma

[jira] [Updated] (FLINK-29123) Dynamic paramters are not pushed to working with kubernetes

2022-08-26 Thread Peter Vary (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Vary updated FLINK-29123: --- Summary: Dynamic paramters are not pushed to working with kubernetes (was: Dynamic paramters are no

[jira] [Created] (FLINK-29123) Dynamic paramters are not pushed to working with kubertenes

2022-08-26 Thread Peter Vary (Jira)
Peter Vary created FLINK-29123: -- Summary: Dynamic paramters are not pushed to working with kubertenes Key: FLINK-29123 URL: https://issues.apache.org/jira/browse/FLINK-29123 Project: Flink Issu

[GitHub] [flink] SwimSweet commented on a diff in pull request #20671: [FLINK-28915] Flink Native k8s mode jar localtion support s3 schema.

2022-08-26 Thread GitBox
SwimSweet commented on code in PR #20671: URL: https://github.com/apache/flink/pull/20671#discussion_r956232987 ## flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java: ## @@ -498,6 +498,20 @@ public class KubernetesConfigOptions

[jira] [Commented] (FLINK-29108) Kubernetes operator: Support queryable state

2022-08-26 Thread Ron Crocker (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585531#comment-17585531 ] Ron Crocker commented on FLINK-29108: - [~masteryhx] In a word, yes. There's two thi

[GitHub] [flink] snuyanzin commented on pull request #20663: [FLINK-29067][Table SQL/API] Replace deprecated SqlParser#configBuilder with SqlParser#config

2022-08-26 Thread GitBox
snuyanzin commented on PR #20663: URL: https://github.com/apache/flink/pull/20663#issuecomment-1228695193 @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 comment.

[GitHub] [flink] xintongsong commented on a diff in pull request #20647: [FLINK-29053] Hybrid shuffle has concurrent modification of buffer when compression is enabled

2022-08-26 Thread GitBox
xintongsong commented on code in PR #20647: URL: https://github.com/apache/flink/pull/20647#discussion_r956152093 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/ReadOnlySlicedNetworkBuffer.java: ## @@ -141,7 +141,9 @@ public ReadOnlySlicedNetworkBuffer

[GitHub] [flink] gaborgsomogyi commented on pull request #20265: [FLINK-25910][runtime][security] Propagate obtained delegation tokens to TaskManagers

2022-08-26 Thread GitBox
gaborgsomogyi commented on PR #20265: URL: https://github.com/apache/flink/pull/20265#issuecomment-1228604965 Just resolved the conflicts. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spec

[jira] [Closed] (FLINK-29056) Throw PartitionNotFoundException if the partition file is not readable for hybrid shuffle.

2022-08-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29056. Resolution: Fixed master (1.16): c643a2953ba44b3b316ba52983932329dc0162e4 > Throw PartitionNotFou

[GitHub] [flink] xintongsong closed pull request #20666: [FLINK-29056] Throw PartitionNotFoundException if the partition file is not readable for hybrid shuffle

2022-08-26 Thread GitBox
xintongsong closed pull request #20666: [FLINK-29056] Throw PartitionNotFoundException if the partition file is not readable for hybrid shuffle URL: https://github.com/apache/flink/pull/20666 -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[jira] [Assigned] (FLINK-29101) PipelinedRegionSchedulingStrategy benchmark shows performance degradation

2022-08-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29101: Assignee: Weijie Guo > PipelinedRegionSchedulingStrategy benchmark shows performance degr

[jira] [Commented] (FLINK-29122) Improve robustness of FileUtils.expandDirectory()

2022-08-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585389#comment-17585389 ] Robert Metzger commented on FLINK-29122: Draft: https://github.com/rmetzger/flin

[jira] [Assigned] (FLINK-29122) Improve robustness of FileUtils.expandDirectory()

2022-08-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-29122: -- Assignee: Robert Metzger > Improve robustness of FileUtils.expandDirectory() > -

[jira] [Created] (FLINK-29122) Improve robustness of FileUtils.expandDirectory()

2022-08-26 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-29122: -- Summary: Improve robustness of FileUtils.expandDirectory() Key: FLINK-29122 URL: https://issues.apache.org/jira/browse/FLINK-29122 Project: Flink Issue

[GitHub] [flink] fsk119 commented on pull request #20678: [FLINK-29097][sql-gateway]Moving json se/deserializers from sql-gateway-api to sql-gateway

2022-08-26 Thread GitBox
fsk119 commented on PR #20678: URL: https://github.com/apache/flink/pull/20678#issuecomment-1228426125 I add a commit to 1. move the serializer 2. modify the ColumnInfo. I find the `Column` also has comment field. -- This is an automated message from the Apache Git Service. To resp

[jira] [Closed] (FLINK-28883) Fix HiveTableSink failed to report metrics to hive metastore

2022-08-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28883. --- Release Note: In batch mode, Hive sink now will report statistics for written tables and partitions to Hive

[GitHub] [flink] wuchong merged pull request #20549: [FLINK-28883][hive] Fix HiveTableSink failed to report statistic to hive metastore in batch mode

2022-08-26 Thread GitBox
wuchong merged PR #20549: URL: https://github.com/apache/flink/pull/20549 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

[GitHub] [flink] HuangXingBo commented on pull request #20685: [FLINK-28429][python] Optimize PyFlink tests

2022-08-26 Thread GitBox
HuangXingBo commented on PR #20685: URL: https://github.com/apache/flink/pull/20685#issuecomment-1228417670 Due to the different performance of machines in the Azure, there is actually a deviation of about 30~40 minutes at most. Sometimes, the test time on the master can be exceed to 1.5 ho

[jira] [Closed] (FLINK-27033) YARNITCase failed due to OOM

2022-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27033. Resolution: Fixed > YARNITCase failed due to OOM > > >

[jira] [Commented] (FLINK-29006) PulsarSourceITCase failed with Could not acquire the minimum required resources.

2022-08-26 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585328#comment-17585328 ] Yufan Sheng commented on FLINK-29006: - [~hxbks2ks] The root cause should be the bug

[GitHub] [flink] wuchong commented on a diff in pull request #20549: [FLINK-28883][hive] Fix HiveTableSink failed to report statistic to hive metastore in batch mode

2022-08-26 Thread GitBox
wuchong commented on code in PR #20549: URL: https://github.com/apache/flink/pull/20549#discussion_r955971797 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveOptions.java: ## @@ -134,6 +134,17 @@ public class HiveOptions { public

[jira] [Closed] (FLINK-28976) Changelog 1st materialization delayed unneccesarily

2022-08-26 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-28976. - Resolution: Fixed Merged into master as 91e1291e942afc69779f09ead549352d5d357f22 .. a38

[jira] [Closed] (FLINK-29035) ExpressionReducer does not work with jar resources

2022-08-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-29035. --- Assignee: dalongliu Resolution: Fixed Fixed in master: 0ade193d39326dd5b84334348a4b6ce76c4a915a > Exp

[GitHub] [flink] wuchong merged pull request #20635: [FLINK-29035][table-planner] Fix bug of ExpressionReducer does not work with jar resources

2022-08-26 Thread GitBox
wuchong merged PR #20635: URL: https://github.com/apache/flink/pull/20635 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

[GitHub] [flink] rkhachatryan merged pull request #20687: [BP-1.15][FLINK-28976][state] Don't add extra delay to the 1st materialization

2022-08-26 Thread GitBox
rkhachatryan merged PR #20687: URL: https://github.com/apache/flink/pull/20687 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.

[jira] [Commented] (FLINK-29121) SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed

2022-08-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585320#comment-17585320 ] Jark Wu commented on FLINK-29121: - cc [~fsk119] > SqlGatewayRestAPIStabilityTest.testSq

[jira] [Updated] (FLINK-29121) SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed

2022-08-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29121: Fix Version/s: 1.16.0 > SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed >

[jira] [Created] (FLINK-29121) SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed

2022-08-26 Thread Jark Wu (Jira)
Jark Wu created FLINK-29121: --- Summary: SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed Key: FLINK-29121 URL: https://issues.apache.org/jira/browse/FLINK-29121 Project: Flink

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #355: [FLINK-28734][helm] Configurable role(binding) names

2022-08-26 Thread GitBox
gaborgsomogyi commented on PR #355: URL: https://github.com/apache/flink-kubernetes-operator/pull/355#issuecomment-1228391322 cc @gyfora @mbalassi -- 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 t

[GitHub] [flink] wuchong commented on pull request #18975: [FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant passe

2022-08-26 Thread GitBox
wuchong commented on PR #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1228391354 The `HiveDialectQueryITCase.testCastTimeStampToDecimal` is still failed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-28734) Configurable role(binding) names in the helm chart

2022-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28734: --- Labels: pull-request-available (was: ) > Configurable role(binding) names in the helm chart

[GitHub] [flink-kubernetes-operator] gaborgsomogyi opened a new pull request, #355: [FLINK-28734][helm] Configurable role(binding) names

2022-08-26 Thread GitBox
gaborgsomogyi opened a new pull request, #355: URL: https://github.com/apache/flink-kubernetes-operator/pull/355 ## What is the purpose of the change The names of the roles and rolebindings in the helm chart are not yet configurable. In this PR it's made configurable. ## Brief

[GitHub] [flink] wangyang0918 commented on a diff in pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-26 Thread GitBox
wangyang0918 commented on code in PR #20673: URL: https://github.com/apache/flink/pull/20673#discussion_r955943999 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java: ## @@ -1119,4 +1166,34 @@ private TestingLongSta

[GitHub] [flink] XComp commented on a diff in pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-26 Thread GitBox
XComp commented on code in PR #20673: URL: https://github.com/apache/flink/pull/20673#discussion_r955938498 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java: ## @@ -1119,4 +1166,34 @@ private TestingLongStateHandl

[GitHub] [flink] snuyanzin commented on pull request #20663: [FLINK-29067][Table SQL/API] Replace deprecated SqlParser#configBuilder with SqlParser#config

2022-08-26 Thread GitBox
snuyanzin commented on PR #20663: URL: https://github.com/apache/flink/pull/20663#issuecomment-1228362843 @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 comment.

[GitHub] [flink] wangyang0918 commented on a diff in pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-26 Thread GitBox
wangyang0918 commented on code in PR #20673: URL: https://github.com/apache/flink/pull/20673#discussion_r955930855 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java: ## @@ -1119,4 +1166,34 @@ private TestingLongSta

[GitHub] [flink] flinkbot commented on pull request #20690: FLINK-27107. Typo in Task.

2022-08-26 Thread GitBox
flinkbot commented on PR #20690: URL: https://github.com/apache/flink/pull/20690#issuecomment-1228355773 ## CI report: * 459dc89ac49b2d10bf59471007c0f6bad2c38e31 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zentol commented on pull request #20685: [FLINK-28429][python] Optimize PyFlink tests

2022-08-26 Thread GitBox
zentol commented on PR #20685: URL: https://github.com/apache/flink/pull/20685#issuecomment-1228354535 This doesn't seem to have the desired effect; the runtime of flink-python is still 51m, like on master. -- This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [flink] HarshaR99 opened a new pull request, #20690: FLINK-27107. Typo in Task.

2022-08-26 Thread GitBox
HarshaR99 opened a new pull request, #20690: URL: https://github.com/apache/flink/pull/20690 Two small typos in Task TaskCancelerWatchDog/TaskInterrupter field: executerThread -> executorThread TaskCanceler field: executer -> executor ## What is the purpose of the ch

[GitHub] [flink] HarshaR99 closed pull request #20604: FLINK-27107. Typo in Task.

2022-08-26 Thread GitBox
HarshaR99 closed pull request #20604: FLINK-27107. Typo in Task. URL: https://github.com/apache/flink/pull/20604 -- 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,

[GitHub] [flink] flinkbot commented on pull request #20689: [FLINK-28984][runtime] Fix the problem that FsCheckpointStateOutputStream is not being released normally

2022-08-26 Thread GitBox
flinkbot commented on PR #20689: URL: https://github.com/apache/flink/pull/20689#issuecomment-1228342426 ## CI report: * 9b267d3f979a2d29653ef0ed00e03a39a5f2ab93 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] ChangjiGuo commented on pull request #20689: [FLINK-28984][runtime] Fix the problem that FsCheckpointStateOutputStream is not being released normally

2022-08-26 Thread GitBox
ChangjiGuo commented on PR #20689: URL: https://github.com/apache/flink/pull/20689#issuecomment-1228341795 Hi, @Myasuka. Can you help me review this pr? Thx -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[jira] [Updated] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

2022-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28984: --- Labels: pull-request-available (was: ) > FsCheckpointStateOutputStream is not being release

[GitHub] [flink] ChangjiGuo opened a new pull request, #20689: [FLINK-28984][runtime] Fix the problem that FsCheckpointStateOutputStream is not being released normally

2022-08-26 Thread GitBox
ChangjiGuo opened a new pull request, #20689: URL: https://github.com/apache/flink/pull/20689 ## What is the purpose of the change This pr is used to solve the problem that the FsCheckpointStateOutputStream is not released normally in some scenarios. See https://issues.apache

[GitHub] [flink] wangyang0918 commented on a diff in pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-26 Thread GitBox
wangyang0918 commented on code in PR #20673: URL: https://github.com/apache/flink/pull/20673#discussion_r955901418 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java: ## @@ -1119,4 +1166,34 @@ private TestingLongSta

[GitHub] [flink] wangyang0918 commented on a diff in pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-26 Thread GitBox
wangyang0918 commented on code in PR #20673: URL: https://github.com/apache/flink/pull/20673#discussion_r955896987 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java: ## @@ -1119,4 +1166,34 @@ private TestingLongSta

[jira] [Updated] (FLINK-28906) Add AlgoOperator for AgglomerativeClustering

2022-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28906: --- Labels: pull-request-available (was: ) > Add AlgoOperator for AgglomerativeClustering > ---

[GitHub] [flink-ml] zhipeng93 opened a new pull request, #148: [FLINK-28906] Add AlgoOperator for AgglomerativeClustering

2022-08-26 Thread GitBox
zhipeng93 opened a new pull request, #148: URL: https://github.com/apache/flink-ml/pull/148 ## What is the purpose of the change - Add AlgoOperator for AgglomerativeClustering[1] in Flink ML. ## Brief change log - Added AlgoOperator for AgglomerativeClustering. - Added java/p

[GitHub] [flink] wangyang0918 commented on a diff in pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-26 Thread GitBox
wangyang0918 commented on code in PR #20673: URL: https://github.com/apache/flink/pull/20673#discussion_r955886917 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java: ## @@ -1119,4 +1166,34 @@ private TestingLongSta

[GitHub] [flink] flinkbot commented on pull request #20688: [FLINK-28764][table-planner] Support more than 64 distinct aggregate function calls in one aggregate SQL query

2022-08-26 Thread GitBox
flinkbot commented on PR #20688: URL: https://github.com/apache/flink/pull/20688#issuecomment-1228307836 ## CI report: * af5a62774c27a8b56fa6573053ace0701b2c677e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28764) Support more than 64 distinct aggregate function calls in one aggregate SQL query

2022-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28764: --- Labels: pull-request-available (was: ) > Support more than 64 distinct aggregate function c

[GitHub] [flink] WeiZhong94 opened a new pull request, #20688: [FLINK-28764][table-planner] Support more than 64 distinct aggregate function calls in one aggregate SQL query

2022-08-26 Thread GitBox
WeiZhong94 opened a new pull request, #20688: URL: https://github.com/apache/flink/pull/20688 ## What is the purpose of the change *This pull request rewrite the FlinkAggregateExpandDistinctAggregatesRule to support more than 64 distinct aggregate function calls in one agg

[jira] [Commented] (FLINK-28461) PyFlink Table should add get_resolved_schema method

2022-08-26 Thread bo zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585280#comment-17585280 ] bo zhao commented on FLINK-28461: - May I file a PR for this? Looks like a lower hanging

[jira] [Closed] (FLINK-27175) Fail to call Hive UDAF when the UDAF is with only one parameter with array type

2022-08-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27175. --- Resolution: Fixed Fixed in master: c086a91d977a5cb51d1b7c962bcb51f7d2a867fc > Fail to call Hive UDAF when t

[GitHub] [flink] wuchong merged pull request #19423: [FLINK-27175][hive] Fix fail to call Hive UDAF when the UDAF accepts one parameter with array type

2022-08-26 Thread GitBox
wuchong merged PR #19423: URL: https://github.com/apache/flink/pull/19423 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

[jira] [Updated] (FLINK-29120) Unexpected join hint propagation into view

2022-08-26 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29120: Description: As expected, Join Hint should only affects the current query block, and does not aff

[jira] [Created] (FLINK-29120) Unexpected join hint propagation into view

2022-08-26 Thread lincoln lee (Jira)
lincoln lee created FLINK-29120: --- Summary: Unexpected join hint propagation into view Key: FLINK-29120 URL: https://issues.apache.org/jira/browse/FLINK-29120 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-28764) Support more than 64 distinct aggregate function calls in one aggregate SQL query

2022-08-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28764: --- Assignee: Wei Zhong > Support more than 64 distinct aggregate function calls in one aggregate SQL

[jira] [Updated] (FLINK-29118) Remove default_catalog in the HiveServer2 Endpoint

2022-08-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29118: -- Description: Hive only has one Catalog. We don't require the default_catalog. Hive JDBC Drive

[jira] [Updated] (FLINK-29118) Remove default_catalog in the HiveServer2 Endpoint

2022-08-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29118: -- Attachment: image-2022-08-26-17-40-49-989.png > Remove default_catalog in the HiveServer2 Endp

[jira] [Created] (FLINK-29119) Should clarify how join hints work with CTE

2022-08-26 Thread lincoln lee (Jira)
lincoln lee created FLINK-29119: --- Summary: Should clarify how join hints work with CTE Key: FLINK-29119 URL: https://issues.apache.org/jira/browse/FLINK-29119 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-29118) Remove default_catalog in the HiveServer2 Endpoint

2022-08-26 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-29118: - Summary: Remove default_catalog in the HiveServer2 Endpoint Key: FLINK-29118 URL: https://issues.apache.org/jira/browse/FLINK-29118 Project: Flink Issue Ty

[GitHub] [flink] WencongLiu commented on pull request #20678: [FLINK-29097][sql-gateway]Moving json se/deserializers from sql-gateway-api to sql-gateway

2022-08-26 Thread GitBox
WencongLiu commented on PR #20678: URL: https://github.com/apache/flink/pull/20678#issuecomment-1228272556 @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 comment

[GitHub] [flink] HuangXingBo commented on pull request #20685: [FLINK-28429][python] Optimize PyFlink tests

2022-08-26 Thread GitBox
HuangXingBo commented on PR #20685: URL: https://github.com/apache/flink/pull/20685#issuecomment-1228252796 @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 commen

[jira] [Comment Edited] (FLINK-29088) Project push down cause the source reuse can not work

2022-08-26 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585251#comment-17585251 ] Aitozi edited comment on FLINK-29088 at 8/26/22 9:04 AM: - [~twal

[jira] [Closed] (FLINK-28646) Handle scaling operation separately in reconciler/service

2022-08-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28646. -- Resolution: Fixed merged to main 0a346ec7c6e8b770c1c10aa01686ee68c9dd4f27 > Handle scaling operation

[jira] [Commented] (FLINK-29088) Project push down cause the source reuse can not work

2022-08-26 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585251#comment-17585251 ] Aitozi commented on FLINK-29088: [~twalthr] Thanks for your inputs. > I guess the impl

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #351: [FLINK-28646] Handle scaling operation separately in reconciler/service

2022-08-26 Thread GitBox
gyfora merged PR #351: URL: https://github.com/apache/flink-kubernetes-operator/pull/351 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] flinkbot commented on pull request #20687: [BP-1.15][FLINK-28976][state] Don't add extra delay to the 1st materialization

2022-08-26 Thread GitBox
flinkbot commented on PR #20687: URL: https://github.com/apache/flink/pull/20687#issuecomment-1228242435 ## CI report: * 2c8c9692044b3d2ed718c2a31e68ed9bd79ec8f9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29117) Tried to associate with unreachable remote resourcemanager address

2022-08-26 Thread geonyeong kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] geonyeong kim updated FLINK-29117: -- Description: Hello. I am planning to distribute and use FlinkDeployment through the flink ku

[GitHub] [flink] rkhachatryan opened a new pull request, #20687: [BP-1.15][FLINK-28976][state] Don't add extra delay to the 1st materialization

2022-08-26 Thread GitBox
rkhachatryan opened a new pull request, #20687: URL: https://github.com/apache/flink/pull/20687 Backport of #20585 to 1.15. -- 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.

[jira] [Closed] (FLINK-29116) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] geonyeong kim closed FLINK-29116. - Resolution: Duplicate > Tried to associate with unreachable remote address > ---

[jira] [Updated] (FLINK-29116) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] geonyeong kim updated FLINK-29116: -- Labels: bug features (was: features) > Tried to associate with unreachable remote address > -

[jira] [Updated] (FLINK-29117) Tried to associate with unreachable remote resourcemanager address

2022-08-26 Thread geonyeong kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] geonyeong kim updated FLINK-29117: -- Summary: Tried to associate with unreachable remote resourcemanager address (was: Tried to as

[jira] [Updated] (FLINK-29117) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] geonyeong kim updated FLINK-29117: -- Attachment: (was: Screen Shot 2022-08-26 at 5.04.37 PM.png) > Tried to associate with unre

[jira] [Updated] (FLINK-29117) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] geonyeong kim updated FLINK-29117: -- Attachment: taskmanager_log.png > Tried to associate with unreachable remote address > ---

[jira] [Updated] (FLINK-29117) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] geonyeong kim updated FLINK-29117: -- Description: Hello. I am planning to distribute and use FlinkDeployment through the flink ku

[jira] [Updated] (FLINK-29117) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] geonyeong kim updated FLINK-29117: -- Description: Hello. I am planning to distribute and use FlinkDeployment through the flink ku

[jira] [Created] (FLINK-29117) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
geonyeong kim created FLINK-29117: - Summary: Tried to associate with unreachable remote address Key: FLINK-29117 URL: https://issues.apache.org/jira/browse/FLINK-29117 Project: Flink Issue Ty

[GitHub] [flink] wuchong commented on pull request #18975: [FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant passe

2022-08-26 Thread GitBox
wuchong commented on PR #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1228225348 `HiveDialectQueryITCase.testCastTimeStampToDecimal:804` is failed, please take a look. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] flinkbot commented on pull request #20686: [FLINK-29112][table-planner] Print the lookup join hint on the node in the origin RelNode tree for easier debuging

2022-08-26 Thread GitBox
flinkbot commented on PR #20686: URL: https://github.com/apache/flink/pull/20686#issuecomment-1228223447 ## CI report: * 9f8ceabd93c4692bad3e349b0efa08d6931827dc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-29116) Tried to associate with unreachable remote address

2022-08-26 Thread geonyeong kim (Jira)
geonyeong kim created FLINK-29116: - Summary: Tried to associate with unreachable remote address Key: FLINK-29116 URL: https://issues.apache.org/jira/browse/FLINK-29116 Project: Flink Issue Ty

[GitHub] [flink] XComp commented on a diff in pull request #20673: [BP-1.15][FLINK-28265][k8s] Make KubernetesStateHandleStore#addEntry idempotent

2022-08-26 Thread GitBox
XComp commented on code in PR #20673: URL: https://github.com/apache/flink/pull/20673#discussion_r955802991 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java: ## @@ -1119,4 +1166,34 @@ private TestingLongStateHandl

[jira] [Updated] (FLINK-29112) Print the lookup join hint on the node `Correlate` in the origin RelNode tree for easier debuging

2022-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29112: --- Labels: pull-request-available (was: ) > Print the lookup join hint on the node `Correlate`

  1   2   >