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

2021-12-13 Thread Yun Gao (Jira)
[ 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

2021-12-13 Thread Yun Gao (Jira)
[ 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

2021-12-13 Thread Roman Khachatryan (Jira)
[ 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 > --- > > Key

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18099: URL: https://github.com/apache/flink/pull/18099#issuecomment-993245917 ## CI report: * 8a9a813bd60577b00805d10c95441b0220ff0241 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-985453331 ## CI report: * 6f8845033645564e7603e86899ec747fd823f6f9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
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 Apach

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

2021-12-13 Thread GitBox
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 pro

[jira] [Commented] (FLINK-25240) Update log4j2 version to 2.15.0

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

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

2021-12-13 Thread GitBox
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

2021-12-13 Thread GitBox
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 `build-apache-repo.yml

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

2021-12-13 Thread GitBox
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 r

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

2021-12-13 Thread GitBox
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

2021-12-13 Thread GitBox
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 @@ +/* + * Licensed

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * f68137e6e62deb0c765833d8ebdcefea357b01eb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
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 @@ +/* + * Li

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

2021-12-13 Thread ASF GitHub Bot (Jira)
[ 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

2021-12-13 Thread GitBox
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

2021-12-13 Thread GitBox
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 @@ +/* + * Li

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

2021-12-13 Thread Till Rohrmann (Jira)
[ 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

2021-12-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

2021-12-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-985453331 ## CI report: * 4f2e086e98a70e21f2a3397506530a8726bbfcb7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458963#comment-17458963 ] Qingsheng Ren commented on FLINK-25132: --- [~trohrmann] It waiting for another round

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * f68137e6e62deb0c765833d8ebdcefea357b01eb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
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 @@ +/* + * Li

[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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-985453331 ## CI report: * 4f2e086e98a70e21f2a3397506530a8726bbfcb7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458961#comment-17458961 ] Till Rohrmann commented on FLINK-23391: --- What is the plan time-wise for removing t

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

2021-12-13 Thread Yun Gao (Jira)
[ 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 > org.apache.flink.connector.file.src.reader.TextLineInputFor

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

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

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

2021-12-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

2021-12-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458955#comment-17458955 ] Till Rohrmann commented on FLINK-25107: --- Hi [~dannycranmer] can you give a quick u

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

2021-12-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458954#comment-17458954 ] Till Rohrmann commented on FLINK-25132: --- [~renqs] what is missing for the PR to be

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

2021-12-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458953#comment-17458953 ] Till Rohrmann commented on FLINK-25150: --- [~gaoyunhaii] can this ticket be closed?

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

2021-12-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458951#comment-17458951 ] Till Rohrmann commented on FLINK-25210: --- [~affe] can I assign you to this ticket?

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

2021-12-13 Thread Till Rohrmann (Jira)
[ 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

2021-12-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458949#comment-17458949 ] Till Rohrmann commented on FLINK-25263: --- Thanks for taking care of this problem [~

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

2021-12-13 Thread arya (Jira)
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 / Pyth

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 8b16953c06c56eeb6db23fdc8a54101048dc6dbd Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2021-12-13 Thread Jira
[ 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

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

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

2021-12-13 Thread GitBox
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: issues-unsub

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

2021-12-13 Thread GitBox
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: issues-unsub

[jira] [Assigned] (FLINK-25249) Reimplement KafkaSourceTestEnv with KafkaContainer

2021-12-13 Thread Yun Gao (Jira)
[ 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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 0a89d73af633e62f39b9ba728b0551a95a28eaba Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-975923151 ## CI report: * e7898cfe6876c6dfd71272e8aa2b6b8593948bd7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

2021-12-13 Thread Jira
[ 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"

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

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

2021-12-13 Thread Yingjie Cao (Jira)
[ 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

2021-12-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458937#comment-17458937 ] Yingjie Cao commented on FLINK-22096: - Fixed via: 481f30539c79e212f8974a07ff261c389

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

2021-12-13 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458936#comment-17458936 ] Huang Xingbo commented on FLINK-20633: -- [~gaoyunhaii] The existing python tests wil

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

2021-12-13 Thread GitBox
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: issues-unsubscr..

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

2021-12-13 Thread GitBox
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 un

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

2021-12-13 Thread GitBox
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: issues-unsubscr..

[GitHub] [flink] wsry commented on pull request #18090: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-12-13 Thread GitBox
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 un

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

2021-12-13 Thread GitBox
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: issues-unsubscr..

[GitHub] [flink] wsry commented on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-12-13 Thread GitBox
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 un

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

2021-12-13 Thread rerorero (Jira)
[ 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 an

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

2021-12-13 Thread rerorero (Jira)
[ 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 an

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread rerorero (Jira)
[ 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 an

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

2021-12-13 Thread rerorero (Jira)
[ 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 an

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread rerorero (Jira)
[ 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 an

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

2021-12-13 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread rerorero (Jira)
[ 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 an

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread rerorero (Jira)
[ 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 an

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

2021-12-13 Thread rerorero (Jira)
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 Iss

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

2021-12-13 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458930#comment-17458930 ] Yun Gao commented on FLINK-25292: - https://dev.azure.com/apache-flink/apache-flink/_buil

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread Yun Gao (Jira)
[ 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

2021-12-13 Thread Yun Gao (Jira)
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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458928#comment-17458928 ] Yun Gao commented on FLINK-18356: - https://dev.azure.com/apache-flink/apache-flink/_buil

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
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 specif

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-989489342 ## CI report: * 814558a213ca9451cfe4fcc28511c5776dc16735 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 0cff4b34864166335b53974c911a737f32b4d983 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 801da058f67f6181a1fdd1e0fdfebbd45643cfb7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 801da058f67f6181a1fdd1e0fdfebbd45643cfb7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-12-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458911#comment-17458911 ] Qingsheng Ren commented on FLINK-25263: --- This is probably caused by file system pe

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

2021-12-13 Thread Qingsheng Ren (Jira)
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

2021-12-13 Thread Qingsheng Ren (Jira)
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

2021-12-13 Thread Qingsheng Ren (Jira)
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

2021-12-13 Thread Qingsheng Ren (Jira)
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

2021-12-13 Thread Qingsheng Ren (Jira)
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 Type:

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

2021-12-13 Thread Qingsheng Ren (Jira)
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

2021-12-13 Thread GitBox
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 Software

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

2021-12-13 Thread GitBox
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 Software

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

2021-12-13 Thread GitBox
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 Foun

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

2021-12-13 Thread GitBox
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 Foun

  1   2   3   4   5   6   >