[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-12 Thread GitBox
yunfengzhou-hub commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r727635514 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/CacheStreamOperator.java ## @@ -0,0 +1,141 @@ +/* + *

[jira] [Updated] (FLINK-24529) flink sql job cannot use custom job name

2021-10-12 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] simenliuxing updated FLINK-24529: - Description: In the 1.14.0 branch, I set the configuration of StreamTableEnvironment as

[jira] [Created] (FLINK-24528) Flink HBase Asyc Lookup throw NPE if rowkey is null

2021-10-12 Thread zhisheng (Jira)
zhisheng created FLINK-24528: Summary: Flink HBase Asyc Lookup throw NPE if rowkey is null Key: FLINK-24528 URL: https://issues.apache.org/jira/browse/FLINK-24528 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-23696) RMQSourceTest.testRedeliveredSessionIDsAck fails on azure

2021-10-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428004#comment-17428004 ] Yuan Mei commented on FLINK-23696: -- another case:

[GitHub] [flink] RocMarshal commented on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-12 Thread GitBox
RocMarshal commented on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-941932352 @leonardBang Could you help me to merge it if there are nothing inappropriate ? Thank you. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-24529) flink sql job cannot use custom job name

2021-10-12 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427995#comment-17427995 ] simenliuxing commented on FLINK-24529: -- [~jark] hi jark . Can you help me look at this problem  

[jira] [Created] (FLINK-24529) flink sql job cannot use custom job name

2021-10-12 Thread simenliuxing (Jira)
simenliuxing created FLINK-24529: Summary: flink sql job cannot use custom job name Key: FLINK-24529 URL: https://issues.apache.org/jira/browse/FLINK-24529 Project: Flink Issue Type:

[GitHub] [flink] nanmu42 opened a new pull request #17461: [FLINK-24503] [Deployment / Kubernetes] change kubernetes.rest-service.exposed.type defaults to ClusterIP

2021-10-12 Thread GitBox
nanmu42 opened a new pull request #17461: URL: https://github.com/apache/flink/pull/17461 ## What is the purpose of the change This patch aims to improve security of Flink native Kubernetes deployment on vendor k8s cluster as the original

[GitHub] [flink] flinkbot edited a comment on pull request #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17311: URL: https://github.com/apache/flink/pull/17311#issuecomment-921772935 ## CI report: * c0a29893bdaa662e2fa2ce1bb4f0398440c72fb5 Azure:

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-12 Thread GitBox
yunfengzhou-hub commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r727632118 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperator.java ## @@ -0,0 +1,170 @@

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-12 Thread GitBox
yunfengzhou-hub commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r727636497 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastContext.java ## @@ -0,0 +1,123 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #17461: [FLINK-24503] [Deployment / Kubernetes] change kubernetes.rest-service.exposed.type defaults to ClusterIP

2021-10-12 Thread GitBox
flinkbot commented on pull request #17461: URL: https://github.com/apache/flink/pull/17461#issuecomment-941929462 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-24503) Security: native kubernetes exposes REST service via LoadBalancer in default

2021-10-12 Thread LI Zhennan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428010#comment-17428010 ] LI Zhennan commented on FLINK-24503: Hi [~xtsong], I have submitted a PR:

[jira] [Created] (FLINK-24527) Add SqlUseDialect and UseDialectOperation

2021-10-12 Thread chouc (Jira)
chouc created FLINK-24527: - Summary: Add SqlUseDialect and UseDialectOperation Key: FLINK-24527 URL: https://issues.apache.org/jira/browse/FLINK-24527 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-24529) flink sql job cannot use custom job name

2021-10-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428000#comment-17428000 ] Ingo Bürk commented on FLINK-24529: --- CC [~twalthr] > flink sql job cannot use custom job name >

[GitHub] [flink] Myasuka commented on a change in pull request #17419: [FLINK-24460][rocksdb] Rocksdb Iterator Error Handling Improvement

2021-10-12 Thread GitBox
Myasuka commented on a change in pull request #17419: URL: https://github.com/apache/flink/pull/17419#discussion_r727686247 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksIteratorWrapper.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #17461: [FLINK-24503] [Deployment / Kubernetes] change kubernetes.rest-service.exposed.type defaults to ClusterIP

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17461: URL: https://github.com/apache/flink/pull/17461#issuecomment-941929030 ## CI report: * c1b70a0eca8014f62194ccc75001da67accfb0f5 Azure:

[jira] [Commented] (FLINK-24520) Building of WebUI failed on Ubuntu 20

