[GitHub] [flink] flinkbot edited a comment on pull request #13474: [FLINK-19391][network] Moved notification during subpartition request to the requester.

flinkbot edited a comment on pull request #13474: URL: https://github.com/apache/flink/pull/13474#issuecomment-698189239 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

[GitHub] [flink] flinkbot edited a comment on pull request #13460: [FLINK-19364][python] Add Batch Physical Pandas Group Window Aggregate Rule and RelNode

flinkbot edited a comment on pull request #13460: URL: https://github.com/apache/flink/pull/13460#issuecomment-697191079 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

[GitHub] [flink] flinkbot edited a comment on pull request #13003: [FLINK-18737][docs]translate jdbc connector

flinkbot edited a comment on pull request #13003: URL: https://github.com/apache/flink/pull/13003#issuecomment-664836878 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

[GitHub] [flink] flinkbot edited a comment on pull request #12454: [FLINK-17091][Arvo] Adapt Avro record conversion to new timestamp bridged classes

flinkbot edited a comment on pull request #12454: URL: https://github.com/apache/flink/pull/12454#issuecomment-637988260 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

[GitHub] [flink] flinkbot edited a comment on pull request #13416: [FLINK-19179] Extend managed memory fraction calculation for various use cases.

flinkbot edited a comment on pull request #13416: URL: https://github.com/apache/flink/pull/13416#issuecomment-694667551 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

[GitHub] [flink] flinkbot edited a comment on pull request #13437: [FLINK-19189][runtime] Enable pipelined scheduling by default

flinkbot edited a comment on pull request #13437: URL: https://github.com/apache/flink/pull/13437#issuecomment-695936739 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

[GitHub] [flink] flinkbot edited a comment on pull request #12768: [FLINK-17804][parquet] Follow Parquet spec when decoding DECIMAL

flinkbot edited a comment on pull request #12768: URL: https://github.com/apache/flink/pull/12768#issuecomment-649137157 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

[GitHub] [flink] flinkbot edited a comment on pull request #9356: [FLINK-13340][kafka][table] Add 'topics' and 'subscriptionPattern' option for Flink Kafka connector

flinkbot edited a comment on pull request #9356: URL: https://github.com/apache/flink/pull/9356#issuecomment-518115797 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

[GitHub] [flink] flinkbot edited a comment on pull request #13468: fix properties type cast error

flinkbot edited a comment on pull request #13468: URL: https://github.com/apache/flink/pull/13468#issuecomment-698096647 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

[GitHub] [flink] flinkbot edited a comment on pull request #13228: [FLINK-19026][network] Improve threading model of CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #13228: URL: https://github.com/apache/flink/pull/13228#issuecomment-679094462 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

[GitHub] [flink] flinkbot edited a comment on pull request #13445: [FLINK-19331][state-processor-api] Native resource leak when working with RocksDB

flinkbot edited a comment on pull request #13445: URL: https://github.com/apache/flink/pull/13445#issuecomment-696385131 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

[GitHub] [flink] flinkbot edited a comment on pull request #13422: [FLINK-19286][runtime] Improve pipelined region scheduling performance

flinkbot edited a comment on pull request #13422: URL: https://github.com/apache/flink/pull/13422#issuecomment-694779455 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

[GitHub] [flink] flinkbot edited a comment on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

flinkbot edited a comment on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-689028555 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

[GitHub] [flink] zentol commented on a change in pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

zentol commented on a change in pull request #14950: URL: https://github.com/apache/flink/pull/14950#discussion_r578977899 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/StateTrackingMockExecutionGraph.java ## @@ -0,0 +1,459 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #13358: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

flinkbot edited a comment on pull request #13358: URL: https://github.com/apache/flink/pull/13358#issuecomment-689269505 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

[GitHub] [flink] flinkbot edited a comment on pull request #13455: [FLINK-19361][hive] Create a synchronized metastore client to talk to…

flinkbot edited a comment on pull request #13455: URL: https://github.com/apache/flink/pull/13455#issuecomment-696719238 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

[GitHub] [flink] flinkbot edited a comment on pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

flinkbot edited a comment on pull request #8741: URL: https://github.com/apache/flink/pull/8741#issuecomment-502078258 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

