[GitHub] [flink] flinkbot commented on pull request #13744: [FLINK-19766][table-runtime] Introduce File streaming compaction operators

flinkbot commented on pull request #13744: URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975 ## CI report: * 73d36420f9e131efb1ba70053b5ef315f79afd68 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13745: [FLINK-19767] Add AbstractSlotPoolFactory

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

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r510031269 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java ## @@ -0,0 +1,209 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #13653: [FLINK-17528][table] Remove RowData#get() and ArrayData#get() and use FieldGetter and ElementGetter instead

flinkbot edited a comment on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488 ## CI report: * 0c876d6befc487412629e6a1e8883fa5fbeb31e6 Azure:

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r510058532 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -0,0 +1,360 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #13726: [BP-1.11][FLINK-19557] Trigger LeaderRetrievalListener notification upon ZooKeeper reconnection in ZooKeeperLeaderRetrievalService

flinkbot edited a comment on pull request #13726: URL: https://github.com/apache/flink/pull/13726#issuecomment-713567666 ## CI report: * f0ac074feed577550c7026b190db031561a25f77 Azure:

[GitHub] [flink] flinkbot commented on pull request #13746: [FLINK-19675][python] Fix PythonCalcExpandProjectRule to handle cases when the calc node contains WHERE clause, composite fields access and

flinkbot commented on pull request #13746: URL: https://github.com/apache/flink/pull/13746#issuecomment-714469108 ## CI report: * 9becc81983d757b76614749a96a14a94f14aa7d6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-19770) mvn clean verify - testConfigurePythonExecution failing

Juha Mynttinen created FLINK-19770: -- Summary: mvn clean verify - testConfigurePythonExecution failing Key: FLINK-19770 URL: https://issues.apache.org/jira/browse/FLINK-19770 Project: Flink

[GitHub] [flink] TsReaper opened a new pull request #13748: [FLINK-19769][streaming] Reuse StreamRecord in SourceOutputWithWatermarks#collect

TsReaper opened a new pull request #13748: URL: https://github.com/apache/flink/pull/13748 ## What is the purpose of the change `SourceOutputWithWatermarks#collect` always creates a new `StreamRecord` object which can be reused quite easily. We should reuse the `StreamRecord` for

[GitHub] [flink] twalthr commented on a change in pull request #13732: [FLINK-19275][connector-kafka] Support reading and writing Kafka meta… …data

twalthr commented on a change in pull request #13732: URL: https://github.com/apache/flink/pull/13732#discussion_r510140104 ## File path: flink-core/src/main/java/org/apache/flink/types/Row.java ## @@ -274,4 +278,119 @@ public static Row join(Row first, Row... remainings) {

[GitHub] [flink] XComp commented on pull request #13747: [FLINK-19662][runtime] Exposing the JobManager's memory configuration through /jobmanager/config

XComp commented on pull request #13747: URL: https://github.com/apache/flink/pull/13747#issuecomment-714475833 @tillrohrmann Feel free to have a look. This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-19662) Create or extend REST endpoint to expose memory configuration

