[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

2022-11-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629640#comment-17629640 ] Matthias Pohl commented on FLINK-29387: ---

[jira] [Commented] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-11-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629639#comment-17629639 ] Matthias Pohl commented on FLINK-26037: ---

[GitHub] [flink] gaborgsomogyi commented on pull request #21147: [FLINK-28330][runtime][security] Remove old delegation token framework code

2022-11-06 Thread GitBox
gaborgsomogyi commented on PR #21147: URL: https://github.com/apache/flink/pull/21147#issuecomment-1305213040 @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

[jira] [Updated] (FLINK-29849) Event time temporal join on an upsert source may produce incorrect execution plan

2022-11-06 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29849: Description: For current implementation, the execution plan is incorrect when do event time

[jira] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

2022-11-06 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629630#comment-17629630 ] Yanfei Lei commented on FLINK-29913: I added

[jira] [Updated] (FLINK-29580) pulsar.consumer.autoUpdatePartitionsIntervalSeconds doesn't work and should be removed

2022-11-06 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-29580: Summary: pulsar.consumer.autoUpdatePartitionsIntervalSeconds doesn't work and should be removed

[GitHub] [flink] fredia commented on a diff in pull request #21050: [FLINK-29095][state] Improve logging in SharedStateRegistry

2022-11-06 Thread GitBox
fredia commented on code in PR #21050: URL: https://github.com/apache/flink/pull/21050#discussion_r1015085362 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java: ## @@ -95,60 +95,78 @@ public StreamStateHandle registerReference(

[jira] [Comment Edited] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2022-11-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629585#comment-17629585 ] Yang Wang edited comment on FLINK-22262 at 11/7/22 7:25 AM: Thanks [~yunta]

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-06 Thread Brian Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629618#comment-17629618 ] Brian Zhou commented on FLINK-28695: Thanks [~Weijie Guo] for your suggestion, we can try that. For

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #160: [FLINK-29434] Add AlgoOperator for Splitter

2022-11-06 Thread GitBox
zhipeng93 commented on code in PR #160: URL: https://github.com/apache/flink-ml/pull/160#discussion_r1015050760 ## flink-ml-examples/src/main/java/org/apache/flink/ml/examples/feature/RandomSplitterExample.java: ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

2022-11-06 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629614#comment-17629614 ] Weihua Hu commented on FLINK-27341: --- Hi, [~chesnay] , [~gaoyunhaii]  I think this was introduced by

[jira] [Comment Edited] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629601#comment-17629601 ] Weijie Guo edited comment on FLINK-28695 at 11/7/22 6:22 AM: - [~Brian Zhou]

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #354: [FLINK-29840] Fix bug that old record may overwrite new record in Table Store when snapshot committing is slow

2022-11-06 Thread GitBox
LadyForest commented on code in PR #354: URL: https://github.com/apache/flink-table-store/pull/354#discussion_r1015039112 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreWriteOperator.java: ## @@ -88,18 +97,31 @@ public void setup(

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629601#comment-17629601 ] Weijie Guo commented on FLINK-28695: [~Brian Zhou] If you suspect that the problem is caused by

[jira] [Created] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

2022-11-06 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-29913: -- Summary: Shared state would be discarded by mistake when maxConcurrentCheckpoint>1 Key: FLINK-29913 URL: https://issues.apache.org/jira/browse/FLINK-29913 Project: Flink

[GitHub] [flink] yanghuaiGit closed pull request #19893: [hotfix][flink-sql-parse]Remove unnecessary subclass overrides

2022-11-06 Thread GitBox
yanghuaiGit closed pull request #19893: [hotfix][flink-sql-parse]Remove unnecessary subclass overrides URL: https://github.com/apache/flink/pull/19893 -- 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

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-06 Thread Brian Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629596#comment-17629596 ] Brian Zhou commented on FLINK-28695: Not sure if the original reporter has the same, but from our

[jira] [Commented] (FLINK-14937) Flink WebUI could not display

2022-11-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629593#comment-17629593 ] Yang Wang commented on FLINK-14937: --- I am not aware of any issues of Flink webui. Maybe you need to

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

2022-11-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629591#comment-17629591 ] Yang Wang commented on FLINK-29315: --- Maybe I could upgrade the kernel version of all the CI machines

[GitHub] [flink] flinkbot commented on pull request #21246: Update json.md

2022-11-06 Thread GitBox
flinkbot commented on PR #21246: URL: https://github.com/apache/flink/pull/21246#issuecomment-1305087097 ## CI report: * 1f3e63b496d5be77bcc1545dd08dce822d937d1b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] mattfysh opened a new pull request, #21246: Update json.md

2022-11-06 Thread GitBox
mattfysh opened a new pull request, #21246: URL: https://github.com/apache/flink/pull/21246 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] (FLINK-29777) [JUnit5 Migration] Module: flink-dstl

2022-11-06 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29777 ] Yanfei Lei deleted comment on FLINK-29777: was (Author: yanfei lei): Hi [~masteryhx] , I'd like to work on this, could you please assign it to me?  > [JUnit5 Migration] Module: flink-dstl >

