[GitHub] [flink-web] fsk119 commented on pull request #549: [FLINK-20760][Project Website] Fix broken doc link

2022-06-09 Thread GitBox
fsk119 commented on PR #549: URL: https://github.com/apache/flink-web/pull/549#issuecomment-1152037403 Hi. You should open the PR in the Flink repo. I am not sure the usage of the Flink web repo. -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Updated] (FLINK-27994) ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator

2022-06-09 Thread wangkang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangkang updated FLINK-27994: - Attachment: image-2022-06-10-14-50-05-003.png > ERROR org.apache.flink.runtime.source.coordinator.Sourc

[jira] [Updated] (FLINK-27994) ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator

2022-06-09 Thread wangkang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangkang updated FLINK-27994: - Description: 使用flink cdc 2.2.0报错 2661 [jobmanager-io-thread-1] WARN  org.apache.flink.runtime.util.Hado

[jira] [Updated] (FLINK-27994) ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator

2022-06-09 Thread wangkang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangkang updated FLINK-27994: - Attachment: (was: image-2022-06-10-14-41-41-651.png) > ERROR org.apache.flink.runtime.source.coordi

[jira] [Updated] (FLINK-27994) ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator

2022-06-09 Thread wangkang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangkang updated FLINK-27994: - Description: 使用flink cdc 2.2.0报错 2661 [jobmanager-io-thread-1] WARN  org.apache.flink.runtime.util.Hado

[jira] [Created] (FLINK-27995) Upgrade Janio version

2022-06-09 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-27995: - Summary: Upgrade Janio version Key: FLINK-27995 URL: https://issues.apache.org/jira/browse/FLINK-27995 Project: Flink Issue Type: Improvement Co

[jira] [Closed] (FLINK-27913) Remove savepointHistoryMaxCount and savepointHistoryMaxAge from FlinkOperatorConfiguration

2022-06-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27913. -- Resolution: Fixed merged to main 9d1be9cadd2b292b2a9ea37852f1b3cda65d1422 > Remove savepointHistoryMa

[jira] [Created] (FLINK-27994) ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator

2022-06-09 Thread wangkang (Jira)
wangkang created FLINK-27994: Summary: ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator Key: FLINK-27994 URL: https://issues.apache.org/jira/browse/FLINK-27994 Project: Flink

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #264: [FLINK-27913] Remove savepointHistoryMaxCount and savepointHistoryMaxAge from FlinkOperatorConfiguration

2022-06-09 Thread GitBox
gyfora merged PR #264: URL: https://github.com/apache/flink-kubernetes-operator/pull/264 -- 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-kubernetes-operator] gyfora commented on pull request #227: [FLINK-27685] Scale subresource prototype

2022-06-09 Thread GitBox
gyfora commented on PR #227: URL: https://github.com/apache/flink-kubernetes-operator/pull/227#issuecomment-1152018399 @Aitozi thank you for raising these concerns. I think the main question is, why would anyone use autoscaling/HPA (and expect it to work) if they hardcode parallelism or ha

[GitHub] [flink-web] wanglijie95 commented on a diff in pull request #545: Add blogs for FLIP-147 support checkpoints after tasks finished

2022-06-09 Thread GitBox
wanglijie95 commented on code in PR #545: URL: https://github.com/apache/flink-web/pull/545#discussion_r894187979 ## _posts/2022-06-01-final-checkpoint-part1.md: ## @@ -0,0 +1,173 @@ +--- +layout: post +title: "FLIP-147: Support Checkpoints After Tasks Finished - Part One" +da

[GitHub] [flink] flinkbot commented on pull request #19927: [FLINK-27903][runtime] Introduce and support HYBRID resultPartitionType

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

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #227: [FLINK-27685] Scale subresource prototype

2022-06-09 Thread GitBox
gyfora commented on code in PR #227: URL: https://github.com/apache/flink-kubernetes-operator/pull/227#discussion_r894195379 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -278,4 +280,10 @@ public static boolean isK

