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

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-24520) Building of WebUI failed on Ubuntu 20

[ 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 edited a comment on pull request #17461: [FLINK-24503] [Deployment / Kubernetes] change kubernetes.rest-service.exposed.type defaults to ClusterIP

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-24503) Security: native kubernetes exposes REST service via LoadBalancer in default

[ 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:

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

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

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

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

[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

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

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

[ 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] nanmu42 opened a new pull request #17461: [FLINK-24503] [Deployment / Kubernetes] change kubernetes.rest-service.exposed.type defaults to ClusterIP

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

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

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

[ 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] Myasuka commented on a change in pull request #17419: [FLINK-24460][rocksdb] Rocksdb Iterator Error Handling Improvement

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 ## @@

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

[ 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 >

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

[ 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] [Updated] (FLINK-24529) flink sql job cannot use custom job name

[ 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-24529) flink sql job cannot use custom job name

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:

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

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] [Created] (FLINK-24527) Add SqlUseDialect and UseDialectOperation

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

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

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-ml] yunfengzhou-hub commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

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 @@ +/* + *

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

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 @@

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

[ 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

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

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

[ 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] [Assigned] (FLINK-24517) Streamline Flink releases

[ 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] [Created] (FLINK-24525) Use different names for release branch and tags

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] [Created] (FLINK-24524) Rework release guide and scripts to be used from the root directory

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] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

[ 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-24523) Extend GPG setup instructions

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 kafka connector fails to write to the topic with schema

[ 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

[ 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

[ 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

[ 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] [Created] (FLINK-24522) Remove spaces from python wheel azure artifacts

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] [Updated] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

[ 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] [Created] (FLINK-24521) Add release script for Python wheel step

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

[ 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-24520) Building of WebUI failed on Ubuntu 20

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

[ 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-24519) Add release script for uplading release to SVN

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 not fails to write to the topic with schema with default value for int

[ 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] [Created] (FLINK-24518) Combine deployment of staging jars and binary release creation

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 kafka connector fails to write to the topic with schema

[ 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] [Updated] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

[ 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 not fails to write to the topic with schema with default value for int

[ 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

[ 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] [Created] (FLINK-24517) Streamline Flink releases

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-24517) Streamline Flink releases

[ 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] [Comment Edited] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

[ 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] [Comment Edited] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

[ 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] [Commented] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

[ 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] [Updated] (FLINK-24494) Avro Confluent Registry SQL not fails to write to the topic with schema with default value for int

[ 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] [Closed] (FLINK-24231) Buffer debloating microbenchmark for multiply gate

[ https://issues.apache.org/jira/browse/FLINK-24231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24231. Assignee: Dawid Wysakowicz Resolution: Implemented Implemented in

[GitHub] [flink-benchmarks] dawidwys merged pull request #35: [FLINK-24231] Benchmark for buffer debloating multiple gates

dawidwys merged pull request #35: URL: https://github.com/apache/flink-benchmarks/pull/35 -- 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] zentol commented on a change in pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

zentol commented on a change in pull request #17458: URL: https://github.com/apache/flink/pull/17458#discussion_r727364094 ## File path: docs/content/docs/flinkDev/building.md ## @@ -52,11 +52,19 @@ mvn clean install -DskipTests This instructs

[GitHub] [flink] flinkbot edited a comment on pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

flinkbot edited a comment on pull request #17441: URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036 ## CI report: * 5a10760f62b70db58a953e0d8e304bafa56a053e Azure:

[GitHub] [flink] zentol commented on a change in pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

zentol commented on a change in pull request #17458: URL: https://github.com/apache/flink/pull/17458#discussion_r727361542 ## File path: docs/content/docs/flinkDev/building.md ## @@ -52,11 +52,19 @@ mvn clean install -DskipTests This instructs

[GitHub] [flink] zentol commented on a change in pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

zentol commented on a change in pull request #17458: URL: https://github.com/apache/flink/pull/17458#discussion_r727359834 ## File path: docs/content/docs/flinkDev/building.md ## @@ -52,11 +52,19 @@ mvn clean install -DskipTests This instructs

[GitHub] [flink-statefun] neoXfire opened a new pull request #275: Use JDK 8 Optional instead of shaded Optional class from Guava.

neoXfire opened a new pull request #275: URL: https://github.com/apache/flink-statefun/pull/275 I got this error on sample project with Flink embedded using `org.apache.flink:statefun-flink-datastream:3.1.0` and `org.apache.flink:flink-clients_2.12:1.14.0` ``` Exception in

[jira] [Commented] (FLINK-24516) Modernize Maven Archetype

[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427811#comment-17427811 ] Seth Wiesman commented on FLINK-24516: -- [~MartijnVisser] maybe you have some ideas about what this

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 202b39e05a73f8644d7cc3b46ed3511052d35fd4 Azure:

[jira] [Created] (FLINK-24516) Modernize Maven Archetype

Seth Wiesman created FLINK-24516: Summary: Modernize Maven Archetype Key: FLINK-24516 URL: https://issues.apache.org/jira/browse/FLINK-24516 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #17450: [FLINK-24418][table-planner] Add support for casting RAW to BINARY

flinkbot edited a comment on pull request #17450: URL: https://github.com/apache/flink/pull/17450#issuecomment-939949291 ## CI report: * e17cd221fe36ee6064cfff125b0a9b025c5310bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 3edc8a26d8a9bff3a8878570d038d53e54c5a4ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17217: [FLINK-24186][table-planner] Allow multiple rowtime attributes for collect() and print()

flinkbot edited a comment on pull request #17217: URL: https://github.com/apache/flink/pull/17217#issuecomment-916047672 ## CI report: * 578e56afa1aaa77e228151f13eba81ededa2b3d0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17459: [FLINK-24397] Remove TableSchema usages from Flink connectors

flinkbot edited a comment on pull request #17459: URL: https://github.com/apache/flink/pull/17459#issuecomment-940996979 ## CI report: * 69e676d0e426e4a9eb437b3bd4628f9c3cd3b7eb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17439: [FLINK-23271][table-planner] Disallow cast from decimal numerics to boolean

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

[GitHub] [flink] dawidwys edited a comment on pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

dawidwys edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-941031617 I found the reason why the exception was swallowed. Please see: https://issues.apache.org/jira/browse/FLINK-24515. I think we should not swallow exceptions if

[jira] [Closed] (FLINK-24515) MailboxExecutor#submit swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-24515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24515. Fix Version/s: (was: 1.14.1) (was: 1.15.0)

[jira] [Commented] (FLINK-24515) MailboxExecutor#submit swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-24515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427775#comment-17427775 ] Dawid Wysakowicz commented on FLINK-24515: -- Hmm, I see. Yeah, I think it actually makes sense.

[jira] [Updated] (FLINK-24515) MailboxExecutor#submit swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-24515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24515: - Priority: Major (was: Critical) > MailboxExecutor#submit swallows exceptions >

[GitHub] [flink] dawidwys closed pull request #17460: [FLINK-24515] MailboxExecutor#submit swallows exceptions

dawidwys closed pull request #17460: URL: https://github.com/apache/flink/pull/17460 -- 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-24515) MailboxExecutor#submit swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-24515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427752#comment-17427752 ] Piotr Nowojski commented on FLINK-24515: I think it's intentional "feature" and not a bug, that

[GitHub] [flink] flinkbot edited a comment on pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

flinkbot edited a comment on pull request #17441: URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036 ## CI report: * 0040bfe2d73e9b07cf348fd91a6d93149689bebb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

flinkbot edited a comment on pull request #17441: URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036 ## CI report: * 0040bfe2d73e9b07cf348fd91a6d93149689bebb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

[GitHub] [flink] JingGe commented on a change in pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

JingGe commented on a change in pull request #17458: URL: https://github.com/apache/flink/pull/17458#discussion_r727177127 ## File path: docs/content/docs/flinkDev/building.md ## @@ -52,11 +52,19 @@ mvn clean install -DskipTests This instructs

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

[GitHub] [flink] JingGe commented on a change in pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

JingGe commented on a change in pull request #17458: URL: https://github.com/apache/flink/pull/17458#discussion_r727165480 ## File path: docs/content/docs/flinkDev/building.md ## @@ -52,11 +52,19 @@ mvn clean install -DskipTests This instructs

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

[GitHub] [flink] JingGe commented on a change in pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

JingGe commented on a change in pull request #17458: URL: https://github.com/apache/flink/pull/17458#discussion_r727162524 ## File path: docs/content/docs/flinkDev/building.md ## @@ -52,11 +52,19 @@ mvn clean install -DskipTests This instructs

[jira] [Closed] (FLINK-24467) Set min and max buffer size even if the difference less than threshold

[ https://issues.apache.org/jira/browse/FLINK-24467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24467. Fix Version/s: 1.14.1 1.15.0 Resolution: Fixed Implemented in:

[GitHub] [flink] JingGe commented on a change in pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

JingGe commented on a change in pull request #17458: URL: https://github.com/apache/flink/pull/17458#discussion_r727162253 ## File path: docs/content/docs/flinkDev/building.md ## @@ -52,11 +52,19 @@ mvn clean install -DskipTests This instructs

[GitHub] [flink] flinkbot edited a comment on pull request #17460: [FLINK-24515] MailboxExecutor#submit swallows exceptions

flinkbot edited a comment on pull request #17460: URL: https://github.com/apache/flink/pull/17460#issuecomment-941032272 ## CI report: * ce893d0fb77003619b23fc0b8108b858dafdb9db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

[GitHub] [flink] dawidwys closed pull request #17437: [FLINK-24467][streaming] Announce the min and max buffer size despite last diff less than threshold

dawidwys closed pull request #17437: URL: https://github.com/apache/flink/pull/17437 -- 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 commented on pull request #17460: [FLINK-24515] MailboxExecutor#submit swallows exceptions

flinkbot commented on pull request #17460: URL: https://github.com/apache/flink/pull/17460#issuecomment-941034024 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 commented on pull request #17460: [FLINK-24515] MailboxExecutor#submit swallows exceptions

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

[GitHub] [flink] fapaul commented on a change in pull request #17459: [FLINK-24397] Remove TableSchema usages from Flink connectors

fapaul commented on a change in pull request #17459: URL: https://github.com/apache/flink/pull/17459#discussion_r727157348 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunction.java ## @@ -1,313 +0,0 @@ -/*

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

[GitHub] [flink] dawidwys commented on pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

dawidwys commented on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-941031617 I found the reason why the exception was swallowed. Please see: https://issues.apache.org/jira/browse/FLINK-24515. I think we should not swallow exceptions if debloating

[GitHub] [flink] fapaul commented on a change in pull request #17459: [FLINK-24397] Remove TableSchema usages from Flink connectors

fapaul commented on a change in pull request #17459: URL: https://github.com/apache/flink/pull/17459#discussion_r727156469 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcDataTypeTest.java ## @@ -101,50 +101,46 @@

[jira] [Updated] (FLINK-24515) MailboxExecutor#submit swallows exceptions

[ https://issues.apache.org/jira/browse/FLINK-24515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24515: --- Labels: pull-request-available (was: ) > MailboxExecutor#submit swallows exceptions >

[GitHub] [flink] dawidwys opened a new pull request #17460: [FLINK-24515] MailboxExecutor#submit swallows exceptions

dawidwys opened a new pull request #17460: URL: https://github.com/apache/flink/pull/17460 ## What is the purpose of the change The PR fixes {{MailboxExecutor#submit}} that it properly throws exception from within the mailbox. ## Verifying this change All tests in

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

[GitHub] [flink] fapaul commented on a change in pull request #17459: [FLINK-24397] Remove TableSchema usages from Flink connectors

fapaul commented on a change in pull request #17459: URL: https://github.com/apache/flink/pull/17459#discussion_r727142712 ## File path: flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/table/HBaseConnectorOptionsUtil.java ## @@ -57,8

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 375a3b3fdbb7fb73a700a07e707f5521e2ad6ff6 Azure:

  1   2   3   >