[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * c7c2d77d245ae1415f534390b6bbb65466d38775 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * c7c2d77d245ae1415f534390b6bbb65466d38775 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18442: [BP-1.14]FLINK-25678][runtime] Make TaskExecutorStateChangelogStoragesManager.shutdown thread-safe

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18442: URL: https://github.com/apache/flink/pull/18442#issuecomment-1018490440 ## CI report: * 116eefa7d950b80132158eb2b732cddb31ec4572 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18442: [BP-1.14]FLINK-25678][runtime] Make TaskExecutorStateChangelogStoragesManager.shutdown thread-safe

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18442: URL: https://github.com/apache/flink/pull/18442#issuecomment-1018490440 ## CI report: * 116eefa7d950b80132158eb2b732cddb31ec4572 Azure:

[GitHub] [flink] Aitozi edited a comment on pull request #12345: draft: [FLINK-17971] [Runtime/StateBackends] Add RocksDB SST ingestion for batch writes

2022-01-21 Thread GitBox
Aitozi edited a comment on pull request #12345: URL: https://github.com/apache/flink/pull/12345#issuecomment-1019084179 -- 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

[GitHub] [flink] Aitozi commented on pull request #12345: draft: [FLINK-17971] [Runtime/StateBackends] Add RocksDB SST ingestion for batch writes

2022-01-21 Thread GitBox
Aitozi commented on pull request #12345: URL: https://github.com/apache/flink/pull/12345#issuecomment-1019084179 Do we have some plan to drive this feature forward ? We have applied partly of this patch to improve the performance in our internal version, and thanks for your effort @lgo .

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * 44a88561780f8e995f69cad227fd53ac3340ff4f Azure:

[jira] [Commented] (FLINK-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP

2022-01-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480354#comment-17480354 ] Matthias Pohl commented on FLINK-25753: ---

[jira] [Commented] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

2022-01-21 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480348#comment-17480348 ] RocMarshal commented on FLINK-25738: Hi, [~MartijnVisser] May I help to do some translation tasks in

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * 5115a30fdef014a1457212bdec8835166738bced Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * 5115a30fdef014a1457212bdec8835166738bced Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18436: [BP-1.13][FLINK-24334][k8s] Set FLINK_LOG_DIR environment for JobManager and TaskManager pod if configured via options

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18436: URL: https://github.com/apache/flink/pull/18436#issuecomment-1018094327 ## CI report: * f87a46d760404ab5d51b2d5ed554459d3b07fde6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18436: [BP-1.13][FLINK-24334][k8s] Set FLINK_LOG_DIR environment for JobManager and TaskManager pod if configured via options

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18436: URL: https://github.com/apache/flink/pull/18436#issuecomment-1018094327 ## CI report: * f87a46d760404ab5d51b2d5ed554459d3b07fde6 Azure:

[GitHub] [flink] wangyang0918 commented on pull request #18436: [BP-1.13][FLINK-24334][k8s] Set FLINK_LOG_DIR environment for JobManager and TaskManager pod if configured via options

2022-01-21 Thread GitBox
wangyang0918 commented on pull request #18436: URL: https://github.com/apache/flink/pull/18436#issuecomment-1019041761 @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] lindong28 commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-21 Thread GitBox
lindong28 commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r790076382 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSerializerWrapper.java ## @@ -32,26

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18430: URL: https://github.com/apache/flink/pull/18430#issuecomment-1017872223 ## CI report: * e17686bce0bcb94c10e5dc1c925c19755c7305dc Azure:

[jira] [Commented] (FLINK-25757) Fix this security issue related to this exploit: https://www.exploit-db.com/exploits/48978

2022-01-21 Thread Michael Bailey (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480302#comment-17480302 ] Michael Bailey commented on FLINK-25757: [~MartijnVisser]  the exploit here claims to be able to

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2022-01-21 Thread GitBox
galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1018971976 @xintongsong I've realized something as I'm working through the docs and checking things. The existing GCS

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18430: URL: https://github.com/apache/flink/pull/18430#issuecomment-1017872223 ## CI report: * ad64cae7dc0e9da68dc0e8e0498509b85ca791cd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * c7c2d77d245ae1415f534390b6bbb65466d38775 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18430: [FLINK-25577][docs] Update GCS documentation

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18430: URL: https://github.com/apache/flink/pull/18430#issuecomment-1017872223 ## CI report: * ad64cae7dc0e9da68dc0e8e0498509b85ca791cd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2022-01-21 Thread GitBox
galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1018904405 Sounds good, and let me know if I can help with anything. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] sap1ens commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2022-01-21 Thread GitBox
sap1ens commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1018899641 Thank you for the suggestion  Yep, it seems fairly straightforward, we'll add the change. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2022-01-21 Thread GitBox
galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1018897986 @sap1ens I thought of another way to potentially address this issue, which could be done entirely in your fork. But please check me on this. Instead of changing the

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18446: [FLINK-25277][Hotfix] Add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18446: URL: https://github.com/apache/flink/pull/18446#issuecomment-1018723961 ## CI report: * 4003f0d72af128a66e4f76a0c0b76e7943552e69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 26aa7ccebd039dfa7f890d9d927e93c22ca58a0f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[jira] [Closed] (FLINK-25748) Website misses some Repositories

2022-01-21 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf closed FLINK-25748. > Website misses some Repositories > > >

[jira] [Resolved] (FLINK-25748) Website misses some Repositories

2022-01-21 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf resolved FLINK-25748. -- Resolution: Fixed > Website misses some Repositories >

[jira] [Updated] (FLINK-25756) Dedicated Opensearch connectors

2022-01-21 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25756: - Issue Type: New Feature (was: Improvement) > Dedicated Opensearch connectors >

[GitHub] [flink] flinkbot edited a comment on pull request #18445: [FLINK-25755][runtime] AdaptiveScheduler: Introduce shared interface…

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18445: URL: https://github.com/apache/flink/pull/18445#issuecomment-1018642854 ## CI report: * c660ed20b710697879e1db386cc4e6ebdfd4b546 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848205 ## CI report: * 5b2d44dfea90aa64e7f9c2e65307604abb5ad556 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 34089ffca97044c814fba0a68a6cd7562ede905e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 4787b6611ab7ff005e635716d9eca612e0fe71b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * cfb11b3de3e838c30e5c1a44edc919c775ee75fe UNKNOWN * 67a1b9f2f64179cd885df1385dff5fed43a58ec0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18445: [FLINK-25755][runtime] AdaptiveScheduler: Introduce shared interface…

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18445: URL: https://github.com/apache/flink/pull/18445#issuecomment-1018642854 ## CI report: * 81e47cb90ae0facc4c158b8d39a17733868367d3 Azure:

[jira] [Closed] (FLINK-25757) Fix this security issue related to this exploit: https://www.exploit-db.com/exploits/48978

2022-01-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25757. -- Resolution: Invalid I'm not sure why you think this is an exploit. Flink runs user provided

[GitHub] [flink] flinkbot edited a comment on pull request #18381: [hotfix][flink-annotations] Add v1.15 as the next Flink version to master

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18381: URL: https://github.com/apache/flink/pull/18381#issuecomment-1014523784 ## CI report: * 6ce750022ca8bfbf18e2df2eb496ad8fd63553ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848205 ## CI report: * 386e9d632753391d80bbbcd41dacb6a1786d5727 Azure:

[GitHub] [flink] metaswirl commented on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
metaswirl commented on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-1018807185 > Sorry for the inconveniences I've caused with my merge. It caused just more trouble.  Thank you for fixing the code  -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #18381: [hotfix][flink-annotations] Add v1.15 as the next Flink version to master

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18381: URL: https://github.com/apache/flink/pull/18381#issuecomment-1014523784 ## CI report: * 2fe465933260f527c7776a89b2016e558457e634 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848205 ## CI report: * 2c46519978e62a0f60b8a178d126458d3c11da4b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18444: [FLINK-25754] Drop KeyExtractor.ColumnWithIndex

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18444: URL: https://github.com/apache/flink/pull/18444#issuecomment-1018545207 ## CI report: * 21196a482fd15f78943ee20991b6baad2928e04d Azure:

[jira] [Assigned] (FLINK-25679) Build arm64 Linux images for Apache Flink

2022-01-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-25679: -- Assignee: Robert Metzger > Build arm64 Linux images for Apache Flink >

[jira] [Commented] (FLINK-25756) Dedicated Opensearch connectors

2022-01-21 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480243#comment-17480243 ] Andriy Redko commented on FLINK-25756: -- [~MartijnVisser] awesome, we are working on the pull

[jira] [Created] (FLINK-25757) Fix this security issue related to this exploit: https://www.exploit-db.com/exploits/48978

2022-01-21 Thread Michael Bailey (Jira)
Michael Bailey created FLINK-25757: -- Summary: Fix this security issue related to this exploit: https://www.exploit-db.com/exploits/48978 Key: FLINK-25757 URL: https://issues.apache.org/jira/browse/FLINK-25757

[jira] [Commented] (FLINK-25756) Dedicated Opensearch connectors

2022-01-21 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480240#comment-17480240 ] Martijn Visser commented on FLINK-25756: [~reta] Thanks for opening the ticket. There is

[GitHub] [flink] flinkbot edited a comment on pull request #18443: [FLINK-25707] AdaptiveScheduler transitions executions to scheduled

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18443: URL: https://github.com/apache/flink/pull/18443#issuecomment-1018526979 ## CI report: * 34053c55deebf9259e32913eb34b569b3a474541 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * e71f6482ba8f7e911c26db5d9b1b1b4cc692c641 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18442: [BP-1.14]FLINK-25678][runtime] Make TaskExecutorStateChangelogStoragesManager.shutdown thread-safe

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18442: URL: https://github.com/apache/flink/pull/18442#issuecomment-1018490440 ## CI report: * 116eefa7d950b80132158eb2b732cddb31ec4572 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18431: [FLINK-25024][docs] Add Changelog backend docs

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18431: URL: https://github.com/apache/flink/pull/18431#issuecomment-1017952324 ## CI report: * f58ab18ad9596e758779524e0cb4f967f3ba9a90 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18381: [hotfix][flink-annotations] Add v1.15 as the next Flink version to master

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18381: URL: https://github.com/apache/flink/pull/18381#issuecomment-1014523784 ## CI report: * 407dbd00b6169cf0df0667e76811d468356be63d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[jira] [Updated] (FLINK-25756) Dedicated Opensearch connectors

2022-01-21 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andriy Redko updated FLINK-25756: - Description: Since the time Opensearch got forked from Elasticsearch a few things got changed.

[GitHub] [flink] tillrohrmann commented on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
tillrohrmann commented on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-1018746050 Sorry for the inconveniences I've caused with my merge. It caused just more trouble.  -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Created] (FLINK-25756) Dedicated Opensearch connectors

2022-01-21 Thread Andriy Redko (Jira)
Andriy Redko created FLINK-25756: Summary: Dedicated Opensearch connectors Key: FLINK-25756 URL: https://issues.apache.org/jira/browse/FLINK-25756 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * f70a1809bb907c903b40f9861cb4342b3adca20c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[jira] [Commented] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

2022-01-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480219#comment-17480219 ] Till Rohrmann commented on FLINK-25749: --- The problem is indeed caused by

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * f70a1809bb907c903b40f9861cb4342b3adca20c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 058cac39b343263eb7ee8c719946d518bd629bfe Azure:

[jira] [Commented] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

2022-01-21 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480214#comment-17480214 ] David Morávek commented on FLINK-25749: --- Merging https://github.com/apache/flink/pull/18446 after

[GitHub] [flink] zentol closed pull request #18441: Release 1.14 error in consumer kafka message

2022-01-21 Thread GitBox
zentol closed pull request #18441: URL: https://github.com/apache/flink/pull/18441 -- 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] zentol commented on pull request #18441: Release 1.14 error in consumer kafka message

2022-01-21 Thread GitBox
zentol commented on pull request #18441: URL: https://github.com/apache/flink/pull/18441#issuecomment-1018734448 [This is not the right place to ask question.](https://flink.apache.org/gettinghelp.html) -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-21 Thread GitBox
CrynetLogistics commented on a change in pull request #18314: URL: https://github.com/apache/flink/pull/18314#discussion_r789880495 ## File path:

[jira] [Comment Edited] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

2022-01-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480212#comment-17480212 ] Till Rohrmann edited comment on FLINK-25749 at 1/21/22, 5:54 PM: -

[GitHub] [flink] flinkbot edited a comment on pull request #18416: [FLINK-25715][clients] Add deployment option (`execution.submit-failed-job-on-application-error`) for submitting a failed job when th

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18416: URL: https://github.com/apache/flink/pull/18416#issuecomment-1017255537 ## CI report: * 9b8c8e8ace0ea4922f12c3014fa8d9b8c1acf11c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[jira] [Commented] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

2022-01-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480212#comment-17480212 ] Till Rohrmann commented on FLINK-25749: --- David raised the suspicion that the instability could be

[jira] [Assigned] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

2022-01-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25749: - Assignee: Till Rohrmann > YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP >

[GitHub] [flink] flinkbot edited a comment on pull request #18446: [FLINK-25277][Hotfix] Add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18446: URL: https://github.com/apache/flink/pull/18446#issuecomment-1018723961 ## CI report: * 4003f0d72af128a66e4f76a0c0b76e7943552e69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot commented on pull request #18446: [FLINK-25277][Hotfix] Add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot commented on pull request #18446: URL: https://github.com/apache/flink/pull/18446#issuecomment-1018723961 ## CI report: * 4003f0d72af128a66e4f76a0c0b76e7943552e69 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18446: [FLINK-25277][Hotfix] Add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot commented on pull request #18446: URL: https://github.com/apache/flink/pull/18446#issuecomment-1018723309 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 #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] dmvk opened a new pull request #18446: [FLINK-25277][Hotfix] Add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
dmvk opened a new pull request #18446: URL: https://github.com/apache/flink/pull/18446 hotfix of https://github.com/apache/flink/pull/18169 to fix https://issues.apache.org/jira/browse/FLINK-25749 -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #18428: [FLINK-25575] Add Sink V2 operators and translation

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18428: URL: https://github.com/apache/flink/pull/18428#issuecomment-1017677769 ## CI report: * f4fdde6fd2c0cf28cf44d63bd8dfc34da24690d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18189: URL: https://github.com/apache/flink/pull/18189#issuecomment-1000280224 ## CI report: * 7c26d9777bcd41a91c33c2b6aaeaff61939fd6d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-21 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

  1   2   3   4   5   >