2021-10-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428011#comment-17428011 ] Ingo Bürk commented on FLINK-24520: --- What was the Maven command used here? > Building of WebUI failed

[GitHub] [flink] flinkbot commented on pull request #17461: [FLINK-24503] [Deployment / Kubernetes] change kubernetes.rest-service.exposed.type defaults to ClusterIP

2021-10-12 Thread GitBox
flinkbot commented on pull request #17461: URL: https://github.com/apache/flink/pull/17461#issuecomment-941929030 ## CI report: * c1b70a0eca8014f62194ccc75001da67accfb0f5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-24503) Security: native kubernetes exposes REST service via LoadBalancer in default

2021-10-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24503: --- Labels: pull-request-available security (was: security) > Security: native kubernetes

[GitHub] [flink] flinkbot edited a comment on pull request #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17311: URL: https://github.com/apache/flink/pull/17311#issuecomment-921772935 ## CI report: * c0a29893bdaa662e2fa2ce1bb4f0398440c72fb5 Azure:

[jira] [Comment Edited] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427871#comment-17427871 ] Mahendran Ponnusamy edited comment on FLINK-24494 at 10/12/21, 7:04 PM:

[jira] [Created] (FLINK-24518) Combine deployment of staging jars and binary release creation

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24518: Summary: Combine deployment of staging jars and binary release creation Key: FLINK-24518 URL: https://issues.apache.org/jira/browse/FLINK-24518 Project:

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Description:   Given a schema registered to a topic with default value as '0'

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Summary: Avro Confluent Registry SQL kafka connector fails to write to the topic

[jira] [Created] (FLINK-24519) Add release script for uplading release to SVN

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24519: Summary: Add release script for uplading release to SVN Key: FLINK-24519 URL: https://issues.apache.org/jira/browse/FLINK-24519 Project: Flink Issue

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Description:   Given a schema registered to a topic with name and namespave

[jira] [Created] (FLINK-24520) Building of WebUI failed on Ubuntu 20

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24520: Summary: Building of WebUI failed on Ubuntu 20 Key: FLINK-24520 URL: https://issues.apache.org/jira/browse/FLINK-24520 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Attachment: image-2021-10-12-12-21-02-008.png > Avro Confluent Registry SQL kafka

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Attachment: image-2021-10-12-12-21-46-177.png > Avro Confluent Registry SQL kafka

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Affects Version/s: 1.14.0 > Avro Confluent Registry SQL kafka connector fails to

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Description:  *Summary:* Given a schema registered to a topic with name and

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Description:  *Summary:* Given a schema registered to a topic with name and

[jira] [Created] (FLINK-24524) Rework release guide and scripts to be used from the root directory

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24524: Summary: Rework release guide and scripts to be used from the root directory Key: FLINK-24524 URL: https://issues.apache.org/jira/browse/FLINK-24524 Project:

[jira] [Created] (FLINK-24525) Use different names for release branch and tags

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24525: Summary: Use different names for release branch and tags Key: FLINK-24525 URL: https://issues.apache.org/jira/browse/FLINK-24525 Project: Flink

[jira] [Commented] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427871#comment-17427871 ] Mahendran Ponnusamy commented on FLINK-24494: - Thank you [~MartijnVisser], I figured the

[jira] [Created] (FLINK-24522) Remove spaces from python wheel azure artifacts

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24522: Summary: Remove spaces from python wheel azure artifacts Key: FLINK-24522 URL: https://issues.apache.org/jira/browse/FLINK-24522 Project: Flink

[jira] [Created] (FLINK-24523) Extend GPG setup instructions

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24523: Summary: Extend GPG setup instructions Key: FLINK-24523 URL: https://issues.apache.org/jira/browse/FLINK-24523 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Attachment: Screen Shot 2021-10-12 at 10.38.55 AM.png > Avro Confluent Registry

[jira] [Comment Edited] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427871#comment-17427871 ] Mahendran Ponnusamy edited comment on FLINK-24494 at 10/12/21, 7:11 PM:

[jira] [Updated] (FLINK-24517) Streamline Flink releases

2021-10-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24517: - Component/s: Release System > Streamline Flink releases > - > >

[jira] [Created] (FLINK-24517) Streamline Flink releases

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24517: Summary: Streamline Flink releases Key: FLINK-24517 URL: https://issues.apache.org/jira/browse/FLINK-24517 Project: Flink Issue Type: Technical Debt

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Attachment: (was: image-2021-10-12-12-06-16-262.png) > Avro Confluent

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Attachment: (was: image-2021-10-12-12-09-24-259.png) > Avro Confluent

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Attachment: (was: KafkaTableTumbling.java) > Avro Confluent Registry SQL not

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Attachment: image-2021-10-12-12-18-53-016.png > Avro Confluent Registry SQL kafka

