[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762398015 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,243 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * e356372cdc970974a4b481120bce0107c65e6061 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18012: [FLINK-25164] DogStatsD Metrics Reporter

flinkbot edited a comment on pull request #18012: URL: https://github.com/apache/flink/pull/18012#issuecomment-985975795 ## CI report: * c10da0687e8b7832c1e663706eeb5d5420bcc2f4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-7009) dogstatsd mode in statsd reporter

[ https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453293#comment-17453293 ] Yaroslav Tkachenko commented on FLINK-7009: --- Created another issue https://issu

[GitHub] [flink] flinkbot commented on pull request #18012: [FLINK-25164] DogStatsD Metrics Reporter

flinkbot commented on pull request #18012: URL: https://github.com/apache/flink/pull/18012#issuecomment-985975855 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

[GitHub] [flink] flinkbot commented on pull request #18012: [FLINK-25164] DogStatsD Metrics Reporter

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

[jira] [Updated] (FLINK-25164) DogStatsD Metrics Reporter

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

[GitHub] [flink] sap1ens opened a new pull request #18012: [FLINK-25164] DogStatsD Metrics Reporter

sap1ens opened a new pull request #18012: URL: https://github.com/apache/flink/pull/18012 ## What is the purpose of the change This pull request adds a new metrics reporter for the DogStatsD protocol. ## Brief change log - Adding new `flink-metrics/flink-metrics-dogstats

[jira] [Created] (FLINK-25164) DogStatsD Metrics Reporter

Yaroslav Tkachenko created FLINK-25164: -- Summary: DogStatsD Metrics Reporter Key: FLINK-25164 URL: https://issues.apache.org/jira/browse/FLINK-25164 Project: Flink Issue Type: New Featur

[GitHub] [flink-ml] lindong28 commented on a change in pull request #37: [FLINK-24955] Add One Hot Encoder to Flink ML

lindong28 commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r762376047 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/feature/OneHotEncoderTest.java ## @@ -0,0 +1,334 @@ +/* + * Licensed to the Apache Software F

[GitHub] [flink] xinbinhuang commented on pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

xinbinhuang commented on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-985965780 > @xinbinhuang , this pull request could be review by @KarmaGYZ . Thank you! @KarmaGYZ can you help take a look? -- This is an automated message from the Apache Git

[GitHub] [flink] xinbinhuang commented on a change in pull request #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph

xinbinhuang commented on a change in pull request #17873: URL: https://github.com/apache/flink/pull/17873#discussion_r762384359 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorTest.java ## @@ -577,6 +577,57 @@ public vo

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zjureel 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

zjureel edited a comment on pull request #18007: URL: https://github.com/apache/flink/pull/18007#issuecomment-985457343 @tillrohrmann @xintongsong could you please have look at this PR for [FLINK-25085](https://issues.apache.org/jira/browse/FLINK-25085) when you are free, thanks -- This

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

RocMarshal commented on a change in pull request #16962: URL: https://github.com/apache/flink/pull/16962#discussion_r762374906 ## File path: docs/content/docs/connectors/table/jdbc.md ## @@ -458,6 +463,38 @@ SELECT * FROM mydb.`custom_schema.test_table2`; SELECT * FROM `custom

[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: * 263f1d63585e1629f4de31d80d79531ed68c5816 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] camilesing commented on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

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

[jira] [Commented] (FLINK-25163) Add more options for rocksdb state backend to make configuration more flexible

[ https://issues.apache.org/jira/browse/FLINK-25163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453266#comment-17453266 ] 刘方奇 commented on FLINK-25163: - [~yunta] , Hi, Can you help to see this issue. If ok, I can t

[jira] [Created] (FLINK-25163) Add more options for rocksdb state backend to make configuration more flexible

刘方奇 created FLINK-25163: --- Summary: Add more options for rocksdb state backend to make configuration more flexible Key: FLINK-25163 URL: https://issues.apache.org/jira/browse/FLINK-25163 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8235aed4e30f0bc4388cd3b4d92b5c868dc154e0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8235aed4e30f0bc4388cd3b4d92b5c868dc154e0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] liufangqi commented on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

liufangqi commented on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-985932863 > @AHeise THX, I think I fix it, can you review it in the new commit? Additionally, there are other commits that reply your change requests, could you help to review i

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] shenzhu commented on a change in pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

shenzhu commented on a change in pull request #17919: URL: https://github.com/apache/flink/pull/17919#discussion_r762351158 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionITCase.java ## @@ -282,17 +282,15 @@ pro

[GitHub] [flink] shenzhu commented on a change in pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

shenzhu commented on a change in pull request #17919: URL: https://github.com/apache/flink/pull/17919#discussion_r762350300 ## File path: flink-architecture-tests/violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 ## @@ -106,8 +106,6 @@ org.apache.flink.connector.file.src.reader

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 56515bd322459d965610005e3f3da140aa9ce1a7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-6765) PojoSerializer returns wrong ConvertDeserializer when migration is required

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

[jira] [Updated] (FLINK-13031) Support dynamic offset in tumbling windows

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

[jira] [Updated] (FLINK-21968) Calcite parser doesn't support to parse "-- test"

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

[jira] [Updated] (FLINK-6735) Add a checkbox to hide the plan visualizer

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

[jira] [Updated] (FLINK-6814) Store information about whether or not a registered state is queryable in checkpoints

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

[jira] [Updated] (FLINK-6770) Add excludeSerializersInCheckpoints to ExecutionConfig

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

[jira] [Updated] (FLINK-6790) Flink Kafka Consumer Cannot Round Robin Fetch Records

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

[jira] [Updated] (FLINK-12381) W/o HA, upon a full restart, checkpointing crashes

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

[jira] [Updated] (FLINK-9586) Make collection sources parallelisable

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

[jira] [Updated] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

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

[jira] [Updated] (FLINK-13570) Pluggable Intermediate Result Storage

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

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

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

[jira] [Updated] (FLINK-22010) when flink executed union all opeators,exception occured

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

[jira] [Updated] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

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

[jira] [Updated] (FLINK-22012) Add nightly-build pipeline to test flink-ml repo with the latest flink repo snapshot

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

[jira] [Updated] (FLINK-22060) Move null handling from ErrorInfo into Task.notifyFinalState

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

[jira] [Updated] (FLINK-22013) Add Github Actions to flink-ml for every push and pull request

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

[jira] [Updated] (FLINK-21863) SortPartition should allow chaining of KeySelectors to support different sorting orders for the fields

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

[jira] [Updated] (FLINK-22086) Does it support rate-limiting on reading hive in flink 1.12?Read hive source lead to high loadaverage

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

[jira] [Updated] (FLINK-22090) Upload logs fails

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

[jira] [Updated] (FLINK-22078) Introduce a Printer interface to rederict the output to the desired stream

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

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453218#comment-17453218 ] Jun Qin commented on FLINK-16419: - [~qzhzm173227] not sure you have opened a new Jira...

[GitHub] [flink] JingGe commented on a change in pull request #17995: [POC] Prevent configurations in user jars

JingGe commented on a change in pull request #17995: URL: https://github.com/apache/flink/pull/17995#discussion_r762194790 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -159,6 +160,15 @@ publi

[GitHub] [flink] flinkbot edited a comment on pull request #18011: [FLINK-25114] Remove flink-scala dependency from flink-table-runtime

flinkbot edited a comment on pull request #18011: URL: https://github.com/apache/flink/pull/18011#issuecomment-985689192 ## CI report: * 6ed5a0c8b1deae8371f93845aeb8185816177570 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18001: [FLINK-24086][runtime] Rebuilding the SharedStateRegistry only when the restore method is called for the first time

flinkbot edited a comment on pull request #18001: URL: https://github.com/apache/flink/pull/18001#issuecomment-985051499 ## CI report: * 6ec26d9cab9862322a136bed84ec3be710e67a16 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

flinkbot edited a comment on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-982775752 ## CI report: * ed2461b7c05386fc82ac4967bf97b120a2288e20 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

[ https://issues.apache.org/jira/browse/FLINK-24261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453172#comment-17453172 ] Matthias commented on FLINK-24261: -- Timeout in topic deletion: https://dev.azure.com/m

[jira] [Commented] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453171#comment-17453171 ] Matthias commented on FLINK-24341: -- A backport to 1.13 also caused this issue: [right a

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 58dade49aa396a3e78899ae49dd9e739a36750c8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 70192d2e673d98c361a388dfaecc97ca2b6d125d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18010: [FLINK-24227][connectors/kinesis] Relocated flink-connector-aws-base in flink-connector-kinesis shaded jar

flinkbot edited a comment on pull request #18010: URL: https://github.com/apache/flink/pull/18010#issuecomment-985625624 ## CI report: * 2e1eb05a198c9401670ac1aff5e47d76a0e1c4a0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] CrynetLogistics commented on pull request #18010: [FLINK-24227][connectors/kinesis] Relocated flink-connector-aws-base in flink-connector-kinesis shaded jar

CrynetLogistics commented on pull request #18010: URL: https://github.com/apache/flink/pull/18010#issuecomment-985730694 Link to build: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=27543&view=results -- This is an automated message from the Apache Git Service. T

[jira] [Created] (FLINK-25162) Flink : Connectors : Hive fails with VectorizedRowBatch not found

Sergey Nuyanzin created FLINK-25162: --- Summary: Flink : Connectors : Hive fails with VectorizedRowBatch not found Key: FLINK-25162 URL: https://issues.apache.org/jira/browse/FLINK-25162 Project: Fli

[GitHub] [flink] XComp commented on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

XComp commented on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-985725105 @slinkydeveloper I refactored your code after I realized that there was some concurrent development on the same issue. I moved the code into `flink-test-utils-junit` to align it w

[GitHub] [flink] XComp commented on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

XComp commented on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-985722180 Although, I'm not that sure anymore whether `FlinkThrowableAssert` wouldn't be the only implementation. `FlinkMatchers` covers only `CompletableFuture` and the cause chain use cas

[GitHub] [flink-web] XComp opened a new pull request #485: [FLINK-25096] Adds pointer to custom Assert implementations in flink-test-utils-junit

XComp opened a new pull request #485: URL: https://github.com/apache/flink-web/pull/485 Adds pointer to custom Flink Assert implementations that were added in the context of FLINK-25096. (related [Flink PR #17967](https://github.com/apache/flink/pull/17967) -- This is an automated messa

[GitHub] [flink] flinkbot edited a comment on pull request #18009: [FLINK-25126][kafka] Reset internal transaction state of FlinkKafkaIn…

flinkbot edited a comment on pull request #18009: URL: https://github.com/apache/flink/pull/18009#issuecomment-985559926 ## CI report: * bfbaca4c52dbb6b094c79067dec6526062ef15d2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] XComp commented on a change in pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

XComp commented on a change in pull request #17967: URL: https://github.com/apache/flink/pull/17967#discussion_r762125450 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/DefaultJobMasterServiceProcessTest.java ## @@ -63,11 +64,92 @@ public void te

[GitHub] [flink] XComp commented on a change in pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

XComp commented on a change in pull request #17967: URL: https://github.com/apache/flink/pull/17967#discussion_r762123534 ## File path: flink-core/src/test/java/org/apache/flink/testutils/assertj/CauseTreeContainsAssert.java ## @@ -0,0 +1,74 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] flinkbot edited a comment on pull request #18011: [FLINK-25114] Remove flink-scala dependency from flink-table-runtime

flinkbot edited a comment on pull request #18011: URL: https://github.com/apache/flink/pull/18011#issuecomment-985689192 ## CI report: * 6ed5a0c8b1deae8371f93845aeb8185816177570 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #18011: [FLINK-25114] Remove flink-scala dependency from flink-table-runtime

flinkbot commented on pull request #18011: URL: https://github.com/apache/flink/pull/18011#issuecomment-985690417 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

[GitHub] [flink] flinkbot commented on pull request #18011: [FLINK-25114] Remove flink-scala dependency from flink-table-runtime

flinkbot commented on pull request #18011: URL: https://github.com/apache/flink/pull/18011#issuecomment-985689192 ## CI report: * 6ed5a0c8b1deae8371f93845aeb8185816177570 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-25114) Remove flink-scala dependency from flink-table-runtime

[ https://issues.apache.org/jira/browse/FLINK-25114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25114: --- Labels: pull-request-available (was: ) > Remove flink-scala dependency from flink-table-run

[GitHub] [flink] slinkydeveloper opened a new pull request #18011: [FLINK-25114] Remove flink-scala dependency from flink-table-runtime

slinkydeveloper opened a new pull request #18011: URL: https://github.com/apache/flink/pull/18011 ## What is the purpose of the change Remove flink-scala dependency from flink-table-runtime, removing transitive dependency on scala runtime. ## Brief change log * Remove f

[jira] [Closed] (FLINK-24687) flink-table uber jar should not include flink-connector-files dependency

[ https://issues.apache.org/jira/browse/FLINK-24687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24687. Fix Version/s: 1.15.0 Release Note: The table file system connector is not part of the table-

[GitHub] [flink] flinkbot edited a comment on pull request #17985: [FLINK-25111][table-api][table-planner] Add config option to determine CAST behaviour

flinkbot edited a comment on pull request #17985: URL: https://github.com/apache/flink/pull/17985#issuecomment-983795245 ## CI report: * 54f10f50957d9af82964a206f0ff97105715c8ca Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18001: [FLINK-24086][runtime] Rebuilding the SharedStateRegistry only when the restore method is called for the first time

flinkbot edited a comment on pull request #18001: URL: https://github.com/apache/flink/pull/18001#issuecomment-985051499 ## CI report: * 7fc4a42487df298cdbcce9f6f72e3c5b6351bb83 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] twalthr closed pull request #17897: [FLINK-24687][table] Move FileSystemTableSource/Sink in flink-connector-files

twalthr closed pull request #17897: URL: https://github.com/apache/flink/pull/17897 -- 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-unsubsc

[GitHub] [flink] flinkbot edited a comment on pull request #18001: [FLINK-24086][runtime] Rebuilding the SharedStateRegistry only when the restore method is called for the first time

flinkbot edited a comment on pull request #18001: URL: https://github.com/apache/flink/pull/18001#issuecomment-985051499 ## CI report: * 7fc4a42487df298cdbcce9f6f72e3c5b6351bb83 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18005: [BP-1.13][FLINK-24506][config] Adds checkpoint directory to CheckpointConfig

flinkbot edited a comment on pull request #18005: URL: https://github.com/apache/flink/pull/18005#issuecomment-985405041 ## CI report: * aa58b6058cb78226432a15ddbebac82babebca18 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

flinkbot edited a comment on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-949170131 ## CI report: * fc6d9ef126185b79ec6edc6d4feedf0df95564f6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rkhachatryan commented on a change in pull request #17945: [FLINK-21027][state] Introduce KeyedStateBackend#isSafeToReuseState for opmitization hint

rkhachatryan commented on a change in pull request #17945: URL: https://github.com/apache/flink/pull/17945#discussion_r762086896 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java ## @@ -137,10 +137,25 @@ */ boolean dereg

[jira] [Updated] (FLINK-25161) Update dependency for japicmp-maven-plugin

[ https://issues.apache.org/jira/browse/FLINK-25161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25161: --- Labels: pull-request-available (was: ) > Update dependency for japicmp-maven-plugin >

[GitHub] [flink] flinkbot edited a comment on pull request #18008: [FLINK-25161][buildsystem] update jaxb-impl dependency for japicmp-maven-plugin

flinkbot edited a comment on pull request #18008: URL: https://github.com/apache/flink/pull/18008#issuecomment-985494700 ## CI report: * 4072cb3fa3f994f9738f28067ae4fa79cde1841f Azure: [SUCCESS](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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17897: [FLINK-24687][table] Move FileSystemTableSource/Sink in flink-connector-files

flinkbot edited a comment on pull request #17897: URL: https://github.com/apache/flink/pull/17897#issuecomment-977984065 ## CI report: * a96dbbc98f8d598f50ee96df7880594987c5fe49 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   5   >