[jira] [Updated] (FLINK-19195) question on security vulnerabilities in flink

[ https://issues.apache.org/jira/browse/FLINK-19195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel Costa updated FLINK-19195: - Issue Type: Bug (was: Wish) > question on security vulnerabilities in flink >

[jira] [Created] (FLINK-19195) question on security vulnerabilities in flink

Miguel Costa created FLINK-19195: Summary: question on security vulnerabilities in flink Key: FLINK-19195 URL: https://issues.apache.org/jira/browse/FLINK-19195 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 ## CI report: * 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN * d98718acd049396b6eafd12d81d5404d0393798d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13343: [FLINK-19083] Remove deprecated DataStream#split

flinkbot edited a comment on pull request #13343: URL: https://github.com/apache/flink/pull/13343#issuecomment-68843 ## CI report: * 83007c1bc19b10cf5369b0e4718979d71e674fac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13284: [FLINK-17016][runtime] Integrate pipelined region scheduling

flinkbot edited a comment on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000 ## CI report: * 6af35bfdfa14c049bf4abe1c88ee49a689f38085 UNKNOWN * acc8ba0856f79a5e7915e8612ef0789190a3806d UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 ## CI report: * 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN * 43239addb3380c94c2c3452557b8ecb1f5982e1b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13311: [FLINK-18721] Migrate YarnResourceManager to the new YarnResourceManagerDriver

flinkbot edited a comment on pull request #13311: URL: https://github.com/apache/flink/pull/13311#issuecomment-686196434 ## CI report: * b7660009b48d48261b767855d8973c63741ab493 UNKNOWN * f16d78f22d3d66e763f5629a377936bcb20b80c4 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 ## CI report: * 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN * 43239addb3380c94c2c3452557b8ecb1f5982e1b Azure:

[jira] [Created] (FLINK-19196) FlinkSQL aggregation function to aggregate array typed column to Map/Multiset

sam lin created FLINK-19196: --- Summary: FlinkSQL aggregation function to aggregate array typed column to Map/Multiset Key: FLINK-19196 URL: https://issues.apache.org/jira/browse/FLINK-19196 Project: Flink

[GitHub] [flink] StephanEwen commented on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

StephanEwen commented on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-690764909 Thanks a lot for the review! I would proceed to merge the first reviewed commits already, and then open a new PR for the remaining commits. That should make

[jira] [Created] (FLINK-19197) Add documentation for PersistedStateRegistry

Tzu-Li (Gordon) Tai created FLINK-19197: --- Summary: Add documentation for PersistedStateRegistry Key: FLINK-19197 URL: https://issues.apache.org/jira/browse/FLINK-19197 Project: Flink

[jira] [Updated] (FLINK-19198) Invalid default value for consume-start-offset in Hive streaming

[ https://issues.apache.org/jira/browse/FLINK-19198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-19198: - Description: The default value for `streaming-source.consume-start-offset` in Hive streaming is

[jira] [Updated] (FLINK-19198) Invalid default value for consume-start-offset in Hive streaming

[ https://issues.apache.org/jira/browse/FLINK-19198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-19198: - Description: The default value for `streaming-source.consume-start-offset` in Hive streaming is

[jira] [Commented] (FLINK-19198) Invalid default value for consume-start-offset in Hive streaming

[ https://issues.apache.org/jira/browse/FLINK-19198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193978#comment-17193978 ] Paul Lin commented on FLINK-19198: -- I'd like to fix this if we all agree to. > Invalid default value

[GitHub] [flink] flinkbot edited a comment on pull request #13010: [FLINK-18735][table] Add support for more types to DataGen source

flinkbot edited a comment on pull request #13010: URL: https://github.com/apache/flink/pull/13010#issuecomment-665174560 ## CI report: * a96948229811ec6f8b72a2fd2ad019a9fa6b2d67 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13179: [FLINK-18978][state-backends] Support full table scan of key and namespace from statebackend

flinkbot edited a comment on pull request #13179: URL: https://github.com/apache/flink/pull/13179#issuecomment-674957571 ## CI report: * b985e226543345724377647b73884a2527ac5b30 Azure:

[GitHub] [flink] StephanEwen commented on a change in pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

StephanEwen commented on a change in pull request #13344: URL: https://github.com/apache/flink/pull/13344#discussion_r486658903 ## File path: flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceReaderBaseUnitTest.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 ## CI report: * 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN * d98718acd049396b6eafd12d81d5404d0393798d Azure:

[GitHub] [flink] sjwiesman commented on pull request #13010: [FLINK-18735][table] Add support for more types to DataGen source

sjwiesman commented on pull request #13010: URL: https://github.com/apache/flink/pull/13010#issuecomment-690711964 Sorry for the long back and forth, just pushed a fix addressing your comments. This is an automated message

[GitHub] [flink] StephanEwen commented on a change in pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

StephanEwen commented on a change in pull request #13344: URL: https://github.com/apache/flink/pull/13344#discussion_r486659810 ## File path: flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderOutput.java ## @@

[GitHub] [flink] StephanEwen commented on a change in pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

StephanEwen commented on a change in pull request #13344: URL: https://github.com/apache/flink/pull/13344#discussion_r486660080 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/SourceReaderBase.java ## @@ -99,67

[GitHub] [flink-web] xintongsong commented on pull request #378: Add xtsong to the committer list.

xintongsong commented on pull request #378: URL: https://github.com/apache/flink-web/pull/378#issuecomment-690824584 Thanks for the reminder @zhuzhurk, and thanks for the pointer @morsapaes (Marta!) PR updated. This is

[jira] [Created] (FLINK-19198) Invalid default value for consume-start-offset in Hive streaming

Paul Lin created FLINK-19198: Summary: Invalid default value for consume-start-offset in Hive streaming Key: FLINK-19198 URL: https://issues.apache.org/jira/browse/FLINK-19198 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 ## CI report: * 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN * e563be1c3fe203184c2f78bd01ed23d35e83198c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13010: [FLINK-18735][table] Add support for more types to DataGen source

flinkbot edited a comment on pull request #13010: URL: https://github.com/apache/flink/pull/13010#issuecomment-665174560 ## CI report: * a96948229811ec6f8b72a2fd2ad019a9fa6b2d67 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13179: [FLINK-18978][state-backends] Support full table scan of key and namespace from statebackend

flinkbot edited a comment on pull request #13179: URL: https://github.com/apache/flink/pull/13179#issuecomment-674957571 ## CI report: * b985e226543345724377647b73884a2527ac5b30 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 ## CI report: * 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN * d98718acd049396b6eafd12d81d5404d0393798d Azure:

[jira] [Updated] (FLINK-19197) Add documentation for PersistedStateRegistry

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

[GitHub] [flink-statefun] tzulitai opened a new pull request #147: [FLINK-19197] [docs] Add documentation for PersistedStateRegistry

tzulitai opened a new pull request #147: URL: https://github.com/apache/flink-statefun/pull/147 Preview of the new documentation: 

[GitHub] [flink] flinkbot edited a comment on pull request #13010: [FLINK-18735][table] Add support for more types to DataGen source

flinkbot edited a comment on pull request #13010: URL: https://github.com/apache/flink/pull/13010#issuecomment-665174560 ## CI report: * cbe73382b1eb400653d068a8726bc673fb7e6394 Azure:

[GitHub] [flink] StephanEwen commented on a change in pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

StephanEwen commented on a change in pull request #13344: URL: https://github.com/apache/flink/pull/13344#discussion_r486658430 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherTask.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #13179: [FLINK-18978][state-backends] Support full table scan of key and namespace from statebackend

flinkbot edited a comment on pull request #13179: URL: https://github.com/apache/flink/pull/13179#issuecomment-674957571 ## CI report: * 32e7196f7eb7474982fa0e4e6489403316575099 Azure:

[jira] [Created] (FLINK-19199) Add execution attempt ID to feedback channel keys

Tzu-Li (Gordon) Tai created FLINK-19199: --- Summary: Add execution attempt ID to feedback channel keys Key: FLINK-19199 URL: https://issues.apache.org/jira/browse/FLINK-19199 Project: Flink

[jira] [Updated] (FLINK-19199) Add execution attempt ID to feedback channel keys

[ https://issues.apache.org/jira/browse/FLINK-19199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19199: --- Labels: pull-request-available (was: ) > Add execution attempt ID to feedback channel keys

[GitHub] [flink-statefun] tzulitai opened a new pull request #148: [FLINK-19199] [core] Add execution attempt ID to feedback channel keys

tzulitai opened a new pull request #148: URL: https://github.com/apache/flink-statefun/pull/148 The feedback brokers identify a single pair of producer / consumer with a `SubtaskFeedbackKey`, which is uniquely identified within a job by only the subtask index. This can potentially

[GitHub] [flink] flinkbot edited a comment on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

flinkbot edited a comment on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-684611193 ## CI report: * c266341c63cc4cdc28a6585a82294710fd8ebbc5 UNKNOWN * cb369a8127cc00759e82f2fe58e06737a5eadb7e Azure:

[GitHub] [flink] dianfu commented on pull request #12992: [FLINK-18716][python][docs] Remove the deprecated execute and insert_into calls in PyFlink Table API docs.

dianfu commented on pull request #12992: URL: https://github.com/apache/flink/pull/12992#issuecomment-690119048 @WeiZhong94 could you rebase the PR? This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-18836) Python UDTF doesn't work well when the return type isn't generator

[ https://issues.apache.org/jira/browse/FLINK-18836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193496#comment-17193496 ] Dian Fu commented on FLINK-18836: - [~hxbks2ks] could you help to take a look at this issue? > Python

[GitHub] [flink] StephanEwen commented on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

StephanEwen commented on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-690119651 Is this class only used in the DataSet API, or is it also used in the SQL runtime (batch case)? If the latter is true, we should verify that there is no performance

[GitHub] [flink-web] xintongsong opened a new pull request #378: Add xtsong to the committer list.

xintongsong opened a new pull request #378: URL: https://github.com/apache/flink-web/pull/378 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Created] (FLINK-19191) Reduce the default number for async operations

Igal Shilman created FLINK-19191: Summary: Reduce the default number for async operations Key: FLINK-19191 URL: https://issues.apache.org/jira/browse/FLINK-19191 Project: Flink Issue Type:

[jira] [Commented] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193526#comment-17193526 ] Piotr Nowojski commented on FLINK-19109: As I wrote, I don't think we can not backport the

[jira] [Comment Edited] (FLINK-19159) Using Scalafmt to format scala source code

[ https://issues.apache.org/jira/browse/FLINK-19159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193544#comment-17193544 ] darion yaphet edited comment on FLINK-19159 at 9/10/20, 11:06 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 ## CI report: * 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN * d154ff654bd927988a42f2881e8f690a121ea536 Azure:

[GitHub] [flink] xintongsong closed pull request #13347: [FLINK-19151][yarn]Fix the unit value according to different yarn scheduler

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

[jira] [Closed] (FLINK-19151) Flink does not normalize container resource with correct configurations when Yarn FairScheduler is used

[ https://issues.apache.org/jira/browse/FLINK-19151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-19151. Resolution: Fixed Fixed via * master: 00bf41f33a10b59850f0ee4fe31c0271484d6d4c * release-1.11:

[GitHub] [flink] flinkbot edited a comment on pull request #13369: [FLINK-19173][python] Add Pandas Batch Group Aggregation Function Operator

flinkbot edited a comment on pull request #13369: URL: https://github.com/apache/flink/pull/13369#issuecomment-690035137 ## CI report: * c07c5e36851207112dc67aad490005a3d26d39c5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13368: [FLINK-19000] Forward initialization timestamp from Dispatcher to ExecGraph

flinkbot edited a comment on pull request #13368: URL: https://github.com/apache/flink/pull/13368#issuecomment-690035026 ## CI report: * 59deb5d9ae2ddf42b40ff4391d567daa8abef8db Azure:

[jira] [Created] (FLINK-19190) Use camelCase for metric names

Igal Shilman created FLINK-19190: Summary: Use camelCase for metric names Key: FLINK-19190 URL: https://issues.apache.org/jira/browse/FLINK-19190 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-18836) Python UDTF doesn't work well when the return type isn't generator

[ https://issues.apache.org/jira/browse/FLINK-18836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193498#comment-17193498 ] Huang Xingbo commented on FLINK-18836: -- [~dian.fu] Thanks a lot for reporting this. I will take a

[jira] [Updated] (FLINK-18633) Download miniconda is instable

[ https://issues.apache.org/jira/browse/FLINK-18633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18633: Fix Version/s: (was: 1.11.3) (was: 1.12.0) > Download miniconda is instable >

[GitHub] [flink] dawidwys commented on pull request #13357: [FLINK-19165] Refactor the UnilateralSortMerger

dawidwys commented on pull request #13357: URL: https://github.com/apache/flink/pull/13357#issuecomment-690123429 It is used exclusively in the DataSet API so far. SQL runtime (blink) has its own version that originates from this classes but diverged substantially. We can think of

[GitHub] [flink] dianfu closed pull request #13075: [FLINK-18833][doc][python] Improve the Python documentation about sql

dianfu closed pull request #13075: URL: https://github.com/apache/flink/pull/13075 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-18833) Improve the Python documentation about sql

[ https://issues.apache.org/jira/browse/FLINK-18833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18833. --- Resolution: Fixed master: 0f98a83e07b04cf019eecb36cec81ceccea386fd > Improve the Python documentation

[jira] [Updated] (FLINK-18833) Improve the Python documentation about sql

[ https://issues.apache.org/jira/browse/FLINK-18833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18833: Fix Version/s: (was: 1.11.3) > Improve the Python documentation about sql >

[jira] [Assigned] (FLINK-18833) Improve the Python documentation about sql

[ https://issues.apache.org/jira/browse/FLINK-18833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-18833: --- Assignee: Huang Xingbo > Improve the Python documentation about sql >

[GitHub] [flink] flinkbot edited a comment on pull request #13370: [hotfix][docs] Update shaded_version to the latest release

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

[GitHub] [flink] flinkbot edited a comment on pull request #13352: [FLINK-19092][sql-parser] Parse comment on computed column failed

flinkbot edited a comment on pull request #13352: URL: https://github.com/apache/flink/pull/13352#issuecomment-688773679 ## CI report: * d9345a586435c7b1efb8aa8ffe210d659bd01c3b Azure:

[jira] [Commented] (FLINK-19167) Proccess Function Example could not work

[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193513#comment-17193513 ] Aljoscha Krettek commented on FLINK-19167: -- This depends on what the rest of the system is

[GitHub] [flink-statefun] igalshilman opened a new pull request #145: [FLINK-19191] Set the default maxInflightAsyncOperations to 1024

igalshilman opened a new pull request #145: URL: https://github.com/apache/flink-statefun/pull/145 The default upper limit for async operations per task slot is currently set to 10 million, and it is unrealistically high, this PR sets it to a more realistic value. A closer example

[jira] [Updated] (FLINK-19191) Reduce the default number for async operations

[ https://issues.apache.org/jira/browse/FLINK-19191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19191: --- Labels: pull-request-available (was: ) > Reduce the default number for async operations >

[GitHub] [flink] flinkbot edited a comment on pull request #13347: [FLINK-19151][yarn]Fix the unit value according to different yarn scheduler

flinkbot edited a comment on pull request #13347: URL: https://github.com/apache/flink/pull/13347#issuecomment-688594190 ## CI report: * 69e1ce21bc78442f69a9a366c8e6222800d54ca1 Azure:

[GitHub] [flink] echauchot commented on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

echauchot commented on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-690156463 @ifndef-SleePy or @pnowojski @rkhachatryan I addressed all the comments PTAL. There is just the UTest

[jira] [Commented] (FLINK-19159) Using Scalafmt to format scala source code

[ https://issues.apache.org/jira/browse/FLINK-19159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193544#comment-17193544 ] darion yaphet commented on FLINK-19159: ---

[GitHub] [flink] flinkbot edited a comment on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

flinkbot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-667140037 ## CI report: * 31abcb25fdf72394dbfa91d0ba9e151968375ad7 UNKNOWN * db99952f8166cb4d6337dcb3815e72ff2b49604b UNKNOWN *

[jira] [Commented] (FLINK-19171) K8s Resource Manager may lead to resource leak after pod deleted

[ https://issues.apache.org/jira/browse/FLINK-19171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193543#comment-17193543 ] Yi Tang commented on FLINK-19171: - bq. BTW, if you are interested in contributing to any of the

[jira] [Commented] (FLINK-19171) K8s Resource Manager may lead to resource leak after pod deleted

[ https://issues.apache.org/jira/browse/FLINK-19171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193542#comment-17193542 ] Yi Tang commented on FLINK-19171: - bq. So, if you don't mind, I'd like to close this ticket It's ok.

[GitHub] [flink] flinkbot edited a comment on pull request #13283: [FLINK-18759][tests] Add readme.md for TPC-DS tools

flinkbot edited a comment on pull request #13283: URL: https://github.com/apache/flink/pull/13283#issuecomment-683593514 ## CI report: * 62f40cd28a36147d84a77b499e63b6224df8b038 Azure:

[jira] [Updated] (FLINK-19192) Set higher limit on the HTTP connection pool

[ https://issues.apache.org/jira/browse/FLINK-19192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19192: --- Labels: pull-request-available (was: ) > Set higher limit on the HTTP connection pool >

[GitHub] [flink-statefun] igalshilman opened a new pull request #146: [FLINK-19192] Set HTTP connection pool size to 1024

igalshilman opened a new pull request #146: URL: https://github.com/apache/flink-statefun/pull/146 This PR increase the max size of the http connection pool to 1024. The connection pool holds connections to the various endpoints and possibly various endpoint instances. The remote

[GitHub] [flink] aljoscha closed pull request #13354: [FLINK-19135] Strip ExecutionException in (Stream)ExecutionEnvironment.execute()

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

[GitHub] [flink] StephanEwen commented on pull request #13354: [FLINK-19135] Strip ExecutionException in (Stream)ExecutionEnvironment.execute()

StephanEwen commented on pull request #13354: URL: https://github.com/apache/flink/pull/13354#issuecomment-690118312 Good fix, thanks! +1 to merge this This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

flinkbot edited a comment on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-684611193 ## CI report: * c266341c63cc4cdc28a6585a82294710fd8ebbc5 UNKNOWN * 8003ac0791570594085b8672d4d47c33fc2bbaf2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13352: [FLINK-19092][sql-parser] Parse comment on computed column failed

flinkbot edited a comment on pull request #13352: URL: https://github.com/apache/flink/pull/13352#issuecomment-688773679 ## CI report: * d9345a586435c7b1efb8aa8ffe210d659bd01c3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13344: [FLINK-10740] FLIP-27 File Source and various Updates on the Split Reader API

flinkbot edited a comment on pull request #13344: URL: https://github.com/apache/flink/pull/13344#issuecomment-688495541 ## CI report: * 15a81e82a4a42cd255baad4ffd3e7e20343b5389 UNKNOWN * d154ff654bd927988a42f2881e8f690a121ea536 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13284: [FLINK-17016][runtime] Integrate pipelined region scheduling

flinkbot edited a comment on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000 ## CI report: * 6af35bfdfa14c049bf4abe1c88ee49a689f38085 UNKNOWN * acc8ba0856f79a5e7915e8612ef0789190a3806d UNKNOWN *

[jira] [Comment Edited] (FLINK-14406) Add metric for managed memory

[ https://issues.apache.org/jira/browse/FLINK-14406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190677#comment-17190677 ] Matthias edited comment on FLINK-14406 at 9/10/20, 10:07 AM: - I discussed

[GitHub] [flink] rmetzger commented on a change in pull request #13356: [FLINK-16789][runtime][rest] Enable JMX RMI port retrieval via REST API

rmetzger commented on a change in pull request #13356: URL: https://github.com/apache/flink/pull/13356#discussion_r486233737 ## File path: docs/_includes/generated/jmx_server_configuration.html ## @@ -0,0 +1,18 @@ + Review comment: Why is this file generated now? (I

[GitHub] [flink] aljoscha commented on pull request #13354: [FLINK-19135] Strip ExecutionException in (Stream)ExecutionEnvironment.execute()

aljoscha commented on pull request #13354: URL: https://github.com/apache/flink/pull/13354#issuecomment-690150927 Thanks for the review! I'm thinking to also backport this to 1.10.x and 1.11.x but I'm torn because we would be flip-flopping in minor releases.

[GitHub] [flink] aljoscha edited a comment on pull request #13354: [FLINK-19135] Strip ExecutionException in (Stream)ExecutionEnvironment.execute()

aljoscha edited a comment on pull request #13354: URL: https://github.com/apache/flink/pull/13354#issuecomment-690150927 Thanks for the review! I'm thinking to also backport this to 1.10.x and 1.11.x but I'm torn because we would be flip-flopping in minor releases. What do you think?

[jira] [Updated] (FLINK-19151) Flink does not normalize container resource with correct configurations when Yarn FairScheduler is used

[ https://issues.apache.org/jira/browse/FLINK-19151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19151: - Fix Version/s: 1.12.0 > Flink does not normalize container resource with correct configurations

[jira] [Updated] (FLINK-19178) Introduce the memory weights configuration option and interfaces

[ https://issues.apache.org/jira/browse/FLINK-19178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19178: - Fix Version/s: 1.11.3 > Introduce the memory weights configuration option and interfaces >

[jira] [Comment Edited] (FLINK-19159) Using Scalafmt to format scala source code

[ https://issues.apache.org/jira/browse/FLINK-19159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193544#comment-17193544 ] darion yaphet edited comment on FLINK-19159 at 9/10/20, 11:08 AM: --

[jira] [Comment Edited] (FLINK-19159) Using Scalafmt to format scala source code

[ https://issues.apache.org/jira/browse/FLINK-19159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193544#comment-17193544 ] darion yaphet edited comment on FLINK-19159 at 9/10/20, 11:08 AM: --

[jira] [Comment Edited] (FLINK-19159) Using Scalafmt to format scala source code

[ https://issues.apache.org/jira/browse/FLINK-19159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193544#comment-17193544 ] darion yaphet edited comment on FLINK-19159 at 9/10/20, 11:08 AM: --

[jira] [Updated] (FLINK-19178) Introduce the memory weights configuration option and interfaces

[ https://issues.apache.org/jira/browse/FLINK-19178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19178: - Fix Version/s: (was: 1.11.3) > Introduce the memory weights configuration option and

[jira] [Created] (FLINK-19192) Set higher limit on the HTTP connection pool

Igal Shilman created FLINK-19192: Summary: Set higher limit on the HTTP connection pool Key: FLINK-19192 URL: https://issues.apache.org/jira/browse/FLINK-19192 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-19192) Set higher limit on the HTTP connection pool

[ https://issues.apache.org/jira/browse/FLINK-19192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-19192: Assignee: Igal Shilman > Set higher limit on the HTTP connection pool >

[jira] [Closed] (FLINK-19171) K8s Resource Manager may lead to resource leak after pod deleted

[ https://issues.apache.org/jira/browse/FLINK-19171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-19171. Resolution: Not A Problem > K8s Resource Manager may lead to resource leak after pod deleted >

[GitHub] [flink] azagrebin commented on a change in pull request #13355: [FLINK-17554] Allow to register release hooks for the classloader

azagrebin commented on a change in pull request #13355: URL: https://github.com/apache/flink/pull/13355#discussion_r485755685 ## File path: flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java ## @@ -123,6 +123,17 @@ */

[GitHub] [flink] flinkbot edited a comment on pull request #13311: [FLINK-18721] Migrate YarnResourceManager to the new YarnResourceManagerDriver

flinkbot edited a comment on pull request #13311: URL: https://github.com/apache/flink/pull/13311#issuecomment-686196434 ## CI report: * b7660009b48d48261b767855d8973c63741ab493 UNKNOWN * f16d78f22d3d66e763f5629a377936bcb20b80c4 UNKNOWN *

[GitHub] [flink-statefun] igalshilman opened a new pull request #144: [FLINK-19190] Use camelCase for metric names

igalshilman opened a new pull request #144: URL: https://github.com/apache/flink-statefun/pull/144 This PR renames the metric names from a snake case to a camel case. This is an automated message from the Apache Git

[jira] [Updated] (FLINK-19190) Use camelCase for metric names

[ https://issues.apache.org/jira/browse/FLINK-19190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19190: --- Labels: pull-request-available (was: ) > Use camelCase for metric names >

[jira] [Closed] (FLINK-18633) Download miniconda is instable

[ https://issues.apache.org/jira/browse/FLINK-18633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18633. --- Resolution: Cannot Reproduce It seems that this issue has not occurred for a very long time. Just closing

[jira] [Commented] (FLINK-19171) K8s Resource Manager may lead to resource leak after pod deleted

[ https://issues.apache.org/jira/browse/FLINK-19171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193534#comment-17193534 ] Xintong Song commented on FLINK-19171: -- [~yittg], bq. it's also a requirement that users should

[GitHub] [flink] echauchot edited a comment on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

echauchot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-690156463 @ifndef-SleePy or @pnowojski @rkhachatryan I addressed all the comments PTAL. There is just the UTest to address left.

[jira] [Updated] (FLINK-19151) Flink does not normalize container resource with correct configurations when Yarn FairScheduler is used

[ https://issues.apache.org/jira/browse/FLINK-19151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19151: - Fix Version/s: 1.11.3 > Flink does not normalize container resource with correct configurations

[GitHub] [flink] azagrebin commented on a change in pull request #13355: [FLINK-17554] Allow to register release hooks for the classloader

azagrebin commented on a change in pull request #13355: URL: https://github.com/apache/flink/pull/13355#discussion_r486269832 ## File path: flink-connectors/flink-connector-kinesis/src/test/resources/log4j2-test.properties ## @@ -0,0 +1,29 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

flinkbot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-667140037 ## CI report: * 31abcb25fdf72394dbfa91d0ba9e151968375ad7 UNKNOWN * db99952f8166cb4d6337dcb3815e72ff2b49604b UNKNOWN *

[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-679099456 ## CI report: * d141f10ef060063162dc073b1cd66729f5f75a3b UNKNOWN * 407169bc192b5d05bfba2c264849f1a6e7b81415 Azure:

  1   2   3   >