[GitHub] [flink] flinkbot edited a comment on pull request #11359: [FLINK-16095] [docs-zh] Translate "Modules" page of "Table API & SQL" into Chinese

flinkbot edited a comment on pull request #11359: URL: https://github.com/apache/flink/pull/11359#issuecomment-596915123 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

[GitHub] [flink] flinkbot edited a comment on pull request #10354: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource

flinkbot edited a comment on pull request #10354: URL: https://github.com/apache/flink/pull/10354#issuecomment-559645834 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

[GitHub] [flink] flinkbot edited a comment on pull request #13405: [FLINK-19270] Extract an inteface from AbstractKeyedStateBackend

flinkbot edited a comment on pull request #13405: URL: https://github.com/apache/flink/pull/13405#issuecomment-694050574 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

[GitHub] [flink] flinkbot edited a comment on pull request #13289: [FLINK-18548][table-planner] support flexible syntax for Temporal table join

flinkbot edited a comment on pull request #13289: URL: https://github.com/apache/flink/pull/13289#issuecomment-683886127 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

[GitHub] [flink] flinkbot edited a comment on pull request #13414: [FLINK-19227][Table SQL / API] The catalog is still created after opening failed in catalog registering

flinkbot edited a comment on pull request #13414: URL: https://github.com/apache/flink/pull/13414#issuecomment-694640971 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

[GitHub] [flink] flinkbot edited a comment on pull request #13420: [FLINK-19229][python] Introduce the PythonStreamGroupAggregateOperator for Python UDAF.

flinkbot edited a comment on pull request #13420: URL: https://github.com/apache/flink/pull/13420#issuecomment-694771096 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

[GitHub] [flink] flinkbot edited a comment on pull request #13429: [FLINK-19140] Fix UDTF documentation which uses wrong alias

flinkbot edited a comment on pull request #13429: URL: https://github.com/apache/flink/pull/13429#issuecomment-695771100 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

[GitHub] [flink] flinkbot edited a comment on pull request #13430: [BP-1.11][FLINK-19140] Fix UDTF documentation which uses wrong alias

flinkbot edited a comment on pull request #13430: URL: https://github.com/apache/flink/pull/13430#issuecomment-695771924 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

[GitHub] [flink] flinkbot edited a comment on pull request #8331: [FLINK-11987][flink-connector-kafka-0.11] convert NEXT_TRANSACTIONAL_ID_HINT_DESCRIPTOR to a non-static variabl…

flinkbot edited a comment on pull request #8331: URL: https://github.com/apache/flink/pull/8331#issuecomment-488582162 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

[GitHub] [flink] flinkbot edited a comment on pull request #13332: [FLINK-19128][sql-client] Remove the runtime execution configuration in sql-client-defaults.yaml

flinkbot edited a comment on pull request #13332: URL: https://github.com/apache/flink/pull/13332#issuecomment-687611369 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

[GitHub] [flink] flinkbot edited a comment on pull request #13446: [FLINK-18779][table sql/planner]Support the SupportsFilterPushDown for LookupTableSource

flinkbot edited a comment on pull request #13446: URL: https://github.com/apache/flink/pull/13446#issuecomment-696484481 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

[GitHub] [flink] flinkbot edited a comment on pull request #8142: [FLINK-12148][clients] Give precedence to specified local jar

flinkbot edited a comment on pull request #8142: URL: https://github.com/apache/flink/pull/8142#issuecomment-481692125 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

[GitHub] [flink] flinkbot edited a comment on pull request #13427: [FLINK-17767][table-planner-blink]Tumbling/Sliding window aggregate support window start offset in batch and streaming mode

flinkbot edited a comment on pull request #13427: URL: https://github.com/apache/flink/pull/13427#issuecomment-695763230 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

[GitHub] [flink] flinkbot edited a comment on pull request #13442: [FLINK-19321][Table SQL / Runtime]CollectSinkFunction does not define serialVersionUID

flinkbot edited a comment on pull request #13442: URL: https://github.com/apache/flink/pull/13442#issuecomment-696189196 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

[GitHub] [flink] flinkbot edited a comment on pull request #13392: [FLINK-18713][table-planner-blink] Change duration configOption to duration type

flinkbot edited a comment on pull request #13392: URL: https://github.com/apache/flink/pull/13392#issuecomment-692536820 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

