[jira] [Commented] (FLINK-25106) Support tombstone messages in FLINK's "kafka" connector

2021-11-30 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451578#comment-17451578 ] Martijn Visser commented on FLINK-25106: [~varunyeligar] Thanks for clarifying. If I understand

[GitHub] [flink] shenzhu commented on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

2021-11-30 Thread GitBox
shenzhu commented on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-983372453 > @shenzhu Thx again for your time and effort here. It would be great to go for option 1. since as you already mentioned we're trying to move all the logic in

[GitHub] [flink-web] crazyzhou opened a new pull request #484: Add Pravega Flink connector 101 blog

2021-11-30 Thread GitBox
crazyzhou opened a new pull request #484: URL: https://github.com/apache/flink-web/pull/484 A replicate of https://cncf.pravega.io/blog/2021/11/01/pravega-flink-connector-101/ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] Zakelly commented on pull request #16964: [FLINK-23791] Enable RocksDB info log by default

2021-11-30 Thread GitBox
Zakelly commented on pull request #16964: URL: https://github.com/apache/flink/pull/16964#issuecomment-983368636 After FLINK-24046, we provide default value for each option in `RocksDBConfigurableOptions`, which could be loaded via `RocksDBResourceContainer`. So I reopen this PR and

[GitHub] [flink] alpreu commented on a change in pull request #17930: [FLINK-24326][docs][connectors] Update elasticsearch sink pages with new unified sink API (FLIP-143) implementation

2021-11-30 Thread GitBox
alpreu commented on a change in pull request #17930: URL: https://github.com/apache/flink/pull/17930#discussion_r759917751 ## File path: docs/content/docs/connectors/datastream/elasticsearch.md ## @@ -65,240 +61,90 @@ about how to package the program with the libraries for

[GitHub] [flink] flinkbot edited a comment on pull request #16964: [FLINK-23791] Enable RocksDB info log by default

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #16964: URL: https://github.com/apache/flink/pull/16964#issuecomment-904569778 ## CI report: * 85158d496f87c535525f9e5ad05269038402f02f Azure:

[GitHub] [flink] alpreu commented on a change in pull request #17930: [FLINK-24326][docs][connectors] Update elasticsearch sink pages with new unified sink API (FLIP-143) implementation

2021-11-30 Thread GitBox
alpreu commented on a change in pull request #17930: URL: https://github.com/apache/flink/pull/17930#discussion_r759916773 ## File path: docs/content/docs/connectors/datastream/elasticsearch.md ## @@ -43,15 +43,11 @@ of the Elasticsearch installation: -

[GitHub] [flink] alpreu commented on a change in pull request #17930: [FLINK-24326][docs][connectors] Update elasticsearch sink pages with new unified sink API (FLIP-143) implementation

2021-11-30 Thread GitBox
alpreu commented on a change in pull request #17930: URL: https://github.com/apache/flink/pull/17930#discussion_r759916214 ## File path: docs/content/docs/connectors/datastream/elasticsearch.md ## @@ -43,15 +43,11 @@ of the Elasticsearch installation: -

[GitHub] [flink] flinkbot edited a comment on pull request #16964: [FLINK-23791] Enable RocksDB info log by default

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #16964: URL: https://github.com/apache/flink/pull/16964#issuecomment-904569778 ## CI report: * 85158d496f87c535525f9e5ad05269038402f02f Azure:

[jira] [Closed] (FLINK-24980) Collect sizes of finished BLOCKING result partitions

2021-11-30 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-24980. --- Fix Version/s: 1.15.0 Resolution: Fixed Done via 3761bbf68c183cf4728353948acea0a2ac40f2a7 > Collect

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

2021-11-30 Thread GitBox
weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r759912742 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasFeatureColsDefaultAsNull.java ## @@ -0,0 +1,28 @@ +package

