[jira] [Created] (FLINK-24540) Fix Resocue leak due to Files.list

2021-10-13 Thread lujie (Jira)
lujie created FLINK-24540: - Summary: Fix Resocue leak due to Files.list Key: FLINK-24540 URL: https://issues.apache.org/jira/browse/FLINK-24540 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-939291136 ## CI report: * 7892230e8d668a7f038c17b21d9fc55088f8ba89 Azure:

[jira] [Created] (FLINK-24539) ChangelogNormalize operator tooks too long time to INITIALIZING until failed

2021-10-13 Thread vmaster.cc (Jira)
vmaster.cc created FLINK-24539: -- Summary: ChangelogNormalize operator tooks too long time to INITIALIZING until failed Key: FLINK-24539 URL: https://issues.apache.org/jira/browse/FLINK-24539 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #17466: [FLINK-24535] Update Glue Schema Registry with the lastest version

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17466: URL: https://github.com/apache/flink/pull/17466#issuecomment-942744642 ## CI report: * 34cc2ebe38b62a0ae104b568ece9701af5c309a8 Azure:

[jira] [Commented] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError

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

[jira] [Updated] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20908: - Fix Version/s: 1.14.1 1.15.0 >

[jira] [Updated] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20908: - Priority: Major (was: Minor) >

[jira] [Updated] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20908: - Labels: test-stability (was: auto-deprioritized-major test-stability) >

[jira] [Updated] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20908: - Affects Version/s: 1.14.0 > ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp

[jira] [Created] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2021-10-13 Thread Xintong Song (Jira)
Xintong Song created FLINK-24538: Summary: ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE Key: FLINK-24538 URL: https://issues.apache.org/jira/browse/FLINK-24538

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17466: [FLINK-24535] Update Glue Schema Registry with the lastest version

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17466: URL: https://github.com/apache/flink/pull/17466#issuecomment-942744642 ## CI report: * 33acb76d1cd8a7d9b88afcba69abbe15effd9b84 Azure:

[jira] [Updated] (FLINK-24537) Array of rows containing constant strings of different length and an integer throws AssertionError

2021-10-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24537: Description: This issue is from [the mailing

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

2021-10-13 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 edited comment on FLINK-23486 at 10/14/21, 3:37 AM: ---

[jira] [Created] (FLINK-24537) Array of rows containing constant strings of different length and an integer throws AssertionError

2021-10-13 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-24537: --- Summary: Array of rows containing constant strings of different length and an integer throws AssertionError Key: FLINK-24537 URL: https://issues.apache.org/jira/browse/FLINK-24537

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

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

[jira] [Resolved] (FLINK-24460) Rocksdb Iterator Error Handling Improvement

2021-10-13 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24460. -- Fix Version/s: 1.14.1 1.15.0 Resolution: Fixed merged in master:

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

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

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

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

[jira] [Updated] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15550: - Fix Version/s: 1.12.6 > testCancelTaskExceptionAfterTaskMarkedFailed failed on azure >

[jira] [Updated] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15550: - Priority: Major (was: Minor) > testCancelTaskExceptionAfterTaskMarkedFailed failed on azure >

[GitHub] [flink] Myasuka closed pull request #17419: [FLINK-24460][rocksdb] Rocksdb Iterator Error Handling Improvement

2021-10-13 Thread GitBox
Myasuka closed pull request #17419: URL: https://github.com/apache/flink/pull/17419 -- 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] [Reopened] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-15550: --

[jira] [Updated] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15550: - Labels: (was: auto-deprioritized-major) > testCancelTaskExceptionAfterTaskMarkedFailed failed

[jira] [Created] (FLINK-24536) flink sql where condition is not supported != writing

2021-10-13 Thread simenliuxing (Jira)
simenliuxing created FLINK-24536: Summary: flink sql where condition is not supported != writing Key: FLINK-24536 URL: https://issues.apache.org/jira/browse/FLINK-24536 Project: Flink Issue

[jira] [Updated] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15550: - Affects Version/s: 1.12.5 > testCancelTaskExceptionAfterTaskMarkedFailed failed on azure >

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

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24503: - Release Note: For native Kubernetes deployments, REST & Web UI are now exposed as ClusterIP

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

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24503: - Release Note: For native Kubernetes deployments, REST & Web UI are now exposed as ClusterIP

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

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-24503. Release Note: For native Kubernetes deployments, REST & Web UI are now exposed as ClusterIP

[jira] [Assigned] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

2021-10-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19722: Assignee: xuyangzhong > Pushdown Watermark to SourceProvider (new Source) >

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

2021-10-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24503: - Fix Version/s: 1.15.0 > Security: native kubernetes exposes REST service via LoadBalancer in

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

2021-10-13 Thread GitBox
xintongsong closed pull request #17461: URL: https://github.com/apache/flink/pull/17461 -- 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 #17466: [FLINK-24535] Update Glue Schema Registry with the lastest version

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17466: URL: https://github.com/apache/flink/pull/17466#issuecomment-942744642 ## CI report: * 33acb76d1cd8a7d9b88afcba69abbe15effd9b84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17466: [FLINK-24535] Update Glue Schema Registry with the lastest version

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17466: URL: https://github.com/apache/flink/pull/17466#issuecomment-942744642 ## CI report: * 33acb76d1cd8a7d9b88afcba69abbe15effd9b84 Azure:

[jira] [Updated] (FLINK-24535) Update with the latest AWS Glue Schema Registry version

2021-10-13 Thread Linyu Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Linyu Yao updated FLINK-24535: -- Description: This change is to update the flink avro and json schema serializer / deserializer with 

[jira] [Commented] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

2021-10-13 Thread xuyangzhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428567#comment-17428567 ] xuyangzhong commented on FLINK-19722: - I'll try to fix this issue. > Pushdown Watermark to

[GitHub] [flink] flinkbot edited a comment on pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-939291136 ## CI report: * 7837a03f2745e5d67912fda5317bf755c0a62d8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-939291136 ## CI report: * 7837a03f2745e5d67912fda5317bf755c0a62d8f Azure:

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

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

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

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

[jira] [Comment Edited] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-13 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425935#comment-17425935 ] Yuepeng Pan edited comment on FLINK-10230 at 10/14/21, 2:03 AM: Could

[jira] [Commented] (FLINK-24495) Python installdeps hangs

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

[jira] [Commented] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

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

[jira] [Commented] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

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

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

2021-10-13 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] simenliuxing closed FLINK-24529. Resolution: Not A Problem > flink sql job cannot use custom job name >

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