[jira] [Commented] (FLINK-29777) [JUnit5 Migration] Module: flink-dstl

2022-11-06 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629590#comment-17629590 ] Yanfei Lei commented on FLINK-29777: Hi [~masteryhx] , I'd like to work on this, could you please

[jira] [Updated] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-06 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-29899: --- Component/s: Runtime / Task (was: Runtime / State Backends) > flink-runtime

[jira] [Updated] (FLINK-29899) flink-runtime tests fail with exit code 137 returned from Docker

2022-11-06 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-29899: --- Description:

[jira] [Commented] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2022-11-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629585#comment-17629585 ] Yang Wang commented on FLINK-22262: --- Thanks [~yunta] for sharing your problem. I think the root cause

[jira] [Comment Edited] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629583#comment-17629583 ] Weijie Guo edited comment on FLINK-28695 at 11/7/22 4:04 AM: - [~Brian Zhou]

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629583#comment-17629583 ] Weijie Guo commented on FLINK-28695: [~Brian Zhou] Just to confirm, if you do not manually delete

[jira] [Commented] (FLINK-29871) Upgrade operator Flink version and examples to 1.16

2022-11-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629581#comment-17629581 ] Yang Wang commented on FLINK-29871: --- +1 for using the X.Y.1 in operator for stability. > Upgrade

[GitHub] [flink-kubernetes-operator] yangjf2019 commented on a diff in pull request #425: [hotfix][docs] Typo fix in doc pages

2022-11-06 Thread GitBox
yangjf2019 commented on code in PR #425: URL: https://github.com/apache/flink-kubernetes-operator/pull/425#discussion_r1014981758 ## docs/content/docs/custom-resource/reference.md: ## @@ -67,7 +67,7 @@ This page serves as a full reference for FlinkDeployment custom resource

[jira] [Closed] (FLINK-29709) Bump Pulsar to 2.10.2

2022-11-06 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-29709. - Assignee: Yufan Sheng Resolution: Fixed master via b5a4d485e7041c57124d4188bce63c4a2066ce22 >

[GitHub] [flink] tisonkun merged pull request #21204: [FLINK-29709][Connector/Pulsar] Bump the Pulsar to latest 2.10.2

2022-11-06 Thread GitBox
tisonkun merged PR #21204: URL: https://github.com/apache/flink/pull/21204 -- 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] yuzelin commented on pull request #21229: [FLINK-29857][hive] Fix failure to connect to 'HiveServer2Endpoint' when using hive3 beeline

2022-11-06 Thread GitBox
yuzelin commented on PR #21229: URL: https://github.com/apache/flink/pull/21229#issuecomment-1305037002 @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-kubernetes-operator] yangjf2019 commented on a diff in pull request #425: [hotfix][docs] Typo fix in doc pages

2022-11-06 Thread GitBox
yangjf2019 commented on code in PR #425: URL: https://github.com/apache/flink-kubernetes-operator/pull/425#discussion_r1014975971 ## docs/content/docs/custom-resource/reference.md: ## @@ -67,7 +67,7 @@ This page serves as a full reference for FlinkDeployment custom resource

[jira] [Updated] (FLINK-29857) Fix failure to connect to 'HiveServer2Endpoint' when using hive3 beeline