[GitHub] [flink] flinkbot edited a comment on pull request #13444: [BP-1.11][FLINK-19244] CsvRowDataDeserializationSchema throws cast ex…

flinkbot edited a comment on pull request #13444: URL: https://github.com/apache/flink/pull/13444#issuecomment-696202108 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

[GitHub] [flink] zentol commented on a change in pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

zentol commented on a change in pull request #14950: URL: https://github.com/apache/flink/pull/14950#discussion_r578976880 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/StateTrackingMockExecutionGraph.java ## @@ -0,0 +1,459 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #13426: [FLINK-19244] CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

flinkbot edited a comment on pull request #13426: URL: https://github.com/apache/flink/pull/13426#issuecomment-695220756 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

[GitHub] [flink] flinkbot edited a comment on pull request #13436: [FLINK-19301][python] Improve the package structure of Python DataStream API

flinkbot edited a comment on pull request #13436: URL: https://github.com/apache/flink/pull/13436#issuecomment-695928048 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

[GitHub] [flink] flinkbot edited a comment on pull request #13401: [FLINK-19161][file connector] Add first version of the FLIP-27 File Source

flinkbot edited a comment on pull request #13401: URL: https://github.com/apache/flink/pull/13401#issuecomment-693272292 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

[GitHub] [flink] flinkbot edited a comment on pull request #13433: [BP-1.11][FLINK-19280][jdbc] Fix option "sink.buffer-flush.max-rows" for JDBC can't be disabled by setting to zero

flinkbot edited a comment on pull request #13433: URL: https://github.com/apache/flink/pull/13433#issuecomment-695888255 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

[GitHub] [flink] flinkbot edited a comment on pull request #13435: [FLINK-19299][tests] Fix that NettyShuffleEnvironmentBuilder#setBufferSize does not take effect

flinkbot edited a comment on pull request #13435: URL: https://github.com/apache/flink/pull/13435#issuecomment-695891985 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

[GitHub] [flink] flinkbot edited a comment on pull request #13432: [FLINK-19280][connectors] fix the bug of the option "sink.buffer-flush.max-rows" for JDBC can't be disabled by set to zero

flinkbot edited a comment on pull request #13432: URL: https://github.com/apache/flink/pull/13432#issuecomment-695807197 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

[GitHub] [flink] flinkbot edited a comment on pull request #13189: [FLINK-18661][Kinesis] Stream consumer Registration/Deregistration

flinkbot edited a comment on pull request #13189: URL: https://github.com/apache/flink/pull/13189#issuecomment-675341370 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

[GitHub] [flink] flinkbot edited a comment on pull request #13102: [FLINK-18515][Kinesis] Adding FanOutRecordPublisher for Kinesis EFO support

flinkbot edited a comment on pull request #13102: URL: https://github.com/apache/flink/pull/13102#issuecomment-671232457 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

[GitHub] [flink] flinkbot edited a comment on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

flinkbot edited a comment on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-662518124 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

[GitHub] [flink] flinkbot edited a comment on pull request #13275: [FLINK-19064][hbase] HBaseRowDataInputFormat is leaking resources

flinkbot edited a comment on pull request #13275: URL: https://github.com/apache/flink/pull/13275#issuecomment-682387017 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

[GitHub] [flink] flinkbot edited a comment on pull request #13417: [FLINK-FLINK][docs] Update the version in docs/_config.yml to be the latest released minor version

flinkbot edited a comment on pull request #13417: URL: https://github.com/apache/flink/pull/13417#issuecomment-694697532 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

[GitHub] [flink] flinkbot edited a comment on pull request #13396: [FLINK-19248] add missing lastJobExecutionResult assignment after job finished in ContexEnvironment

flinkbot edited a comment on pull request #13396: URL: https://github.com/apache/flink/pull/13396#issuecomment-693187999 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

[GitHub] [flink] flinkbot edited a comment on pull request #13418: [FLINK-FLINK][docs] Update the version in docs/_config.yml to be the latest released minor version

flinkbot edited a comment on pull request #13418: URL: https://github.com/apache/flink/pull/13418#issuecomment-694697519 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

[GitHub] [flink] flinkbot edited a comment on pull request #13384: [FLINK-19224][state-processor-api] Support reading window operator state

