[GitHub] [flink] flinkbot edited a comment on pull request #18478: [FLINK-25787][flink-connector-gcp-pubsub] Adding endpoint support in Pubsub Source / Sink

flinkbot edited a comment on pull request #18478: URL: https://github.com/apache/flink/pull/18478#issuecomment-1020156897 ## CI report: * 7d269e64204469eb03c1b102f44a5930ceb45d62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18478: [FLINK-25787][flink-connector-gcp-pubsub] Adding endpoint support in Pubsub Source / Sink

flinkbot edited a comment on pull request #18478: URL: https://github.com/apache/flink/pull/18478#issuecomment-1020156897 ## CI report: * 7d269e64204469eb03c1b102f44a5930ceb45d62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18478: [FLINK-25787][flink-connector-gcp-pubsub] Adding endpoint support in Pubsub Source / Sink

flinkbot edited a comment on pull request #18478: URL: https://github.com/apache/flink/pull/18478#issuecomment-1020156897 ## CI report: * 7d269e64204469eb03c1b102f44a5930ceb45d62 Azure:

[GitHub] [flink] iammehrabalam commented on pull request #18478: [FLINK-25787][flink-connector-gcp-pubsub] Adding endpoint support in Pubsub Source / Sink

iammehrabalam commented on pull request #18478: URL: https://github.com/apache/flink/pull/18478#issuecomment-1030563576 @flinkbot run azure -- 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

[jira] [Updated] (FLINK-25787) Adding endpoint support in Pubsub Source / Sink

