[GitHub] [flink] KarmaGYZ commented on pull request #19481: [FLINK-27256][runtime] Log the root exception in closing the task man…

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

[GitHub] [flink] flinkbot commented on pull request #19484: [FLINK-27258] [Doc] fix chinese deploment doc malformed text

flinkbot commented on PR #19484: URL: https://github.com/apache/flink/pull/19484#issuecomment-1099832665 ## CI report: * 714c3dfc1eec638a1ec71330e31bb0dab6bbe8ed UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27258) Deployment Chinese document malformed text

[ https://issues.apache.org/jira/browse/FLINK-27258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27258: --- Labels: pull-request-available (was: ) > Deployment Chinese document malformed text >

[GitHub] [flink] BenJFan opened a new pull request, #19484: [FLINK-27258] [Doc] fix chinese deploment doc malformed text

BenJFan opened a new pull request, #19484: URL: https://github.com/apache/flink/pull/19484 ## What is the purpose of the change  fix chinese deploment doc malformed

[GitHub] [flink] mas-chen commented on a diff in pull request #19456: [FLINK-27041][connector/kafka] Catch IllegalStateException in KafkaPartitionSplitReader.fetch() to handle no valid partition case

mas-chen commented on code in PR #19456: URL: https://github.com/apache/flink/pull/19456#discussion_r851041663 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java: ## @@ -131,12 +138,7 @@ public

[GitHub] [flink-kubernetes-operator] tweise commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

tweise commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r851041385 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -102,36 +111,84

[GitHub] [flink] dianfu commented on a diff in pull request #19480: [FLINK-27213][API/Python]Add PurgingTrigger

dianfu commented on code in PR #19480: URL: https://github.com/apache/flink/pull/19480#discussion_r851034880 ## flink-python/pyflink/datastream/window.py: ## @@ -840,6 +841,65 @@ def register_next_fire_timestamp(self,

[jira] [Created] (FLINK-27259) Observer should not clear savepoint errors even though deployment is healthy

Yang Wang created FLINK-27259: - Summary: Observer should not clear savepoint errors even though deployment is healthy Key: FLINK-27259 URL: https://issues.apache.org/jira/browse/FLINK-27259 Project:

[jira] [Created] (FLINK-27258) Deployment Chinese document malformed text

FanJia created FLINK-27258: -- Summary: Deployment Chinese document malformed text Key: FLINK-27258 URL: https://issues.apache.org/jira/browse/FLINK-27258 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-27258) Deployment Chinese document malformed text

[ https://issues.apache.org/jira/browse/FLINK-27258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522637#comment-17522637 ] FanJia commented on FLINK-27258: Let me fix it for my first issue. > Deployment Chinese document

[jira] [Commented] (FLINK-27218) Serializer in OperatorState has not been updated when new Serializers are NOT incompatible

[ https://issues.apache.org/jira/browse/FLINK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522634#comment-17522634 ] Yun Tang commented on FLINK-27218: -- [~mayuehappy] I think you're right, this would affect the

[jira] [Commented] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522632#comment-17522632 ] Yang Wang commented on FLINK-27257: --- The expected behavior is the subsequent reconciliation should

[jira] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257 ] Yang Wang deleted comment on FLINK-27257: --- was (Author: fly_in_gis): It is also strange that the subsequent reconciliation does not trigger the savepoint again. Otherwise, this should not be

[GitHub] [flink] liuzhuang2017 commented on pull request #19483: [hotfix][docs-zh] Fix "Google Cloud PubSub" Chinese page under "DataStream Connectors"

liuzhuang2017 commented on PR #19483: URL: https://github.com/apache/flink/pull/19483#issuecomment-1099812887 @wuchong ,Thanks for your review. -- 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] [Comment Edited] (FLINK-27236) No task slot allocated for job in larege-scale job

[ https://issues.apache.org/jira/browse/FLINK-27236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522631#comment-17522631 ] Lijie Wang edited comment on FLINK-27236 at 4/15/22 3:15 AM: - [~freeke]  ->

[jira] [Commented] (FLINK-27236) No task slot allocated for job in larege-scale job

[ https://issues.apache.org/jira/browse/FLINK-27236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522631#comment-17522631 ] Lijie Wang commented on FLINK-27236: [~freeke]  -> At least, the previous execution shouldn't be

[GitHub] [flink] flinkbot commented on pull request #19483: [hotfix][docs-zh] Fix "Google Cloud PubSub" Chinese page under "DataStream Connectors"

flinkbot commented on PR #19483: URL: https://github.com/apache/flink/pull/19483#issuecomment-1099811000 ## CI report: * deb4187089fc00f51f320a4983d00584e802d779 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] wuchong commented on pull request #19483: [hotfix][docs-zh] Fix "Google Cloud PubSub" Chinese page under "DataStream Connectors"

wuchong commented on PR #19483: URL: https://github.com/apache/flink/pull/19483#issuecomment-1099810162 I will merge it when the CI passed. -- 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] liuzhuang2017 opened a new pull request, #19483: [hotfix][docs-zh] Fix "Google Cloud PubSub" Chinese page under "DataStream Connectors"

liuzhuang2017 opened a new pull request, #19483: URL: https://github.com/apache/flink/pull/19483 ## What is the purpose of the change # **This is the English document：**

[jira] [Commented] (FLINK-27055) java.lang.ArrayIndexOutOfBoundsException in BinarySegmentUtils

[ https://issues.apache.org/jira/browse/FLINK-27055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522629#comment-17522629 ] Kenny Ma commented on FLINK-27055: -- [~jark] do you have any suggestion? Upgrading to 1.14 would require

[jira] [Commented] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522628#comment-17522628 ] Yang Wang commented on FLINK-27257: --- It is also strange that the subsequent reconciliation does not

[jira] [Commented] (FLINK-27247) ScalarOperatorGens.numericCasting is not compatible with legacy behavior

[ https://issues.apache.org/jira/browse/FLINK-27247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522626#comment-17522626 ] xuyang commented on FLINK-27247: Hi, [~matriv], I think currently this is not the problem with casting.

[jira] [Commented] (FLINK-27121) Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Chinese

[ https://issues.apache.org/jira/browse/FLINK-27121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522625#comment-17522625 ] LEI ZHOU commented on FLINK-27121: -- [~martijnvisser] ok，thanks very much!!! > Translate

[GitHub] [flink] flinkbot commented on pull request #19482: [FLINK-27244][hive] Support read sub-directories in partition directory with Hive tables

flinkbot commented on PR #19482: URL: https://github.com/apache/flink/pull/19482#issuecomment-1099802626 ## CI report: * e9b2b761abf6aee6415b4daec7374340015c0426 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-24932) Frocksdb cannot run on Apple M1

[ https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522624#comment-17522624 ] Yun Tang commented on FLINK-24932: -- [~maver1ck] Thanks for your information. We actually always watch

[jira] [Created] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

Yang Wang created FLINK-27257: - Summary: Flink kubernetes operator triggers savepoint failed because of not all tasks running Key: FLINK-27257 URL: https://issues.apache.org/jira/browse/FLINK-27257

[GitHub] [flink-kubernetes-operator] tweise commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

tweise commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r851023715 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/ApplicationObserver.java: ## @@ -70,23 +70,28 @@

[GitHub] [flink] snailHumming commented on pull request #19401: [FLINK-25716][docs-zh] Translate "Streaming Concepts" page of "Applic…

snailHumming commented on PR #19401: URL: https://github.com/apache/flink/pull/19401#issuecomment-1099800909 Should I create a new PR for applying these changes to master branch？ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-27244) Support subdirectories with Hive tables

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

[GitHub] [flink] luoyuxia opened a new pull request, #19482: [FLINK-27244][hive] Support read sub-directories in partition directory with Hive tables

luoyuxia opened a new pull request, #19482: URL: https://github.com/apache/flink/pull/19482 ## What is the purpose of the change Support read sub-directories in partition directory with Hive tables ## Brief change log Add an option to read partition

[GitHub] [flink] flinkbot commented on pull request #19481: [FLINK-27256][runtime] Log the root exception in closing the task man…

flinkbot commented on PR #19481: URL: https://github.com/apache/flink/pull/19481#issuecomment-1099795917 ## CI report: * fd30fc5691495b033a82c8289454d16fd9f6107f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27256) Log the root exception in closing the task manager connection

[ https://issues.apache.org/jira/browse/FLINK-27256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27256: --- Labels: pull-request-available (was: ) > Log the root exception in closing the task

[GitHub] [flink] KarmaGYZ opened a new pull request, #19481: [FLINK-27256][runtime] Log the root exception in closing the task man…

KarmaGYZ opened a new pull request, #19481: URL: https://github.com/apache/flink/pull/19481 …ager connection ## What is the purpose of the change Log the root exception in closing the task manager connection for ease of debugging. ## Brief change log

[jira] [Commented] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

[ https://issues.apache.org/jira/browse/FLINK-27212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522618#comment-17522618 ] Wenlong Lyu commented on FLINK-27212: - [~matriv] I think you may have some misunderstanding here.

[GitHub] [flink] flinkbot commented on pull request #19480: [FLINK-27213][API/Python]Add PurgingTrigger

flinkbot commented on PR #19480: URL: https://github.com/apache/flink/pull/19480#issuecomment-1099791847 ## CI report: * 2bb742ac2836616e82401169eed3f24a8a608315 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-27256) Log the root exception in closing the task manager connection

Yangze Guo created FLINK-27256: -- Summary: Log the root exception in closing the task manager connection Key: FLINK-27256 URL: https://issues.apache.org/jira/browse/FLINK-27256 Project: Flink

[jira] [Updated] (FLINK-27213) Add PurgingTrigger

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

[GitHub] [flink] cun8cun8 opened a new pull request, #19480: [FLINK-27213][API/Python]Add PurgingTrigger

cun8cun8 opened a new pull request, #19480: URL: https://github.com/apache/flink/pull/19480 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] xuyangzhong commented on pull request #19465: [FLINK-27239][table-planner] rewrite PreValidateReWriter from scala to java

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

[GitHub] [flink] PatrickRen commented on a diff in pull request #19456: [FLINK-27041][connector/kafka] Catch IllegalStateException in KafkaPartitionSplitReader.fetch() to handle no valid partition cas

PatrickRen commented on code in PR #19456: URL: https://github.com/apache/flink/pull/19456#discussion_r851005151 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java: ## @@ -131,12 +138,7 @@ public

[jira] [Comment Edited] (FLINK-27236) No task slot allocated for job in larege-scale job

[ https://issues.apache.org/jira/browse/FLINK-27236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522609#comment-17522609 ] yanpengshi edited comment on FLINK-27236 at 4/15/22 2:00 AM: - Hi.

[jira] [Commented] (FLINK-27236) No task slot allocated for job in larege-scale job

[ https://issues.apache.org/jira/browse/FLINK-27236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522609#comment-17522609 ] yanpengshi commented on FLINK-27236: Hi. [~wanglijie95], thank you for your response, I have ever

[jira] [Commented] (FLINK-27235) Publish Flink k8s Operator Helm Charts via Github Actions

[ https://issues.apache.org/jira/browse/FLINK-27235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522606#comment-17522606 ] Yang Wang commented on FLINK-27235: --- Fot the main branch, I expect only when the

[jira] [Assigned] (FLINK-27235) Publish Flink k8s Operator Helm Charts via Github Actions

[ https://issues.apache.org/jira/browse/FLINK-27235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-27235: - Assignee: Gezim Sejdiu > Publish Flink k8s Operator Helm Charts via Github Actions >

[jira] [Updated] (FLINK-27245) Flink job on Yarn cannot revover when zookeeper in Exception

[ https://issues.apache.org/jira/browse/FLINK-27245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hjw updated FLINK-27245: Description: Flink job cannot revover when zookeeper in Exception. I noticed that the data in

[jira] [Commented] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

[ https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522595#comment-17522595 ] J Y commented on FLINK-27255: - has this issue existed for awhile now (1.11+)?  or, is it just constrained to

[jira] [Assigned] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

[ https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-27255: Assignee: Haizhou Zhao > Flink-avro does not support serialization and deserialization

[jira] [Commented] (FLINK-27101) Periodically break the chain of incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522594#comment-17522594 ] Feifan Wang commented on FLINK-27101: - Hi [~yunta], [~pnowojski] , I think solution 3 can support

[jira] [Created] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

Haizhou Zhao created FLINK-27255: Summary: Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters Key: FLINK-27255 URL:

[jira] [Commented] (FLINK-27101) Periodically break the chain of incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522586#comment-17522586 ] Steven Zhen Wu commented on FLINK-27101: [~pnowojski] Option 3 (externally triggered checkpoint)

[jira] [Updated] (FLINK-24066) Provides a new stop entry for Kubernetes session mode

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

[jira] [Updated] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26177: --- Labels: pull-request-available stale-blocker stale-critical test-stability (was:

[jira] [Updated] (FLINK-23847) [Kafka] Error msg are obscure when KafkaConsumer init, valueDeserializer is null

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

[jira] [Updated] (FLINK-23187) [Documentation] PubSubSink should use "withTopicName" rather than "withSubscriptionName"

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

[jira] [Updated] (FLINK-23861) flink sql client support dynamic params

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

[jira] [Updated] (FLINK-23397) [DOCS] task_failure_recovery page return 404

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

[jira] [Updated] (FLINK-24398) KafkaSourceFetcherManager should re-use an existing SplitFetcher to commit offset if possible

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

[jira] [Updated] (FLINK-25747) UdfStreamOperatorCheckpointingITCase hangs on AZP

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

[jira] [Updated] (FLINK-24142) Fix Document DataStream Connectors File Sink ORC Format Scala example

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

[jira] [Updated] (FLINK-24009) Upgrade to Apache pom parent 24

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

[jira] [Updated] (FLINK-24093) Supports setting the percentage of kubernetes Request resources

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

[jira] [Updated] (FLINK-24251) Make default constructor of BinaryStringData construct empty binary string again

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

[GitHub] [flink] mas-chen commented on a diff in pull request #19456: [FLINK-27041][connector/kafka] Catch IllegalStateException in KafkaPartitionSplitReader.fetch() to handle no valid partition case

mas-chen commented on code in PR #19456: URL: https://github.com/apache/flink/pull/19456#discussion_r850797500 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java: ## @@ -131,12 +138,7 @@ public

[GitHub] [flink] flinkbot commented on pull request #19479: [FLINK-25694][FileSystems][S3] Upgrade Presto to resolve GSON/Alluxio Vulnerability

flinkbot commented on PR #19479: URL: https://github.com/apache/flink/pull/19479#issuecomment-1099563224 ## CI report: * 309ce3cb15d98a31d4307c7b6322d44469bc8a73 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-25694) Upgrade Presto to resolve GSON/Alluxio Vulnerability

[ https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522513#comment-17522513 ] David Perkins commented on FLINK-25694: --- Created PRs for 1.14 and 1.15 * release-1.14:

[GitHub] [flink] David-N-Perkins opened a new pull request, #19479: [FLINK-25694][FileSystems][S3] Upgrade Presto to resolve GSON/Alluxio Vulnerability

David-N-Perkins opened a new pull request, #19479: URL: https://github.com/apache/flink/pull/19479 ## What is the purpose of the change * Updated presto to the latest version due to GSON bug ## Brief change log - Updated prosto library to `.272` ## Verifying this change

[GitHub] [flink] flinkbot commented on pull request #19478: [FLINK-25694][FileSystems][S3] Upgrade Presto to resolve GSON/Alluxio Vulnerability

flinkbot commented on PR #19478: URL: https://github.com/apache/flink/pull/19478#issuecomment-1099553046 ## CI report: * 2a1fd978334d3712397ab1b35da3fddc883c933f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] David-N-Perkins opened a new pull request, #19478: [FLINK-25694][FileSystems][S3] Upgrade Presto to resolve GSON/Alluxio Vulnerability

David-N-Perkins opened a new pull request, #19478: URL: https://github.com/apache/flink/pull/19478 ## What is the purpose of the change * Updated presto to the latest version due to GSON bug ## Brief change log - Updated prosto library to `.272` ## Verifying this change

[GitHub] [flink] MartijnVisser commented on pull request #19428: [FLINK-25694][FileSystems][S3] Upgrade Presto to resolve GSON/Alluxio Vulnerability

MartijnVisser commented on PR #19428: URL: https://github.com/apache/flink/pull/19428#issuecomment-1099530607 @David-N-Perkins I think we could consider backports to both `release-1.15` and `release-1.14`, being the last 2 releases that are being supported. I'm not 100% sure if we could

[GitHub] [flink] MartijnVisser commented on pull request #19473: [FLINK-27231][Connector/Pulsar] Bump pulsar to 2.10.0

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

[GitHub] [flink] David-N-Perkins commented on pull request #19428: [FLINK-25694][FileSystems][S3] Upgrade Presto to resolve GSON/Alluxio Vulnerability

David-N-Perkins commented on PR #19428: URL: https://github.com/apache/flink/pull/19428#issuecomment-1099523678 @MartijnVisser Does this need to get merged into any other support branches? And is there a time frame on when this would get released? My company is tracking this

[jira] [Closed] (FLINK-27120) Translate "Gradle" tab of "Application Development > Project Configuration > Overview" to Chinese

[ https://issues.apache.org/jira/browse/FLINK-27120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27120. -- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] MartijnVisser merged pull request #19403: [FLINK-27120][docs-zh] Translate "Gradle" tab of development > conf > overview

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

[jira] [Closed] (FLINK-25694) Upgrade Presto to resolve GSON/Alluxio Vulnerability

[ https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25694. -- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master:

[jira] [Assigned] (FLINK-25694) Upgrade Presto to resolve GSON/Alluxio Vulnerability

[ https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25694: -- Assignee: David Perkins > Upgrade Presto to resolve GSON/Alluxio Vulnerability >

[GitHub] [flink] MartijnVisser merged pull request #19428: [FLINK-25694][FileSystems][S3] Upgrade Presto to resolve GSON/Alluxio Vulnerability

MartijnVisser merged PR #19428: URL: https://github.com/apache/flink/pull/19428 -- 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] MartijnVisser commented on pull request #19428: [FLINK-25694][FileSystems][S3] Upgrade Presto to resolve GSON/Alluxio Vulnerability

MartijnVisser commented on PR #19428: URL: https://github.com/apache/flink/pull/19428#issuecomment-1099521175 Verified that S3 is working as expected in https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=34682=results. Merging this now. Thanks again @David-N-Perkins !

[jira] [Created] (FLINK-27254) Add Volume and VolumeMount supports for FlinkSessionJob

Xin Hao created FLINK-27254: --- Summary: Add Volume and VolumeMount supports for FlinkSessionJob Key: FLINK-27254 URL: https://issues.apache.org/jira/browse/FLINK-27254 Project: Flink Issue Type:

[GitHub] [flink] XComp commented on pull request #19475: [FLINK-27250][sql][build] Remove custom surefire config

XComp commented on PR #19475: URL: https://github.com/apache/flink/pull/19475#issuecomment-1099402041 Out of curiosity: How did you test this change? Just running CI with this change and verifying that no error occurs? Or do we have other means to check that everything's working as

[GitHub] [flink] gaoyunhaii closed pull request #19466: (1.15) [FLINK-27231][FLINK-27230][FLINK-27233] Fix the remaining licence issues on 1.15

gaoyunhaii closed pull request #19466: (1.15) [FLINK-27231][FLINK-27230][FLINK-27233] Fix the remaining licence issues on 1.15 URL: https://github.com/apache/flink/pull/19466 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] gaoyunhaii commented on pull request #19466: (1.15) [FLINK-27231][FLINK-27230][FLINK-27233] Fix the remaining licence issues on 1.15

gaoyunhaii commented on PR #19466: URL: https://github.com/apache/flink/pull/19466#issuecomment-1099369913 Very thanks @dawidwys @zentol for the review! Will merge~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #165: [FLINK-26140] Support rollback strategies

gyfora commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1099324926 @wangyang0918 I just pushed a commit before your comment :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #165: [FLINK-26140] Support rollback strategies

wangyang0918 commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1099317348 One more comment, I forgot to note that the session job rollback has not been supported. I assume it will be done in a separate ticket. -- This is an automated

[jira] [Updated] (FLINK-27253) Remove custom surefire config from connector-cassandra

[ https://issues.apache.org/jira/browse/FLINK-27253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27253: --- Labels: pull-request-available (was: ) > Remove custom surefire config from

[GitHub] [flink] flinkbot commented on pull request #19477: [FLINK-27253][cassandra][build] Remove custom surefire config

flinkbot commented on PR #19477: URL: https://github.com/apache/flink/pull/19477#issuecomment-1099288245 ## CI report: * 92e8bcb226fc5d467ff8c3d18725c065687fedfa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27252) Remove surefire fork options from connector-hive

[ https://issues.apache.org/jira/browse/FLINK-27252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27252: --- Labels: pull-request-available (was: ) > Remove surefire fork options from connector-hive

[GitHub] [flink] flinkbot commented on pull request #19476: [FLINK-27252][hive][build] Remove surefire fork settings

flinkbot commented on PR #19476: URL: https://github.com/apache/flink/pull/19476#issuecomment-1099288080 ## CI report: * 8598760b2ff4e76da87afa2b929ad9b6d1292069 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522355#comment-17522355 ] Etienne Chauchot edited comment on FLINK-26793 at 4/14/22 3:10 PM: ---

[jira] [Comment Edited] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522355#comment-17522355 ] Etienne Chauchot edited comment on FLINK-26793 at 4/14/22 3:08 PM: ---

[jira] [Created] (FLINK-27253) Remove custom surefire config from connector-cassandra

Chesnay Schepler created FLINK-27253: Summary: Remove custom surefire config from connector-cassandra Key: FLINK-27253 URL: https://issues.apache.org/jira/browse/FLINK-27253 Project: Flink

[jira] [Commented] (FLINK-27232) .scalafmt.conf cant be located when running in sub-directory

[ https://issues.apache.org/jira/browse/FLINK-27232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522372#comment-17522372 ] Marios Trivyzas commented on FLINK-27232: - I get your points, not insisting, we can leave it as

[jira] [Created] (FLINK-27252) Remove surefire fork options from connector-hive

Chesnay Schepler created FLINK-27252: Summary: Remove surefire fork options from connector-hive Key: FLINK-27252 URL: https://issues.apache.org/jira/browse/FLINK-27252 Project: Flink

[jira] [Commented] (FLINK-27247) ScalarOperatorGens.numericCasting is not compatible with legacy behavior

[ https://issues.apache.org/jira/browse/FLINK-27247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522367#comment-17522367 ] Marios Trivyzas commented on FLINK-27247: - Commented on the PR as well, I think we need to fix

[jira] [Commented] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522363#comment-17522363 ] fanrui commented on FLINK-26803: Hi [~akalashnikov] , thanks for your quick feedback. For some flink

[jira] [Comment Edited] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522355#comment-17522355 ] Etienne Chauchot edited comment on FLINK-26793 at 4/14/22 2:59 PM: ---

[jira] [Comment Edited] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522355#comment-17522355 ] Etienne Chauchot edited comment on FLINK-26793 at 4/14/22 2:56 PM: ---

[jira] [Comment Edited] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522355#comment-17522355 ] Etienne Chauchot edited comment on FLINK-26793 at 4/14/22 2:55 PM: ---

[jira] [Comment Edited] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522355#comment-17522355 ] Etienne Chauchot edited comment on FLINK-26793 at 4/14/22 2:55 PM: ---

[jira] [Updated] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-26793: - Attachment: taskmanager_127.0.1.1_33251-af56fa_log > Flink Cassandra connector

[jira] [Updated] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-26793: - Attachment: jobmanager_log.txt > Flink Cassandra connector performance issue >

  1   2   3   4   >