2021-10-13 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428556#comment-17428556 ] simenliuxing commented on FLINK-24529: -- [~matriv] Thanks for your reply and verification. My job

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

2021-10-13 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] simenliuxing updated FLINK-24529: - Attachment: (was: image-2021-10-14-09-33-31-560.png) > flink sql job cannot use custom job

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

2021-10-13 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] simenliuxing updated FLINK-24529: - Attachment: (was: image-2021-10-14-09-28-41-048.png) > flink sql job cannot use custom job

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

2021-10-13 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] simenliuxing updated FLINK-24529: - Attachment: (was: image-2021-10-14-09-29-17-121.png) > flink sql job cannot use custom job

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

2021-10-13 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] simenliuxing updated FLINK-24529: - Attachment: image-2021-10-14-09-33-31-560.png > flink sql job cannot use custom job name >

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

2021-10-13 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] simenliuxing updated FLINK-24529: - Attachment: image-2021-10-14-09-29-17-121.png > flink sql job cannot use custom job name >

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

2021-10-13 Thread simenliuxing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] simenliuxing updated FLINK-24529: - Attachment: image-2021-10-14-09-28-41-048.png > flink sql job cannot use custom job name >

[GitHub] [flink] flinkbot edited a comment on pull request #17466: [FLINK-24535] Update Glue Schema Registry with the lastest version

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17466: URL: https://github.com/apache/flink/pull/17466#issuecomment-942744642 ## CI report: * 33acb76d1cd8a7d9b88afcba69abbe15effd9b84 Azure:

[GitHub] [flink] flinkbot commented on pull request #17466: [FLINK-24535] Update Glue Schema Registry with the lastest version

2021-10-13 Thread GitBox
flinkbot commented on pull request #17466: URL: https://github.com/apache/flink/pull/17466#issuecomment-942745284 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 #17466: [FLINK-24535] Update Glue Schema Registry with the lastest version

2021-10-13 Thread GitBox
flinkbot commented on pull request #17466: URL: https://github.com/apache/flink/pull/17466#issuecomment-942744642 ## CI report: * 33acb76d1cd8a7d9b88afcba69abbe15effd9b84 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-24535) Update with the latest AWS Glue Schema Registry version

2021-10-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24535: --- Labels: pull-request-available (was: ) > Update with the latest AWS Glue Schema Registry

[GitHub] [flink] LinyuYao1021 opened a new pull request #17466: [FLINK-24535] Update Glue Schema Registry with the lastest version