[jira] [Created] (FLINK-24521) Add release script for Python wheel step

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24521: Summary: Add release script for Python wheel step Key: FLINK-24521 URL: https://issues.apache.org/jira/browse/FLINK-24521 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-10-12 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Attachment: image-2021-10-12-12-19-37-227.png > Avro Confluent Registry SQL kafka

[jira] [Assigned] (FLINK-24517) Streamline Flink releases

2021-10-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24517: Assignee: (was: Chesnay Schepler) > Streamline Flink releases >

[jira] [Updated] (FLINK-24526) Combine all environment variables into a single section

2021-10-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24526: - Description: In every release the first thing I always do is scour the release guide

[jira] [Updated] (FLINK-24526) Combine all environment variables into a single section

2021-10-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24526: - Description: In every release the first thing I always do is scour the release guide

[jira] [Created] (FLINK-24526) Combine all environment variables into a single section

2021-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24526: Summary: Combine all environment variables into a single section Key: FLINK-24526 URL: https://issues.apache.org/jira/browse/FLINK-24526 Project: Flink

[GitHub] [flink] wuchong merged pull request #16639: [FLINK-23549][connector][kafka][docs] - Corrected syntax error in create table example

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

[jira] [Commented] (FLINK-24050) Support primary keys on metadata columns

2021-10-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427475#comment-17427475 ] Jark Wu commented on FLINK-24050: - I have another use case need this feature: For example, there is

[GitHub] [flink] flinkbot commented on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

2021-10-12 Thread GitBox
flinkbot commented on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 356ff14e4347563bbc8aecebc9a5edd8ef5b32a2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zentol opened a new pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
zentol opened a new pull request #17455: URL: https://github.com/apache/flink/pull/17455 Since the tests specifically tests the AkkaRpcSystemLoader, which relies on the flink-rpc-akka jar to be available (which runs in the package phase since FLINK-24445), it needs to be an ITCase. --

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-10-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427549#comment-17427549 ] Xintong Song commented on FLINK-23493: --

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[jira] [Commented] (FLINK-24512) Allow metadata columns can also be part of primary key

2021-10-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427473#comment-17427473 ] Jark Wu commented on FLINK-24512: - Thanks [~airblader], I forgot there is an issue (y) > Allow metadata

[jira] [Closed] (FLINK-24512) Allow metadata columns can also be part of primary key

2021-10-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24512. --- Resolution: Duplicate > Allow metadata columns can also be part of primary key >

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

2021-10-12 Thread GitBox
yunfengzhou-hub commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r726848319 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/coordinator/HeadOperatorCoordinator.java ## @@ -63,10 +63,16

[jira] [Updated] (FLINK-24513) AkkaRpcSystemLoader must be an ITCase

2021-10-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24513: - Issue Type: Technical Debt (was: Bug) > AkkaRpcSystemLoader must be an ITCase >

[jira] [Updated] (FLINK-24513) AkkaRpcSystemLoader must be an ITCase

2021-10-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24513: --- Labels: pull-request-available (was: ) > AkkaRpcSystemLoader must be an ITCase >

[GitHub] [flink] flinkbot commented on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot commented on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[jira] [Commented] (FLINK-24077) HBaseConnectorITCase.testTableSink

2021-10-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427548#comment-17427548 ] Xintong Song commented on FLINK-24077: --

[jira] [Commented] (FLINK-23486) Add metrics for the ChangelogStateBackend

2021-10-12 Thread xingyuan cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427466#comment-17427466 ] xingyuan cheng commented on FLINK-23486: [~roman]

[jira] [Commented] (FLINK-24050) Support primary keys on metadata columns

2021-10-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427476#comment-17427476 ] Jark Wu commented on FLINK-24050: - [~airblader] do you have plan to work on this? > Support primary

[jira] [Updated] (FLINK-24050) Support primary keys on metadata columns

2021-10-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-24050: -- Description: Currently, primary keys are required to consist solely of physical columns. However,

[jira] [Commented] (FLINK-24050) Support primary keys on metadata columns

2021-10-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427477#comment-17427477 ] Ingo Bürk commented on FLINK-24050: --- No, I'm not planning on working on this for the time being. It's

[GitHub] [flink] fapaul commented on pull request #17342: [FLINK-20928] Fix flaky test by retrying notifyCheckpointComplete until either commit success or timeout

