[GitHub] [flink] slinkydeveloper commented on a change in pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

slinkydeveloper commented on a change in pull request #17544: URL: https://github.com/apache/flink/pull/17544#discussion_r739121306 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSource.java ## @@ -217,7 +283,12 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17594: [FLINK-24612][connectors/kafka] Configure Kafka test container log levels accordingly to test logger

flinkbot edited a comment on pull request #17594: URL: https://github.com/apache/flink/pull/17594#issuecomment-953889076 ## CI report: * 1d924ef17f3fee36597174a376965763fbcb447b Azure:

[jira] [Closed] (FLINK-21263) Job hangs under backpressure

[ https://issues.apache.org/jira/browse/FLINK-21263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-21263. -- Resolution: Abandoned > Job hangs under backpressure > > >

[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:

[jira] [Created] (FLINK-24706) AkkaInvocationHandler silently ignores deserialization errors

Chesnay Schepler created FLINK-24706: Summary: AkkaInvocationHandler silently ignores deserialization errors Key: FLINK-24706 URL: https://issues.apache.org/jira/browse/FLINK-24706 Project: Flink

[GitHub] [flink] echauchot commented on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

echauchot commented on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-954722957 > > > @echauchot > > > > Sure, I saw the comments about split and data types etc... But I feel unconfortable about draft PRs because they usually cannot be merged as is.

[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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a 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: * 10ca9cf225390e479797cac385c89c3b45eb2cb1 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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a Azure:

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

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

[GitHub] [flink] dmvk opened a new pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

dmvk opened a new pull request #17607: URL: https://github.com/apache/flink/pull/17607 This PR introduces idempotent transactions in `ZooKeeperStateHandleStore#addAndLock` method. In case of unstable connection we may actually retry transactions that have already succeeded and therefore

[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:

[jira] [Commented] (FLINK-24692) kubernetes session mode deployment failed since slot allocation timeout

[ https://issues.apache.org/jira/browse/FLINK-24692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435891#comment-17435891 ] Zhou Parker commented on FLINK-24692: - [~wangyang0918] I have upload jobmanager log. please have a

[jira] [Updated] (FLINK-24692) kubernetes session mode deployment failed since slot allocation timeout

[ https://issues.apache.org/jira/browse/FLINK-24692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhou Parker updated FLINK-24692: Attachment: jobmanager_log.txt > kubernetes session mode deployment failed since slot allocation

[GitHub] [flink] flinkbot edited a comment on pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

flinkbot edited a comment on pull request #17538: URL: https://github.com/apache/flink/pull/17538#issuecomment-948574914 ## CI report: * d36f7665608a5e8f42e0f136e5dea5cd07e5c45b 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: * d5e52d57ca158cfc2ffcad32f3b71969744f2bcd Azure:

[GitHub] [flink] fapaul commented on pull request #17594: [FLINK-24612][connectors/kafka] Configure Kafka test container log levels accordingly to test logger

fapaul commented on pull request #17594: URL: https://github.com/apache/flink/pull/17594#issuecomment-954655166 @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] pnowojski merged pull request #17573: [FLINK-24190][runtime] Forbid to split the first record in the buffer if it physically fit it.

pnowojski merged pull request #17573: URL: https://github.com/apache/flink/pull/17573 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-24190) Handling large record with buffer debloat

[ https://issues.apache.org/jira/browse/FLINK-24190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24190. -- Resolution: Fixed Merged to master as a3378133471^..a3378133471 > Handling large record with

[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: * c08e84b8a66a9e6a2e5db9412fc26fcc7aa8e1c5 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

pnowojski commented on a change in pull request #17229: URL: https://github.com/apache/flink/pull/17229#discussion_r739165161 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -523,11 +534,15 @@ protected void

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

flinkbot commented on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954693023 ## CI report: * 10ca9cf225390e479797cac385c89c3b45eb2cb1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot commented on pull request #17605: URL: https://github.com/apache/flink/pull/17605#issuecomment-954692477 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] echauchot commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

echauchot commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r735440587 ## File path: flink-formats/flink-parquet/pom.xml ## @@ -26,7 +26,7 @@ under the License. org.apache.flink

[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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a Azure:

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

pnowojski opened a new pull request #38: URL: https://github.com/apache/flink-benchmarks/pull/38 This is mimicking https://github.com/apache/flink/pull/17518 change. FYI @zentol -- 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 #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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a Azure:

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

zentol commented on a change in pull request #17606: URL: https://github.com/apache/flink/pull/17606#discussion_r739241181 ## File path: flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java ## @@ -240,17 +241,20 @@ private Object

[jira] [Created] (FLINK-24707) Upgrade Curator framework dependecy.

David Morávek created FLINK-24707: - Summary: Upgrade Curator framework dependecy. Key: FLINK-24707 URL: https://issues.apache.org/jira/browse/FLINK-24707 Project: Flink Issue Type:

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

flinkbot commented on pull request #17607: URL: https://github.com/apache/flink/pull/17607#issuecomment-954764965 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 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-21141) Timeout bug in data stream connect operation when one of the data stream does not have new messages very frequently

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

[jira] [Updated] (FLINK-21147) Resuming Savepoint (file, async, no parallelism change) fails with UnknownHostException

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

[jira] [Updated] (FLINK-21038) jobmanager.sh may misinterpret webui-port argument

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

[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: * 9aa8115b9b3fa8cc853f7821c29f939870c79e5d Azure:

[jira] [Updated] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

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

[jira] [Updated] (FLINK-21196) Sensitive information(password) is in plain text format in flink-conf.yaml configuration file

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

[jira] [Updated] (FLINK-21165) Timestamps/Watermarks chained erroneously with previous operator

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

[jira] [Updated] (FLINK-21119) Building Flink Azure FS Hadoop hangs during python CI

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

[jira] [Updated] (FLINK-21109) Introduce "retractAccumulators" interface for AggregateFunction in Table/SQL API

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

[jira] [Updated] (FLINK-20996) Using a cryptographically weak Pseudo Random Number Generator (PRNG)

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

[jira] [Closed] (FLINK-24695) Update how to configure unaligned checkpoints in the documentation

[ https://issues.apache.org/jira/browse/FLINK-24695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24695. -- Fix Version/s: 1.14.1 1.15.0 Resolution: Fixed Merged to master as

[jira] [Updated] (FLINK-24695) Update how to configure unaligned checkpoints in the documentation

[ https://issues.apache.org/jira/browse/FLINK-24695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24695: --- Affects Version/s: (was: 1.14.1) 1.14.0 > Update how to

[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:

[jira] [Created] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

lincoln lee created FLINK-24704: --- Summary: Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction Key: FLINK-24704 URL:

[jira] [Updated] (FLINK-24666) The lenient option was not exposed to users on RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24666: Priority: Major (was: Minor) > The lenient option was not exposed to users on

[jira] [Commented] (FLINK-24666) The lenient option was not exposed to users on RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435949#comment-17435949 ] lincoln lee commented on FLINK-24666: - The `lenient` option should cover all the stream operators

[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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a 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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a Azure:

[GitHub] [flink-benchmarks] akalash commented on pull request #38: [FLINK-24018] Remove Scala dependencies from flink dependencies

akalash commented on pull request #38: URL: https://github.com/apache/flink-benchmarks/pull/38#issuecomment-954753503 @pnowojski, LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

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

flinkbot commented on pull request #17606: URL: https://github.com/apache/flink/pull/17606#issuecomment-954753157 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 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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a Azure:

[jira] [Updated] (FLINK-24543) Zookeeper connection issue causes inconsistent state in Flink

[ https://issues.apache.org/jira/browse/FLINK-24543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24543: --- Labels: pull-request-available (was: ) > Zookeeper connection issue causes inconsistent

[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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a 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: * c08e84b8a66a9e6a2e5db9412fc26fcc7aa8e1c5 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

[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] 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: * 9aa8115b9b3fa8cc853f7821c29f939870c79e5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

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

[jira] [Updated] (FLINK-24703) Add support for reading CSV files based on StreamFormat (new file source API)

[ https://issues.apache.org/jira/browse/FLINK-24703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24703: --- Labels: pull-request-available (was: ) > Add support for reading CSV files based on

[GitHub] [flink] flinkbot edited a comment on pull request #17594: [FLINK-24612][connectors/kafka] Configure Kafka test container log levels accordingly to test logger

flinkbot edited a comment on pull request #17594: URL: https://github.com/apache/flink/pull/17594#issuecomment-953889076 ## CI report: * 1d924ef17f3fee36597174a376965763fbcb447b Azure:

[jira] [Commented] (FLINK-24553) Change buffer debloating default configuration values

[ https://issues.apache.org/jira/browse/FLINK-24553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435946#comment-17435946 ] Piotr Nowojski commented on FLINK-24553: +1 for your proposals. > Change buffer debloating

[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 #17603: [FLINK-24553][core] Changed buffer debloat default configuration valu…

flinkbot edited a comment on pull request #17603: URL: https://github.com/apache/flink/pull/17603#issuecomment-954578652 ## CI report: * f30eb63e02e2ed66aaa86a3f2da5a5331abcb540 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17569: [FLINK-24648] CEIL and FLOOR should support DECADE, CENTURY, MILLENNIUM

flinkbot edited a comment on pull request #17569: URL: https://github.com/apache/flink/pull/17569#issuecomment-951868685 ## CI report: * 520393631cc0c66cc4fb583adb8bc844e2f8905d 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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a 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: * 10ca9cf225390e479797cac385c89c3b45eb2cb1 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 commented on pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

flinkbot commented on pull request #17607: URL: https://github.com/apache/flink/pull/17607#issuecomment-954762085 ## CI report: * 7ccc4b0240e733447c42bbfa48911f768afac57d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r739272758 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/AsyncSinkBase.java ## @@ -49,6 +50,28 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

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

[jira] [Created] (FLINK-24703) Add support for reading CSV files based on StreamFormat (new file source API)

Alexander Fedulov created FLINK-24703: - Summary: Add support for reading CSV files based on StreamFormat (new file source API) Key: FLINK-24703 URL: https://issues.apache.org/jira/browse/FLINK-24703

[jira] [Updated] (FLINK-24670) Restructure unaligned checkpoints documentation page to "Checkpointing under back pressure"

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

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

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

[jira] [Closed] (FLINK-24670) Restructure unaligned checkpoints documentation page to "Checkpointing under back pressure"

[ https://issues.apache.org/jira/browse/FLINK-24670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24670. -- Resolution: Fixed Merged to master as e6ef94814e4^ Merged to release-1.14 as ba0a7f725b4^ >

[jira] [Updated] (FLINK-21129) Long metric names cause Graphite to not store them

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

[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: * d5e52d57ca158cfc2ffcad32f3b71969744f2bcd Azure:

[jira] [Assigned] (FLINK-24694) Translate "Checkpointing under backpressure" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24694: -- Assignee: zlzhang0122 > Translate "Checkpointing under backpressure" page into

[jira] [Commented] (FLINK-24694) Translate "Checkpointing under backpressure" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435938#comment-17435938 ] Piotr Nowojski commented on FLINK-24694: Sure, thanks! > Translate "Checkpointing under

[jira] [Updated] (FLINK-21201) Creating BoundedBlockingSubpartition blocks TaskManager’s main thread

[ https://issues.apache.org/jira/browse/FLINK-21201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21201: --- Priority: Not a Priority (was: Minor) > Creating BoundedBlockingSubpartition blocks

[GitHub] [flink] flinkbot edited a comment on pull request #17602: [FLINK-24699][build] Run scalastyle in validate phase

flinkbot edited a comment on pull request #17602: URL: https://github.com/apache/flink/pull/17602#issuecomment-954553527 ## CI report: * a6a5d73a54c1d3ab9d125c14c5f33bb20351bd9e Azure:

[jira] [Updated] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-24704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24704: --- Labels: pull-request-available (was: ) > Exception occurs when the input record loses

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

lincoln-lil opened a new pull request #17605: URL: https://github.com/apache/flink/pull/17605 ## What is the purpose of the change Fix the exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction ## Verifying this change This

[jira] [Created] (FLINK-24705) Flink blood relationship

HideOnBush created FLINK-24705: -- Summary: Flink blood relationship Key: FLINK-24705 URL: https://issues.apache.org/jira/browse/FLINK-24705 Project: Flink Issue Type: New Feature

[jira] [Commented] (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:comment-tabpanel=17435961#comment-17435961 ] Chesnay Schepler commented on FLINK-24550: -- The deserialization of the ArchivedExecutionGraph

[GitHub] [flink] fapaul commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

fapaul commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r739209225 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AbstractAvroBulkFormat.java ## @@ -0,0 +1,207 @@ +/* + * Licensed to

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

echauchot commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r735440587 ## File path: flink-formats/flink-parquet/pom.xml ## @@ -26,7 +26,7 @@ under the License. org.apache.flink

[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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a 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 * f9d4472ab57a0f70c531bc4275ebd8f26f6a Azure:

[jira] [Updated] (FLINK-24706) AkkaInvocationHandler silently ignores deserialization errors

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

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

zentol opened a new pull request #17606: URL: https://github.com/apache/flink/pull/17606 Fixes an issue where issues during the deserialization of RPC messages were silently ignored. We now forward the error to the returned future instead. @tillrohrmann Could you take a look? --

[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: * c08e84b8a66a9e6a2e5db9412fc26fcc7aa8e1c5 Azure:

[GitHub] [flink] pnowojski commented on pull request #17595: [FLINK-24670][docs] Restructure unaligned checkpoints docs to checkpointing under backpressure

pnowojski commented on pull request #17595: URL: https://github.com/apache/flink/pull/17595#issuecomment-954639318 Thanks for the review @infoverload ! -- 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

[GitHub] [flink] pnowojski merged pull request #17595: [FLINK-24670][docs] Restructure unaligned checkpoints docs to checkpointing under backpressure

pnowojski merged pull request #17595: URL: https://github.com/apache/flink/pull/17595 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-24702) toUpperCase/toLowerCase calls may cause problems with some system locales

[ https://issues.apache.org/jira/browse/FLINK-24702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435927#comment-17435927 ] Fabian Paul commented on FLINK-24702: - [~mfussenegger] thanks for opening this ticket. I think it

  1   2   3   4   >