[GitHub] [flink] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

jherico commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r716419484 ## File path:

[jira] [Updated] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-24381: - Description: This following is error message. Password is 'bar' and is displayed. Could we hidden it

[GitHub] [flink] qianchutao commented on pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

qianchutao commented on pull request #17358: URL: https://github.com/apache/flink/pull/17358#issuecomment-927601326 @fapaul -- 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

[jira] [Commented] (FLINK-24383) Remove the deprecated SlidingTimeWindows and TumblingTimeWindows.

[ https://issues.apache.org/jira/browse/FLINK-24383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420526#comment-17420526 ] Roc Marshal commented on FLINK-24383: - Hi, [~jark], Could you please assign this ticket to me ?

[jira] [Updated] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed

[ https://issues.apache.org/jira/browse/FLINK-24380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24380: --- Labels: pull-request-available (was: ) > Flink should handle the state transition of the

[jira] [Updated] (FLINK-24377) TM resource may not be properly released after heartbeat timeout

[ https://issues.apache.org/jira/browse/FLINK-24377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24377: --- Labels: pull-request-available (was: ) > TM resource may not be properly released after

[jira] [Commented] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format

[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420556#comment-17420556 ] Martijn Visser commented on FLINK-20454: [~caozhen1937] Do you still want to work on this task?

[jira] [Commented] (FLINK-24385) Add TRY_CAST function to be able to handle errors

[ https://issues.apache.org/jira/browse/FLINK-24385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420564#comment-17420564 ] Ingo Bürk commented on FLINK-24385: --- While MySQL has a TRY_CAST as proposed here, in Oracle there

[GitHub] [flink] flinkbot commented on pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

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

[GitHub] [flink-web] joemoe commented on a change in pull request #468: Release blog post 1.14 draft iteration

joemoe commented on a change in pull request #468: URL: https://github.com/apache/flink-web/pull/468#discussion_r716588518 ## File path: _posts/2021-09-21-release-1.14.0.md ## @@ -0,0 +1,274 @@ +--- +layout: post +title: "Apache Flink 1.14.0 Release Announcement" +date:

[GitHub] [flink] flinkbot commented on pull request #17364: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

flinkbot commented on pull request #17364: URL: https://github.com/apache/flink/pull/17364#issuecomment-927778695 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 #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

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

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

flinkbot edited a comment on pull request #17360: URL: https://github.com/apache/flink/pull/17360#issuecomment-927544424 ## CI report: * d364ab24be51b23c260be42ddac97690384279ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

flinkbot edited a comment on pull request #17363: URL: https://github.com/apache/flink/pull/17363#issuecomment-927758743 ## CI report: * cc51de6fac70261acfaa5bb2d1c86ae3a704ae45 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

rkhachatryan commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r716640216 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ##

[GitHub] [flink-web] StephanEwen commented on pull request #468: Release blog post 1.14 draft iteration

StephanEwen commented on pull request #468: URL: https://github.com/apache/flink-web/pull/468#issuecomment-927740714 Thanks, everyone for the comments, I am incorporating them now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-web] StephanEwen closed pull request #466: Add Apache Flink release 1.14.0

StephanEwen closed pull request #466: URL: https://github.com/apache/flink-web/pull/466 -- 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-web] StephanEwen commented on pull request #466: Add Apache Flink release 1.14.0

StephanEwen commented on pull request #466: URL: https://github.com/apache/flink-web/pull/466#issuecomment-927740746 Closed, because this is now subsumed by #468 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[GitHub] [flink-web] StephanEwen commented on a change in pull request #468: Release blog post 1.14 draft iteration

StephanEwen commented on a change in pull request #468: URL: https://github.com/apache/flink-web/pull/468#discussion_r716576155 ## File path: _posts/2021-09-21-release-1.14.0.md ## @@ -0,0 +1,274 @@ +--- +layout: post +title: "Apache Flink 1.14.0 Release Announcement" +date:

[GitHub] [flink-web] StephanEwen commented on a change in pull request #468: Release blog post 1.14 draft iteration

StephanEwen commented on a change in pull request #468: URL: https://github.com/apache/flink-web/pull/468#discussion_r716575894 ## File path: _posts/2021-09-21-release-1.14.0.md ## @@ -0,0 +1,274 @@ +--- +layout: post +title: "Apache Flink 1.14.0 Release Announcement" +date:

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420672#comment-17420672 ] Igal Shilman commented on FLINK-22533: -- Hi [~nferrario], I'd like to try and make it up for the

[jira] [Commented] (FLINK-16024) support filter pushdown in jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420674#comment-17420674 ] ranqiqiang commented on FLINK-16024: support  sql filter by self, hope to use hint /* */ .

[jira] [Created] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator

David Morávek created FLINK-24386: - Summary: JobMaster should guard against exceptions from OperatorCoordinator Key: FLINK-24386 URL: https://issues.apache.org/jira/browse/FLINK-24386 Project: Flink

[GitHub] [flink] AHeise commented on a change in pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

AHeise commented on a change in pull request #17351: URL: https://github.com/apache/flink/pull/17351#discussion_r716633195 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink/SinkWriter.java ## @@ -63,6 +63,9 @@ default void writeWatermark(Watermark

[GitHub] [flink] AHeise commented on a change in pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

AHeise commented on a change in pull request #17351: URL: https://github.com/apache/flink/pull/17351#discussion_r716633195 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink/SinkWriter.java ## @@ -63,6 +63,9 @@ default void writeWatermark(Watermark

[GitHub] [flink] AHeise commented on a change in pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

AHeise commented on a change in pull request #17351: URL: https://github.com/apache/flink/pull/17351#discussion_r716633917 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink/SinkWriter.java ## @@ -63,6 +63,9 @@ default void writeWatermark(Watermark

[GitHub] [flink-ml] gaoyunhaii opened a new pull request #8: [FLINK-4][iteration] Add operator wrapper for all-round iterations.

gaoyunhaii opened a new pull request #8: URL: https://github.com/apache/flink-ml/pull/8 This PR adds operator wrapper for all-round iterations. For such kind of iteration, one user operator would live across the whole period of the iteration. The wrapper operator would process the epoch

[GitHub] [flink] fapaul commented on a change in pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

fapaul commented on a change in pull request #17351: URL: https://github.com/apache/flink/pull/17351#discussion_r716397622 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/NoopCommitterHandler.java ## @@ -34,7 +34,8 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

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

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

slinkydeveloper commented on a change in pull request #17350: URL: https://github.com/apache/flink/pull/17350#discussion_r716431275 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/AbstractFileSystemTable.java ## @@ -59,15 +68,19

[jira] [Commented] (FLINK-24384) Count checkpoints failed in trigger phase into numberOfFailedCheckpoints

[ https://issues.apache.org/jira/browse/FLINK-24384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420557#comment-17420557 ] Feifan Wang commented on FLINK-24384: - Hi [~uce], would you like hive a look at this proposal ? >

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r716486324 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[GitHub] [flink-benchmarks] dawidwys commented on a change in pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate

dawidwys commented on a change in pull request #32: URL: https://github.com/apache/flink-benchmarks/pull/32#discussion_r716504290 ## File path: src/main/java/org/apache/flink/benchmark/BufferDebloatedCheckpointTimeBenchmark.java ## @@ -0,0 +1,261 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-24385) Add TRY_CAST function to be able to handle errors

[ https://issues.apache.org/jira/browse/FLINK-24385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420595#comment-17420595 ] Timo Walther commented on FLINK-24385: -- +1 for {{TRY_CAST}}. The Oracle syntax seems pretty verbose

[jira] [Closed] (FLINK-24378) Dim table join operator Push down

[ https://issues.apache.org/jira/browse/FLINK-24378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24378. Resolution: Duplicate Please correct me if I'm wrong but this looks like a duplicate of

[GitHub] [flink] flinkbot edited a comment on pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

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

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r716522297 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java ## @@

[jira] [Comment Edited] (FLINK-24293) Tasks from the same job on a machine share user jar

[ https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420605#comment-17420605 ] huntercc edited comment on FLINK-24293 at 9/27/21, 11:50 AM: - I don't think

[jira] [Assigned] (FLINK-24327) Integrate new Sinks with Table API

[ https://issues.apache.org/jira/browse/FLINK-24327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-24327: --- Assignee: Alexander Preuss (was: Fabian Paul) > Integrate new Sinks with Table API >

[jira] [Updated] (FLINK-24327) Integrate Elasticsearch 7 sink with Table API

[ https://issues.apache.org/jira/browse/FLINK-24327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24327: Summary: Integrate Elasticsearch 7 sink with Table API (was: Integrate new Sinks with Table API)

[GitHub] [flink] flinkbot edited a comment on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

flinkbot edited a comment on pull request #17351: URL: https://github.com/apache/flink/pull/17351#issuecomment-926586520 ## CI report: * 050cc583fbf1a19ec41aad97cdc6f7c81403 Azure:

[GitHub] [flink] flinkbot commented on pull request #17364: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

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

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420714#comment-17420714 ] Nicolas Ferrario commented on FLINK-22533: -- Hi [~igal], That'd be sweet!! We're just using

[jira] [Assigned] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-22533: Assignee: Igal Shilman > Allow creating custom metrics > - >

[GitHub] [flink] fapaul opened a new pull request #17364: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

fapaul opened a new pull request #17364: URL: https://github.com/apache/flink/pull/17364 Unchanged backport of #17351 -- 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] rkhachatryan commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

rkhachatryan commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r716642699 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java

[GitHub] [flink-benchmarks] dawidwys commented on a change in pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate

dawidwys commented on a change in pull request #32: URL: https://github.com/apache/flink-benchmarks/pull/32#discussion_r716642820 ## File path: src/main/java/org/apache/flink/benchmark/BufferDebloatedCheckpointTimeBenchmark.java ## @@ -0,0 +1,261 @@ +/* + * Licensed to the

[GitHub] [flink] rkhachatryan commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

rkhachatryan commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r716642699 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java

[GitHub] [flink] flinkbot edited a comment on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

flinkbot edited a comment on pull request #17351: URL: https://github.com/apache/flink/pull/17351#issuecomment-926586520 ## CI report: * 050cc583fbf1a19ec41aad97cdc6f7c81403 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

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

[GitHub] [flink] flinkbot edited a comment on pull request #17364: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

flinkbot edited a comment on pull request #17364: URL: https://github.com/apache/flink/pull/17364#issuecomment-927811962 ## CI report: * b7253293dc0838d6dca2f2bd72c060f914b3477d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout.

flinkbot edited a comment on pull request #17362: URL: https://github.com/apache/flink/pull/17362#issuecomment-927655340 ## CI report: * 836d2fab45fb6708abb8cdd184d72cf8a7fd2e15 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

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

[GitHub] [flink] fapaul commented on a change in pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

fapaul commented on a change in pull request #17351: URL: https://github.com/apache/flink/pull/17351#discussion_r716585011 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink/SinkWriter.java ## @@ -63,6 +63,9 @@ default void writeWatermark(Watermark

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[GitHub] [flink] Airblader commented on pull request #17325: [FLINK-24197] fix WEB UI build failure on windows

Airblader commented on pull request #17325: URL: https://github.com/apache/flink/pull/17325#issuecomment-927805850 The PR title / commit message seem to reference the wrong JIRA issue? -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-benchmarks] pnowojski commented on a change in pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate

pnowojski commented on a change in pull request #32: URL: https://github.com/apache/flink-benchmarks/pull/32#discussion_r716635529 ## File path: src/main/java/org/apache/flink/benchmark/BufferDebloatedCheckpointTimeBenchmark.java ## @@ -0,0 +1,261 @@ +/* + * Licensed to the

[GitHub] [flink] fapaul commented on a change in pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

fapaul commented on a change in pull request #17351: URL: https://github.com/apache/flink/pull/17351#discussion_r716639035 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink/SinkWriter.java ## @@ -63,6 +63,9 @@ default void writeWatermark(Watermark

[GitHub] [flink] flinkbot edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

flinkbot edited a comment on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692 ## CI report: * 92bef8d45d7ef5bc445fdd40d30ee1dfcc36b42d Azure:

[GitHub] [flink] MartijnVisser commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

MartijnVisser commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-927836453 @NickBurkard I think the CI failed due to https://github.com/apache/flink/pull/17359 so it probably needs another rebase. -- This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

flinkbot commented on pull request #17360: URL: https://github.com/apache/flink/pull/17360#issuecomment-927534884 -- 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 #17359: [FLINK-24358] Fix glue schema e2e dependency convergence

flinkbot edited a comment on pull request #17359: URL: https://github.com/apache/flink/pull/17359#issuecomment-927544368 ## CI report: * 910e824bcd51230c9de6502e5c79b915682f6dda Azure:

[GitHub] [flink] flinkbot commented on pull request #17359: [FLINK-24358] Fix glue schema e2e dependency convergence

flinkbot commented on pull request #17359: URL: https://github.com/apache/flink/pull/17359#issuecomment-927534912 -- 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] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

jherico commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r716423444 ## File path:

[GitHub] [flink] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

jherico commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r716423291 ## File path:

[GitHub] [flink] Airblader commented on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-927608002 Thanks! That's good to know, and clearly not how flink-table currently seems to do it. Would it make sense to enforce that _all_ (public?) classes (maybe except for a

[GitHub] [flink] KarmaGYZ opened a new pull request #17361: [FLINK-24380][k8s] Terminate the pod if it failed

KarmaGYZ opened a new pull request #17361: URL: https://github.com/apache/flink/pull/17361 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] xintongsong opened a new pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout.

xintongsong opened a new pull request #17362: URL: https://github.com/apache/flink/pull/17362 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[jira] [Updated] (FLINK-24237) Consider disabling or lowering DNS caching timeout in docker image

[ https://issues.apache.org/jira/browse/FLINK-24237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24237: -- Description: A recent [blog post|https://mux.com/blog/5-years-of-flink-at-mux/] by Mux

[jira] [Commented] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420597#comment-17420597 ] Roman Khachatryan commented on FLINK-24207: --- That's an interesting idea, however I have some

[jira] [Assigned] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-24381: - Assignee: Ada Wong > Hidden password value when Flink SQL connector throw exception. >

[jira] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420635#comment-17420635 ] Chesnay Schepler commented on FLINK-24381: -- I think adding ConfigOption#isSecret is an

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * 1b7da8565a2ab9560f1aad65007930c91945087f UNKNOWN *

[jira] [Comment Edited] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420492#comment-17420492 ] Arvid Heise edited comment on FLINK-24207 at 9/27/21, 6:06 AM: --- I'm a bit

[jira] [Commented] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420492#comment-17420492 ] Arvid Heise commented on FLINK-24207: - I'm a bit torn on this one. It sounds like a reasonable idea.

[GitHub] [flink] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

jherico commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r716424797 ## File path: flink-formats/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryAvroOptions.java

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

flinkbot edited a comment on pull request #17360: URL: https://github.com/apache/flink/pull/17360#issuecomment-927544424 ## CI report: * Unknown: [CANCELED](TBD) * d364ab24be51b23c260be42ddac97690384279ac UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

slinkydeveloper commented on a change in pull request #17350: URL: https://github.com/apache/flink/pull/17350#discussion_r716445907 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/AbstractFileSystemTable.java ## @@ -59,15 +68,19

[jira] [Commented] (FLINK-24290) Support STRUCTURED_TYPE for JSON_OBJECT / JSON_ARRAY

[ https://issues.apache.org/jira/browse/FLINK-24290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420547#comment-17420547 ] Timo Walther commented on FLINK-24290: -- Why is a UDF not working to avoid the issue with

[GitHub] [flink] flinkbot edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

flinkbot edited a comment on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692 ## CI report: * 98fac3d3a2b3e3c79cbea8625625faee50b16de8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17351: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available

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

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

flinkbot edited a comment on pull request #17360: URL: https://github.com/apache/flink/pull/17360#issuecomment-927544424 ## CI report: * Unknown: [CANCELED](TBD) * d364ab24be51b23c260be42ddac97690384279ac Azure:

[GitHub] [flink] flinkbot commented on pull request #17361: [FLINK-24380][k8s] Terminate the pod if it failed

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

[GitHub] [flink] SteNicholas commented on pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

SteNicholas commented on pull request #17105: URL: https://github.com/apache/flink/pull/17105#issuecomment-927684054 > @SteNicholas, as there was no activity here and we would like to have this this issue fixed, we will take this over in the next couple of days. I'm updating the

[GitHub] [flink] SteNicholas edited a comment on pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

SteNicholas edited a comment on pull request #17105: URL: https://github.com/apache/flink/pull/17105#issuecomment-927684054 > @SteNicholas, as there was no activity here and we would like to have this this issue fixed, we will take this over in the next couple of days. @pnowojski

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r716522297 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java ## @@

[jira] [Updated] (FLINK-24324) Create ElasticSearch 7 Sink

[ https://issues.apache.org/jira/browse/FLINK-24324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24324: --- Labels: pull-request-available (was: ) > Create ElasticSearch 7 Sink >

[jira] [Assigned] (FLINK-24324) Create ElasticSearch 7 Sink

[ https://issues.apache.org/jira/browse/FLINK-24324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-24324: --- Assignee: Fabian Paul (was: Alexander Preuss) > Create ElasticSearch 7 Sink >

[GitHub] [flink-benchmarks] dawidwys commented on a change in pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate

dawidwys commented on a change in pull request #32: URL: https://github.com/apache/flink-benchmarks/pull/32#discussion_r716553975 ## File path: src/main/java/org/apache/flink/benchmark/BufferDebloatedCheckpointTimeBenchmark.java ## @@ -0,0 +1,261 @@ +/* + * Licensed to the

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

RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-927241423 @alpinegizmo @dawidwys Could you help me to review this PR ? Thank you very much. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] jherico commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

jherico commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r716419119 ## File path: flink-formats/flink-avro-glue-schema-registry/pom.xml ## @@ -178,5 +192,33 @@ under the License.

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

slinkydeveloper commented on a change in pull request #17350: URL: https://github.com/apache/flink/pull/17350#discussion_r716418986 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSource.java ## @@ -164,7 +167,7 @@

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

slinkydeveloper commented on a change in pull request #17350: URL: https://github.com/apache/flink/pull/17350#discussion_r716431275 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/AbstractFileSystemTable.java ## @@ -59,15 +68,19

[GitHub] [flink] twalthr commented on a change in pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

twalthr commented on a change in pull request #17186: URL: https://github.com/apache/flink/pull/17186#discussion_r716450218 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java ## @@

[GitHub] [flink] flinkbot commented on pull request #17362: [FLINK-24377][runtime] Fix TM potentially not released after heartbeat timeout.

flinkbot commented on pull request #17362: URL: https://github.com/apache/flink/pull/17362#issuecomment-927632144 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 #17361: [FLINK-24380][k8s] Terminate the pod if it failed

flinkbot commented on pull request #17361: URL: https://github.com/apache/flink/pull/17361#issuecomment-927632169 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-24379) AWS Glue Schema Registry support doesn't work for table API

[ https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420560#comment-17420560 ] Danny Cranmer commented on FLINK-24379: --- Yep I can take a look > AWS Glue Schema Registry support

[jira] [Commented] (FLINK-21582) COALESCE not works when cast a variable return null

[ https://issues.apache.org/jira/browse/FLINK-21582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420561#comment-17420561 ] Francesco Guardiani commented on FLINK-21582: - Links to

[jira] [Commented] (FLINK-24290) Support STRUCTURED_TYPE for JSON_OBJECT / JSON_ARRAY

[ https://issues.apache.org/jira/browse/FLINK-24290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420574#comment-17420574 ] Ingo Bürk commented on FLINK-24290: --- `fromValues(AbstractDataType, Iterable)` calls

  1   2   3   4   >