[GitHub] [flink] zhuzhurk closed pull request #17905: [FLINK-24980] Introduce numBytesProduced counter into ResultPartition to record the size of result partition.

2021-11-30 Thread GitBox
zhuzhurk closed pull request #17905: URL: https://github.com/apache/flink/pull/17905 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

2021-11-30 Thread GitBox
weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r759909634 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModelData.java ## @@ -0,0 +1,134 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

2021-11-30 Thread GitBox
weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r759909541 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnParams.java ## @@ -0,0 +1,18 @@ +package

[jira] [Commented] (FLINK-25106) Support tombstone messages in FLINK's "kafka" connector

2021-11-30 Thread Varun Yeligar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451559#comment-17451559 ] Varun Yeligar commented on FLINK-25106: --- [~MartijnVisser] , In our use-case we want to receive all

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * e7d585c7aab70989fe340f5f14b359952433ddf2 Azure:

[jira] [Created] (FLINK-25124) A deadlock occurs when the jdbc sink uses two consecutive dimension tables to associate

2021-11-30 Thread shizhengchao (Jira)
shizhengchao created FLINK-25124: Summary: A deadlock occurs when the jdbc sink uses two consecutive dimension tables to associate Key: FLINK-25124 URL: https://issues.apache.org/jira/browse/FLINK-25124

[jira] [Comment Edited] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-30 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451554#comment-17451554 ] chenqizhu edited comment on FLINK-25099 at 12/1/21, 7:01 AM: - this is my

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-30 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451554#comment-17451554 ] chenqizhu commented on FLINK-25099: --- this is my submmision cli example. As you can see, it's very

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

2021-11-30 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451550#comment-17451550 ] Ada Wong commented on FLINK-23324: -- [~jark]  please assign someone to review it. > Postgres of JDBC

[jira] [Assigned] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

2021-11-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-18779: Assignee: Yuan Zhu > Support the SupportsFilterPushDown interface for LookupTableSource

[jira] [Commented] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

2021-11-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451544#comment-17451544 ] Jingsong Lee commented on FLINK-18779: -- [~straw]  Thanks, CC [~godfreyhe]  > Support the

[jira] [Updated] (FLINK-25116) Fabric8FlinkKubeClientITCase hangs on Azure

2021-11-30 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25116: Labels: test-stability (was: ) > Fabric8FlinkKubeClientITCase hangs on Azure >

[jira] [Commented] (FLINK-25117) NoSuchMethodError getCatalog()