2022-11-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29857: --- Labels: pull-request-available (was: ) > Fix failure to connect to 'HiveServer2Endpoint'

[GitHub] [flink] yuzelin commented on pull request #21229: [FLINK-29857][hive] Fix failure to connect to 'HiveServer2Endpoint' when using hive3 beeline

2022-11-06 Thread GitBox
yuzelin commented on PR #21229: URL: https://github.com/apache/flink/pull/21229#issuecomment-1305035651 cc @fsk119 -- 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

[jira] [Assigned] (FLINK-29839) HiveServer2 endpoint doesn't support TGetInfoType value 'CLI_ODBC_KEYWORDS'

2022-11-06 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-29839: - Assignee: yuzelin > HiveServer2 endpoint doesn't support TGetInfoType value

[jira] [Commented] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

2022-11-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629577#comment-17629577 ] Yang Wang commented on FLINK-29892: --- This is a known limit for current Flink options parser. Similar

[jira] [Commented] (FLINK-29898) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI

2022-11-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629575#comment-17629575 ] Yang Wang commented on FLINK-29898: --- >From the current implementation, this issue could only happen

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #160: [FLINK-29434] Add AlgoOperator for Splitter

2022-11-06 Thread GitBox
weibozhao commented on code in PR #160: URL: https://github.com/apache/flink-ml/pull/160#discussion_r1014970752 ## flink-ml-python/pyflink/ml/lib/feature/normalizer.py: ## @@ -44,7 +44,7 @@ def __init__(self, java_params): def set_p(self, value: float): return

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #355: Bump Flink version to 1.16.0

2022-11-06 Thread GitBox
JingsongLi commented on code in PR #355: URL: https://github.com/apache/flink-table-store/pull/355#discussion_r1014968244 ## flink-table-store-connector/src/main/1.16.0/org/apache/flink/table/store/connector/TableConfigUtils.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #355: Bump Flink version to 1.16.0

2022-11-06 Thread GitBox
JingsongLi commented on code in PR #355: URL: https://github.com/apache/flink-table-store/pull/355#discussion_r1014968244 ## flink-table-store-connector/src/main/1.16.0/org/apache/flink/table/store/connector/TableConfigUtils.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-06 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629572#comment-17629572 ] Rui Fan commented on FLINK-28695: - Hi [~Brian Zhou] , thanks for your feedback, I will take a look this

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

2022-11-06 Thread Brian Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629570#comment-17629570 ] Brian Zhou commented on FLINK-28695: >From investigating the code, looks like it is related to

[GitHub] [flink] czy006 commented on pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-11-06 Thread GitBox
czy006 commented on PR #21012: URL: https://github.com/apache/flink/pull/21012#issuecomment-1305007688 @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.

[jira] [Commented] (FLINK-29492) Kafka exactly-once sink causes OutOfMemoryError

2022-11-06 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629566#comment-17629566 ] Hang Ruan commented on FLINK-29492: --- [~fpaul] , sorry for my late response. I think this bug should

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-11-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629563#comment-17629563 ] Xintong Song commented on FLINK-29572: -- Thanks for the pointer, [~huwh]. I think FLINK-27341 is

[jira] [Updated] (FLINK-29912) jdbc scan.partition.column can specify any type of field

2022-11-06 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29912: - Description: scan.partition.column can specify any type of field. At present, scan.partition.column

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #354: [FLINK-29840] Fix bug that old record may overwrite new record in Table Store when snapshot committing is slow

2022-11-06 Thread GitBox
LadyForest commented on code in PR #354: URL: https://github.com/apache/flink-table-store/pull/354#discussion_r1014946479 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/AbstractFileStoreWrite.java: ## @@ -48,17 +49,20 @@ */ public

[jira] [Updated] (FLINK-29912) jdbcscan.partition.column can specify any type of field