2021-10-13 Thread GitBox
LinyuYao1021 opened a new pull request #17466: URL: https://github.com/apache/flink/pull/17466 ## What is the purpose of the change *This pull request is to update the flink avro schema serializer / deserializer with the latest AWS Glue Schema Registry version v1.1.5*

[jira] [Created] (FLINK-24535) Update with the latest AWS Glue Schema Registry version

2021-10-13 Thread Linyu Yao (Jira)
Linyu Yao created FLINK-24535: - Summary: Update with the latest AWS Glue Schema Registry version Key: FLINK-24535 URL: https://issues.apache.org/jira/browse/FLINK-24535 Project: Flink Issue

[GitHub] [flink-statefun] sjwiesman commented on pull request #276: [FLINK-24534] Use the async transport if transport is not specified.

2021-10-13 Thread GitBox
sjwiesman commented on pull request #276: URL: https://github.com/apache/flink-statefun/pull/276#issuecomment-942714405 Please update the docs as well. Should we increase the default max number of async requests? -- This is an automated message from the Apache Git Service. To

[GitHub] [flink-statefun] igalshilman commented on pull request #275: Use JDK 8 Optional instead of shaded Optional class from Guava.

2021-10-13 Thread GitBox
igalshilman commented on pull request #275: URL: https://github.com/apache/flink-statefun/pull/275#issuecomment-942681494 I see that there are also format violations, don't worry about that I'll re-format while merging. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink-statefun] igalshilman commented on pull request #275: Use JDK 8 Optional instead of shaded Optional class from Guava.

2021-10-13 Thread GitBox
igalshilman commented on pull request #275: URL: https://github.com/apache/flink-statefun/pull/275#issuecomment-942680176 Thank you @neoXfire for your contribution! Indeed a JDK optional is the one we should be using, I think that the Guava's one slipped there by mistake, so good catch!

[jira] [Updated] (FLINK-24534) Set async based transport for remote functions default

2021-10-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24534: --- Labels: pull-request-available (was: ) > Set async based transport for remote functions

[GitHub] [flink-statefun] igalshilman opened a new pull request #276: [FLINK-24534] Use the async transport if transport is not specified.

2021-10-13 Thread GitBox
igalshilman opened a new pull request #276: URL: https://github.com/apache/flink-statefun/pull/276 This PR sets the Netty based, asynchronous transport as the default transport for endpoint definitions that did not specify a particular transport. -- This is an automated

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

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 8acec6fdafb2c7744232ec4ce554a2999a053f85 Azure:

[GitHub] [flink] Airblader commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-10-13 Thread GitBox
Airblader commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r728368143 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java ## @@ -100,44 +100,6 @@

[GitHub] [flink] flinkbot commented on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-13 Thread GitBox
flinkbot commented on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-942425244 -- 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

[GitHub] [flink] dannycranmer commented on a change in pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-10-13 Thread GitBox
dannycranmer commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r727937279 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/async/KinesisDataStreamsSinkConfig.java

[GitHub] [flink] flinkbot edited a comment on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-942425244 -- 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

[GitHub] [flink] zentol merged pull request #17051: [FLINK-23978][scala] Move Scala-reliant FieldAccessors to flink-streaming-scala

2021-10-13 Thread GitBox
zentol merged pull request #17051: URL: https://github.com/apache/flink/pull/17051 -- 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] RocMarshal edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-13 Thread GitBox
RocMarshal edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-941932352 @leonardBang @dawidwys 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

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

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-10-13 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r728128460 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/async/KinesisDataStreamsSink.java

[GitHub] [flink-benchmarks] dawidwys commented on a change in pull request #37: [FLINK-24531] Fix connection time out when checking the backpressure

2021-10-13 Thread GitBox
dawidwys commented on a change in pull request #37: URL: https://github.com/apache/flink-benchmarks/pull/37#discussion_r727934259 ## File path: src/main/java/org/apache/flink/benchmark/BackpressureUtils.java ## @@ -65,20 +69,27 @@ static void waitForBackpressure(JobID jobID,

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

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

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

[GitHub] [flink] flinkbot commented on pull request #17462: Metadata fix

2021-10-13 Thread GitBox
flinkbot commented on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 -- 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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17464: [FLINK-24413] Casting to a CHAR() and VARCHAR() doesn't trim the stri…

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17464: URL: https://github.com/apache/flink/pull/17464#issuecomment-942309521 -- 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

[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-13 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] JingGe commented on a change in pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

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

