[jira] [Updated] (FLINK-25266) StreamingKafkaITCase fails with incorrect number of messages

[ https://issues.apache.org/jira/browse/FLINK-25266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25266: Labels: test-stability (was: ) > StreamingKafkaITCase fails with incorrect number of messages >

[jira] [Updated] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25210: Labels: test-stability (was: ) > PulsarSource(Un)OrderedE2ECase is broken >

[jira] [Assigned] (FLINK-25144) Manual test

[ https://issues.apache.org/jira/browse/FLINK-25144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-25144: - Assignee: Roman Khachatryan > Manual test > --- > >

[GitHub] [flink] flinkbot edited a comment on pull request #18099: [FLINK-25294][python] Fix cloudpickle import

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] AHeise commented on a change in pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

AHeise commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r768390735 ## File path: flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/avro/Datum.java ## @@ -0,0 +1,55 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #18099: [FLINK-25294][python] Fix cloudpickle import

flinkbot commented on pull request #18099: URL: https://github.com/apache/flink/pull/18099#issuecomment-993247041 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-25240) Update log4j2 version to 2.15.0

[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458964#comment-17458964 ] João Boto commented on FLINK-25240: --- new version of log4j is available (2.16.0) that fully disables

[GitHub] [flink] AHeise commented on a change in pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

AHeise commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r768390250 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/StreamFormat.java ## @@ -157,6 +166,88 @@

[GitHub] [flink] dmvk edited a comment on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

dmvk edited a comment on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-993245732 There are still places in CI scripts where the version needs to be bumped: - There is another entry in `azure-pipelines.yml` - Multiple entries in

[GitHub] [flink] flinkbot commented on pull request #18099: [FLINK-25294][python] Fix cloudpickle import

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

[GitHub] [flink] dmvk commented on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

dmvk commented on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-993245732 There are still places in CI scripts where the version needs to be bumped: - There is another entry in `azure-pipelines.yml` - Multiple entries in `build-apache-repo.yml` [1]

[GitHub] [flink] AHeise commented on a change in pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

AHeise commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r768389463 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetReaders.java ## @@ -0,0 +1,94 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * f68137e6e62deb0c765833d8ebdcefea357b01eb Azure:

[GitHub] [flink] AHeise commented on a change in pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

AHeise commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r768389182 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -0,0 +1,236 @@ +/* + *

[jira] [Updated] (FLINK-25294) Incorrect cloudpickle import

[ https://issues.apache.org/jira/browse/FLINK-25294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25294: --- Labels: pull-request-available (was: ) > Incorrect cloudpickle import >

[GitHub] [flink] siavash119 opened a new pull request #18099: [FLINK-25294][python] Fix cloudpickle import

siavash119 opened a new pull request #18099: URL: https://github.com/apache/flink/pull/18099 ## What is the purpose of the change Fixes [FLINK-25294](https://issues.apache.org/jira/browse/FLINK-25294) Incorrect cloudpickle import possibly left over when fixing incorrect cloudpickle

[GitHub] [flink] AHeise commented on a change in pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

AHeise commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r768387795 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -0,0 +1,236 @@ +/* + *

[jira] [Updated] (FLINK-25292) Azure failed due to unable to fetch some archives

[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25292: -- Priority: Critical (was: Major) > Azure failed due to unable to fetch some archives >

[jira] [Comment Edited] (FLINK-25132) KafkaSource cannot work with object-reusing DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-25132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458963#comment-17458963 ] Qingsheng Ren edited comment on FLINK-25132 at 12/14/21, 7:41 AM: --

[jira] [Commented] (FLINK-20633) test_configuration.test_add_all test failed in py35

[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458962#comment-17458962 ] Till Rohrmann commented on FLINK-20633: --- Can we retry the downloads [~hxbks2ks]? >

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

flinkbot edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-985453331 ## CI report: * 4f2e086e98a70e21f2a3397506530a8726bbfcb7 Azure:

[jira] [Commented] (FLINK-25132) KafkaSource cannot work with object-reusing DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-25132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458963#comment-17458963 ] Qingsheng Ren commented on FLINK-25132: --- [~trohrmann] It waiting for another round of review from

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * f68137e6e62deb0c765833d8ebdcefea357b01eb Azure:

[GitHub] [flink] AHeise commented on a change in pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

AHeise commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r768387505 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -0,0 +1,236 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

flinkbot edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-985453331 ## CI report: * 4f2e086e98a70e21f2a3397506530a8726bbfcb7 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458961#comment-17458961 ] Till Rohrmann commented on FLINK-23391: --- What is the plan time-wise for removing the

[jira] [Closed] (FLINK-25150) org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules

[ https://issues.apache.org/jira/browse/FLINK-25150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25150. --- Fix Version/s: 1.15.0 Resolution: Fixed >

[jira] [Commented] (FLINK-25150) org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules

[ https://issues.apache.org/jira/browse/FLINK-25150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458959#comment-17458959 ] Yun Gao commented on FLINK-25150: - Yes, it is fixed, I'll close it~ >

[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458957#comment-17458957 ] Till Rohrmann commented on FLINK-25025: --- Any updates on this ticket [~hxbks2ks]? >

[jira] [Commented] (FLINK-25107) GlueSchemaRegistryAvroKinesisITCase and GlueSchemaRegistryJsonKinesisITCase are skipped on AzureCI but fail when enabled

[ https://issues.apache.org/jira/browse/FLINK-25107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458955#comment-17458955 ] Till Rohrmann commented on FLINK-25107: --- Hi [~dannycranmer] can you give a quick update on the

[jira] [Commented] (FLINK-25132) KafkaSource cannot work with object-reusing DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-25132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458954#comment-17458954 ] Till Rohrmann commented on FLINK-25132: --- [~renqs] what is missing for the PR to be merged? >

[jira] [Commented] (FLINK-25150) org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules

[ https://issues.apache.org/jira/browse/FLINK-25150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458953#comment-17458953 ] Till Rohrmann commented on FLINK-25150: --- [~gaoyunhaii] can this ticket be closed? >

[jira] [Commented] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458951#comment-17458951 ] Till Rohrmann commented on FLINK-25210: --- [~affe] can I assign you to this ticket? >

[jira] [Assigned] (FLINK-25263) KafkaSourceE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25263: - Assignee: Qingsheng Ren > KafkaSourceE2ECase is broken >

[jira] [Commented] (FLINK-25263) KafkaSourceE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458949#comment-17458949 ] Till Rohrmann commented on FLINK-25263: --- Thanks for taking care of this problem [~renqs]. >

[jira] [Created] (FLINK-25294) Incorrect cloudpickle import

arya created FLINK-25294: Summary: Incorrect cloudpickle import Key: FLINK-25294 URL: https://issues.apache.org/jira/browse/FLINK-25294 Project: Flink Issue Type: Bug Components: API /

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

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

[jira] [Updated] (FLINK-24987) Enhance ExternalizedCheckpointCleanup enum

[ https://issues.apache.org/jira/browse/FLINK-24987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-24987: -- Fix Version/s: 1.13.5 1.14.2 > Enhance ExternalizedCheckpointCleanup enum >

[jira] [Commented] (FLINK-24987) Enhance ExternalizedCheckpointCleanup enum

[ https://issues.apache.org/jira/browse/FLINK-24987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458944#comment-17458944 ] Ingo Bürk commented on FLINK-24987: --- Fixed in 1.14 commit 30da65ca7e6d7481cef02eb0ebe9a00a1de94c0c

[GitHub] [flink] Airblader merged pull request #18096: [FLINK-24987][BP 1.13] Enhance ExternalizedCheckpointCleanup

Airblader merged pull request #18096: URL: https://github.com/apache/flink/pull/18096 -- 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] Airblader merged pull request #18095: [FLINK-24987][BP 1.14] Enhance ExternalizedCheckpointCleanup

Airblader merged pull request #18095: URL: https://github.com/apache/flink/pull/18095 -- 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] [Assigned] (FLINK-25249) Reimplement KafkaSourceTestEnv with KafkaContainer

[ https://issues.apache.org/jira/browse/FLINK-25249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-25249: --- Assignee: Qingsheng Ren > Reimplement KafkaSourceTestEnv with KafkaContainer >

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 0a89d73af633e62f39b9ba728b0551a95a28eaba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

flinkbot edited a comment on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-975923151 ## CI report: * e7898cfe6876c6dfd71272e8aa2b6b8593948bd7 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458941#comment-17458941 ] Yun Gao commented on FLINK-23944: - Hi [~syhily] do we have updates on this issue~? >

[jira] [Updated] (FLINK-25267) Unable to (always) recover using checkpoint in HA setup (both Zookeeper and Kubernetes)

[ https://issues.apache.org/jira/browse/FLINK-25267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kerem Ulutaş updated FLINK-25267: - Description: My Stateful Functions job is running on Kubernetes (minikube on my local env) and

[jira] [Commented] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

[ https://issues.apache.org/jira/browse/FLINK-23956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458940#comment-17458940 ] Yun Gao commented on FLINK-23956: - Hi [~fpaul] do we have updates on this issue~? >

[jira] [Closed] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-22096. --- Resolution: Fixed > ServerTransportErrorHandlingTest.testRemoteClose fail >

[jira] [Commented] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458937#comment-17458937 ] Yingjie Cao commented on FLINK-22096: - Fixed via: 481f30539c79e212f8974a07ff261c389bfbdbe2 on

[jira] [Commented] (FLINK-20633) test_configuration.test_add_all test failed in py35

[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458936#comment-17458936 ] Huang Xingbo commented on FLINK-20633: -- [~gaoyunhaii] The existing python tests will mvn download

[GitHub] [flink] wsry closed pull request #18089: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

wsry closed pull request #18089: URL: https://github.com/apache/flink/pull/18089 -- 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] wsry commented on pull request #18089: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

wsry commented on pull request #18089: URL: https://github.com/apache/flink/pull/18089#issuecomment-993214303 Merged. -- 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] wsry closed pull request #18090: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

wsry closed pull request #18090: URL: https://github.com/apache/flink/pull/18090 -- 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] wsry commented on pull request #18090: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

wsry commented on pull request #18090: URL: https://github.com/apache/flink/pull/18090#issuecomment-993214141 Merged. -- 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] wsry closed pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

wsry closed pull request #17532: URL: https://github.com/apache/flink/pull/17532 -- 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] wsry commented on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

wsry commented on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-993214025 Merged. -- 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

[jira] [Updated] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rerorero updated FLINK-25293: - Description: Is it possible to let KafkaSource fail if it keeps failing to commit offset?   I faced

[jira] [Updated] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rerorero updated FLINK-25293: - Description: Is it possible to let KafkaSource fail if it keeps failing to commit offset?   I faced

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[jira] [Updated] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rerorero updated FLINK-25293: - Description: Is it possible to let KafkaSource fail if it keeps failing to commit offset?   I faced

[jira] [Updated] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rerorero updated FLINK-25293: - Description: Is it possible to let KafkaSource fail if it keeps failing to commit offset?   I faced

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[jira] [Updated] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rerorero updated FLINK-25293: - Description: Is it possible to let KafkaSource fail if it keeps failing to commit offset?   I faced

[jira] [Commented] (FLINK-20633) test_configuration.test_add_all test failed in py35

[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458934#comment-17458934 ] Yun Gao commented on FLINK-20633: - Hi [~hxbks2ks] Do we have progress with this issue~? >

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[jira] [Updated] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rerorero updated FLINK-25293: - Description: Is it possible to let KafkaSource fail if it keeps failing to commit offset?   I faced

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[jira] [Updated] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] rerorero updated FLINK-25293: - Description: Is it possible to let KafkaSource fail if it keeps failing to commit offset?   I faced

[jira] [Created] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

rerorero created FLINK-25293: Summary: Option to let fail if KafkaSource keeps failing to commit offset Key: FLINK-25293 URL: https://issues.apache.org/jira/browse/FLINK-25293 Project: Flink

[jira] [Commented] (FLINK-25292) Azure failed due to unable to fetch some archives

[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458930#comment-17458930 ] Yun Gao commented on FLINK-25292: -

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[jira] [Updated] (FLINK-25292) Azure failed due to unable to fetch some archives

[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25292: Affects Version/s: 1.14.0 > Azure failed due to unable to fetch some archives >

[jira] [Created] (FLINK-25292) Azure failed due to unable to fetch some archives

Yun Gao created FLINK-25292: --- Summary: Azure failed due to unable to fetch some archives Key: FLINK-25292 URL: https://issues.apache.org/jira/browse/FLINK-25292 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458928#comment-17458928 ] Yun Gao commented on FLINK-18356: -

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[GitHub] [flink] JingsongLi commented on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

JingsongLi commented on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-993189509 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

flinkbot edited a comment on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-989489342 ## CI report: * 814558a213ca9451cfe4fcc28511c5776dc16735 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 801da058f67f6181a1fdd1e0fdfebbd45643cfb7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 801da058f67f6181a1fdd1e0fdfebbd45643cfb7 Azure:

[jira] [Commented] (FLINK-25263) KafkaSourceE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458911#comment-17458911 ] Qingsheng Ren commented on FLINK-25263: --- This is probably caused by file system permission issues

[jira] [Created] (FLINK-25290) Add table source and sink test suite in connector testing framework

Qingsheng Ren created FLINK-25290: - Summary: Add table source and sink test suite in connector testing framework Key: FLINK-25290 URL: https://issues.apache.org/jira/browse/FLINK-25290 Project: Flink

[jira] [Created] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework

Qingsheng Ren created FLINK-25291: - Summary: Add failure cases in DataStream source and sink suite of connector testing framework Key: FLINK-25291 URL: https://issues.apache.org/jira/browse/FLINK-25291

[jira] [Created] (FLINK-25288) Add savepoint and metric cases in DataStream source suite of connector testing framework

Qingsheng Ren created FLINK-25288: - Summary: Add savepoint and metric cases in DataStream source suite of connector testing framework Key: FLINK-25288 URL: https://issues.apache.org/jira/browse/FLINK-25288

[jira] [Created] (FLINK-25289) Add DataStream sink test suite in connector testing framework

Qingsheng Ren created FLINK-25289: - Summary: Add DataStream sink test suite in connector testing framework Key: FLINK-25289 URL: https://issues.apache.org/jira/browse/FLINK-25289 Project: Flink

[jira] [Created] (FLINK-25287) Refactor connector testing framework interfaces

Qingsheng Ren created FLINK-25287: - Summary: Refactor connector testing framework interfaces Key: FLINK-25287 URL: https://issues.apache.org/jira/browse/FLINK-25287 Project: Flink Issue

[jira] [Created] (FLINK-25286) Improve connector testing framework to support more scenarios

Qingsheng Ren created FLINK-25286: - Summary: Improve connector testing framework to support more scenarios Key: FLINK-25286 URL: https://issues.apache.org/jira/browse/FLINK-25286 Project: Flink

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r768307680 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,215 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r768307375 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,215 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r768307326 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/Knn.java ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r768306705 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/Knn.java ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software

  1   2   3   4   5   6   >