2022-11-06 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29912: - Summary: jdbcscan.partition.column can specify any type of field (was: scan.partition.column can

[jira] [Updated] (FLINK-29912) scan.partition.column can specify any type of field

2022-11-06 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29912: - Summary: scan.partition.column can specify any type of field (was: scan.partition. column can specify

[jira] [Updated] (FLINK-29912) jdbc scan.partition.column can specify any type of field

2022-11-06 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29912: - Summary: jdbc scan.partition.column can specify any type of field (was: jdbcscan.partition.column can

[jira] [Updated] (FLINK-29912) scan.partition. column can specify any type of field

2022-11-06 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29912: - Description: scan.partition.column can specify any type of field. At present, scan. partition Column

[jira] [Created] (FLINK-29912) scan.partition. column can specify any type of field

2022-11-06 Thread waywtdcc (Jira)
waywtdcc created FLINK-29912: Summary: scan.partition. column can specify any type of field Key: FLINK-29912 URL: https://issues.apache.org/jira/browse/FLINK-29912 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-29887) Lookup cache in JDBC table connector is not each process (i.e. TaskManager) will hold a cache

2022-11-06 Thread linweijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linweijiang closed FLINK-29887. --- Resolution: Not A Bug > Lookup cache in JDBC table connector is not each process (i.e.

[GitHub] [flink] lincoln-lil commented on pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-11-06 Thread GitBox
lincoln-lil commented on PR #21219: URL: https://github.com/apache/flink/pull/21219#issuecomment-1304978130 @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] luoyuxia commented on a diff in pull request #21242: [FLINK-29878][hive] Fix flink-sql-connector hive error

2022-11-06 Thread GitBox
luoyuxia commented on code in PR #21242: URL: https://github.com/apache/flink/pull/21242#discussion_r1014940126 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -151,8 +157,6 @@ under the License.

[GitHub] [flink] luoyuxia commented on a diff in pull request #21242: [FLINK-29878][hive] Fix flink-sql-connector hive error

2022-11-06 Thread GitBox
luoyuxia commented on code in PR #21242: URL: https://github.com/apache/flink/pull/21242#discussion_r1014940126 ## flink-connectors/flink-sql-connector-hive-3.1.3/pom.xml: ## @@ -151,8 +157,6 @@ under the License.

[jira] [Updated] (FLINK-29858) Jdbc reading supports setting multiple queryTemplates

2022-11-06 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29858: - Labels: jdbc_connector (was: ) > Jdbc reading supports setting multiple queryTemplates >

[GitHub] [flink] snuyanzin commented on pull request #21150: [hotfix] Replace deprecated kafka-clients methods

2022-11-06 Thread GitBox
snuyanzin commented on PR #21150: URL: https://github.com/apache/flink/pull/21150#issuecomment-1304918113 @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

[jira] [Updated] (FLINK-29900) Implement Table API for DynamoDB Sink

2022-11-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29900: --- Labels: pull-request-available (was: ) > Implement Table API for DynamoDB Sink >

[GitHub] [flink-connector-aws] hlteoh37 opened a new pull request, #15: [FLINK-29900][Connectors/DynamoDB] Implement Table API for DynamoDB sink

2022-11-06 Thread GitBox
hlteoh37 opened a new pull request, #15: URL: https://github.com/apache/flink-connector-aws/pull/15 ## What is the purpose of the change - Implement Table API for DynamoDB sink ## Verifying this change ## Does this pull request potentially affect one of the following

[GitHub] [flink] ericxiao251 commented on pull request #21077: [FLINK-29498] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

2022-11-06 Thread GitBox
ericxiao251 commented on PR #21077: URL: https://github.com/apache/flink/pull/21077#issuecomment-1304891224 @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 commented on pull request #21245: [FLINK-29379][streaming] Migrate CheckpointConfig to use Configuration field and ConfigOption

2022-11-06 Thread GitBox
flinkbot commented on PR #21245: URL: https://github.com/apache/flink/pull/21245#issuecomment-1304887277 ## CI report: * c050e2fa2a97fbbe07f3ac2be997ddec1bc2535a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] pnowojski opened a new pull request, #21245: [FLINK-29379][streaming] Migrate CheckpointConfig to use Configuration field and ConfigOption

2022-11-06 Thread GitBox
pnowojski opened a new pull request, #21245: URL: https://github.com/apache/flink/pull/21245 ## What is the purpose of the change This PR refactors `CheckpointConfig` to use `Configuration` class ## Brief change log Please check individual commits. ##

[jira] [Updated] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

2022-11-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-29379: --- Fix Version/s: 1.17.0 > Back ExecutionConfig and CheckpointConfig by Configuration >

[jira] [Commented] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

2022-11-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629539#comment-17629539 ] Piotr Nowojski commented on FLINK-29379: First part ({{ExecutionConfig}}) merged as

[GitHub] [flink] pnowojski merged pull request #21056: [FLINK-29379][datastream] Migrate most of the ExecutionConfig fields to Configuration

2022-11-06 Thread GitBox
pnowojski merged PR #21056: URL: https://github.com/apache/flink/pull/21056 -- 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] ericxiao251 commented on pull request #21077: [FLINK-29498] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

2022-11-06 Thread GitBox
ericxiao251 commented on PR #21077: URL: https://github.com/apache/flink/pull/21077#issuecomment-1304884320 @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] ericxiao251 commented on pull request #21077: [FLINK-29498] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

2022-11-06 Thread GitBox
ericxiao251 commented on PR #21077: URL: https://github.com/apache/flink/pull/21077#issuecomment-1304879708 @gaoyunhaii, sorry I didn't get a chance to respond during the week and I believe that should work and I like the idea of only exposing the builder classes :). I have made the

[jira] [Commented] (FLINK-29909) Standardise connector package names

2022-11-06 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629536#comment-17629536 ] Danny Cranmer commented on FLINK-29909: --- merged commit 

[jira] [Resolved] (FLINK-29909) Standardise connector package names

2022-11-06 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-29909. --- Resolution: Fixed > Standardise connector package names >

[jira] [Updated] (FLINK-29909) Standardise connector package names

2022-11-06 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29909: -- Fix Version/s: aws-connector-2.0.0 > Standardise connector package names >

[jira] [Updated] (FLINK-29909) Standardise connector package names

2022-11-06 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29909: -- Component/s: Connectors / DynamoDB > Standardise connector package names >

[jira] [Assigned] (FLINK-29909) Standardise connector package names

2022-11-06 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-29909: - Assignee: Hong Liang Teoh > Standardise connector package names >

[GitHub] [flink-connector-aws] dannycranmer merged pull request #14: [FLINK-29909][Connectors/DynamoDB] Update package names to follow con…

2022-11-06 Thread GitBox
dannycranmer merged PR #14: URL: https://github.com/apache/flink-connector-aws/pull/14 -- 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] wanglijie95 commented on a diff in pull request #21111: [FLINK-29664][runtime] Collect subpartition sizes of blocking result partitions

2022-11-06 Thread GitBox
wanglijie95 commented on code in PR #2: URL: https://github.com/apache/flink/pull/2#discussion_r1014852386 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java: ## @@ -149,13 +159,45 @@ protected void

[GitHub] [flink] snuyanzin commented on pull request #21150: [hotfix] Replace deprecated kafka-clients methods

2022-11-06 Thread GitBox
snuyanzin commented on PR #21150: URL: https://github.com/apache/flink/pull/21150#issuecomment-1304828724 @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

[jira] [Updated] (FLINK-29902) Support “value1.notIn(TABLE)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29902: Issue Type: Improvement (was: New Feature) > Support “value1.notIn(TABLE)” built-in function in Table

[jira] [Updated] (FLINK-29901) Support “NOT IN” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29901: Affects Version/s: (was: 1.16.0) > Support “NOT IN” built-in function in Table API >

[jira] [Commented] (FLINK-29904) Support “string1.notLike(string2)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629480#comment-17629480 ] Dian Fu commented on FLINK-29904: - [~cun8cun8] Have assigned it to you~ > Support

[jira] [Assigned] (FLINK-29904) Support “string1.notLike(string2)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29904: --- Assignee: zhangjingcun > Support “string1.notLike(string2)” built-in function in Table API >

[jira] [Updated] (FLINK-29903) Support “string1.notSimilar(string2)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29903: Affects Version/s: (was: 1.16.0) > Support “string1.notSimilar(string2)” built-in function in Table

[jira] [Commented] (FLINK-29903) Support “string1.notSimilar(string2)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629479#comment-17629479 ] Dian Fu commented on FLINK-29903: - [~cun8cun8] Have assigned it to you~ > Support

[jira] [Updated] (FLINK-29904) Support “string1.notLike(string2)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29904: Issue Type: Improvement (was: New Feature) > Support “string1.notLike(string2)” built-in function in

[jira] [Updated] (FLINK-29903) Support “string1.notSimilar(string2)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29903: Issue Type: Improvement (was: New Feature) > Support “string1.notSimilar(string2)” built-in function in

[jira] [Updated] (FLINK-29904) Support “string1.notLike(string2)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29904: Affects Version/s: (was: 1.16.0) > Support “string1.notLike(string2)” built-in function in Table API

[jira] [Assigned] (FLINK-29903) Support “string1.notSimilar(string2)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29903: --- Assignee: zhangjingcun > Support “string1.notSimilar(string2)” built-in function in Table API >

[jira] [Assigned] (FLINK-29902) Support “value1.notIn(TABLE)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29902: --- Assignee: zhangjingcun > Support “value1.notIn(TABLE)” built-in function in Table API >

[jira] [Commented] (FLINK-29902) Support “value1.notIn(TABLE)” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629478#comment-17629478 ] Dian Fu commented on FLINK-29902: - [~cun8cun8] Have assigned it to you~ > Support “value1.notIn(TABLE)”

[jira] [Commented] (FLINK-29901) Support “NOT IN” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629477#comment-17629477 ] Dian Fu commented on FLINK-29901: - [~cun8cun8] Have assigned it to you~ > Support “NOT IN” built-in

[jira] [Updated] (FLINK-29901) Support “NOT IN” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29901: Issue Type: Improvement (was: New Feature) > Support “NOT IN” built-in function in Table API >

[jira] [Assigned] (FLINK-29901) Support “NOT IN” built-in function in Table API

2022-11-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29901: --- Assignee: zhangjingcun > Support “NOT IN” built-in function in Table API >

[GitHub] [flink] lincoln-lil commented on pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-11-06 Thread GitBox
lincoln-lil commented on PR #21219: URL: https://github.com/apache/flink/pull/21219#issuecomment-1304780562 @JingGe thank you for reviewing this! I've updated the pr according to your comments. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] czy006 commented on pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-11-06 Thread GitBox
czy006 commented on PR #21012: URL: https://github.com/apache/flink/pull/21012#issuecomment-1304771208 @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] flinkbot commented on pull request #21244: [FLINK-29458][docs-zh]Update "Table API sql queries joins module case

2022-11-06 Thread GitBox
flinkbot commented on PR #21244: URL: https://github.com/apache/flink/pull/21244#issuecomment-1304769977 ## CI report: * c0f2aa32273602f67b76eb7a6bd70a8f7743fc2f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] ZmmBigdata opened a new pull request, #21244: [FLINK-29458][docs-zh]Update "Table API sql queries joins module case

2022-11-06 Thread GitBox
ZmmBigdata opened a new pull request, #21244: URL: https://github.com/apache/flink/pull/21244 ## What is the purpose of the change *When two tables have the same field, do not specify the table name,Exception will be thrown:SqlValidatorException :Column 'currency' is ambiguous.

[GitHub] [flink-table-store] SteNicholas opened a new pull request, #355: Bump Flink version to 1.16.0

2022-11-06 Thread GitBox
SteNicholas opened a new pull request, #355: URL: https://github.com/apache/flink-table-store/pull/355 Flink 1.16.0 version has already released. Bump Flink version to 1.16.0. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-29458) When two tables have the same field, do not specify the table name,Exception will be thrown:SqlValidatorException :Column 'currency' is ambiguous

2022-11-06 Thread ZuoYan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZuoYan updated FLINK-29458: --- Affects Version/s: 1.16.0 (was: 1.14.4) > When two tables have the same field,

[jira] [Updated] (FLINK-29911) Improve performance of AgglomerativeClustering

2022-11-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29911: --- Labels: pull-request-available (was: ) > Improve performance of AgglomerativeClustering >

  1   2   >