2021-10-12 Thread GitBox
fapaul commented on pull request #17342: URL: https://github.com/apache/flink/pull/17342#issuecomment-940710690 @lindong28 sorry for the late response. Can you cherry-pick your commit and create a pull request against the 1.14 branch? -- This is an automated message from the Apache Git

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

2021-10-12 Thread GitBox
yunfengzhou-hub commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r726816428 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/datacache/nonkeyed/DataCacheSnapshot.java ## @@ -0,0 +1,201 @@ +/* + *

[jira] [Commented] (FLINK-24511) "sink.parallelism" doesn't work for upsert "values" sink

2021-10-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427510#comment-17427510 ] Leonard Xu commented on FLINK-24511: I'd like to fix this, please assign to me [~jark] >

[GitHub] [flink] flinkbot edited a comment on pull request #17437: [FLINK-24467][streaming] Announce the min and max buffer size despite last diff less than threshold

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17437: URL: https://github.com/apache/flink/pull/17437#issuecomment-938641904 ## CI report: * 99519029ca897f2c0e6cc40e5e8b3ff1557c1cc4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 8e3d80bc6fc29bf1865667fff9ab32495fd217f0 Azure:

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-10-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427550#comment-17427550 ] Xintong Song commented on FLINK-23525: --

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-10-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427551#comment-17427551 ] Xintong Song commented on FLINK-23525: --

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[jira] [Commented] (FLINK-24465) Wrong javadoc and documentation for buffer timeout

2021-10-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427557#comment-17427557 ] Piotr Nowojski commented on FLINK-24465: As {{-1}} is not supported for already over a year and

[jira] [Commented] (FLINK-23683) KafkaSinkITCase hangs on azure

2021-10-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427558#comment-17427558 ] Xintong Song commented on FLINK-23683: --

[jira] [Closed] (FLINK-23549) Kafka table connector create table example in docs has syntax error

2021-10-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23549. --- Resolution: Fixed Fixed in master: e0be71c831e70b3aa5faf56cba06ab8d41bf452a > Kafka table connector create

[GitHub] [flink] flinkbot edited a comment on pull request #17453: [FLINK-24510][Deployment/Scripts]Fix the duplicate log output of libraries/connectors，when logback is used

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17453: URL: https://github.com/apache/flink/pull/17453#issuecomment-940622443 ## CI report: * 853bce04c09bf00f130a0dcebac03e73a799db9e Azure:

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #17: [FLINK-10][iteration] Support the checkpoints for the iteration.

2021-10-12 Thread GitBox
yunfengzhou-hub commented on a change in pull request #17: URL: https://github.com/apache/flink-ml/pull/17#discussion_r726834717 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/HeadOperator.java ## @@ -129,12 +168,89 @@ public void setup(

[GitHub] [flink] flinkbot commented on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot commented on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940762177 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 #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[GitHub] [flink-benchmarks] dawidwys closed pull request #34: [hotfix] Increase warmup iterations and iterations in CheckpointingTimeBenchmark

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

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[jira] [Commented] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

2021-10-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427552#comment-17427552 ] Xintong Song commented on FLINK-22621: --

[jira] [Commented] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

2021-10-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427555#comment-17427555 ] Xintong Song commented on FLINK-22869: --

[GitHub] [flink] twalthr closed pull request #17423: [FLINK-24443][table-runtime] Reenable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs

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

[GitHub] [flink] flinkbot edited a comment on pull request #17455: [FLINK-24513][tests] Make AkkaRpcSystemLoaderTest an ITCase

2021-10-12 Thread GitBox
flinkbot edited a comment on pull request #17455: URL: https://github.com/apache/flink/pull/17455#issuecomment-940760455 ## CI report: * 6c4116af9ca23eee8d49b4856c8bd31dae4d7c55 Azure:

[jira] [Assigned] (FLINK-24397) Reduce TableSchema usage in Table API connectors

2021-10-12 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-24397: --- Assignee: (was: Fabian Paul) > Reduce TableSchema usage in Table API connectors >

[GitHub] [flink] slinkydeveloper opened a new pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

2021-10-12 Thread GitBox
slinkydeveloper opened a new pull request #17454: URL: https://github.com/apache/flink/pull/17454 ## What is the purpose of the change Moved `DecimalDataUtils` and `SqlDateTimeUtils` (renamed to `DateTimeUtils`), removing all usages of the avatica-core methods. ##

[jira] [Updated] (FLINK-24500) Move SqlDateTimeUtils to table-common

2021-10-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24500: --- Labels: pull-request-available (was: ) > Move SqlDateTimeUtils to table-common >

  1   2   3   >