[GitHub] [flink] flinkbot edited a comment on pull request #17610: [hotfix][docs] Fix the outdated upgrading instruction for Kafka Connector

flinkbot edited a comment on pull request #17610: URL: https://github.com/apache/flink/pull/17610#issuecomment-955131667 ## CI report: * 00214af0b13e7695db3b7c30d5b53edafae1f63a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

flinkbot edited a comment on pull request #17608: URL: https://github.com/apache/flink/pull/17608#issuecomment-954803172 ## CI report: * e6d48a2a8d555b42b1720db653674b73eb1b8ba0 Azure:

[jira] [Comment Edited] (FLINK-24646) Add operator wrapper for all-round iterations

[ https://issues.apache.org/jira/browse/FLINK-24646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435839#comment-17435839 ] Yun Gao edited comment on FLINK-24646 at 10/30/21, 3:24 AM: Fixed on master

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #12: [FLINK-24650][iteration] add unbounded iteration.

gaoyunhaii commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r739600581 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationFactory.java ## @@ -0,0 +1,248 @@ +/* + * Licensed to the Apache

[GitHub] [flink] baisui1981 commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

baisui1981 commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-955134599 @zentol @AHeise Thanks to both of you, have already understood me and have understood what I want to express, We want to build a product similar to

[jira] [Updated] (FLINK-24650) Support unbounded iteration.

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

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #12: [FLINK-24650][iteration] add unbounded iteration.

gaoyunhaii commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r739599530 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationFactory.java ## @@ -0,0 +1,248 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17610: [hotfix][docs] Fix the outdated upgrading instruction for Kafka Connector

flinkbot edited a comment on pull request #17610: URL: https://github.com/apache/flink/pull/17610#issuecomment-955131667 ## CI report: * 00214af0b13e7695db3b7c30d5b53edafae1f63a Azure:

[GitHub] [flink] flinkbot commented on pull request #17610: [hotfix][docs] Fix the outdated upgrading instruction for Kafka Connector

flinkbot commented on pull request #17610: URL: https://github.com/apache/flink/pull/17610#issuecomment-955131713 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #17610: [hotfix][docs] Fix the outdated upgrading instruction for Kafka Connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * d9ef87451762a897b00adf72926071be0d822342 Azure:

[GitHub] [flink] gaoyunhaii opened a new pull request #17610: [hotfix][docs] Fix the outdated upgrading instruction for Kafka connector

gaoyunhaii opened a new pull request #17610: URL: https://github.com/apache/flink/pull/17610 ## What is the purpose of the change This PR fixes the outdated instruction on upgrading to the latest version for Kafka Connector. ## Verifying this change This change is

[GitHub] [flink] baisui1981 commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

baisui1981 commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-955126616 > But the user-jar is the same for all tasks. You can't use a manifest in said jar for differentiating which classes should now be loaded / made accessible. You either a)

[jira] [Updated] (FLINK-24663) PyFlink failed to get the site packege path because of SyntaxError in shell command

[ https://issues.apache.org/jira/browse/FLINK-24663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackwangcs updated FLINK-24663: --- Labels: (was: pull-request-available) > PyFlink failed to get the site packege path because of

[GitHub] [flink] JackWangCS closed pull request #17609: [FLINK-24663][Python] Quote bash argument for PythonEnvironmentManagerUtils

JackWangCS closed pull request #17609: URL: https://github.com/apache/flink/pull/17609 -- 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] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 651832650f3de249e2f9398bb87927da3d261dbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 651832650f3de249e2f9398bb87927da3d261dbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 651832650f3de249e2f9398bb87927da3d261dbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 651832650f3de249e2f9398bb87927da3d261dbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 651832650f3de249e2f9398bb87927da3d261dbc Azure:

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

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

[jira] [Updated] (FLINK-20830) Add a type of HEADLESS_CLUSTER_IP for rest service type

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

[jira] [Updated] (FLINK-20880) Turn Json String into Row

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

[jira] [Updated] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

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

[jira] [Updated] (FLINK-20827) Just read record correlating to join key in FilesystemLookUpFunc

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

[jira] [Updated] (FLINK-22984) UnsupportedOperationException when using Python UDF to generate watermark

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

[jira] [Updated] (FLINK-20819) flink : Connectors : JDBC test failing on Red Hat 8.x PowerPC Linux

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

[jira] [Updated] (FLINK-20962) Rewrite the example in 'flink-python/pyflink/shell.py'

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

[jira] [Updated] (FLINK-20912) Increase Log and Metric: Time consumed by Checkpoint Restore

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

[jira] [Updated] (FLINK-20881) flink sql and flink sink must be run in one stream

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

[jira] [Updated] (FLINK-20820) Rename o.a.f.table.runtime.generated package in blink runtime

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

[jira] [Updated] (FLINK-20886) Add the option to get a threaddump on checkpoint timeouts

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

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * e74755211c68fe2bce5a5088c7ea00a4a4b7237f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * e74755211c68fe2bce5a5088c7ea00a4a4b7237f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

flinkbot edited a comment on pull request #17606: URL: https://github.com/apache/flink/pull/17606#issuecomment-954752065 ## CI report: * 3652a3b41d02f84d54924930705ae710d7f7 Azure:

[GitHub] [flink] zentol commented on pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

zentol commented on pull request #17606: URL: https://github.com/apache/flink/pull/17606#issuecomment-955057857 hmm...the `TaskManagerProcessFailureBatchRecoveryITCase` is failing pretty reliably now. I'm wondering if this issue was masking another failure as well... -- This is an

[GitHub] [flink] flinkbot edited a comment on pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

flinkbot edited a comment on pull request #17606: URL: https://github.com/apache/flink/pull/17606#issuecomment-954752065 ## CI report: * d65fff260e684b231835a04583b3e9d600ae96d6 Azure:

[GitHub] [flink] zentol commented on pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

zentol commented on pull request #17606: URL: https://github.com/apache/flink/pull/17606#issuecomment-955045722 @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 specific

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

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

[GitHub] [flink] flinkbot edited a comment on pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

flinkbot edited a comment on pull request #17608: URL: https://github.com/apache/flink/pull/17608#issuecomment-954803172 ## CI report: * 49487256bfb6ae8d304a42330454651924d001fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

flinkbot edited a comment on pull request #17608: URL: https://github.com/apache/flink/pull/17608#issuecomment-954803172 ## CI report: * 49487256bfb6ae8d304a42330454651924d001fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

flinkbot edited a comment on pull request #17606: URL: https://github.com/apache/flink/pull/17606#issuecomment-954752065 ## CI report: * d65fff260e684b231835a04583b3e9d600ae96d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

flinkbot edited a comment on pull request #17606: URL: https://github.com/apache/flink/pull/17606#issuecomment-954752065 ## CI report: * d65fff260e684b231835a04583b3e9d600ae96d6 Azure:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-24327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24327. - Fix Version/s: 1.15.0 Resolution: Fixed Merged into master as

[GitHub] [flink] AHeise merged pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

AHeise merged pull request #17374: URL: https://github.com/apache/flink/pull/17374 -- 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] AHeise merged pull request #17594: [FLINK-24612][connectors/kafka] Configure Kafka test container log levels accordingly to test logger

AHeise merged pull request #17594: URL: https://github.com/apache/flink/pull/17594 -- 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] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * e74755211c68fe2bce5a5088c7ea00a4a4b7237f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

flinkbot edited a comment on pull request #17608: URL: https://github.com/apache/flink/pull/17608#issuecomment-954803172 ## CI report: * 49487256bfb6ae8d304a42330454651924d001fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 5c8ae3d4103b875b368cebb5ab9376c2cff21096 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * 651832650f3de249e2f9398bb87927da3d261dbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

flinkbot edited a comment on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023 ## CI report: * c208976e1df1e97ab7951395e8be0c1f205a170a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

flinkbot edited a comment on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023 ## CI report: * c208976e1df1e97ab7951395e8be0c1f205a170a Azure:

[GitHub] [flink] lincoln-lil edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

lincoln-lil edited a comment on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954909178 Some tests failed, I'll fix it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] lincoln-lil commented on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

lincoln-lil commented on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954909178 Tests failure because runtime context not initialized, I'll fix it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #17609: [FLINK-24663][Python] Quote bash argument for PythonEnvironmentManagerUtils

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

[GitHub] [flink] flinkbot edited a comment on pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

flinkbot edited a comment on pull request #17606: URL: https://github.com/apache/flink/pull/17606#issuecomment-954752065 ## CI report: * d65fff260e684b231835a04583b3e9d600ae96d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

flinkbot edited a comment on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023 ## CI report: * c208976e1df1e97ab7951395e8be0c1f205a170a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

flinkbot edited a comment on pull request #17571: URL: https://github.com/apache/flink/pull/17571#issuecomment-951900326 ## CI report: * a49b4c966901159870a7f0014b2f4520fc35425e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

flinkbot edited a comment on pull request #17571: URL: https://github.com/apache/flink/pull/17571#issuecomment-951900326 ## CI report: * a49b4c966901159870a7f0014b2f4520fc35425e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

flinkbot edited a comment on pull request #17571: URL: https://github.com/apache/flink/pull/17571#issuecomment-951900326 ## CI report: * a49b4c966901159870a7f0014b2f4520fc35425e Azure:

[GitHub] [flink] beyond1920 commented on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

beyond1920 commented on pull request #17571: URL: https://github.com/apache/flink/pull/17571#issuecomment-954862143 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436049#comment-17436049 ] JING ZHANG commented on FLINK-24708: [~TsReaper] cc [~godfrey] [~godfreyhe]  It seems to be a bug in

[jira] [Updated] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-24708: --- Attachment: image-2021-10-29-23-59-48-074.png > `ConvertToNotInOrInRule` has a bug which leads to

[jira] [Created] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

JING ZHANG created FLINK-24708: -- Summary: `ConvertToNotInOrInRule` has a bug which leads to wrong result Key: FLINK-24708 URL: https://issues.apache.org/jira/browse/FLINK-24708 Project: Flink

[jira] [Updated] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-24708: --- Description: A user report this bug in maillist, I paste the content here. We are in the process

[GitHub] [flink] flinkbot edited a comment on pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

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

[GitHub] [flink] flinkbot edited a comment on pull request #17609: [FLINK-24663][Python] Quote bash argument for PythonEnvironmentManagerUtils

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

[GitHub] [flink] flinkbot commented on pull request #17609: [FLINK-24663][Python] Quote bash argument for PythonEnvironmentManagerUtils

flinkbot commented on pull request #17609: URL: https://github.com/apache/flink/pull/17609#issuecomment-954831151 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #17609: [FLINK-24663][Python] Quote bash argument for PythonEnvironmentManagerUtils

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

[jira] [Updated] (FLINK-24663) PyFlink failed to get the site packege path because of SyntaxError in shell command

[ https://issues.apache.org/jira/browse/FLINK-24663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24663: --- Labels: pull-request-available (was: ) > PyFlink failed to get the site packege path

[GitHub] [flink] JackWangCS opened a new pull request #17609: [FLINK-24663][Python] Quote bash argument for PythonEnvironmentManagerUtils

JackWangCS opened a new pull request #17609: URL: https://github.com/apache/flink/pull/17609 ## What is the purpose of the change PyFlink failed to get the site packege path and thus failed install 3rd party dependencies because of SyntaxError in shell command. This PR quotes long bash

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

gaoyunhaii commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r739320492 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftExecutionEnvironment.java ## @@ -0,0 +1,228 @@ +/* + * Licensed

[jira] [Commented] (FLINK-24663) PyFlink failed to get the site packege path because of SyntaxError in shell command

[ https://issues.apache.org/jira/browse/FLINK-24663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436028#comment-17436028 ] jackwangcs commented on FLINK-24663: In fact, we can only quote the long python command part like

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

gaoyunhaii commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r739312559 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftExecutionEnvironment.java ## @@ -0,0 +1,228 @@ +/* + * Licensed

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

gaoyunhaii commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r739311463 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftTransformationTranslator.java ## @@ -0,0 +1,69 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

gaoyunhaii commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r739309491 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftTransformationTranslator.java ## @@ -0,0 +1,69 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

flinkbot edited a comment on pull request #17608: URL: https://github.com/apache/flink/pull/17608#issuecomment-954803172 ## CI report: * 49487256bfb6ae8d304a42330454651924d001fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17604: [FLINK-23919][table-planner-blink] Fix field name conflict bug in `WindowUtil`

flinkbot edited a comment on pull request #17604: URL: https://github.com/apache/flink/pull/17604#issuecomment-954664725 ## CI report: * db26794d5bd076c1389715d25df346ae8f0edf72 Azure:

[GitHub] [flink] flinkbot commented on pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

flinkbot commented on pull request #17608: URL: https://github.com/apache/flink/pull/17608#issuecomment-954803417 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[jira] [Updated] (FLINK-24550) Can not access job information from a standby jobmanager UI

[ https://issues.apache.org/jira/browse/FLINK-24550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24550: --- Labels: pull-request-available (was: ) > Can not access job information from a standby

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink] zentol opened a new pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

zentol opened a new pull request #17608: URL: https://github.com/apache/flink/pull/17608 Based on #17606. We now use the Flink ClassLoader to deserialize the message payload. This should be safe because this serialization only occurs for results from the Flink layer, not the Akka

[GitHub] [flink-benchmarks] pnowojski merged pull request #38: [FLINK-24018] Remove Scala dependencies from flink dependencies

pnowojski merged pull request #38: URL: https://github.com/apache/flink-benchmarks/pull/38 -- 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] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4358f7215221955c9e6a3735c9bcd327a42c8c43 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

gaoyunhaii commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r739284296 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftExecutionEnvironment.java ## @@ -0,0 +1,228 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * ee8fa611b135924ad3a083ff71dbcbc2e1895351 Azure:

  1   2   3   4   >