[GitHub] [flink] lirui-apache commented on a change in pull request #14634: [FLINK-20913][hive]Improve HiveConf creation

lirui-apache commented on a change in pull request #14634: URL: https://github.com/apache/flink/pull/14634#discussion_r557980489 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/util/HiveConfUtilsTest.java ## @@ -0,0 +1,66 @@

[jira] [Created] (FLINK-20989) Functions in ExplodeFunctionUtil should handle null data to avoid NPE

godfrey he created FLINK-20989: -- Summary: Functions in ExplodeFunctionUtil should handle null data to avoid NPE Key: FLINK-20989 URL: https://issues.apache.org/jira/browse/FLINK-20989 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14658: [FLINK-20986][REST] GenericTypeInfo equality issue

flinkbot edited a comment on pull request #14658: URL: https://github.com/apache/flink/pull/14658#issuecomment-760700625 ## CI report: * 2f1138efb8b02d7e910400218e51c4df3a0b6c2f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14659: [FLINK-20931][coordination] Remove globalModVersion from ExecutionGraph

flinkbot edited a comment on pull request #14659: URL: https://github.com/apache/flink/pull/14659#issuecomment-760700709 ## CI report: * 1b050c2b3acb1c1309e9053364a6f22731dba21a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14652: [FLINK-20953][canal][json] Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

flinkbot edited a comment on pull request #14652: URL: https://github.com/apache/flink/pull/14652#issuecomment-760296852 ## CI report: * 72601d907bc02eb3b74499a36f15f713406d911c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14645: [FLINK-20967][docs] HBase properties 'properties.*' function Description

flinkbot edited a comment on pull request #14645: URL: https://github.com/apache/flink/pull/14645#issuecomment-760128893 ## CI report: * 377185e7ca78d74e7e95479f97c27e20b215dce4 Azure:

[GitHub] [flink] rmetzger commented on pull request #14450: [FLINK-19971][hbase] Fix HBase connector dependencies

rmetzger commented on pull request #14450: URL: https://github.com/apache/flink/pull/14450#issuecomment-760714424 I'll take a look This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] wuchong commented on a change in pull request #14652: [FLINK-20953][canal][json] Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

wuchong commented on a change in pull request #14652: URL: https://github.com/apache/flink/pull/14652#discussion_r557955645 ## File path: docs/dev/table/connectors/formats/canal.md ## @@ -292,14 +292,14 @@ Format Options optional (none) String - Only

[jira] [Commented] (FLINK-18383) Translate "JDBC SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265780#comment-17265780 ] bruce lu commented on FLINK-18383: -- Okay! I got it! > Translate "JDBC SQL Connector" page into Chinese

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265767#comment-17265767 ] Xintong Song commented on FLINK-20811: -- We use reflection in production codes for classes that are

[GitHub] [flink] flinkbot commented on pull request #14659: [FLINK-20931][coordination] Remove globalModVersion from ExecutionGraph

flinkbot commented on pull request #14659: URL: https://github.com/apache/flink/pull/14659#issuecomment-760700709 ## CI report: * 1b050c2b3acb1c1309e9053364a6f22731dba21a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14658: [FLINK-20986][REST] GenericTypeInfo equality issue

flinkbot commented on pull request #14658: URL: https://github.com/apache/flink/pull/14658#issuecomment-760700625 ## CI report: * 2f1138efb8b02d7e910400218e51c4df3a0b6c2f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-20986) GenericTypeInfo equality issue

