[jira] [Updated] (FLINK-27524) Introduce cache API to DataStream

2022-07-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27524: --- Labels: pull-request-available (was: ) > Introduce cache API to DataStream >

[GitHub] [flink] flinkbot commented on pull request #20147: [FLINK-27524][datastream] Introduce cache API to DataStream

2022-07-03 Thread GitBox
flinkbot commented on PR #20147: URL: https://github.com/apache/flink/pull/20147#issuecomment-1173375305 ## CI report: * 0303561fbe09202f837f2f597dbf2ee1fe2ffc95 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Sxnan opened a new pull request, #20147: [Flink-27524][datastream] Introduce cache API to DataStream

2022-07-03 Thread GitBox
Sxnan opened a new pull request, #20147: URL: https://github.com/apache/flink/pull/20147 ## What is the purpose of the change Introduce cache API to DataStream. ## Brief change log - Introduce `cache` method to `SingleOutputStreamOperator`. - Introduce

[jira] [Closed] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

2022-07-03 Thread nyingping (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping closed FLINK-26086. - Resolution: Fixed > fixed some causing ambiguities including the 'shit' comment >

[GitHub] [flink] Myasuka commented on pull request #19998: [FLINK-27822][docs-zh] Translate the doc of checkpoint/savepoint guar…

2022-07-03 Thread GitBox
Myasuka commented on PR #19998: URL: https://github.com/apache/flink/pull/19998#issuecomment-1173363015 @zoltar9264 I don't think Github could block submitting a new PR. We use JIRA's issue system to track instead of Github's issue system, I don't know why Github could block this.

[GitHub] [flink] flinkbot commented on pull request #20146: [FLINK-28369][table][python] Support PARSE_URL in Table API

2022-07-03 Thread GitBox
flinkbot commented on PR #20146: URL: https://github.com/apache/flink/pull/20146#issuecomment-1173358960 ## CI report: * 1206b497fd29fd1b67e63981da5adbab16c7a0a1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28369) Support PARSE_URL bulit-in function in Table API

2022-07-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28369: --- Labels: pull-request-available (was: ) > Support PARSE_URL bulit-in function in Table API

[GitHub] [flink] deadwind4 opened a new pull request, #20146: [FLINK-28369][table][python] Support PARSE_URL in Table API

2022-07-03 Thread GitBox
deadwind4 opened a new pull request, #20146: URL: https://github.com/apache/flink/pull/20146 ## What is the purpose of the change Support instr and locate built-in functions in Table API. ## Brief change log - *Support PARSE_URL built-in functions in Table API.* -

[jira] [Created] (FLINK-28369) Support PARSE_URL bulit-in function in Table API

2022-07-03 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28369: --- Summary: Support PARSE_URL bulit-in function in Table API Key: FLINK-28369 URL: https://issues.apache.org/jira/browse/FLINK-28369 Project: Flink Issue Type:

[jira] [Updated] (FLINK-28040) Introduce Trino reader for table store

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28040: - Priority: Minor (was: Major) > Introduce Trino reader for table store >

[jira] [Commented] (FLINK-28040) Introduce Trino reader for table store

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562000#comment-17562000 ] Jingsong Lee commented on FLINK-28040: -- Trino binary is using JDK 11. > Introduce Trino reader for

[jira] [Closed] (FLINK-28063) Optimize PredicateBuilder.in for lots of parameters

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28063. Assignee: Caizhi Weng Resolution: Fixed master: d11a287c756713c6b16a6c93291566a780f97b4a >

[GitHub] [flink-table-store] JingsongLi merged pull request #189: [FLINK-28063] Introduce dedicated In and NotIn predicate function

2022-07-03 Thread GitBox
JingsongLi merged PR #189: URL: https://github.com/apache/flink-table-store/pull/189 -- 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] flinkbot commented on pull request #20145: [FLINK-25315][tests] add new extensions and utils to help the Junit5 …

2022-07-03 Thread GitBox
flinkbot commented on PR #20145: URL: https://github.com/apache/flink/pull/20145#issuecomment-1173319623 ## CI report: * db4fdb4f942b733539be83ef2eedc234a445c4ac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] xintongsong commented on a diff in pull request #20142: [FLINK-28313][rest] Add history server flag to DashboardConfiguration

2022-07-03 Thread GitBox
xintongsong commented on code in PR #20142: URL: https://github.com/apache/flink/pull/20142#discussion_r912612048 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java: ## @@ -139,6 +146,11 @@ public boolean isWebCancelEnabled() {

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #104: [FLINK-27336] Avoid merging when there is only one record

2022-07-03 Thread GitBox
JingsongLi commented on code in PR #104: URL: https://github.com/apache/flink-table-store/pull/104#discussion_r912611645 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/MergeFunctionHelper.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to

[jira] [Closed] (FLINK-28335) Delete topic after tests

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28335. Resolution: Fixed master: c24d3d244b4ae00e599924fa8814498f98f74aab > Delete topic after tests >

[jira] [Assigned] (FLINK-28335) Delete topic after tests

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28335: Assignee: Nicholas Jiang > Delete topic after tests > > >

[GitHub] [flink-table-store] JingsongLi merged pull request #188: [FLINK-28335] Delete topic after tests

2022-07-03 Thread GitBox
JingsongLi merged PR #188: URL: https://github.com/apache/flink-table-store/pull/188 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-28327) Make table store src codes compiled with Flink 1.14

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28327. Resolution: Fixed master: d29816af772a3507008815931a6afc3c72afe5a5 > Make table store src codes

[jira] [Closed] (FLINK-28073) Table Store supports Flink 1.14

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28073. Resolution: Fixed > Table Store supports Flink 1.14 > --- > >

[jira] [Assigned] (FLINK-28073) Table Store supports Flink 1.14

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28073: Assignee: Jingsong Lee > Table Store supports Flink 1.14 >

[GitHub] [flink] yuchengxin opened a new pull request, #20145: [FLINK-25315][tests] add new extensions and utils to help the Junit5 …

2022-07-03 Thread GitBox
yuchengxin opened a new pull request, #20145: URL: https://github.com/apache/flink/pull/20145 …migration ## What is the purpose of the change This pull request adds new extensions and utils to help the Junit5 migration. ## Brief change log - Add

[GitHub] [flink-table-store] JingsongLi merged pull request #184: [FLINK-28327] Make table store src codes compiled with Flink 1.14

2022-07-03 Thread GitBox
JingsongLi merged PR #184: URL: https://github.com/apache/flink-table-store/pull/184 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-27618) Suuport CumeDist

2022-07-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27618: --- Labels: pull-request-available (was: ) > Suuport CumeDist > > >

[GitHub] [flink] luoyuxia commented on pull request #19727: [FLINK-27618][sql] Flink supports CUME_DIST function

2022-07-03 Thread GitBox
luoyuxia commented on PR #19727: URL: https://github.com/apache/flink/pull/19727#issuecomment-1173307574 @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 #20144: [FLINK-27587][python] Support keyed co-broadcast processing

2022-07-03 Thread GitBox
flinkbot commented on PR #20144: URL: https://github.com/apache/flink/pull/20144#issuecomment-1173306587 ## CI report: * 5b4fd94b639113fbbed640ba890d38f03e23d971 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zjuwangg commented on a diff in pull request #20094: [hotfix][doc] fix code mismatch in filesystem.md

2022-07-03 Thread GitBox
zjuwangg commented on code in PR #20094: URL: https://github.com/apache/flink/pull/20094#discussion_r912603500 ## docs/content/docs/connectors/datastream/filesystem.md: ## @@ -315,9 +315,9 @@ final FileSink sink = FileSink .forRowFormat(new Path(outputPath), new

[jira] [Updated] (FLINK-27587) Support keyed co-broadcast processing in PyFlink

2022-07-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27587: --- Labels: pull-request-available (was: ) > Support keyed co-broadcast processing in PyFlink

[GitHub] [flink] Vancior opened a new pull request, #20144: [FLINK-27587][python] Support keyed co-broadcast processing

2022-07-03 Thread GitBox
Vancior opened a new pull request, #20144: URL: https://github.com/apache/flink/pull/20144 ## What is the purpose of the change This PR implements keyed broadcast processing ( `KeyedStream.connect(BroadcastStream).process(KeyedBroadcastProcessFunction)` ) in PyFlink.

[jira] [Commented] (FLINK-25315) Add new extensions and classes to help the JUnit5 migration

2022-07-03 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561989#comment-17561989 ] Yun Tang commented on FLINK-25315: -- [~catyee] already assigned to you, please go ahead. > Add new

[jira] [Updated] (FLINK-28341) Fix comment in BytesKeyNormalizationUtil.java

2022-07-03 Thread shen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shen updated FLINK-28341: - Affects Version/s: 1.15.1 > Fix comment in BytesKeyNormalizationUtil.java >

[jira] [Assigned] (FLINK-25315) Add new extensions and classes to help the JUnit5 migration

2022-07-03 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-25315: Assignee: Yuan Kui > Add new extensions and classes to help the JUnit5 migration >

[jira] [Comment Edited] (FLINK-25315) Add new extensions and classes to help the JUnit5 migration

2022-07-03 Thread Yuan Kui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561987#comment-17561987 ] Yuan Kui edited comment on FLINK-25315 at 7/4/22 3:25 AM: -- I'm going to finish

[jira] [Commented] (FLINK-25315) Add new extensions and classes to help the JUnit5 migration

2022-07-03 Thread Yuan Kui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561987#comment-17561987 ] Yuan Kui commented on FLINK-25315: -- I'm going to finish this work, could you assign this ticket to me?

[jira] [Commented] (FLINK-24346) Flink on yarn application mode,LinkageError

2022-07-03 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561986#comment-17561986 ] Biao Geng commented on FLINK-24346: --- Hi [~soberchi...@gamil.com] have you ever tried to run the

[jira] [Commented] (FLINK-28368) Get field type return result problem

2022-07-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561985#comment-17561985 ] Jark Wu commented on FLINK-28368: - It's by design. Nullability is a part of data type in Flink. > Get

[jira] [Closed] (FLINK-28368) Get field type return result problem

2022-07-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28368. --- Resolution: Not A Problem > Get field type return result problem > > >

[jira] [Commented] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink

2022-07-03 Thread DavidLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561984#comment-17561984 ] DavidLiu commented on FLINK-25735: -- The pull request is [https://github.com/apache/flink/pull/20143]

[jira] [Updated] (FLINK-28368) Get field type return result problem

2022-07-03 Thread hunter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hunter updated FLINK-28368: --- Component/s: Table SQL / API (was: Client / Job Submission) > Get field type return

[GitHub] [flink] zoltar9264 commented on pull request #19998: [FLINK-27822][docs-zh] Translate the doc of checkpoint/savepoint guar…

2022-07-03 Thread GitBox
zoltar9264 commented on PR #19998: URL: https://github.com/apache/flink/pull/19998#issuecomment-1173288658 Hi @1996fanrui , I tried to create a new PR , but github doesn't allow it because there is already a PR for the same. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] zhuyufeng0809 commented on pull request #19991: [FLINK-28065][Runtime/Configuration] Fix a never reached code in ProcessMemoryUtils Class

2022-07-03 Thread GitBox
zhuyufeng0809 commented on PR #19991: URL: https://github.com/apache/flink/pull/19991#issuecomment-1173286177 OK, thank you for your Review -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot commented on pull request #20143: [FLINK-25735][content.zh] Chinese Translation - Add documentation for…

2022-07-03 Thread GitBox
flinkbot commented on PR #20143: URL: https://github.com/apache/flink/pull/20143#issuecomment-1173284952 ## CI report: * 8ddd8d5652744476536bc4eb7feb858a3a0d78b4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-27998) Upgrade Calcite version to 1.30

2022-07-03 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561979#comment-17561979 ] Jing Zhang edited comment on FLINK-27998 at 7/4/22 2:58 AM: [~Sergey

[jira] [Commented] (FLINK-27998) Upgrade Calcite version to 1.30

2022-07-03 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561979#comment-17561979 ] Jing Zhang commented on FLINK-27998: [~Sergey Nuyanzin] Sorry for late reponse. > Upgrade Calcite

[jira] [Updated] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink

2022-07-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25735: --- Labels: chinese-translation pull-request-available (was: chinese-translation) > Chinese

[GitHub] [flink] DavidLiu001 opened a new pull request, #20143: [FLINK-25735][content.zh] Chinese Translation - Add documentation for…

2022-07-03 Thread GitBox
DavidLiu001 opened a new pull request, #20143: URL: https://github.com/apache/flink/pull/20143 … KDS Async Sink ## What is the purpose of the change Translate: Connectors/Kinesis page to deprecate old sink (docs/content/docs/connectors/datastream/kinesis.md)

[jira] [Commented] (FLINK-28368) Get field type return result problem

2022-07-03 Thread hunter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561976#comment-17561976 ] hunter commented on FLINK-28368: If this is a bug, send it to me to fix it > Get field type return

[GitHub] [flink] xintongsong commented on pull request #19991: [FLINK-28065][Runtime/Configuration] Fix a never reached code in ProcessMemoryUtils Class

2022-07-03 Thread GitBox
xintongsong commented on PR #19991: URL: https://github.com/apache/flink/pull/19991#issuecomment-1173282190 I tend not to merge this change. First of all, the sanity check is unnecessary for both the `if-` and the `else-` branches here. For the `if-` branch, the sanity is guaranteed

[jira] [Created] (FLINK-28368) Get field type return result problem

2022-07-03 Thread hunter (Jira)
hunter created FLINK-28368: -- Summary: Get field type return result problem Key: FLINK-28368 URL: https://issues.apache.org/jira/browse/FLINK-28368 Project: Flink Issue Type: Improvement

[GitHub] [flink] suxinglee commented on pull request #20134: [FLINK-28353][k8s] Exclude unschedulable nodes using IP addresses of kubernetes nodes

2022-07-03 Thread GitBox
suxinglee commented on PR #20134: URL: https://github.com/apache/flink/pull/20134#issuecomment-1173279678 @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] [Commented] (FLINK-28350) Test last-state upgrades across Flink minor versions

2022-07-03 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561975#comment-17561975 ] Yang Wang commented on FLINK-28350: --- AFAIK, we changed the HA format in the release-1.15. BTW, I

[GitHub] [flink] flinkbot commented on pull request #20142: [FLINK-28313][rest] Add history server flag to DashboardConfiguration

2022-07-03 Thread GitBox
flinkbot commented on PR #20142: URL: https://github.com/apache/flink/pull/20142#issuecomment-1173273886 ## CI report: * c1a77ab9496ca0133de3a7ad94fa913399baef51 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

2022-07-03 Thread jiulong.zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiulong.zhu updated FLINK-28291: Labels: patch-available (was: pull-request-available) > Add kerberos delegation token renewer

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

2022-07-03 Thread jiulong.zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiulong.zhu updated FLINK-28291: Labels: pull-request-available (was: ) > Add kerberos delegation token renewer feature instead

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

2022-07-03 Thread jiulong.zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiulong.zhu updated FLINK-28291: Attachment: FLINK-28291.0001.patch > Add kerberos delegation token renewer feature instead of

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

2022-07-03 Thread jiulong.zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiulong.zhu updated FLINK-28291: Attachment: (was: 0001-add-KerberosDelegationTokenManager-to-renew-token-pe.patch) > Add

[jira] [Updated] (FLINK-28313) Add history server flag to DashboardConfiguration

2022-07-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28313: --- Labels: pull-request-available (was: ) > Add history server flag to DashboardConfiguration

[GitHub] [flink] KarmaGYZ opened a new pull request, #20142: [FLINK-28313][rest] Add history server flag to DashboardConfiguration

2022-07-03 Thread GitBox
KarmaGYZ opened a new pull request, #20142: URL: https://github.com/apache/flink/pull/20142 ## 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

[GitHub] [flink] fredia commented on pull request #20091: [FLINK-27570][runtime] Fix initialize base locations for checkpoint

2022-07-03 Thread GitBox
fredia commented on PR #20091: URL: https://github.com/apache/flink/pull/20091#issuecomment-1173269329 @rkhachatryan could you please take a review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink-connector-elasticsearch] dianfu merged pull request #22: [FLINK-28107][python][connector/elasticsearch] Add a MapElasticsearchEmitter for PyFlink

2022-07-03 Thread GitBox
dianfu merged PR #22: URL: https://github.com/apache/flink-connector-elasticsearch/pull/22 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-28298) Support left and right built-in function in the Table API

2022-07-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28298. --- Assignee: LuNing Wang Resolution: Fixed Merged to master via da720c3b97d5c3e781abb1e910a8337f6a5ee0e4

[jira] [Closed] (FLINK-28238) Fix unstable testCancelOperationAndFetchResultInParallel

2022-07-03 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-28238. - Resolution: Fixed Fix in master: 7974e81ec51a2071b9658f768f651ffc371b15b0 > Fix unstable

[GitHub] [flink] dianfu merged pull request #20104: [FLINK-28298][table][python] Support left and right in Table API

2022-07-03 Thread GitBox
dianfu merged PR #20104: URL: https://github.com/apache/flink/pull/20104 -- 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] fsk119 merged pull request #20063: [FLINK-28238][sql-gateway] Fix unstable testCancelOperationAndFetchResultInParallel

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

[jira] [Updated] (FLINK-28063) Optimize PredicateBuilder.in for lots of parameters

2022-07-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28063: --- Labels: pull-request-available (was: ) > Optimize PredicateBuilder.in for lots of

[GitHub] [flink-table-store] tsreaper opened a new pull request, #189: [FLINK-28063] Introduce dedicated In and NotIn predicate function

2022-07-03 Thread GitBox
tsreaper opened a new pull request, #189: URL: https://github.com/apache/flink-table-store/pull/189 The current treatment of in is to expand into multiple equals and join them using or. But this does not perform well if there are particularly many parameters, we need to introduce

[GitHub] [flink] xintongsong commented on pull request #20042: [FLINK-19358][runtime] Make the job id distinct in application mode w…

2022-07-03 Thread GitBox
xintongsong commented on PR #20042: URL: https://github.com/apache/flink/pull/20042#issuecomment-1173261576 No concerns from my side. -- 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] KarmaGYZ commented on pull request #20123: [FLINK-28310][rest] Introduce aggregating task metrics

2022-07-03 Thread GitBox
KarmaGYZ commented on PR #20123: URL: https://github.com/apache/flink/pull/20123#issuecomment-1173255081 PR updated. -- 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] KarmaGYZ commented on pull request #20042: [FLINK-19358][runtime] Make the job id distinct in application mode w…

2022-07-03 Thread GitBox
KarmaGYZ commented on PR #20042: URL: https://github.com/apache/flink/pull/20042#issuecomment-1173254922 @wangyang0918 @xintongsong If there's no further comment, I'll merge it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] Myasuka commented on pull request #19992: [hotfix][Runtime/Configuration] Fix typo in ProcessMemoryUtils Class

2022-07-03 Thread GitBox
Myasuka commented on PR #19992: URL: https://github.com/apache/flink/pull/19992#issuecomment-1173253243 @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] [Comment Edited] (FLINK-27570) A checkpoint path error does not cause the job to stop

2022-07-03 Thread Underwood (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561840#comment-17561840 ] Underwood edited comment on FLINK-27570 at 7/4/22 1:53 AM: --- [~Zsigner]  

[jira] [Commented] (FLINK-28337) java.lang.IllegalArgumentException: Table identifier not set

2022-07-03 Thread wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561962#comment-17561962 ] wei commented on FLINK-28337: - Ok, thanks~ > java.lang.IllegalArgumentException: Table identifier not set >

[GitHub] [flink] Vancior commented on pull request #20124: [FLINK-28336][python][format] Support parquet-avro format DataStream API

2022-07-03 Thread GitBox
Vancior commented on PR #20124: URL: https://github.com/apache/flink/pull/20124#issuecomment-1173252406 @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-28344) How to connect flink and elasticsearch in pyflink 1.15.0?

2022-07-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561961#comment-17561961 ] Dian Fu commented on FLINK-28344: - Hi, [~elademir] There are two choices: 1) Use [ES Table API & SQL

[jira] [Updated] (FLINK-28322) DataStreamScanProvider's new method is not compatible

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28322: - Description: In FLINK-25990 , Add a method "DataStream produceDataStream(ProviderContext

[jira] [Updated] (FLINK-28322) DataStreamScanProvider's new method is not compatible

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28322: - Description: In FLINK-25990 , Add a method "DataStream produceDataStream(ProviderContext

[jira] [Assigned] (FLINK-28355) Python Bash e2e tests don't clean-up after they've ran, causing disk space issues

2022-07-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-28355: Assignee: Huang Xingbo > Python Bash e2e tests don't clean-up after they've ran, causing

[jira] [Updated] (FLINK-28322) DataStreamScanProvider's new method is not compatible

2022-07-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28322: - Description: In FLINK-25990 , Add a method "DataStream produceDataStream(ProviderContext

[GitHub] [flink] JingsongLi commented on a diff in pull request #20119: [FLINK-28322][table-api] DataStreamScan(Sink)Provider's new method is not compatible

2022-07-03 Thread GitBox
JingsongLi commented on code in PR #20119: URL: https://github.com/apache/flink/pull/20119#discussion_r912568525 ## flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/DataStreamSinkProvider.java: ## @@ -54,8 +54,10 @@ * *

[jira] [Comment Edited] (FLINK-28367) OffsetDateTime does not work with keyBy

2022-07-03 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561943#comment-17561943 ] Lim Qing Wei edited comment on FLINK-28367 at 7/3/22 9:30 PM: -- I had a

[jira] [Commented] (FLINK-28367) OffsetDateTime does not work with keyBy

2022-07-03 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561943#comment-17561943 ] Lim Qing Wei commented on FLINK-28367: -- I had a look, I think part of it is that we are using a

[GitHub] [flink] qingwei91 commented on a diff in pull request #20119: [FLINK-28322][table-api] DataStreamScan(Sink)Provider's new method is not compatible

2022-07-03 Thread GitBox
qingwei91 commented on code in PR #20119: URL: https://github.com/apache/flink/pull/20119#discussion_r912527749 ## flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/DataStreamSinkProvider.java: ## @@ -54,8 +54,10 @@ * * @see

[GitHub] [flink-statefun] knaufk merged pull request #313: [hotfix] Update config-map.yaml to helm chart

2022-07-03 Thread GitBox
knaufk merged PR #313: URL: https://github.com/apache/flink-statefun/pull/313 -- 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] qingwei91 commented on a diff in pull request #20138: FLINK-16024 [jdbc-connector] JDBC Filter Pushdown

2022-07-03 Thread GitBox
qingwei91 commented on code in PR #20138: URL: https://github.com/apache/flink/pull/20138#discussion_r912524224 ## flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarClientFactory.java: ## @@ -153,8 +153,8 @@ public

[jira] [Updated] (FLINK-28367) OffsetDateTime does not work with keyBy

2022-07-03 Thread Henrik Laxhuber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henrik Laxhuber updated FLINK-28367: Priority: Minor (was: Major) > OffsetDateTime does not work with keyBy >

[jira] [Commented] (FLINK-28367) OffsetDateTime does not work with keyBy

2022-07-03 Thread Henrik Laxhuber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561912#comment-17561912 ] Henrik Laxhuber commented on FLINK-28367: - A workaround is to register a custom Kryo serializer

[jira] [Updated] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-03 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28364: --- Priority: Major (was: Minor) > Python Job support for Kubernetes Operator >

[jira] [Commented] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-03 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561899#comment-17561899 ] Gyula Fora commented on FLINK-28364: I think this would be relatively easy to add for somebody who

[jira] [Updated] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-03 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28364: --- Summary: Python Job support for Kubernetes Operator (was: Job types support Python) > Python Job

[jira] [Updated] (FLINK-28367) OffsetDateTime does not work with keyBy

2022-07-03 Thread Henrik Laxhuber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henrik Laxhuber updated FLINK-28367: Description: Using keyBy incorrectly (de-)serializes java.time.OffsetDateTime types - the

[jira] [Created] (FLINK-28367) OffsetDateTime does not work with keyBy

2022-07-03 Thread Henrik Laxhuber (Jira)
Henrik Laxhuber created FLINK-28367: --- Summary: OffsetDateTime does not work with keyBy Key: FLINK-28367 URL: https://issues.apache.org/jira/browse/FLINK-28367 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-28350) Test last-state upgrades across Flink minor versions

2022-07-03 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-28350: -- Assignee: Gyula Fora > Test last-state upgrades across Flink minor versions >

[jira] [Assigned] (FLINK-28348) Add configurable flag to disable last-state fallback for savepoint upgrade

2022-07-03 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-28348: -- Assignee: Matyas Orhidi > Add configurable flag to disable last-state fallback for savepoint

[GitHub] [flink] DavidLiu001 closed pull request #20141: Kinesis translate

2022-07-03 Thread GitBox
DavidLiu001 closed pull request #20141: Kinesis translate URL: https://github.com/apache/flink/pull/20141 -- 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] DavidLiu001 commented on pull request #20141: Kinesis translate

2022-07-03 Thread GitBox
DavidLiu001 commented on PR #20141: URL: https://github.com/apache/flink/pull/20141#issuecomment-1173111918 will pull the latest version and submit a new pull request -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot commented on pull request #20141: Kinesis translate

2022-07-03 Thread GitBox
flinkbot commented on PR #20141: URL: https://github.com/apache/flink/pull/20141#issuecomment-117364 ## CI report: * f3052cda8d7349964aa90c0f67f5ac20005be139 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink

2022-07-03 Thread DavidLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25735 ] DavidLiu deleted comment on FLINK-25735: -- was (Author: JIRAUSER289843): [The PR is https://github.com/apache/flink/pull/20141|https://github.com/apache/flink/pull/20141] > Chinese Translation

[jira] [Comment Edited] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink

2022-07-03 Thread DavidLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561880#comment-17561880 ] DavidLiu edited comment on FLINK-25735 at 7/3/22 3:17 PM: -- [The PR is

[jira] [Commented] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink

2022-07-03 Thread DavidLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561880#comment-17561880 ] DavidLiu commented on FLINK-25735: -- [https://github.com/apache/flink/pull/20141] > Chinese Translation

  1   2   >