[ https://issues.apache.org/jira/browse/FLINK-19662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19662: --- Labels: pull-request-available (was: ) > Create or extend REST endpoint to expose memory

[GitHub] [flink] rkhachatryan commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

rkhachatryan commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r510009258 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartition.java ## @@ -0,0 +1,89 @@

[jira] [Closed] (FLINK-15328) Change the page of taskmanager's metric according to flip-49

[ https://issues.apache.org/jira/browse/FLINK-15328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-15328. Resolution: Duplicate FLINK-19764 was created to cover the new things discussed. I'm going to close this

[jira] [Created] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

YUJIANBO created FLINK-19768: Summary: The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties Key: FLINK-19768 URL: https://issues.apache.org/jira/browse/FLINK-19768

[GitHub] [flink] JingsongLi commented on a change in pull request #13729: [FLINK-19644][hive] Support read specific partition of Hive table in temporal join

JingsongLi commented on a change in pull request #13729: URL: https://github.com/apache/flink/pull/13729#discussion_r510029011 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveLookupFunction.java ## @@ -47,29 +59,46

[GitHub] [flink] JingsongLi commented on a change in pull request #13729: [FLINK-19644][hive] Support read specific partition of Hive table in temporal join

JingsongLi commented on a change in pull request #13729: URL: https://github.com/apache/flink/pull/13729#discussion_r510028759 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveLookupFunction.java ## @@ -134,9 +188,48

[GitHub] [flink] flinkbot edited a comment on pull request #13744: [FLINK-19766][table-runtime] Introduce File streaming compaction operators

flinkbot edited a comment on pull request #13744: URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975 ## CI report: * 73d36420f9e131efb1ba70053b5ef315f79afd68 Azure:

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r510053495 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -0,0 +1,360 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #13745: [FLINK-19767] Add AbstractSlotPoolFactory

flinkbot edited a comment on pull request #13745: URL: https://github.com/apache/flink/pull/13745#issuecomment-714370772 ## CI report: * c6f0ef39c65468a7f613e31bac530b148d36a9d4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13742: [FLINK-19626][table-planner-blink] Introduce multi-input operator construction algorithm

flinkbot edited a comment on pull request #13742: URL: https://github.com/apache/flink/pull/13742#issuecomment-714296461 ## CI report: * ddbf38d29507b98186d2b1a22716e7fb9593f5db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13653: [FLINK-17528][table] Remove RowData#get() and ArrayData#get() and use FieldGetter and ElementGetter instead

flinkbot edited a comment on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488 ## CI report: * 0c876d6befc487412629e6a1e8883fa5fbeb31e6 Azure:

[jira] [Closed] (FLINK-19596) Do not recover CompletedCheckpointStore on each failover

[ https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao closed FLINK-19596. -- Resolution: Fixed Fixed in https://issues.apache.org/jira/browse/FLINK-19401 > Do not recover

[GitHub] [flink] wangxlong commented on pull request #13672: [FLINK-19660][docs][python] Translate page "table_environment.zh.md" into Chinese

wangxlong commented on pull request #13672: URL: https://github.com/apache/flink/pull/13672#issuecomment-714450587 Hi @dianfu, could you help cc in your free time, thanks. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #13300: [FLINK-19077][table-runtime] Import process time temporal join operator.

flinkbot edited a comment on pull request #13300: URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567 ## CI report: * 831c8b47f5ac23fabf85fc6e1e868a39e057e540 Azure:

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r510014166 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -0,0 +1,360 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #13300: [FLINK-19077][table-runtime] Import process time temporal join operator.

flinkbot edited a comment on pull request #13300: URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567 ## CI report: * 26d7664c3772665425813a493ae546208dfae2bb Azure:

[jira] [Commented] (FLINK-19765) flink SqlUseCatalog.getCatalogName is not unified with SqlCreateCatalog and SqlDropCatalog

[ https://issues.apache.org/jira/browse/FLINK-19765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218900#comment-17218900 ] Jark Wu commented on FLINK-19765: - Yes, we can improve them to just return a String. Btw,

[GitHub] [flink] flinkbot edited a comment on pull request #13653: [FLINK-17528][table] Remove RowData#get() and ArrayData#get() and use FieldGetter and ElementGetter instead

flinkbot edited a comment on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488 ## CI report: * 0c876d6befc487412629e6a1e8883fa5fbeb31e6 Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #13729: [FLINK-19644][hive] Support read specific partition of Hive table in temporal join

JingsongLi commented on a change in pull request #13729: URL: https://github.com/apache/flink/pull/13729#discussion_r510029692 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveLookupFunction.java ## @@ -47,29 +59,46

[GitHub] [flink] gaoyunhaii commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

gaoyunhaii commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r510037094 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactory.java ## @@ -136,26 +144,41 @@ public

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r510055491 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -0,0 +1,360 @@ +/* + *

[GitHub] [flink] SteNicholas removed a comment on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

SteNicholas removed a comment on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-712550577 @StephanEwen ,thanks for your detailed explanation. I have already followed the comments you mentioned. @aljoscha , what do you think about the name of

[GitHub] [flink] SteNicholas commented on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

SteNicholas commented on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-714432932 @StephanEwen ,thanks for your detailed explanation. I have followed the comments you mentioned to update the JavaDoc. @aljoscha , what do you think about the naming of

[GitHub] [flink] flinkbot edited a comment on pull request #13703: [FLINK-19696] Add runtime batch committer operators for the new sink API

flinkbot edited a comment on pull request #13703: URL: https://github.com/apache/flink/pull/13703#issuecomment-712821004 ## CI report: * 58ee54d456da57f99b6124c787b7cbaeedcfb261 Azure:

[jira] [Commented] (FLINK-19757) TimeStampData can cause time inconsistent problem

[ https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218955#comment-17218955 ] Jark Wu commented on FLINK-19757: - We stores the epoch seconds since {{1970-01-01 00:00:00}} for

[jira] [Comment Edited] (FLINK-19757) TimeStampData can cause time inconsistent problem

[ https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218976#comment-17218976 ] Jark Wu edited comment on FLINK-19757 at 10/22/20, 12:25 PM: - As I said

[jira] [Comment Edited] (FLINK-19757) TimeStampData can cause time inconsistent problem

[ https://issues.apache.org/jira/browse/FLINK-19757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218976#comment-17218976 ] Jark Wu edited comment on FLINK-19757 at 10/22/20, 12:26 PM: - As I said

[GitHub] [flink] TsReaper commented on pull request #13636: [FLINK-19641][hive] Optimize parallelism calculating of HiveTableSource by checking file number

TsReaper commented on pull request #13636: URL: https://github.com/apache/flink/pull/13636#issuecomment-714471424 > Thanks for contribution, we should not rely on `StatsSetupConst.NUM_FILES`, because in Hive metastore, these stats information is just a hint, and they may not correct. >

[jira] [Updated] (FLINK-19770) mvn clean verify - testConfigurePythonExecution failing

[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juha Mynttinen updated FLINK-19770: --- Component/s: Build System > mvn clean verify - testConfigurePythonExecution failing >

[GitHub] [flink] wangxlong closed pull request #10356: [FLINK-14902][Connector-JDBC]JDBCTableSource Supports AsyncLookupFunction

wangxlong closed pull request #10356: URL: https://github.com/apache/flink/pull/10356 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 4:39 AM: --- Thanks

[GitHub] [flink] flinkbot edited a comment on pull request #13696: [FLINK-19726][table] Implement new providers for blink planner

flinkbot edited a comment on pull request #13696: URL: https://github.com/apache/flink/pull/13696#issuecomment-712617122 ## CI report: * f2e5f3867663c020ec292722b63d5788b43fd3b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13755: [FLINK-19700][k8s] Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

flinkbot edited a comment on pull request #13755: URL: https://github.com/apache/flink/pull/13755#issuecomment-714883306 ## CI report: * e31a8a6b6e3c8628503b4534c2bdff345365c1e0 Azure:

[GitHub] [flink] xintongsong commented on a change in pull request #13755: [FLINK-19700][k8s] Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

xintongsong commented on a change in pull request #13755: URL: https://github.com/apache/flink/pull/13755#discussion_r510580616 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java ## @@ -85,10 +86,20 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13678: [FLINK-19586] Add stream committer operators for new Sink API

flinkbot edited a comment on pull request #13678: URL: https://github.com/apache/flink/pull/13678#issuecomment-711439155 ## CI report: * 463b5c8ed21f93caaeb7b938aa9e72abb35619b2 UNKNOWN * 2ba5bda5c5a15c370c231e1cedfa03fd0bc0b41b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13736: [FLINK-19654][python][e2e] Reduce pyflink e2e test parallelism

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

[jira] [Commented] (FLINK-19215) "Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test" failed with "Dispatcher REST endpoint has not started within a timeout of 20 sec"

[ https://issues.apache.org/jira/browse/FLINK-19215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219462#comment-17219462 ] Robert Metzger commented on FLINK-19215: Backported to 1.11 in:

[GitHub] [flink] flinkbot edited a comment on pull request #13746: [FLINK-19675][python] Fix PythonCalcExpandProjectRule to handle cases when the calc node contains WHERE clause, composite fields acce

flinkbot edited a comment on pull request #13746: URL: https://github.com/apache/flink/pull/13746#issuecomment-714469108 ## CI report: * 9becc81983d757b76614749a96a14a94f14aa7d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13736: [FLINK-19654][python][e2e] Reduce pyflink e2e test parallelism

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

[GitHub] [flink] shouweikun commented on a change in pull request #13716: [FLINK-19706][table-runtime] Add WARN logs when hive table partition …

shouweikun commented on a change in pull request #13716: URL: https://github.com/apache/flink/pull/13716#discussion_r510623126 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/MetastoreCommitPolicy.java ## @@ -45,6 +45,9 @@

[GitHub] [flink] rmetzger opened a new pull request #13757: [FLINK-18117][e2e] Add debugging information for hadoop startup

rmetzger opened a new pull request #13757: URL: https://github.com/apache/flink/pull/13757 ## What is the purpose of the change This adds some non-invasive environment debugging to understand why the namenode can not allocate the http port inside a docker container. I was not

[jira] [Updated] (FLINK-18117) "Kerberized YARN per-job on Docker test" fails with "Could not start hadoop cluster."

[ https://issues.apache.org/jira/browse/FLINK-18117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18117: --- Labels: pull-request-available test-stability (was: test-stability) > "Kerberized YARN

[GitHub] [flink] flinkbot commented on pull request #13757: [FLINK-18117][e2e] Add debugging information for hadoop startup

flinkbot commented on pull request #13757: URL: https://github.com/apache/flink/pull/13757#issuecomment-714929264 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] flinkbot edited a comment on pull request #13716: [FLINK-19706][table-runtime] Add WARN logs when hive table partition …

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

[GitHub] [flink] flinkbot edited a comment on pull request #13678: [FLINK-19586] Add stream committer operators for new Sink API

flinkbot edited a comment on pull request #13678: URL: https://github.com/apache/flink/pull/13678#issuecomment-711439155 ## CI report: * 463b5c8ed21f93caaeb7b938aa9e72abb35619b2 UNKNOWN * 2ba5bda5c5a15c370c231e1cedfa03fd0bc0b41b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13753: [FLINK-19765][flink-table-planner] refactor SqlToOperationConverter a…

flinkbot edited a comment on pull request #13753: URL: https://github.com/apache/flink/pull/13753#issuecomment-714862730 ## CI report: * b85f48049fd05f5c6da1cb91c6dfb4c6d201100c Azure:

[jira] [Commented] (FLINK-19770) PythonProgramOptionsTest requires package phase before execution

[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219404#comment-17219404 ] Shuiqiang Chen commented on FLINK-19770: [~juha.mynttinen] Thank you for reporting this issue,

[jira] [Closed] (FLINK-19660) Translate page 'table_environment.zh.md' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19660. --- Resolution: Fixed Merged to master via 1f8627be60a3e5b4fd2512f1f9446a2cf139f93d > Translate page

[GitHub] [flink] flinkbot edited a comment on pull request #13746: [FLINK-19675][python] Fix PythonCalcExpandProjectRule to handle cases when the calc node contains WHERE clause, composite fields acce

flinkbot edited a comment on pull request #13746: URL: https://github.com/apache/flink/pull/13746#issuecomment-714469108 ## CI report: * 9becc81983d757b76614749a96a14a94f14aa7d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13736: [FLINK-19654][python][e2e] Reduce pyflink e2e test parallelism

flinkbot edited a comment on pull request #13736: URL: https://github.com/apache/flink/pull/13736#issuecomment-714183394 ## CI report: * 429e63595a174e68e44a339d2dbccca57f07d6f5 Azure:

[GitHub] [flink] liuyongvs opened a new pull request #13753: [FLINK-19765][flink-table-planner] refactor SqlToOperationConverter a…

liuyongvs opened a new pull request #13753: URL: https://github.com/apache/flink/pull/13753 …nd unified the SqlUseCatalog.getCatalogName() with SqlCreateCatalog and SqlDropCatalog. ## What is the purpose of the change *flink SqlUseCatalog.getCatalogName is not unified

[GitHub] [flink] dianfu closed pull request #13672: [FLINK-19660][docs][python] Translate page "table_environment.zh.md" into Chinese

dianfu closed pull request #13672: URL: https://github.com/apache/flink/pull/13672 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] [Updated] (FLINK-19765) flink SqlUseCatalog.getCatalogName is not unified with SqlCreateCatalog and SqlDropCatalog

[ https://issues.apache.org/jira/browse/FLINK-19765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19765: --- Labels: pull-request-available (was: ) > flink SqlUseCatalog.getCatalogName is not unified

[jira] [Created] (FLINK-19775) SystemProcessingTimeServiceTest.testImmediateShutdown is instable

Dian Fu created FLINK-19775: --- Summary: SystemProcessingTimeServiceTest.testImmediateShutdown is instable Key: FLINK-19775 URL: https://issues.apache.org/jira/browse/FLINK-19775 Project: Flink

[jira] [Commented] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219412#comment-17219412 ] Rui Li commented on FLINK-19644: [~Leonard Xu] Thanks for driving this efforts! Regarding loading the

[jira] [Commented] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219415#comment-17219415 ] Jark Wu commented on FLINK-19644: - We can give {{max_partition}} a clear definition which is a strategy

[GitHub] [flink] JingsongLi commented on a change in pull request #13636: [FLINK-19641][hive] Optimize parallelism calculating of HiveTableSource by checking file number

JingsongLi commented on a change in pull request #13636: URL: https://github.com/apache/flink/pull/13636#discussion_r510558674 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java ## @@ -69,7 +69,7 @@

[jira] [Commented] (FLINK-19755) flink cep docs exist looping match when coming to 17, 14 using AFTER MATCH SKIP TO LAST A 

[ https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219422#comment-17219422 ] jackylau commented on FLINK-19755: -- hi [~jark] [~dianfu], i modify the data to solve the looping match,

[jira] [Updated] (FLINK-19755) flink cep docs exist looping match when coming to 17, 14 using AFTER MATCH SKIP TO LAST A 

[ https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-19755: - Attachment: 7CA31459-B125-4cea-8C75-3D101C27A9F9.png

[GitHub] [flink] flinkbot edited a comment on pull request #12647: [FLINK-18044][Connectors/Common] Add the subtask index information to the SourceReaderContext.

flinkbot edited a comment on pull request #12647: URL: https://github.com/apache/flink/pull/12647#issuecomment-643898574 ## CI report: * dde8225437b4208d565a74e9a78c9398eea11025 Azure:

[jira] [Updated] (FLINK-19700) Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

[ https://issues.apache.org/jira/browse/FLINK-19700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19700: --- Labels: pull-request-available (was: ) > Make Kubernetes Client in

[GitHub] [flink] SteNicholas opened a new pull request #13755: [FLINK-19700][k8s] Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

SteNicholas opened a new pull request #13755: URL: https://github.com/apache/flink/pull/13755 ## What is the purpose of the change *Currently, the Kubernetes Client in `KubernetesResourceManagerDriver` is using a dedicated thread pool through calling

[GitHub] [flink] SteNicholas commented on pull request #13755: [FLINK-19700][k8s] Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

SteNicholas commented on pull request #13755: URL: https://github.com/apache/flink/pull/13755#issuecomment-714875554 @xintongsong @wangyang0918, could you please help to review the pull request if you are available? This is

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219021#comment-17219021 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:13 AM: --- According

[GitHub] [flink] flinkbot edited a comment on pull request #13754: [FLINK-19755][cep][docs] fix flink cep docs of looping matching bug.

flinkbot edited a comment on pull request #13754: URL: https://github.com/apache/flink/pull/13754#issuecomment-714876169 ## CI report: * 3717c92c917638c1dbde99081f6aa890d723f39e Azure:

[GitHub] [flink] flinkbot commented on pull request #13755: [FLINK-19700][k8s] Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

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

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:32 AM: --- How about

[jira] [Updated] (FLINK-19770) PythonProgramOptionsTest requires package phase before execution

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

[GitHub] [flink] shuiqiangchen opened a new pull request #13756: [FLINK-19770][python][test] Changed the PythonProgramOptionTest to be an ITCase.

shuiqiangchen opened a new pull request #13756: URL: https://github.com/apache/flink/pull/13756 ## What is the purpose of the change Fixed the error that PythonProgramOptionsTest requires package phase before execution. ## Brief change log Changed the

[GitHub] [flink] danny0405 commented on pull request #12919: [FLINK-16048][avro] Support read/write confluent schema registry avro…

danny0405 commented on pull request #12919: URL: https://github.com/apache/flink/pull/12919#issuecomment-714889392 > @danny0405 @dawidwys > Any reasons all the fields read and written by this format has prefix 'record_' ? (I'm using flink sql for this client) > I found responsible

[GitHub] [flink] flinkbot commented on pull request #13756: [FLINK-19770][python][test] Changed the PythonProgramOptionTest to be an ITCase.

flinkbot commented on pull request #13756: URL: https://github.com/apache/flink/pull/13756#issuecomment-714890476 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] flinkbot edited a comment on pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

flinkbot edited a comment on pull request #13676: URL: https://github.com/apache/flink/pull/13676#issuecomment-711145212 ## CI report: * 80e2c4e0a1fff42e9c2d2798ed7884a148870ee5 Azure:

[jira] [Updated] (FLINK-19706) Add WARN logs when hive table partition has existed before commit in `MetastoreCommitPolicy`

[ https://issues.apache.org/jira/browse/FLINK-19706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19706: - Fix Version/s: 1.12.0 > Add WARN logs when hive table partition has existed before commit in >

[GitHub] [flink] JingsongLi commented on a change in pull request #13716: [FLINK-19706][table-runtime] Add WARN logs when hive table partition …

JingsongLi commented on a change in pull request #13716: URL: https://github.com/apache/flink/pull/13716#discussion_r510583777 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/MetastoreCommitPolicy.java ## @@ -45,6 +45,9 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

flinkbot edited a comment on pull request #13676: URL: https://github.com/apache/flink/pull/13676#issuecomment-711145212 ## CI report: * 80e2c4e0a1fff42e9c2d2798ed7884a148870ee5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13696: [FLINK-19726][table] Implement new providers for blink planner

flinkbot edited a comment on pull request #13696: URL: https://github.com/apache/flink/pull/13696#issuecomment-712617122 ## CI report: * f2e5f3867663c020ec292722b63d5788b43fd3b2 Azure:

[jira] [Commented] (FLINK-19765) flink SqlUseCatalog.getCatalogName is not unified with SqlCreateCatalog and SqlDropCatalog

[ https://issues.apache.org/jira/browse/FLINK-19765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219405#comment-17219405 ] jackylau commented on FLINK-19765: -- hi [~jark] yeap. thanks. could you review it when the ci passed. >

[GitHub] [flink] flinkbot commented on pull request #13753: [FLINK-19765][flink-table-planner] refactor SqlToOperationConverter a…

flinkbot commented on pull request #13753: URL: https://github.com/apache/flink/pull/13753#issuecomment-714857845 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] [Commented] (FLINK-19201) PyFlink e2e tests is instable and failed with "Connection broken: OSError"

[ https://issues.apache.org/jira/browse/FLINK-19201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219406#comment-17219406 ] Dian Fu commented on FLINK-19201: - Another instance:

[jira] [Commented] (FLINK-19201) PyFlink e2e tests is instable and failed with "Connection broken: OSError"

[ https://issues.apache.org/jira/browse/FLINK-19201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219407#comment-17219407 ] Dian Fu commented on FLINK-19201: - cc [~hxbks2ks] > PyFlink e2e tests is instable and failed with

[jira] [Commented] (FLINK-19215) "Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test" failed with "Dispatcher REST endpoint has not started within a timeout of 20 sec"

[ https://issues.apache.org/jira/browse/FLINK-19215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219409#comment-17219409 ] Dian Fu commented on FLINK-19215: - Instance on 1.11:

[jira] [Commented] (FLINK-19201) PyFlink e2e tests is instable and failed with "Connection broken: OSError"

[ https://issues.apache.org/jira/browse/FLINK-19201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219410#comment-17219410 ] Huang Xingbo commented on FLINK-19201: -- [~dian.fu] Thanks a lot for reporting. I will increase the

[jira] [Updated] (FLINK-19775) SystemProcessingTimeServiceTest.testImmediateShutdown is instable

[ https://issues.apache.org/jira/browse/FLINK-19775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19775: Labels: test-stability (was: ) > SystemProcessingTimeServiceTest.testImmediateShutdown is instable >

[GitHub] [flink] flinkbot commented on pull request #13753: [FLINK-19765][flink-table-planner] refactor SqlToOperationConverter a…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13746: [FLINK-19675][python] Fix PythonCalcExpandProjectRule to handle cases when the calc node contains WHERE clause, composite fields acce

flinkbot edited a comment on pull request #13746: URL: https://github.com/apache/flink/pull/13746#issuecomment-714469108 ## CI report: * 9becc81983d757b76614749a96a14a94f14aa7d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13736: [FLINK-19654][python][e2e] Reduce pyflink e2e test parallelism

flinkbot edited a comment on pull request #13736: URL: https://github.com/apache/flink/pull/13736#issuecomment-714183394 ## CI report: * 429e63595a174e68e44a339d2dbccca57f07d6f5 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #13732: [FLINK-19275][connector-kafka] Support reading and writing Kafka meta… …data

wuchong commented on a change in pull request #13732: URL: https://github.com/apache/flink/pull/13732#discussion_r510556244 ## File path: flink-core/src/main/java/org/apache/flink/types/Row.java ## @@ -274,4 +278,119 @@ public static Row join(Row first, Row... remainings) {

[jira] [Commented] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219414#comment-17219414 ] Jingsong Lee commented on FLINK-19644: -- I second [~lirui], it is better to reuse old options. And I

[jira] [Assigned] (FLINK-19769) Reuse StreamRecord in SourceOutputWithWatermarks#collect

[ https://issues.apache.org/jira/browse/FLINK-19769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19769: Assignee: Caizhi Weng > Reuse StreamRecord in SourceOutputWithWatermarks#collect >

<    1   2   3   4   5   >