[jira] [Updated] (FLINK-27903) Introduce and support HYBRID resultPartitionType

2022-06-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27903: --- Labels: pull-request-available (was: ) > Introduce and support HYBRID resultPartitionType >

[GitHub] [flink] reswqa opened a new pull request, #19927: [FLINK-27903][runtime] Introduce and support HYBRID resultPartitionType

2022-06-09 Thread GitBox
reswqa opened a new pull request, #19927: URL: https://github.com/apache/flink/pull/19927 ## What is the purpose of the change *Introduce and support HYBRID resultPartitionType* ## Brief change log - *Introduce HYBRID resultPartitionType.* - *Make streamGraph a

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-06-09 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552579#comment-17552579 ] Jing Ge commented on FLINK-27246: - Hi [~maver1ck] could you share the SQL that we could

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-06-09 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552578#comment-17552578 ] Jing Ge commented on FLINK-27246: - Hi [~maver1ck] could you share the SQL that we could

[GitHub] [flink] dusukang commented on pull request #19741: [FLINK-27794][connectors/jdbc]Fix the bug of wrong primary key in MysqlCatalog

2022-06-09 Thread GitBox
dusukang commented on PR #19741: URL: https://github.com/apache/flink/pull/19741#issuecomment-1151985970 @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-27197) Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource

2022-06-09 Thread LuNng Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552522#comment-17552522 ] LuNng Wang edited comment on FLINK-27197 at 6/10/22 6:06 AM: -

[GitHub] [flink] dusukang commented on pull request #19741: [FLINK-27794][connectors/jdbc]Fix the bug of wrong primary key in MysqlCatalog

2022-06-09 Thread GitBox
dusukang commented on PR #19741: URL: https://github.com/apache/flink/pull/19741#issuecomment-1151985487 Thanks for your reply. -- 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

[GitHub] [flink-table-store] LadyForest commented on pull request #141: [FLINK-27371] Record schema id in ManifestFileMeta and DataFileMeta

2022-06-09 Thread GitBox
LadyForest commented on PR #141: URL: https://github.com/apache/flink-table-store/pull/141#issuecomment-1151983023 Hi, @JingsongLi sorry for being late. Would you mind rebasing and resolving conflicts sooner or later? -- This is an automated message from the Apache Git Service. To respon

[jira] [Created] (FLINK-27993) When only use 'flex SQL' to develop programs, `watermark` can be defined when creating view tables

2022-06-09 Thread HunterHunter (Jira)
HunterHunter created FLINK-27993: Summary: When only use 'flex SQL' to develop programs, `watermark` can be defined when creating view tables Key: FLINK-27993 URL: https://issues.apache.org/jira/browse/FLINK-27993

[jira] [Created] (FLINK-27992) cep StreamExecMatch need check the parallelism and maxParallelism of the two transformation in it

2022-06-09 Thread jackylau (Jira)
jackylau created FLINK-27992: Summary: cep StreamExecMatch need check the parallelism and maxParallelism of the two transformation in it Key: FLINK-27992 URL: https://issues.apache.org/jira/browse/FLINK-27992

[jira] [Assigned] (FLINK-27987) Let FileSystemTableSource extend from SupportsStatisticReport

2022-06-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27987: -- Assignee: Yunhong Zheng > Let FileSystemTableSource extend from SupportsStatisticReport > ---

[jira] [Assigned] (FLINK-27985) Introduce FlinkRecomputeStatisticsProgram to compute statistics after filter push and partition pruning

2022-06-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27985: -- Assignee: godfrey he > Introduce FlinkRecomputeStatisticsProgram to compute statistics after

[jira] [Assigned] (FLINK-27983) Introduce SupportsStatisticsReport interface

2022-06-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27983: -- Assignee: godfrey he > Introduce SupportsStatisticsReport interface > ---

[jira] [Assigned] (FLINK-27984) Introduce FileBasedStatisticsReportableDecodingFormat interface