[ https://issues.apache.org/jira/browse/FLINK-20986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265765#comment-17265765 ] Jark Wu commented on FLINK-20986: - If you have two non-equal instances of the same Class, that's mostly

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265760#comment-17265760 ] Zhenqiu Huang commented on FLINK-20811: --- [~xintongsong] Currently, Flink master branch is still

[jira] [Comment Edited] (FLINK-20565) Fix typo in EXPLAIN Statements docs.

[ https://issues.apache.org/jira/browse/FLINK-20565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247736#comment-17247736 ] Jark Wu edited comment on FLINK-20565 at 1/15/21, 7:03 AM: --- Fixed in -

[jira] [Closed] (FLINK-20565) Fix typo in EXPLAIN Statements docs.

[ https://issues.apache.org/jira/browse/FLINK-20565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20565. --- Fix Version/s: (was: 1.13.0) Resolution: Fixed > Fix typo in EXPLAIN Statements docs. >

[jira] [Updated] (FLINK-17372) SlotManager should expose total required resources

[ https://issues.apache.org/jira/browse/FLINK-17372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17372: - Parent: FLINK-20988 Issue Type: Sub-task (was: Improvement) > SlotManager should

[jira] [Updated] (FLINK-18229) Pending worker requests should be properly cleared

[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18229: - Parent: FLINK-20988 Issue Type: Sub-task (was: Improvement) > Pending worker requests

[jira] [Updated] (FLINK-18788) Refactor sql-client based the proposed interfaces of FLIP-84

[ https://issues.apache.org/jira/browse/FLINK-18788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18788: Labels: sprint (was: ) > Refactor sql-client based the proposed interfaces of FLIP-84 >

[jira] [Updated] (FLINK-13554) ResourceManager should have a timeout on starting new TaskExecutors.

[ https://issues.apache.org/jira/browse/FLINK-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13554: - Parent: FLINK-20988 Issue Type: Sub-task (was: Improvement) > ResourceManager should

[jira] [Updated] (FLINK-18791) Simplify the logic of SqlCommandParser and CliClient

[ https://issues.apache.org/jira/browse/FLINK-18791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18791: Labels: sprint (was: ) > Simplify the logic of SqlCommandParser and CliClient >

[jira] [Updated] (FLINK-20332) Add workers recovered from previous attempt to pending resources

[ https://issues.apache.org/jira/browse/FLINK-20332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20332: - Parent: FLINK-20988 Issue Type: Sub-task (was: Improvement) > Add workers recovered

[jira] [Commented] (FLINK-20986) GenericTypeInfo equality issue

[ https://issues.apache.org/jira/browse/FLINK-20986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265755#comment-17265755 ] Tianshi Zhu commented on FLINK-20986: - I also submitted a pr for review, since this is a small fix.

[jira] [Created] (FLINK-20988) Various resource allocation improvements for active resource managers

Xintong Song created FLINK-20988: Summary: Various resource allocation improvements for active resource managers Key: FLINK-20988 URL: https://issues.apache.org/jira/browse/FLINK-20988 Project: Flink

[jira] [Commented] (FLINK-20986) GenericTypeInfo equality issue

[ https://issues.apache.org/jira/browse/FLINK-20986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265753#comment-17265753 ] Tianshi Zhu commented on FLINK-20986: - I tried to reproduce the problem locally, but can't create

[GitHub] [flink] flinkbot commented on pull request #14659: [FLINK-20931][coordination] Remove globalModVersion from ExecutionGraph

flinkbot commented on pull request #14659: URL: https://github.com/apache/flink/pull/14659#issuecomment-760693990 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-20931) Remove globalModVersion from ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-20931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20931: --- Labels: pull-request-available (was: ) > Remove globalModVersion from ExecutionGraph >

[GitHub] [flink] rmetzger closed pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

rmetzger closed pull request #14512: URL: https://github.com/apache/flink/pull/14512 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] flinkbot commented on pull request #14658: [FLINK-20986][REST] GenericTypeInfo equality issue

flinkbot commented on pull request #14658: URL: https://github.com/apache/flink/pull/14658#issuecomment-760693177 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] SteNicholas opened a new pull request #14659: [FLINK-20931][coordination] Remove globalModVersion from ExecutionGraph

SteNicholas opened a new pull request #14659: URL: https://github.com/apache/flink/pull/14659 ## What is the purpose of the change *`ExecutionVertexVersioner` is used instead for concurrent global-local and local-local failures' handling. Therefore `ExecutionGraph#globalModVersion`

[GitHub] [flink] wuchong commented on a change in pull request #14645: [FLINK-20967][docs] HBase properties 'properties.*' function Description

wuchong commented on a change in pull request #14645: URL: https://github.com/apache/flink/pull/14645#discussion_r557913884 ## File path: docs/dev/table/connectors/hbase.md ## @@ -172,6 +172,15 @@ Connector Options Integer Defines the parallelism of the HBase

[jira] [Updated] (FLINK-20986) GenericTypeInfo equality issue

[ https://issues.apache.org/jira/browse/FLINK-20986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20986: --- Labels: pull-request-available (was: ) > GenericTypeInfo equality issue >

[jira] [Commented] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing

[ https://issues.apache.org/jira/browse/FLINK-17011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265748#comment-17265748 ] Robert Metzger commented on FLINK-17011: I'm not very familiar with that part of the code. Maybe

[jira] [Updated] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing

[ https://issues.apache.org/jira/browse/FLINK-17011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17011: --- Component/s: API / DataStream > Introduce builder to create

[GitHub] [flink] tianshizz opened a new pull request #14658: [FLINK-20986][REST] GenericTypeInfo equality issue

tianshizz opened a new pull request #14658: URL: https://github.com/apache/flink/pull/14658 ## 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 on each

[jira] [Commented] (FLINK-20984) can not convert an array into Table

[ https://issues.apache.org/jira/browse/FLINK-20984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265742#comment-17265742 ] Jark Wu commented on FLINK-20984: - You should use {{tableEnv.fromValues(data: _*)}} to tells the

[jira] [Closed] (FLINK-20984) can not convert an array into Table

[ https://issues.apache.org/jira/browse/FLINK-20984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20984. --- Resolution: Not A Problem > can not convert an array into Table > --- > >

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:29 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265737#comment-17265737 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:27 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265737#comment-17265737 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:25 AM: -- Hi

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265737#comment-17265737 ] huajiewang commented on FLINK-20972: Hi [~gaoyunhaii] i can overwrite toString method for my 

[jira] [Updated] (FLINK-20987) Upgrade Stateful Functions to use Flink 1.12

[ https://issues.apache.org/jira/browse/FLINK-20987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20987: --- Labels: pull-request-available (was: ) > Upgrade Stateful Functions to use Flink 1.12 >

[GitHub] [flink-statefun] tzulitai opened a new pull request #192: [FLINK-20987] Upgrade to Flink 1.12

tzulitai opened a new pull request #192: URL: https://github.com/apache/flink-statefun/pull/192 This PR upgrades the Flink dependency to Flink 1.12. Only a few minor changes to some used internal APIs were required. The legal NOTICE files have also been updated accordingly.

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:20 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:19 AM: -- Hi

[jira] [Commented] (FLINK-20986) GenericTypeInfo equality issue

[ https://issues.apache.org/jira/browse/FLINK-20986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265734#comment-17265734 ] Jark Wu commented on FLINK-20986: - Is it possible to reproduce the problem using a Table API? If yes,

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:18 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:18 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:18 AM: -- Hi

[GitHub] [flink] dianfu commented on a change in pull request #14621: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

dianfu commented on a change in pull request #14621: URL: https://github.com/apache/flink/pull/14621#discussion_r557882505 ## File path: flink-python/src/main/java/org/apache/flink/python/util/PythonConfigUtil.java ## @@ -270,4 +296,39 @@ private static boolean

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:17 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:16 AM: -- Hi

[GitHub] [flink] leonardBang commented on pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

leonardBang commented on pull request #14610: URL: https://github.com/apache/flink/pull/14610#issuecomment-760677892 LGTM cc @wuchong This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang commented on FLINK-20972: u are right, my Transaction class is here: scala:  

[jira] [Created] (FLINK-20987) Upgrade Stateful Functions to use Flink 1.12

Tzu-Li (Gordon) Tai created FLINK-20987: --- Summary: Upgrade Stateful Functions to use Flink 1.12 Key: FLINK-20987 URL: https://issues.apache.org/jira/browse/FLINK-20987 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14635: [FLINK-19462][checkpointing] Update failed checkpoint stats

flinkbot edited a comment on pull request #14635: URL: https://github.com/apache/flink/pull/14635#issuecomment-759750009 ## CI report: * 2e65254e667d4360d6c48a5e2ad9d2b620cdb17d Azure:

[jira] [Closed] (FLINK-20751) Port batch python group aggregate nodes to Java

[ https://issues.apache.org/jira/browse/FLINK-20751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20751. --- Assignee: Huang Xingbo Resolution: Fixed Merged to master via 

[GitHub] [flink] dianfu merged pull request #14641: [FLINK-20751][python][table-planner-blink] Port batch python group aggregate nodes to Java

dianfu merged pull request #14641: URL: https://github.com/apache/flink/pull/14641 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

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265726#comment-17265726 ] Yun Gao commented on FLINK-20972: - Hi [~benjobs], If I understand right, the problem is that the 

[jira] [Commented] (FLINK-20873) Upgrade Calcite version to 1.27

[ https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265716#comment-17265716 ] Ruguo Yu commented on FLINK-20873: -- Ok, thanks for your reply. > Upgrade Calcite version to 1.27 >

[jira] [Comment Edited] (FLINK-20982) Flink TaskManager throws RegistrationTimeoutException when using Kubernetes HA

[ https://issues.apache.org/jira/browse/FLINK-20982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265715#comment-17265715 ] Yang Wang edited comment on FLINK-20982 at 1/15/21, 5:54 AM: - I use the

[jira] [Commented] (FLINK-20982) Flink TaskManager throws RegistrationTimeoutException when using Kubernetes HA

[ https://issues.apache.org/jira/browse/FLINK-20982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265715#comment-17265715 ] Yang Wang commented on FLINK-20982: --- I use the following four yaml files to deploy a Flink application

[jira] [Closed] (FLINK-20876) Separate the implementation of StreamExecTemporalJoin

[ https://issues.apache.org/jira/browse/FLINK-20876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20876. -- Resolution: Fixed Fixed in 1.13.0: 5893efeb..38327866 > Separate the implementation of

[GitHub] [flink] godfreyhe closed pull request #14606: [Flink-20876][table-planner-blink] Separate the implementation of StreamExecTemporalJoin

godfreyhe closed pull request #14606: URL: https://github.com/apache/flink/pull/14606 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] flinkbot edited a comment on pull request #14640: [FLINK-20937][Table API/SQL]Drop table can fails, when i create a tab…

flinkbot edited a comment on pull request #14640: URL: https://github.com/apache/flink/pull/14640#issuecomment-760055828 ## CI report: * 17ac8f48c293e42e7c5e63c1724112048fc57827 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14638: [FLINK-20966][table-planner-blink] Rename Stream(/Batch)ExecIntermediateTableScan to Stream(/Batch)PhysicalIntermediateTableScan

flinkbot edited a comment on pull request #14638: URL: https://github.com/apache/flink/pull/14638#issuecomment-759991130 ## CI report: * 99448538758f042069a6e9eb6e319726a54ca92c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14638: [FLINK-20966][table-planner-blink] Rename Stream(/Batch)ExecIntermediateTableScan to Stream(/Batch)PhysicalIntermediateTableScan

flinkbot edited a comment on pull request #14638: URL: https://github.com/apache/flink/pull/14638#issuecomment-759991130 ## CI report: * 99448538758f042069a6e9eb6e319726a54ca92c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * 8e20c81e5253a8b6a8ab9efb929e6413a97fce70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14627: [FLINK-20946][python] Optimize Python ValueState Implementation In PyFlink

flinkbot edited a comment on pull request #14627: URL: https://github.com/apache/flink/pull/14627#issuecomment-759272918 ## CI report: * ff00387c962b937a5dabaaeb9241acfdbc9e49ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14616: [FLINK-20879][table-api] Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

flinkbot edited a comment on pull request #14616: URL: https://github.com/apache/flink/pull/14616#issuecomment-758526377 ## CI report: * 448c026a402e045e050f405daf934a8a7c880c9d UNKNOWN * f429967b7680aa4dce4212ddb01b2c107b3b7117 Azure:

[GitHub] [flink] wolfboys closed pull request #14657: [FLINK-20972][API/DataStream]TwoPhaseCommitSinkFunctionOutput output A large number of EventData

wolfboys closed pull request #14657: URL: https://github.com/apache/flink/pull/14657 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] godfreyhe commented on pull request #14638: [FLINK-20966][table-planner-blink] Rename Stream(/Batch)ExecIntermediateTableScan to Stream(/Batch)PhysicalIntermediateTableScan

godfreyhe commented on pull request #14638: URL: https://github.com/apache/flink/pull/14638#issuecomment-760637099 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-20982) Flink TaskManager throws RegistrationTimeoutException when using Kubernetes HA

[ https://issues.apache.org/jira/browse/FLINK-20982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265678#comment-17265678 ] Yang Wang commented on FLINK-20982: --- Could you please share the full JobManager and TaskManager logs?

[jira] [Commented] (FLINK-16444) Count the read/write/seek/next latency of RocksDB as metrics

[ https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265677#comment-17265677 ] Yun Tang commented on FLINK-16444: -- [~fanrui] We already planed to implement this feature in

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265676#comment-17265676 ] Yun Tang commented on FLINK-16267: -- [~YordanPavlov] The difference between managed memory and actual

[GitHub] [flink] flinkbot edited a comment on pull request #14657: [FLINK-20972][API/DataStream]TwoPhaseCommitSinkFunctionOutput output A large number of EventData

flinkbot edited a comment on pull request #14657: URL: https://github.com/apache/flink/pull/14657#issuecomment-760627801 ## CI report: * 7f8887cd41084bab82a0b7b36df7c9259fe8cde9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14656: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

flinkbot edited a comment on pull request #14656: URL: https://github.com/apache/flink/pull/14656#issuecomment-760627740 ## CI report: * 6cb6c9f2ed48920003bc7c51a785b154eed31ff7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * 8e20c81e5253a8b6a8ab9efb929e6413a97fce70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14627: [FLINK-20946][python] Optimize Python ValueState Implementation In PyFlink

flinkbot edited a comment on pull request #14627: URL: https://github.com/apache/flink/pull/14627#issuecomment-759272918 ## CI report: * ff00387c962b937a5dabaaeb9241acfdbc9e49ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14616: [FLINK-20879][table-api] Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

flinkbot edited a comment on pull request #14616: URL: https://github.com/apache/flink/pull/14616#issuecomment-758526377 ## CI report: * 448c026a402e045e050f405daf934a8a7c880c9d UNKNOWN * f429967b7680aa4dce4212ddb01b2c107b3b7117 Azure:

[jira] [Commented] (FLINK-16444) Count the read/write/seek/next latency of RocksDB as metrics

[ https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265671#comment-17265671 ] fanrui commented on FLINK-16444: [~yunta] I think sampling is more reasonable. The current function is

[GitHub] [flink] 1996fanrui commented on pull request #14614: [FLINK-20911][state-backend-rocksdb] Support configuration of RocksDB log level

1996fanrui commented on pull request #14614: URL: https://github.com/apache/flink/pull/14614#issuecomment-760630571 @Myasuka Thank you for your help and review. This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: in TwoPhaseCommitSinkFunctionOutput Maybe A large number of EventData will be

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: in TwoPhaseCommitSinkFunctionOutput Maybe A large number of EventData will be

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Attachment: 1610682603148.jpg > TwoPhaseCommitSinkFunction Output a large amount of EventData >

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Attachment: 1610682498960.jpg > TwoPhaseCommitSinkFunction Output a large amount of EventData >

[jira] [Commented] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing

[ https://issues.apache.org/jira/browse/FLINK-17011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265665#comment-17265665 ] Yun Tang commented on FLINK-17011: -- The previous PR has been outdated for a while as no one ever

[GitHub] [flink] flinkbot commented on pull request #14657: [FLINK-20972][API/DataStream]TwoPhaseCommitSinkFunctionOutput output A large number of EventData

flinkbot commented on pull request #14657: URL: https://github.com/apache/flink/pull/14657#issuecomment-760627801 ## CI report: * 7f8887cd41084bab82a0b7b36df7c9259fe8cde9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14656: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

flinkbot commented on pull request #14656: URL: https://github.com/apache/flink/pull/14656#issuecomment-760627740 ## CI report: * 6cb6c9f2ed48920003bc7c51a785b154eed31ff7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14652: [FLINK-20953][canal][json] Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

flinkbot edited a comment on pull request #14652: URL: https://github.com/apache/flink/pull/14652#issuecomment-760296852 ## CI report: * 15d8fb2352242415cf503ac44a0025d63933de3e Azure:

[jira] [Commented] (FLINK-16444) Count the read/write/seek/next latency of RocksDB as metrics

[ https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265664#comment-17265664 ] Yun Tang commented on FLINK-16444: -- [~fanrui] Yes, sampling the metrics is what we have already

[GitHub] [flink] flinkbot commented on pull request #14657: [FLINK-20972][API/DataStream]TwoPhaseCommitSinkFunctionOutput output A large number of EventData

flinkbot commented on pull request #14657: URL: https://github.com/apache/flink/pull/14657#issuecomment-760625112 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] wolfboys opened a new pull request #14657: [FLINK-20972][API/DataStream]TwoPhaseCommitSinkFunctionOutput output A large number of EventData

wolfboys opened a new pull request #14657: URL: https://github.com/apache/flink/pull/14657 ## What is the purpose of the change in TwoPhaseCommitSinkFunctionOutput Maybe A large number of EventData will be output(log.info),which will cause IO bottleneck and disk waste.

[jira] [Resolved] (FLINK-20911) Support configuration of RocksDB log level

[ https://issues.apache.org/jira/browse/FLINK-20911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-20911. -- Resolution: Fixed > Support configuration of RocksDB log level >

[jira] [Commented] (FLINK-20911) Support configuration of RocksDB log level

[ https://issues.apache.org/jira/browse/FLINK-20911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265661#comment-17265661 ] Yun Tang commented on FLINK-20911: -- merged in master 02a79dec5aa2d1aaf9c7acb5d59da57fefe8ead3 >

[GitHub] [flink] Myasuka merged pull request #14614: [FLINK-20911][state-backend-rocksdb] Support configuration of RocksDB log level

Myasuka merged pull request #14614: URL: https://github.com/apache/flink/pull/14614 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

[GitHub] [flink] flinkbot edited a comment on pull request #14652: [FLINK-20953][canal][json] Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

flinkbot edited a comment on pull request #14652: URL: https://github.com/apache/flink/pull/14652#issuecomment-760296852 ## CI report: * 15d8fb2352242415cf503ac44a0025d63933de3e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14640: [FLINK-20937][Table API/SQL]Drop table can fails, when i create a tab…

flinkbot edited a comment on pull request #14640: URL: https://github.com/apache/flink/pull/14640#issuecomment-760055828 ## CI report: * cd36249da9dfea6f8a8ce9eccfe89c220535131e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14606: [Flink-20876][table-planner-blink] Separate the implementation of StreamExecTemporalJoin

flinkbot edited a comment on pull request #14606: URL: https://github.com/apache/flink/pull/14606#issuecomment-757754275 ## CI report: * 3776b52cfe3535dcc193b3a922a7d1d658126d66 UNKNOWN * 155b18c169e45a97cd52c5b43883d5cf6b79f038 UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #14656: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

flinkbot commented on pull request #14656: URL: https://github.com/apache/flink/pull/14656#issuecomment-760620925 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

  1   2   3   4   5   6   >