2021-11-30 Thread zzt (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451540#comment-17451540 ] zzt commented on FLINK-25117: - [~wenlong.lwl]  I use flink-1.13.3 image with jars from 1.13.3 and produces

[jira] [Updated] (FLINK-25117) NoSuchMethodError getCatalog()

2021-11-30 Thread zzt (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zzt updated FLINK-25117: Environment: offical docker image,  flink:1.13.3-scala_2.12 (was: offical docker image, 

[jira] [Comment Edited] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

2021-11-30 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451536#comment-17451536 ] Yuan Zhu edited comment on FLINK-18779 at 12/1/21, 6:35 AM: Hi, [~twalthr]

[GitHub] [flink] flinkbot edited a comment on pull request #17971: Update kafka.md

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17971: URL: https://github.com/apache/flink/pull/17971#issuecomment-983331984 ## CI report: * 8ae9baf7cb758e0df2e70d399acc08a13a651aea Azure:

[jira] [Updated] (FLINK-25123) Improve expression description in SQL operator

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25123: Fix Version/s: 1.15.0 > Improve expression description in SQL operator >

[jira] [Updated] (FLINK-25076) Simplify name of SQL operators

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25076: Fix Version/s: 1.15.0 > Simplify name of SQL operators > -- > >

[jira] [Updated] (FLINK-25076) Simplify name of SQL operators

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25076: Component/s: Table SQL / Planner > Simplify name of SQL operators >

[jira] [Updated] (FLINK-25074) Simplify name of window operators in DS by moving details to description

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25074: Fix Version/s: 1.15.0 > Simplify name of window operators in DS by moving details to description

[jira] [Updated] (FLINK-25074) Simplify name of window operators in DS by moving details to description

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25074: Component/s: API / DataStream > Simplify name of window operators in DS by moving details to

[jira] [Updated] (FLINK-25073) Introduce Tree Mode description for job vertex

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25073: Component/s: API / DataStream > Introduce Tree Mode description for job vertex >

[GitHub] [flink] flinkbot commented on pull request #17971: Update kafka.md

2021-11-30 Thread GitBox
flinkbot commented on pull request #17971: URL: https://github.com/apache/flink/pull/17971#issuecomment-983331969 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[jira] [Updated] (FLINK-25073) Introduce Tree Mode description for job vertex

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25073: Fix Version/s: 1.15.0 > Introduce Tree Mode description for job vertex >

[jira] [Updated] (FLINK-25072) Introduce description for operator

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25072: Fix Version/s: 1.15.0 > Introduce description for operator > -- >

[jira] [Commented] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

2021-11-30 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451536#comment-17451536 ] Yuan Zhu commented on FLINK-18779: -- Hi, [~twalthr] ,[~lzljs3620320], [~matriv], [~slinkydeveloper].

[jira] [Updated] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25070: Fix Version/s: 1.15.0 > FLIP-195: Improve the name and structure of vertex and operator name for

[jira] [Comment Edited] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

2021-11-30 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451536#comment-17451536 ] Yuan Zhu edited comment on FLINK-18779 at 12/1/21, 6:31 AM: Hi, [~twalthr]

[jira] [Assigned] (FLINK-25076) Simplify name of SQL operators

2021-11-30 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25076: -- Assignee: Wenlong Lyu > Simplify name of SQL operators > -- > >

[jira] [Assigned] (FLINK-25074) Simplify name of window operators in DS by moving details to description

2021-11-30 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25074: -- Assignee: Wenlong Lyu > Simplify name of window operators in DS by moving details to

[jira] [Assigned] (FLINK-25123) Improve expression description in SQL operator

2021-11-30 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25123: -- Assignee: Wenlong Lyu > Improve expression description in SQL operator >

[jira] [Assigned] (FLINK-25118) Add vertex index as prefix in vertex name

2021-11-30 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25118: -- Assignee: Wenlong Lyu > Add vertex index as prefix in vertex name >

[jira] [Assigned] (FLINK-25073) Introduce Tree Mode description for job vertex

2021-11-30 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25073: -- Assignee: Wenlong Lyu > Introduce Tree Mode description for job vertex >

[jira] [Assigned] (FLINK-25072) Introduce description for operator

2021-11-30 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25072: -- Assignee: Wenlong Lyu > Introduce description for operator >

[jira] [Assigned] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

2021-11-30 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25070: -- Assignee: Wenlong Lyu > FLIP-195: Improve the name and structure of vertex and operator name

[jira] [Created] (FLINK-25123) Improve expression description in SQL operator

2021-11-30 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-25123: --- Summary: Improve expression description in SQL operator Key: FLINK-25123 URL: https://issues.apache.org/jira/browse/FLINK-25123 Project: Flink Issue Type:

[GitHub] [flink] mingwayXue opened a new pull request #17971: Update kafka.md

2021-11-30 Thread GitBox
mingwayXue opened a new pull request #17971: URL: https://github.com/apache/flink/pull/17971 fixed kafka markdown error ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC.

[jira] [Commented] (FLINK-25117) NoSuchMethodError getCatalog()

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451528#comment-17451528 ] Wenlong Lyu commented on FLINK-25117: - [~zzt] I would suggest you not put any flink jars from 1.13.3

[GitHub] [flink] flinkbot edited a comment on pull request #16609: [FLINK-23324][connector-jdbc] fix Postgres case-insensitive.

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #16609: URL: https://github.com/apache/flink/pull/16609#issuecomment-887558020 ## CI report: * 25f7778c5ee8bde238dff84ae777a859931a6f78 Azure:

[jira] [Commented] (FLINK-25102) ParquetFileSystemITCase.testPartialDynamicPartition failed on azure

2021-11-30 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451523#comment-17451523 ] Yun Gao commented on FLINK-25102: -

[GitHub] [flink] flinkbot edited a comment on pull request #16609: [FLINK-23324][connector-jdbc] fix Postgres case-insensitive.

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #16609: URL: https://github.com/apache/flink/pull/16609#issuecomment-887558020 ## CI report: * 25f7778c5ee8bde238dff84ae777a859931a6f78 Azure:

[jira] [Commented] (FLINK-25117) NoSuchMethodError getCatalog()

2021-11-30 Thread zzt (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451516#comment-17451516 ] zzt commented on FLINK-25117: - hi, [~wenlong.lwl] thanks for your reponse. I start the sql-client with

[jira] [Comment Edited] (FLINK-25117) NoSuchMethodError getCatalog()

2021-11-30 Thread zzt (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451516#comment-17451516 ] zzt edited comment on FLINK-25117 at 12/1/21, 5:54 AM: --- hi, [~wenlong.lwl] thanks

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-30 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451514#comment-17451514 ] Junfan Zhang commented on FLINK-25099: -- If you could provide more detailed info like submmision cli

[GitHub] [flink] flinkbot edited a comment on pull request #17970: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17970: URL: https://github.com/apache/flink/pull/17970#issuecomment-983310109 ## CI report: * e8824fe7506c49979f6f151e8daf2eeb13f51c9c Azure:

[GitHub] [flink] flinkbot commented on pull request #17970: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

2021-11-30 Thread GitBox
flinkbot commented on pull request #17970: URL: https://github.com/apache/flink/pull/17970#issuecomment-983310907 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-25122) flink-dist/src/main/flink-bin/bin/flink does not expand variable for FLINK_ENV_JAVA_OPTS

2021-11-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25122: --- Labels: pull-request-available pull-requests-available (was: pull-requests-available) >

[GitHub] [flink] flinkbot commented on pull request #17970: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

2021-11-30 Thread GitBox
flinkbot commented on pull request #17970: URL: https://github.com/apache/flink/pull/17970#issuecomment-983310109 ## CI report: * e8824fe7506c49979f6f151e8daf2eeb13f51c9c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25122) flink-dist/src/main/flink-bin/bin/flink does not expand variable for FLINK_ENV_JAVA_OPTS

2021-11-30 Thread L Z (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] L Z updated FLINK-25122: Labels: pull-requests-available (was: pull-request-available) > flink-dist/src/main/flink-bin/bin/flink does not

[jira] [Updated] (FLINK-25122) flink-dist/src/main/flink-bin/bin/flink does not expand variable for FLINK_ENV_JAVA_OPTS

2021-11-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25122: --- Labels: pull-request-available (was: ) > flink-dist/src/main/flink-bin/bin/flink does not

[GitHub] [flink] CodeFerriCode opened a new pull request #17970: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

2021-11-30 Thread GitBox
CodeFerriCode opened a new pull request #17970: URL: https://github.com/apache/flink/pull/17970 and add FLINK_LOG_PREFIX variable ## What is the purpose of the change Add variable expansion for FLINK_ENV_JAVA_OPTS, and introduce variable FLINK_LOG_PREFIX in flink to

[jira] [Updated] (FLINK-25122) flink-dist/src/main/flink-bin/bin/flink does not expand variable for FLINK_ENV_JAVA_OPTS

2021-11-30 Thread L Z (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] L Z updated FLINK-25122: Description: According to the suggestion on

[GitHub] [flink] flinkbot edited a comment on pull request #17969: [FLINK-25031] Job finishes iff all job vertices finish.

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17969: URL: https://github.com/apache/flink/pull/17969#issuecomment-983248559 ## CI report: * d761590cdefec2a9d57edec6175e73565ff6be3c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * d18299137d194d8f2e10b70480796cfc797a0d69 Azure:

[jira] [Comment Edited] (FLINK-24953) Optime hive parallelism inference

2021-11-30 Thread xiangqiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451507#comment-17451507 ] xiangqiao edited comment on FLINK-24953 at 12/1/21, 5:21 AM: - sorry, this

[jira] [Created] (FLINK-25122) flink-dist/src/main/flink-bin/bin/flink does not expand variable for FLINK_ENV_JAVA_OPTS

2021-11-30 Thread L Z (Jira)
L Z created FLINK-25122: --- Summary: flink-dist/src/main/flink-bin/bin/flink does not expand variable for FLINK_ENV_JAVA_OPTS Key: FLINK-25122 URL: https://issues.apache.org/jira/browse/FLINK-25122 Project:

[jira] [Closed] (FLINK-24953) Optime hive parallelism inference

2021-11-30 Thread xiangqiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao closed FLINK-24953. - Resolution: Duplicate > Optime hive parallelism inference > - > >

[jira] [Commented] (FLINK-24953) Optime hive parallelism inference

2021-11-30 Thread xiangqiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451507#comment-17451507 ] xiangqiao commented on FLINK-24953: --- sorry, this problem has been fixed in master branch. I will close

[GitHub] [flink] xiangqiao123 closed pull request #17826: [FLINK-24953][Connectors / Hive]Optime hive parallelism inference

2021-11-30 Thread GitBox
xiangqiao123 closed pull request #17826: URL: https://github.com/apache/flink/pull/17826 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] xiangqiao123 commented on a change in pull request #17826: [FLINK-24953][Connectors / Hive]Optime hive parallelism inference

2021-11-30 Thread GitBox
xiangqiao123 commented on a change in pull request #17826: URL: https://github.com/apache/flink/pull/17826#discussion_r759859765 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveParallelismInference.java ## @@ -63,10

[GitHub] [flink] xiangqiao123 commented on a change in pull request #17826: [FLINK-24953][Connectors / Hive]Optime hive parallelism inference

2021-11-30 Thread GitBox
xiangqiao123 commented on a change in pull request #17826: URL: https://github.com/apache/flink/pull/17826#discussion_r759859765 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveParallelismInference.java ## @@ -63,10

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 8e8aaa7df0ebae7ec45b9bc2e61ea8e55d9f45b8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 8e8aaa7df0ebae7ec45b9bc2e61ea8e55d9f45b8 Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-30 Thread GitBox
lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r759854126 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-30 Thread GitBox
lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r759853261 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

[GitHub] [flink] shenzhu commented on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

2021-11-30 Thread GitBox
shenzhu commented on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-983287432 > @shenzhu My PR was merged now. If you rebase I think those violations should not show up anymore. Hey @Airblader , thanks for your PR! I just rebased my code, would you

[GitHub] [flink] flinkbot edited a comment on pull request #17945: [FLINK-21027][state] Introduce KeyedStateBackend#isSafeToReuseState for opmitization hint

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17945: URL: https://github.com/apache/flink/pull/17945#issuecomment-981579279 ## CI report: * 175f81daf4357c8e6e3bafa4204a47a679c35a9e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17953: [FLINK-24481][docs] Translate buffer debloat documenation to chinese

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17953: URL: https://github.com/apache/flink/pull/17953#issuecomment-982382670 ## CI report: * 613fdd459bdc162d32219604db1eadd907089eed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17842: URL: https://github.com/apache/flink/pull/17842#issuecomment-974310249 ## CI report: * bfbbc0c07ec324af26872c0c5422ae6262358da0 Azure:

[jira] [Commented] (FLINK-25117) NoSuchMethodError getCatalog()

2021-11-30 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451499#comment-17451499 ] Wenlong Lyu commented on FLINK-25117: - hi, [~zzt] the method

[GitHub] [flink] flinkbot edited a comment on pull request #17956: [FLINK-18779][table sql/planner]Support the SupportsFilterPushDown for LookupTableSource

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17956: URL: https://github.com/apache/flink/pull/17956#issuecomment-982442976 ## CI report: * d0558544d5b853381e1e62a0f248c4891f748641 Azure:

[GitHub] [flink] Myracle commented on a change in pull request #17826: [FLINK-24953][Connectors / Hive]Optime hive parallelism inference

2021-11-30 Thread GitBox
Myracle commented on a change in pull request #17826: URL: https://github.com/apache/flink/pull/17826#discussion_r759839237 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveParallelismInference.java ## @@ -63,10 +63,10 @@

[jira] [Commented] (FLINK-21573) Support expression reuse in codegen

2021-11-30 Thread Q Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451493#comment-17451493 ] Q Kang commented on FLINK-21573: Hi [~godfreyhe] [~lzljs3620320] , I've come up with a simple solution

[jira] [Resolved] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

2021-11-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24046. -- Resolution: Fixed merged in master: 2d2d92e9812851091d7cee9c9c1764a0f7b4fdc8 > Refactor the

[jira] [Updated] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

2021-11-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24046: - Fix Version/s: 1.15.0 (was: 1.14.1) > Refactor the relationship bwtween

[GitHub] [flink] Myasuka closed pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

2021-11-30 Thread GitBox
Myasuka closed pull request #17874: URL: https://github.com/apache/flink/pull/17874 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-30 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r759828179 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-17782) Add array,map,row types support for parquet row writer

2021-11-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451487#comment-17451487 ] Jingsong Lee commented on FLINK-17782: -- [~sujun1020] and [~Runking] , sorry for the late response,

[GitHub] [flink] JingsongLi commented on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

2021-11-30 Thread GitBox
JingsongLi commented on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-983257963 Sorry for the late response, I will take a review in the next few days, hope you are still active. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-968179643 ## CI report: * 1adea585c2e4802e2c6d6b9de46becadc9e3d2c5 Azure:

[jira] [Updated] (FLINK-17782) Add array,map,row types support for parquet row writer

2021-11-30 Thread sujun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sujun updated FLINK-17782: -- Attachment: image-2021-12-01-11-37-21-884.png > Add array,map,row types support for parquet row writer >

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 8e8aaa7df0ebae7ec45b9bc2e61ea8e55d9f45b8 Azure:

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

2021-11-30 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r759828179 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #17953: [FLINK-24481][docs] Translate buffer debloat documenation to chinese

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17953: URL: https://github.com/apache/flink/pull/17953#issuecomment-982382670 ## CI report: * 613fdd459bdc162d32219604db1eadd907089eed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

2021-11-30 Thread GitBox
flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 8e8aaa7df0ebae7ec45b9bc2e61ea8e55d9f45b8 Azure:

[jira] [Updated] (FLINK-25120) Add many kinds of checks in ML Python API

2021-11-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-25120: - Parent: FLINK-25121 Issue Type: Sub-task (was: New Feature) > Add many kinds of checks

[jira] [Updated] (FLINK-24933) Support ML Python API to implement FLIP-173 and FLIP-174

2021-11-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-24933: - Parent: FLINK-25121 Issue Type: Sub-task (was: New Feature) > Support ML Python API to

[jira] [Comment Edited] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-30 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451193#comment-17451193 ] chenqizhu edited comment on FLINK-25099 at 12/1/21, 3:29 AM: - When I ignore

[jira] [Comment Edited] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-30 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451486#comment-17451486 ] chenqizhu edited comment on FLINK-25099 at 12/1/21, 3:28 AM: - Now the only

  1   2   3   4   5   6   7   8   9   >