2022-06-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27984: -- Assignee: godfrey he > Introduce FileBasedStatisticsReportableDecodingFormat interface >

[jira] [Assigned] (FLINK-27988) Let HiveTableSource extend from SupportsStatisticReport

2022-06-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27988: -- Assignee: Yunhong Zheng > Let HiveTableSource extend from SupportsStatisticReport > -

[jira] [Assigned] (FLINK-27990) Parquet format supports reporting statistics

2022-06-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27990: -- Assignee: Yunhong Zheng > Parquet format supports reporting statistics >

[jira] [Assigned] (FLINK-27991) ORC format supports reporting statistics

2022-06-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27991: -- Assignee: Yunhong Zheng > ORC format supports reporting statistics >

[jira] [Assigned] (FLINK-27989) CSV format supports reporting statistics

2022-06-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27989: -- Assignee: Yunhong Zheng > CSV format supports reporting statistics >

[jira] [Created] (FLINK-27991) ORC format supports reporting statistics

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27991: -- Summary: ORC format supports reporting statistics Key: FLINK-27991 URL: https://issues.apache.org/jira/browse/FLINK-27991 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-27986) Refactor the name of finish method for JdbcOutputFormatBuilder

2022-06-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27986: --- Labels: pull-request-available (was: ) > Refactor the name of finish method for JdbcOutputF

[jira] [Created] (FLINK-27990) Parquet format supports reporting statistics

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27990: -- Summary: Parquet format supports reporting statistics Key: FLINK-27990 URL: https://issues.apache.org/jira/browse/FLINK-27990 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27989) CSV format supports reporting statistics

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27989: -- Summary: CSV format supports reporting statistics Key: FLINK-27989 URL: https://issues.apache.org/jira/browse/FLINK-27989 Project: Flink Issue Type: Sub-task

[GitHub] [flink] leo65535 commented on pull request #18794: [FLINK-27986] Refactor the name of finish method for JdbcOutputFormatBuilder

2022-06-09 Thread GitBox
leo65535 commented on PR #18794: URL: https://github.com/apache/flink/pull/18794#issuecomment-1151967851 Welcome @knaufk, done. -- 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] [Created] (FLINK-27988) Let HiveTableSource extend from SupportsStatisticReport

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27988: -- Summary: Let HiveTableSource extend from SupportsStatisticReport Key: FLINK-27988 URL: https://issues.apache.org/jira/browse/FLINK-27988 Project: Flink Issue Typ

[jira] [Created] (FLINK-27987) Let FileSystemTableSource extend from SupportsStatisticReport

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27987: -- Summary: Let FileSystemTableSource extend from SupportsStatisticReport Key: FLINK-27987 URL: https://issues.apache.org/jira/browse/FLINK-27987 Project: Flink Is

[jira] [Created] (FLINK-27986) Refactor the name of finish method for JdbcOutputFormatBuilder

2022-06-09 Thread Lei Xie (Jira)
Lei Xie created FLINK-27986: --- Summary: Refactor the name of finish method for JdbcOutputFormatBuilder Key: FLINK-27986 URL: https://issues.apache.org/jira/browse/FLINK-27986 Project: Flink Issue T

[jira] [Created] (FLINK-27985) Introduce FlinkRecomputeStatisticsProgram to compute statistics after filter push and partition pruning

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27985: -- Summary: Introduce FlinkRecomputeStatisticsProgram to compute statistics after filter push and partition pruning Key: FLINK-27985 URL: https://issues.apache.org/jira/browse/FLINK-2798

[jira] [Created] (FLINK-27984) Introduce FileBasedStatisticsReportableDecodingFormat interface

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27984: -- Summary: Introduce FileBasedStatisticsReportableDecodingFormat interface Key: FLINK-27984 URL: https://issues.apache.org/jira/browse/FLINK-27984 Project: Flink

[jira] [Created] (FLINK-27983) Introduce SupportsStatisticsReport interface

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27983: -- Summary: Introduce SupportsStatisticsReport interface Key: FLINK-27983 URL: https://issues.apache.org/jira/browse/FLINK-27983 Project: Flink Issue Type: Sub-task