[GitHub] [flink] fapaul commented on pull request #16945: [FLINK-23896][streaming] Implement retrying for failed committables for Sinks

2021-10-13 Thread GitBox
fapaul commented on pull request #16945: URL: https://github.com/apache/flink/pull/16945#issuecomment-941990412 This PR is subsumed by https://issues.apache.org/jira/browse/FLINK-23854 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] RocMarshal removed a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-10-13 Thread GitBox
RocMarshal removed a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-932250048 Thanks @Airblader @MartijnVisser for the review. Hi, @wuchong , @xintongsong @twalthr @pnowojski @fsk119 . Could you help me to merge it if there are nothing

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

2021-10-13 Thread GitBox
flinkbot commented on pull request #17461: URL: https://github.com/apache/flink/pull/17461#issuecomment-941929030 -- 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

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

2021-10-13 Thread GitBox
xintongsong commented on pull request #17461: URL: https://github.com/apache/flink/pull/17461#issuecomment-941990469 -- 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

[GitHub] [flink] dmvk commented on pull request #17402: [FLINK-24017] Setup Kryo to be usable without flink-scala

2021-10-13 Thread GitBox
dmvk commented on pull request #17402: URL: https://github.com/apache/flink/pull/17402#issuecomment-942219867 > We already have plenty of such test-cases. Like the KryoSerializerCompatibilityTest or KryoSerializerRegistrationsTest. Great, the `KryoSerializerRegistrationsTest` seems

[GitHub] [flink] slinkydeveloper commented on pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

2021-10-13 Thread GitBox
slinkydeveloper commented on pull request #17441: URL: https://github.com/apache/flink/pull/17441#issuecomment-942097735 This is ready for another pass. I also tested the sql client manually and it works. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] fapaul closed pull request #16945: [FLINK-23896][streaming] Implement retrying for failed committables for Sinks

2021-10-13 Thread GitBox
fapaul closed pull request #16945: URL: https://github.com/apache/flink/pull/16945 -- 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 #17462: [FLINK-23170] Write metadata after materialization

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 -- 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

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

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 -- 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

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

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

[GitHub] [flink] Airblader commented on a change in pull request #17451: [FLINK-24476][docs] Rename Elasticsearch to remove CamelCase

2021-10-13 Thread GitBox
Airblader commented on a change in pull request #17451: URL: https://github.com/apache/flink/pull/17451#discussion_r728084582 ## File path:

[GitHub] [flink] Jiabao-Sun commented on pull request #17464: [FLINK-24413] Casting to a CHAR() and VARCHAR() doesn't trim the stri…

2021-10-13 Thread GitBox
Jiabao-Sun commented on pull request #17464: URL: https://github.com/apache/flink/pull/17464#issuecomment-942312351 -- 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

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

2021-10-13 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 #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17311: URL: https://github.com/apache/flink/pull/17311#issuecomment-921772935 -- 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

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

2021-10-13 Thread GitBox
fapaul commented on pull request #17459: URL: https://github.com/apache/flink/pull/17459#issuecomment-941991770 @twalthr thanks for your review, I addressed all comments, can you have another look? -- This is an automated message from the Apache Git Service. To respond to the message,

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

2021-10-13 Thread GitBox
xintongsong edited a comment on pull request #17461: URL: https://github.com/apache/flink/pull/17461#issuecomment-942041447 For example, the following seems no longer needed for the given example, since the default is changed to ClusterIP. > When using Minikube, you need to call

[GitHub] [flink] flinkbot commented on pull request #17463: [Hotfix][docs-zh] Fix typo in the 'SHOW COLUMNS' section.

2021-10-13 Thread GitBox
flinkbot commented on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-942081615 -- 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

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

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17459: URL: https://github.com/apache/flink/pull/17459#issuecomment-940996979 -- 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

[GitHub] [flink] matriv commented on pull request #17464: [FLINK-24413] Casting to a CHAR() and VARCHAR() doesn't trim the stri…

2021-10-13 Thread GitBox
matriv commented on pull request #17464: URL: https://github.com/apache/flink/pull/17464#issuecomment-942311469 @Jiabao-Sun I think we should postpone a bit this change until the discussion on the jira issue concludes. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #17419: [FLINK-24460][rocksdb] Rocksdb Iterator Error Handling Improvement

2021-10-13 Thread GitBox
flinkbot edited a comment on pull request #17419: URL: https://github.com/apache/flink/pull/17419#issuecomment-936009567 -- 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

  1   2   3   4   >