[ https://issues.apache.org/jira/browse/FLINK-25787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Md Mehrab Alam updated FLINK-25787: --- Priority: Not a Priority (was: Major) > Adding endpoint support in Pubsub Source / Sink >

[jira] [Comment Edited] (FLINK-24881) When the Source is back pressured, the checkpoint interval may not take effect

[ https://issues.apache.org/jira/browse/FLINK-24881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487418#comment-17487418 ] Ken Burford edited comment on FLINK-24881 at 2/5/22, 4:37 AM: -- I just

[jira] [Commented] (FLINK-24881) When the Source is back pressured, the checkpoint interval may not take effect

[ https://issues.apache.org/jira/browse/FLINK-24881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487418#comment-17487418 ] Ken Burford commented on FLINK-24881: - I just recently migrated from Flink 1.11 to 1.14, and I

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

[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487402#comment-17487402 ] Yuan Zhu commented on FLINK-18779: -- Hi [~godfreyhe] , I have fixed the conflicts of this pr. Since it

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 68b185ec99cc4db97323f2b5b09b4d17e09ac80d Azure:

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * c0e55f59361c6d0dc7d27c1f3142a69a2cf7ff61 Azure:

[jira] [Updated] (FLINK-25964) Support shipping extra local files/jars to job/task manager classpaths

[ https://issues.apache.org/jira/browse/FLINK-25964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenya Zhang updated FLINK-25964: - Description: There is no direct support on shipping extra local files/jars to job/task manager

[jira] [Created] (FLINK-25964) Support shipping extra local files/jars to job/task manager classpaths

Chenya Zhang created FLINK-25964: Summary: Support shipping extra local files/jars to job/task manager classpaths Key: FLINK-25964 URL: https://issues.apache.org/jira/browse/FLINK-25964 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #18634: [FLINK-25961] [connectors] Remove transport client from Elasticsearch/7 connectors (tests only)

flinkbot edited a comment on pull request #18634: URL: https://github.com/apache/flink/pull/18634#issuecomment-1030113756 ## CI report: * 2103f20e2da227fed57cd414a620ea948ce03da7 Azure:

[jira] [Updated] (FLINK-25963) FLIP-212: Introduce Flink Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-25963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-25963: - Description:

[jira] [Created] (FLINK-25963) FLIP-212: Introduce Flink Kubernetes Operator

Thomas Weise created FLINK-25963: Summary: FLIP-212: Introduce Flink Kubernetes Operator Key: FLINK-25963 URL: https://issues.apache.org/jira/browse/FLINK-25963 Project: Flink Issue Type:

[GitHub] [flink-statefun-playground] nathantalewis commented on a change in pull request #17: Fix the Kubernetes example

nathantalewis commented on a change in pull request #17: URL: https://github.com/apache/flink-statefun-playground/pull/17#discussion_r799861406 ## File path: deployments/k8s/04-statefun/00-module.yaml ## @@ -5,11 +5,12 @@ metadata: name: module-config data:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 77fbe04fbc3f73a2dab1900d82bbff620b3734d6 Azure:

[jira] [Updated] (FLINK-4860) Sort performance

[ https://issues.apache.org/jira/browse/FLINK-4860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4860: -- Labels: auto-deprioritized-major performance stale-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-10381) concurrent submit job get ProgramAbortException

[ https://issues.apache.org/jira/browse/FLINK-10381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10381: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-13113) Introduce range partition in blink

[ https://issues.apache.org/jira/browse/FLINK-13113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13113: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-13251) Add bandwidth throttling for checkpoint uploading/downloading

[ https://issues.apache.org/jira/browse/FLINK-13251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13251: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-8277) Optimize code generation by using local references

[ https://issues.apache.org/jira/browse/FLINK-8277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8277: -- Labels: auto-deprioritized-major auto-unassigned stale-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-13038) CEP WITHIN don’t support interval expression

[ https://issues.apache.org/jira/browse/FLINK-13038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13038: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-19015) java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15'

[ https://issues.apache.org/jira/browse/FLINK-19015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19015: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18808: --- Labels: pull-request-available stale-assigned usability (was: pull-request-available

[jira] [Updated] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20614: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor

[jira] [Updated] (FLINK-16320) Can not use sub-queries in the VALUES clause

[ https://issues.apache.org/jira/browse/FLINK-16320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16320: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-5151) Add discussion about object mutations to heap-based state backend docs.

[ https://issues.apache.org/jira/browse/FLINK-5151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5151: -- Labels: auto-deprioritized-major stale-assigned (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17196: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-18894) StateFun job stalls on stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18894: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor

[jira] [Updated] (FLINK-21223) Support to specify the input/output types of Python UDFs via string

[ https://issues.apache.org/jira/browse/FLINK-21223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21223: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20696: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-15294) Migrate CustomCommandLine to Executor abstraction

[ https://issues.apache.org/jira/browse/FLINK-15294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15294: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-19008) Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb)

[ https://issues.apache.org/jira/browse/FLINK-19008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19008: --- Labels: auto-deprioritized-major auto-deprioritized-minor perfomance stale-assigned

[jira] [Updated] (FLINK-18717) reuse MiniCluster in table integration test class ?

[ https://issues.apache.org/jira/browse/FLINK-18717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18717: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-15472) Support SQL Client Gateway

[ https://issues.apache.org/jira/browse/FLINK-15472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15472: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-19571) Port Transformation translation logic to TransformationTranslator framework

[ https://issues.apache.org/jira/browse/FLINK-19571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19571: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-20983) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce failed with Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/FLINK-20983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20983: --- Labels: auto-deprioritized-major auto-deprioritized-minor stale-assigned (was:

[jira] [Updated] (FLINK-21565) Support more integer types in TIMESTAMPADD

[ https://issues.apache.org/jira/browse/FLINK-21565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21565: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available

[jira] [Updated] (FLINK-21000) set MetricGroup in SourceCoordinatorContext

[ https://issues.apache.org/jira/browse/FLINK-21000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21000: --- Labels: auto-deprioritized-major auto-deprioritized-minor stale-assigned (was:

[jira] [Updated] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22765: --- Labels: pull-request-available stale-assigned test-stability (was: pull-request-available

[GitHub] [flink] flinkbot edited a comment on pull request #18636: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

flinkbot edited a comment on pull request #18636: URL: https://github.com/apache/flink/pull/18636#issuecomment-1030205943 ## CI report: * 15b25db33ff093a8ce46f3b40eea81cfaf1d084c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 73c9d94b434c6084f7307019ed55759ade49d738 Azure:

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 73c9d94b434c6084f7307019ed55759ade49d738 Azure:

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 73c9d94b434c6084f7307019ed55759ade49d738 Azure:

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 73c9d94b434c6084f7307019ed55759ade49d738 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18635: [FLINK-25962][format-avro] Use namespaces for generated records

flinkbot edited a comment on pull request #18635: URL: https://github.com/apache/flink/pull/18635#issuecomment-1030202679 ## CI report: * 10d2f4e7fc4e70aa4a63e319de0eb946bbe09b5d Azure:

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 73c9d94b434c6084f7307019ed55759ade49d738 Azure:

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 73c9d94b434c6084f7307019ed55759ade49d738 Azure:

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

syhily edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-1030376275 > The only concern is my limited knowledge of Pulsar transactions. Maybe you can clarify the following scenarios. > > The job opens a transaction and sends records,

[GitHub] [flink] flinkbot edited a comment on pull request #18634: [FLINK-25961] [connectors] Remove transport client from Elasticsearch/7 connectors (tests only)

flinkbot edited a comment on pull request #18634: URL: https://github.com/apache/flink/pull/18634#issuecomment-1030113756 ## CI report: * f67189f894705d2092d9c294ab7e6f043feeaee4 Azure:

[GitHub] [flink] syhily commented on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily commented on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-1030376275 > The only concern is my limited knowledge of Pulsar transactions. Maybe you can clarify the following scenarios. > > The job opens a transaction and sends records, now

[GitHub] [flink] flinkbot edited a comment on pull request #18634: [FLINK-25961] [connectors] Remove transport client from Elasticsearch/7 connectors (tests only)

flinkbot edited a comment on pull request #18634: URL: https://github.com/apache/flink/pull/18634#issuecomment-1030113756 ## CI report: * f67189f894705d2092d9c294ab7e6f043feeaee4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18632: [FLINK-24446][table] Fix STRING to TIMESTAMP casting

flinkbot edited a comment on pull request #18632: URL: https://github.com/apache/flink/pull/18632#issuecomment-1030032332 ## CI report: * f15b942f980b24aeef8f36d8d2a3b12e7194ef1c Azure:

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r799821744 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java ## @@ -0,0 +1,203 @@

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 73c9d94b434c6084f7307019ed55759ade49d738 Azure:

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

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 73c9d94b434c6084f7307019ed55759ade49d738 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18611: [FLINK-24385][table] Introduce TRY_CAST

flinkbot edited a comment on pull request #18611: URL: https://github.com/apache/flink/pull/18611#issuecomment-1028155639 ## CI report: * b9037070f0b8ac12c3e1ef1800ea323329580a1f Azure:

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r799721320 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/TopicProducerRegister.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18632: [FLINK-24446][table] Fix STRING to TIMESTAMP casting

flinkbot edited a comment on pull request #18632: URL: https://github.com/apache/flink/pull/18632#issuecomment-1030032332 ## CI report: * d0fb2353c633876f21348580243ea4eddd45db07 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18627: [FLINK-25955][runtime] Introduces `JobManagerRunner` implementation for cleanup

flinkbot edited a comment on pull request #18627: URL: https://github.com/apache/flink/pull/18627#issuecomment-1029768577 ## CI report: * 04d1b72cffce9e99b0f6cd98eac1015c7fec4a4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18634: [FLINK-25961] [connectors] Remove transport client from Elasticsearch/7 connectors (tests only)

flinkbot edited a comment on pull request #18634: URL: https://github.com/apache/flink/pull/18634#issuecomment-1030113756 ## CI report: * f67189f894705d2092d9c294ab7e6f043feeaee4 Azure:

[jira] [Updated] (FLINK-21763) Extend Data Stream's batch mode to handle partitioning/grouping/ordering

[ https://issues.apache.org/jira/browse/FLINK-21763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-21763: -- Description: In the DataSet API, an undocumented (?) feature is using

[jira] [Commented] (FLINK-25924) KDF Integration tests intermittently fails

[ https://issues.apache.org/jira/browse/FLINK-25924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487292#comment-17487292 ] Danny Cranmer commented on FLINK-25924: --- Merged a fix for this (not the disk space issue, but

[jira] [Resolved] (FLINK-25924) KDF Integration tests intermittently fails

[ https://issues.apache.org/jira/browse/FLINK-25924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-25924. --- Resolution: Fixed > KDF Integration tests intermittently fails >

[jira] [Updated] (FLINK-25924) KDF Integration tests intermittently fails

[ https://issues.apache.org/jira/browse/FLINK-25924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-25924: -- Affects Version/s: (was: 1.15.0) > KDF Integration tests intermittently fails >

[GitHub] [flink] dannycranmer merged pull request #18633: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

dannycranmer merged pull request #18633: URL: https://github.com/apache/flink/pull/18633 -- 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] dannycranmer commented on pull request #18633: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

dannycranmer commented on pull request #18633: URL: https://github.com/apache/flink/pull/18633#issuecomment-1030320590 LGTM, as discussed @CrynetLogistics we will follow up and migrate the AWS SDK clients to sync for the tests -- This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot edited a comment on pull request #18626: [FLINK-25953][FLINK-25954] Updates and reorganizes tests around Dispatcher cleanup

flinkbot edited a comment on pull request #18626: URL: https://github.com/apache/flink/pull/18626#issuecomment-1029753226 ## CI report: * 7ae337c4b44f06872408a346941f12d761d6bf90 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18621: [FLINK-25932][table-planner] Add deterministic uid to every Transformation created by StreamExecNode

flinkbot edited a comment on pull request #18621: URL: https://github.com/apache/flink/pull/18621#issuecomment-1029064847 ## CI report: * 6237b7cf6c423d2aabefb979bfe00acf81f0841f Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid confi

dannycranmer commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r799775583 ## File path: flink-connectors/flink-connector-kinesis/pom.xml ## @@ -316,6 +316,7 @@ under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #18424: [FLINK-24439][source] Introduce CoordinatorStore

flinkbot edited a comment on pull request #18424: URL: https://github.com/apache/flink/pull/18424#issuecomment-1017555030 ## CI report: * d3dcfcffac98667f84535dff9d14451f8a17b78e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18606: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

flinkbot edited a comment on pull request #18606: URL: https://github.com/apache/flink/pull/18606#issuecomment-1027976880 ## CI report: * 14dd5cd1c62e0102c72c16f24d87f5a657842848 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18611: [FLINK-24385][table] Introduce TRY_CAST

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

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

flinkbot edited a comment on pull request #18545: URL: https://github.com/apache/flink/pull/18545#issuecomment-1023486118 ## CI report: * c980367f580fefaa6e1024ece67b46326302ca46 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18633: [FLINK-25924][connectors/firehose] Adding a timeout for the Localstac…

flinkbot edited a comment on pull request #18633: URL: https://github.com/apache/flink/pull/18633#issuecomment-1030057483 ## CI report: * bc7ba89f45840f3dbac8b8d34db4761053bf65c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r799738018 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer/PulsarSchemaWrapper.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18611: [FLINK-24385][table] Introduce TRY_CAST

flinkbot edited a comment on pull request #18611: URL: https://github.com/apache/flink/pull/18611#issuecomment-1028155639 ## CI report: * 76f8ace20030e26105ee6a47f156aa80a401b375 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r799731961 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer/PulsarSchemaWrapper.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * ffa1f8798973aa2f4065b278bd7762dd12aa508c Azure:

[GitHub] [flink] XComp commented on a change in pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

XComp commented on a change in pull request #18637: URL: https://github.com/apache/flink/pull/18637#discussion_r799721299 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleaner.java ## @@ -21,42 +21,64 @@ import

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r799721320 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/TopicProducerRegister.java ## @@

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r799719291 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/TopicProducerRegister.java ## @@

[GitHub] [flink] syhily commented on a change in pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily commented on a change in pull request #17452: URL: https://github.com/apache/flink/pull/17452#discussion_r799718395 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java ## @@ -0,0 +1,203 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 8a41b3e09adcf8d5df95af4cd420e3330c91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

flinkbot edited a comment on pull request #18624: URL: https://github.com/apache/flink/pull/18624#issuecomment-1029176049 ## CI report: * 286e07dee07327966f12ae7011bb5c24cd3eae58 Azure:

[jira] [Resolved] (FLINK-25578) Graduate Sink V1 interfaces to PublicEvolving and deprecate them

[ https://issues.apache.org/jira/browse/FLINK-25578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-25578. - Fix Version/s: 1.15.0 Resolution: Fixed > Graduate Sink V1 interfaces to PublicEvolving

[jira] [Commented] (FLINK-25578) Graduate Sink V1 interfaces to PublicEvolving and deprecate them

[ https://issues.apache.org/jira/browse/FLINK-25578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487225#comment-17487225 ] Fabian Paul commented on FLINK-25578: - Merged in master: 5f4659f3fdc22bec8ec98a7818e1cff8e11c2513 >

[GitHub] [flink] XComp commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

XComp commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1030245339 FYI: FLINK-25433 is not considered to be blocked by the efforts of this PR after re-evaluating the problem.  -- This is an automated message from the Apache Git Service. To

  1   2   3   4   5   6   >