[GitHub] [flink] dusukang commented on pull request #19741: [FLINK-27794][connectors/jdbc]Fix the bug of wrong primary key in MysqlCatalog

2022-06-09 Thread GitBox
dusukang commented on PR #19741: URL: https://github.com/apache/flink/pull/19741#issuecomment-1151963744 @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] [Assigned] (FLINK-27982) FLIP-231: Introduce SupportsStatisticReport to support reporting statistics from source connectors

2022-06-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27982: -- Assignee: godfrey he > FLIP-231: Introduce SupportsStatisticReport to support reporting stati

[jira] [Created] (FLINK-27982) FLIP-231: Introduce SupportsStatisticReport to support reporting statistics from source connectors

2022-06-09 Thread godfrey he (Jira)
godfrey he created FLINK-27982: -- Summary: FLIP-231: Introduce SupportsStatisticReport to support reporting statistics from source connectors Key: FLINK-27982 URL: https://issues.apache.org/jira/browse/FLINK-27982

[jira] [Commented] (FLINK-27981) Add python examples to document of "Time Attributes"

2022-06-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552560#comment-17552560 ] Dian Fu commented on FLINK-27981: - [~pemide] Done~ > Add python examples to document of

[jira] [Assigned] (FLINK-27981) Add python examples to document of "Time Attributes"

2022-06-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-27981: --- Assignee: pengmd > Add python examples to document of "Time Attributes" > -

[jira] [Commented] (FLINK-27980) Add python examples to document of "DataStream API Integration"

2022-06-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552559#comment-17552559 ] Dian Fu commented on FLINK-27980: - [~pemide] Done ~ > Add python examples to document o

[jira] [Assigned] (FLINK-27980) Add python examples to document of "DataStream API Integration"

2022-06-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-27980: --- Assignee: pengmd > Add python examples to document of "DataStream API Integration" > -

[jira] [Comment Edited] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-06-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552554#comment-17552554 ] Aitozi edited comment on FLINK-27925 at 6/10/22 5:14 AM: - I thin

[jira] [Commented] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-06-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552554#comment-17552554 ] Aitozi commented on FLINK-27925: Will it cache extra pods of other jobs if we specify th

[GitHub] [flink] luoyuxia commented on a diff in pull request #19714: [FLINK-27603][hive] Hive dialect supports 'reload function'

2022-06-09 Thread GitBox
luoyuxia commented on code in PR #19714: URL: https://github.com/apache/flink/pull/19714#discussion_r894143499 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java: ## @@ -218,7 +217,11 @@ private List processCmd(

[GitHub] [flink] Tartarus0zm commented on a diff in pull request #19714: [FLINK-27603][hive] Hive dialect supports 'reload function'

2022-06-09 Thread GitBox
Tartarus0zm commented on code in PR #19714: URL: https://github.com/apache/flink/pull/19714#discussion_r894140022 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java: ## @@ -218,7 +217,11 @@ private List processCm

[GitHub] [flink] flinkbot commented on pull request #19926: Tt

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

[GitHub] [flink] Aitozi commented on pull request #19886: [FLINK-27921] Introduce the checkResourceRequirementsWithDelay in Dec…

2022-06-09 Thread GitBox
Aitozi commented on PR #19886: URL: https://github.com/apache/flink/pull/19886#issuecomment-1151921104 @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. T

[jira] [Updated] (FLINK-27981) Add python examples to document of "Time Attributes"