flinkbot edited a comment on pull request #13384: URL: https://github.com/apache/flink/pull/13384#issuecomment-692328370 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

[GitHub] [flink] zentol commented on a change in pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

zentol commented on a change in pull request #14950: URL: https://github.com/apache/flink/pull/14950#discussion_r578976098 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/StateTrackingMockExecutionGraph.java ## @@ -0,0 +1,459 @@ +/* +

[GitHub] [flink] zentol commented on a change in pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

zentol commented on a change in pull request #14950: URL: https://github.com/apache/flink/pull/14950#discussion_r578975860 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/declarative/StateTrackingMockExecutionGraph.java ## @@ -0,0 +1,459 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

flinkbot edited a comment on pull request #14868: URL: https://github.com/apache/flink/pull/14868#issuecomment-773192044 ## CI report: * 997d4dddfc4d6ae2f45d80102655d02f09168d1b Azure:

[jira] [Closed] (FLINK-21380) Restarting/Canceling/Failing expose globally-terminal EG

[ https://issues.apache.org/jira/browse/FLINK-21380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21380. Resolution: Fixed master: 2a78440bd333a68c24acfeea016f35ec63bbe3f9 >

[GitHub] [flink] zentol merged pull request #14951: [FLINK-21380][coordination] Hide terminal ExecutionGraph in StateWithExecutionGraph

zentol merged pull request #14951: URL: https://github.com/apache/flink/pull/14951 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

[jira] [Closed] (FLINK-21360) Add resourceTimeout configuration

[ https://issues.apache.org/jira/browse/FLINK-21360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21360. Resolution: Fixed master: 3dbb18491aa81af29f0e3b3ee0b6dd58ce02ef76 > Add resourceTimeout

[GitHub] [flink] zentol merged pull request #14928: [FLINK-21360][coordination] Make resource timeout configurable

zentol merged pull request #14928: URL: https://github.com/apache/flink/pull/14928 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

[jira] [Created] (FLINK-21414) javax.net.ssl.SSLHandshakeException: Received fatal alert: certificate_unknown

Bhagi created FLINK-21414: - Summary: javax.net.ssl.SSLHandshakeException: Received fatal alert: certificate_unknown Key: FLINK-21414 URL: https://issues.apache.org/jira/browse/FLINK-21414 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

flinkbot edited a comment on pull request #14897: URL: https://github.com/apache/flink/pull/14897#issuecomment-775050448 ## CI report: * 06c2bdca6652a653ece66c02c5a96d79326662e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * af8de65a4905ae47ab704a75acfcd1b2e897d915 UNKNOWN * 772e076ed9d773e16713236c942f4e30b659d6eb UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * c9be932fec6390ffb103c000550cbc85747c266e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * c9be932fec6390ffb103c000550cbc85747c266e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * c9be932fec6390ffb103c000550cbc85747c266e Azure:

[GitHub] [flink] curcur commented on pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-781830344 rebase This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578936411 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/changelog/state/ChangelogAggregatingState.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #14964: [FLINK-21410][docs] Document checkpoint interval trade-offs

flinkbot edited a comment on pull request #14964: URL: https://github.com/apache/flink/pull/14964#issuecomment-781637879 ## CI report: * 63cafd0fe1c8c1c43e69f5acf5faf1256073dcea Azure:

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578932063 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -242,6 +265,53 @@ public static StateBackend

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578931859 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -242,6 +265,53 @@ public static StateBackend

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578931575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegateStateBackend.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578904214 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +222,11 @@ public static StateBackend

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * bebd298009b12a9d5ac6518902f5534f8e00ff32 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * bebd298009b12a9d5ac6518902f5534f8e00ff32 UNKNOWN *

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578909351 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatedStateBackend.java ## @@ -0,0 +1,29 @@ +/* + * Licensed to the

[GitHub] [flink] gaoyunhaii commented on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

gaoyunhaii commented on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-781798040 Hi Roman @rkhachatryan very thanks for the review! I updated the PR according to the comments~ This is an

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

gaoyunhaii commented on a change in pull request #14740: URL: https://github.com/apache/flink/pull/14740#discussion_r578907964 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java ## @@ -0,0 +1,329 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

flinkbot edited a comment on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-774628149 ## CI report: * 1976f8fa0310d74fccbd2ccf0ccb6f7b904a60a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * bebd298009b12a9d5ac6518902f5534f8e00ff32 UNKNOWN *

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578904214 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -204,6 +222,11 @@ public static StateBackend

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354] Implement a StateChangelogStateBackend to forward state changes to St…

curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r578903917 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageLoader.java ## @@ -162,14 +163,19 @@ public static

[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

flinkbot edited a comment on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-774628149 ## CI report: * 1976f8fa0310d74fccbd2ccf0ccb6f7b904a60a6 Azure:

[jira] [Updated] (FLINK-21413) TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend

[ https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-21413: --- Description: Take the #TtlMapState as an example,   {code:java} public Map>

[jira] [Updated] (FLINK-21413) TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend

[ https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-21413: --- Attachment: image-2021-02-19-11-13-58-672.png > TtlMapState and TtlListState cannot be clean

[jira] [Created] (FLINK-21413) TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend

Jiayi Liao created FLINK-21413: -- Summary: TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend Key: FLINK-21413 URL: https://issues.apache.org/jira/browse/FLINK-21413

[jira] [Created] (FLINK-21412) pyflink DataTypes.DECIMAL is not available

awayne created FLINK-21412: -- Summary: pyflink DataTypes.DECIMAL is not available Key: FLINK-21412 URL: https://issues.apache.org/jira/browse/FLINK-21412 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-21370) flink-1.12.1 - JDBCExecutionOptions defaults config JDBCDynamicTableFactory default config is not consistent

[ https://issues.apache.org/jira/browse/FLINK-21370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 closed FLINK-21370. -- Resolution: Not A Problem > flink-1.12.1 - JDBCExecutionOptions defaults config JDBCDynamicTableFactory > default

[jira] [Closed] (FLINK-21049) query_configuration.html content out date

[ https://issues.apache.org/jira/browse/FLINK-21049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 closed FLINK-21049. -- Fix Version/s: 1.13.0 Resolution: Fixed > query_configuration.html content out date >

[GitHub] [flink] anlen321 commented on a change in pull request #14684: [FLINK-20460][Connector-HBase] Support async lookup for HBase connector

anlen321 commented on a change in pull request #14684: URL: https://github.com/apache/flink/pull/14684#discussion_r57288 ## File path: flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java ## @@ -94,6 +94,33

[GitHub] [flink] flinkbot edited a comment on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

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

[GitHub] [flink] flinkbot edited a comment on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

flinkbot edited a comment on pull request #14897: URL: https://github.com/apache/flink/pull/14897#issuecomment-775050448 ## CI report: * 35644082e06622b2182b6fb68d9a30df167d5c11 Azure:

[jira] [Commented] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286823#comment-17286823 ] Rex Remind commented on FLINK-20427: Cool, thanks! > Remove

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

gaoyunhaii commented on a change in pull request #14740: URL: https://github.com/apache/flink/pull/14740#discussion_r578879271 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -651,39 +681,52 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

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

[GitHub] [flink] flinkbot edited a comment on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

flinkbot edited a comment on pull request #14897: URL: https://github.com/apache/flink/pull/14897#issuecomment-775050448 ## CI report: * 35644082e06622b2182b6fb68d9a30df167d5c11 Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

gaoyunhaii commented on a change in pull request #14740: URL: https://github.com/apache/flink/pull/14740#discussion_r578879271 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -651,39 +681,52 @@ private void

[GitHub] [flink] KarmaGYZ commented on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

KarmaGYZ commented on pull request #14897: URL: https://github.com/apache/flink/pull/14897#issuecomment-781765733 Thanks for the new comments @tillrohrmann . PR updated according to it. This is an automated message from the

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

KarmaGYZ commented on a change in pull request #14897: URL: https://github.com/apache/flink/pull/14897#discussion_r578874000 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/BiDirectionalResourceToRequirementMapping.java ## @@

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

gaoyunhaii commented on a change in pull request #14740: URL: https://github.com/apache/flink/pull/14740#discussion_r578872539 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCheckpointPlanCalculator.java ## @@ -0,0 +1,329 @@ +/* + *

<    1   2   3   4   5   >