2022-06-09 Thread pengmd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pengmd updated FLINK-27981: --- Summary: Add python examples to document of "Time Attributes" (was: Add python examples to document of Time

[GitHub] [flink] luoyuxia opened a new pull request, #19926: Tt

2022-06-09 Thread GitBox
luoyuxia opened a new pull request, #19926: URL: https://github.com/apache/flink/pull/19926 ## 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 o

[GitHub] [flink] mayuehappy commented on a diff in pull request #19259: [FLINK-23890] improve cep operator timer register policy

2022-06-09 Thread GitBox
mayuehappy commented on code in PR #19259: URL: https://github.com/apache/flink/pull/19259#discussion_r894137179 ## flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CepOperator.java: ## @@ -417,6 +405,9 @@ private void processEvent(NFAState nfaState, IN even

[jira] [Commented] (FLINK-27603) Hive dialect supports "reload function"

2022-06-09 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552530#comment-17552530 ] tartarus commented on FLINK-27603: -- Thanks for your work! I think the reload function

[jira] [Commented] (FLINK-27981) Add python examples to document of Time Attributes"

2022-06-09 Thread pengmd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552527#comment-17552527 ] pengmd commented on FLINK-27981:  [~dianfu]  Could i take this ticket? > Add python exa

[jira] [Created] (FLINK-27981) Add python examples to document of Time Attributes"

2022-06-09 Thread pengmd (Jira)
pengmd created FLINK-27981: -- Summary: Add python examples to document of Time Attributes" Key: FLINK-27981 URL: https://issues.apache.org/jira/browse/FLINK-27981 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-27980) Add python examples to document of "DataStream API Integration"

2022-06-09 Thread pengmd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552526#comment-17552526 ] pengmd commented on FLINK-27980: [~dianfu] Could i take this ticket? > Add python examp

[jira] [Created] (FLINK-27980) Add python examples to document of "DataStream API Integration"

2022-06-09 Thread pengmd (Jira)
pengmd created FLINK-27980: -- Summary: Add python examples to document of "DataStream API Integration" Key: FLINK-27980 URL: https://issues.apache.org/jira/browse/FLINK-27980 Project: Flink Issue T

[GitHub] [flink] dusukang commented on pull request #19741: [FLINK-27794][connectors/jdbc]Fix the bug of wrong primary key in MysqlCatalog

2022-06-09 Thread GitBox
dusukang commented on PR #19741: URL: https://github.com/apache/flink/pull/19741#issuecomment-1151905642 Yeah. Thanks for the comment. I also think it is a good improvement to verify. I'll change it soon. -- This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] pengmide commented on pull request #19918: [FLINK-27935][python][docs] Add Pyflink example of create temporary view document

2022-06-09 Thread GitBox
pengmide commented on PR #19918: URL: https://github.com/apache/flink/pull/19918#issuecomment-1151902566 @dianfu I've fixed the problem, PTAL~ -- 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] [Closed] (FLINK-26801) LogisticRegressionTest.testGetModelData» Runtime Failed to fetch next res...

2022-06-09 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-26801. Resolution: Fixed > LogisticRegressionTest.testGetModelData» Runtime Failed to fetch next res... > ---

[GitHub] [flink] fsk119 commented on a diff in pull request #19741: [FLINK-27794][connectors/jdbc]Fix the bug of wrong primary key in MysqlCatalog

2022-06-09 Thread GitBox
fsk119 commented on code in PR #19741: URL: https://github.com/apache/flink/pull/19741#discussion_r894124861 ## flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java: ## @@ -144,12 +144,13 @@ public String getBaseUrl

[GitHub] [flink] fsk119 commented on a diff in pull request #19741: [FLINK-27794][connectors/jdbc]Fix the bug of wrong primary key in MysqlCatalog

2022-06-09 Thread GitBox
fsk119 commented on code in PR #19741: URL: https://github.com/apache/flink/pull/19741#discussion_r894124861 ## flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java: ## @@ -144,12 +144,13 @@ public String getBaseUrl

[GitHub] [flink-ml] lindong28 merged pull request #107: [FLINK-26801] Support duplicate checkpoint aborted messages

2022-06-09 Thread GitBox
lindong28 merged PR #107: URL: https://github.com/apache/flink-ml/pull/107 -- 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.apac

[GitHub] [flink-ml] lindong28 commented on pull request #107: [FLINK-26801] Support duplicate checkpoint aborted messages

2022-06-09 Thread GitBox
lindong28 commented on PR #107: URL: https://github.com/apache/flink-ml/pull/107#issuecomment-1151895489 Thanks for the fix! LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific com

[jira] [Commented] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-06-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552524#comment-17552524 ] Yang Wang commented on FLINK-27925: --- I agree that we could use a shared informer for t

[GitHub] [flink-web] zhuyufeng0809 commented on pull request #549: [FLINK-20760][Project Website] Fix broken doc link

2022-06-09 Thread GitBox
zhuyufeng0809 commented on PR #549: URL: https://github.com/apache/flink-web/pull/549#issuecomment-1151891546 Hi @wuchong , could you help me to review this PR -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [flink] reswqa commented on pull request #19924: [FLINK-27890][examples] Fix the bug introduced By [FLINK-19317] to use the return result after assignTimestampsAndWatermarks

2022-06-09 Thread GitBox
reswqa commented on PR #19924: URL: https://github.com/apache/flink/pull/19924#issuecomment-1151890385 > > @coderappee You've ended up with two apparently identical commits in this PR. Could you clean that up, please? > > Could you tell me how to do it? Close this pull request and the

[GitHub] [flink] fsk119 commented on pull request #19892: [FLINK-27683][table-planner][realease-1.14] Fix SQL hints can't work with targetColumns

2022-06-09 Thread GitBox
fsk119 commented on PR #19892: URL: https://github.com/apache/flink/pull/19892#issuecomment-1151889948 Could you forcely push to the remote reop? It seems the pipeline blocks... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-27197) Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource

2022-06-09 Thread LuNng Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552522#comment-17552522 ] LuNng Wang commented on FLINK-27197: We need to replace env#fromTableSource. > Port

[jira] [Commented] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-09 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552520#comment-17552520 ] zoucao commented on FLINK-27898: Hi, [~luoyuxia], before opening a pr, I think we should

[jira] [Updated] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

2022-06-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20760: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-avail

[GitHub] [flink-web] zhuyufeng0809 opened a new pull request, #549: [FLINK-20760][Project Website] Fix broken doc link

2022-06-09 Thread GitBox
zhuyufeng0809 opened a new pull request, #549: URL: https://github.com/apache/flink-web/pull/549 ## What is the purpose of the change Fix broken doc link in Apache Flink Code Style and Quality Guide. The link in pic is broken. The [[usage of Java Optional](https://flink.apache.

[jira] [Updated] (FLINK-27713) Bump Apache Beam to 2.40.0

2022-06-09 Thread LuNng Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LuNng Wang updated FLINK-27713: --- Fix Version/s: 1.17.0 > Bump Apache Beam to 2.40.0 > -- > >

[GitHub] [flink] luoyuxia commented on pull request #19656: [FLINK-26371][hive] Support variable substitution for sql statement while using Hive dialect

2022-06-09 Thread GitBox
luoyuxia commented on PR #19656: URL: https://github.com/apache/flink/pull/19656#issuecomment-1151881004 @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] [Resolved] (FLINK-26363) Fail to use such expression like if(1= 1, 2, 3)

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-26363. -- Resolution: Fixed > Fail to use such expression like if(1= 1, 2, 3) >

[jira] [Resolved] (FLINK-26365) improve hive udaf

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-26365. -- Resolution: Duplicate > improve hive udaf > - > > Key: FLINK-26365 >

[jira] [Commented] (FLINK-27898) fix PartitionPushDown in streaming mode for hive source

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552516#comment-17552516 ] luoyuxia commented on FLINK-27898: -- [~zoucao] Thanks for detail explaination. Just go h

[jira] [Commented] (FLINK-25641) Unexpected aggregate plan after load hive module

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552514#comment-17552514 ] luoyuxia commented on FLINK-25641: -- [~jingzhang] When load hive module with a higer pri

[jira] [Assigned] (FLINK-27814) Add an abstraction layer for connectors to read and write row data instead of key-values

2022-06-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-27814: Assignee: Caizhi Weng > Add an abstraction layer for connectors to read and write row dat

[jira] [Closed] (FLINK-27973) Introduce TableWrite and TableCommit as an abstraction layer above FileStore for writing RowData

2022-06-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27973. Fix Version/s: table-store-0.2.0 Assignee: Caizhi Weng Resolution: Fixed master: 2

[GitHub] [flink-table-store] JingsongLi merged pull request #150: [FLINK-27973] Introduce TableWrite and TableCommit as an abstraction layer above FileStore for writing RowData

2022-06-09 Thread GitBox
JingsongLi merged PR #150: URL: https://github.com/apache/flink-table-store/pull/150 -- 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...@

[jira] [Resolved] (FLINK-25095) Case when would be translated into different expression in Hive dialect and default dialect

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-25095. -- Resolution: Duplicate > Case when would be translated into different expression in Hive dialect and >

[jira] [Created] (FLINK-27979) Support to upgrade session cluster in a more fine grained way

2022-06-09 Thread Aitozi (Jira)
Aitozi created FLINK-27979: -- Summary: Support to upgrade session cluster in a more fine grained way Key: FLINK-27979 URL: https://issues.apache.org/jira/browse/FLINK-27979 Project: Flink Issue Type

[jira] [Resolved] (FLINK-27296) CalcOperator CodeGenException: Boolean expression type expected

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27296. -- Resolution: Duplicate > CalcOperator CodeGenException: Boolean expression type expected >

[jira] [Commented] (FLINK-27304) Flink doesn't support Hive primitive type void yet

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552508#comment-17552508 ] luoyuxia commented on FLINK-27304: -- [~godfreyhe] Could you please assign it to me? > F

[jira] [Commented] (FLINK-27305) Hive Dialect support implicit conversion

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552507#comment-17552507 ] luoyuxia commented on FLINK-27305: -- [~godfreyhe] Yes, I aggree. I would like to fix jus

[jira] [Resolved] (FLINK-27305) Hive Dialect support implicit conversion

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27305. -- Resolution: Duplicate > Hive Dialect support implicit conversion > ---

[jira] [Resolved] (FLINK-27378) Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27378. -- Resolution: Duplicate > Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess > -

[jira] [Resolved] (FLINK-27379) CodeGenException: Unable to find common type of

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27379. -- Resolution: Duplicate > CodeGenException: Unable to find common type of >

[GitHub] [flink] wuchong commented on pull request #19254: [BP-1.14][hotfix][table-runtime] Fix ArrayDataSerializer null fields writing

2022-06-09 Thread GitBox
wuchong commented on PR #19254: URL: https://github.com/apache/flink/pull/19254#issuecomment-1151867432 @snuyanzin could you rebase the branch to the latest realese-1.14 and trigger the CI again? -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Resolved] (FLINK-27380) Failed to get Hive result type from org.apache.hadoop.hive.ql.udf.generic.GenericUDAFPercentileApprox

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27380. -- Resolution: Duplicate > Failed to get Hive result type from > org.apache.hadoop.hive.ql.udf.generic.G

[jira] [Closed] (FLINK-27385) Field #1: values VARCHAR(2147483647) ARRAY does not exist for expression index($0, 0)

2022-06-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia closed FLINK-27385. Resolution: Duplicate > Field #1: values VARCHAR(2147483647) ARRAY does not exist for expression > index(

[jira] [Closed] (FLINK-27259) Observer should not clear savepoint errors even though deployment is healthy

2022-06-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang closed FLINK-27259. -- Resolution: Won't Fix > Observer should not clear savepoint errors even though deployment is h

[GitHub] [flink] dusukang commented on pull request #19741: [FLINK-27794][connectors/jdbc]Fix the bug of wrong primary key in MysqlCatalog

2022-06-09 Thread GitBox
dusukang commented on PR #19741: URL: https://github.com/apache/flink/pull/19741#issuecomment-1151851087 @fsk119 Hi. It has passed the CI test. Could you take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

  1   2   3   >