[flink] 02/02: [FLINK-26349][test] migrate AvroParquetRecordFormatTest to AssertJ

This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 128e19156208a306669f1736514f61d85f9ee065 Author: Jing Ge AuthorDate: Wed Mar 9 20:11:53 2022 +0100 [FLINK-26349][test

[flink] 01/02: [FLINK-26349][AvroParquet][test] add test for reading reflect records from parquet file created with generic record schema.

This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e7d9c59d68644a943fc5d059c4a7a9fa3366da10 Author: Jing Ge AuthorDate: Wed Mar 9 15:08:43 2022 +0100 [FLINK-26349][Avro

[flink] branch master updated (155f17d -> 128e191)

This is an automated email from the ASF dual-hosted git repository. arvid pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 155f17d [FLINK-26564][connectors/filesystem] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #49: HotFix] Merged logic for upgradeModes LAST_STATE & SAVEPOINT during r…

gyfora merged pull request #49: URL: https://github.com/apache/flink-kubernetes-operator/pull/49 -- 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: c

[flink-kubernetes-operator] branch main updated (c868268 -> 859040b)

This is an automated email from the ASF dual-hosted git repository. gyfora pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git. from c868268 [FLINK-26572] Improve reconcile reschedule configs and defaults add 859040b [hotfix]

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #50: [FLINK-26594] Helm - Replace operatorNamespace with Release Namespace

gyfora commented on pull request #50: URL: https://github.com/apache/flink-kubernetes-operator/pull/50#issuecomment-1064818468 cc @mbalassi -- 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-kubernetes-operator] gyfora commented on a change in pull request #50: [FLINK-26594] Helm - Replace operatorNamespace with Release Namespace

gyfora commented on a change in pull request #50: URL: https://github.com/apache/flink-kubernetes-operator/pull/50#discussion_r824424886 ## File path: helm/flink-operator/values.yaml ## @@ -18,9 +18,6 @@ --- -operatorNamespace: - name: default Review comment: per

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #51: [FLINK-26572] Improve reconcile reschedule configs and defaults

gyfora merged pull request #51: URL: https://github.com/apache/flink-kubernetes-operator/pull/51 -- 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: c

[flink-kubernetes-operator] branch main updated (a738c81 -> c868268)

This is an automated email from the ASF dual-hosted git repository. gyfora pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git. from a738c81 [FLINK-26507] Allow session and last-state jobs to reconcile in any state add c868268

[GitHub] [flink-kubernetes-operator] gyfora commented on a change in pull request #51: [FLINK-26572] Improve reconcile reschedule configs and defaults

gyfora commented on a change in pull request #51: URL: https://github.com/apache/flink-kubernetes-operator/pull/51#discussion_r824423169 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorConfiguration.java ## @@ -26

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a change in pull request #51: [FLINK-26572] Improve reconcile reschedule configs and defaults

wangyang0918 commented on a change in pull request #51: URL: https://github.com/apache/flink-kubernetes-operator/pull/51#discussion_r824388470 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorConfiguration.java ##

[GitHub] [flink-kubernetes-operator] haoxins commented on a change in pull request #50: Helm: Replace operatorNamespace with Release Namespace

haoxins commented on a change in pull request #50: URL: https://github.com/apache/flink-kubernetes-operator/pull/50#discussion_r824379601 ## File path: helm/flink-operator/values.yaml ## @@ -18,9 +18,6 @@ --- -operatorNamespace: - name: default Review comment: ht

[GitHub] [flink-kubernetes-operator] tweise commented on a change in pull request #51: [FLINK-26572] Improve reconcile reschedule configs and defaults

tweise commented on a change in pull request #51: URL: https://github.com/apache/flink-kubernetes-operator/pull/51#discussion_r824373450 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorConfiguration.java ## @@ -26

[flink-table-store] branch master updated: [FLINK-26544] Apply key & value filter in FileStoreScanImpl

This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git The following commit(s) were added to refs/heads/master by this push: new f69c037 [FLINK-26544] Apply ke

[flink-table-store] branch master updated: [FLINK-26530] Introduce TableStore API and refactor ITCases

This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git The following commit(s) were added to refs/heads/master by this push: new 38785e0 [FLINK-26530] Introduc

[GitHub] [flink-kubernetes-operator] haoxins commented on a change in pull request #50: Helm: Replace operatorNamespace with Release Namespace

haoxins commented on a change in pull request #50: URL: https://github.com/apache/flink-kubernetes-operator/pull/50#discussion_r824361320 ## File path: helm/flink-operator/values.yaml ## @@ -18,9 +18,6 @@ --- -operatorNamespace: - name: default Review comment: >

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a change in pull request #51: [FLINK-26572] Improve reconcile reschedule configs and defaults

wangyang0918 commented on a change in pull request #51: URL: https://github.com/apache/flink-kubernetes-operator/pull/51#discussion_r824359419 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorConfiguration.java ##

[flink] branch master updated: [FLINK-26564][connectors/filesystem] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 155f17d [FLINK-26564][connectors/filesystem]

[GitHub] [flink-kubernetes-operator] gyfora commented on a change in pull request #50: Helm: Replace operatorNamespace with Release Namespace

gyfora commented on a change in pull request #50: URL: https://github.com/apache/flink-kubernetes-operator/pull/50#discussion_r824172450 ## File path: helm/flink-operator/values.yaml ## @@ -18,9 +18,6 @@ --- -operatorNamespace: - name: default Review comment: We

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #50: Helm: Replace operatorNamespace with Release Namespace

gyfora commented on pull request #50: URL: https://github.com/apache/flink-kubernetes-operator/pull/50#issuecomment-1064518738 Hi @haoxins , I think the change makes sense but could you please open a JIRA ticket first? -- This is an automated message from the Apache Git Service. To resp

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #51: [FLINK-26572] Improve reconcile reschedule configs and defaults

gyfora commented on pull request #51: URL: https://github.com/apache/flink-kubernetes-operator/pull/51#issuecomment-1064504062 cc @tweise @wangyang0918 -- 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 t

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #52: [FLINK-26574] Expose config files in helm chart

gyfora commented on pull request #52: URL: https://github.com/apache/flink-kubernetes-operator/pull/52#issuecomment-1064503744 cc @morhidi @mbalassi -- 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 g

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request #52: [FLINK-26574] Expose config files in helm chart

gyfora opened a new pull request #52: URL: https://github.com/apache/flink-kubernetes-operator/pull/52 Main changes: - Move the default config and logging properties to files from the helm templates - Allow users to easily override operator and flink default configs from helm chart

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request #51: [FLINK-26572] Improve reconcile reschedule configs and defaults

gyfora opened a new pull request #51: URL: https://github.com/apache/flink-kubernetes-operator/pull/51 Make config names cleaner and reduce reschedule delays while the job is deploying. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[flink] branch master updated (ed5e614 -> d212b83)

This is an automated email from the ASF dual-hosted git repository. mapohl pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from ed5e614 [FLINK-26306][state/changelog] Randomly offset materialization add d212b83 Revert "[hotfix][table-plann

[flink] branch master updated: [FLINK-26306][state/changelog] Randomly offset materialization

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new ed5e614 [FLINK-26306][state/changelog] Randomly o

[flink] branch master updated (c5352fc -> ce0da79)

This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c5352fc [FLINK-26494][runtime] Adds log message to cleanup failure new cbfca3a [hotfix][table-planner] R

[flink] 02/02: [FLINK-26125][docs][table] Add new documentation for the CAST changes in 1.15. This closes #18813

This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ce0da798f2a198a04f5de42e689dc54fdeba3c36 Author: slinkydeveloper AuthorDate: Tue Feb 15 16:34:39 2022 +0100 [

[flink] 01/02: [hotfix][table-planner] Raw to Binary can fail if the user type ser/de fails

This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit cbfca3afae5d33f9137ae97eb4f4c27ea0d82919 Author: slinkydeveloper AuthorDate: Thu Feb 17 13:33:49 2022 +0100 [

[flink] 03/03: [FLINK-26494][runtime] Adds log message to cleanup failure

This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c5352fc55972420ed5bf1afdfd97834540b1407a Author: Matthias Pohl AuthorDate: Fri Mar 4 21:51:30 2022 +0100 [FLINK-2649

[flink] 02/03: [hotfix][runtime] Adds check for consistency to avoid NullPointerException

This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6ea1782246c0099c8b00067558739850f31e5a68 Author: Matthias Pohl AuthorDate: Fri Mar 4 14:39:35 2022 +0100 [hotfix][ru

[flink] 01/03: [hotfix][runtime] Adds missing @ExtendWith to DefaultResourceCleanerTest

This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit f0fe63ee0ba1983f5a4204f4e55d8961d8465743 Author: Matthias Pohl AuthorDate: Sun Mar 6 16:34:49 2022 +0100 [hotfix][ru

[flink] branch master updated (254c918 -> c5352fc)

This is an automated email from the ASF dual-hosted git repository. mapohl pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 254c918 [FLINK-26550][checkpoint] Correct the information of checkpoint failure new f0fe63e [hotfix][runtime]

[flink] branch release-1.14 updated: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

This is an automated email from the ASF dual-hosted git repository. tangyun pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new 00fed2b [FLINK-26550][checkpoint] C

[flink] branch master updated (0318b26 -> 254c918)

This is an automated email from the ASF dual-hosted git repository. tangyun pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 0318b26 [FLINK-26450] Makes FileStateHandle.discardState fail if the file couldn't be deleted add 254c918 [FL

[flink] branch master updated: [FLINK-26450] Makes FileStateHandle.discardState fail if the file couldn't be deleted

This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 0318b26 [FLINK-26450] Makes FileStateHandle.disc

[flink] branch release-1.14 updated: [FLINK-15550][runtime] Debug logging for TaskTest

This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new 706d1a5 [FLINK-15550][runtime]

[flink] branch release-1.13 updated: [FLINK-15550][runtime] Debug logging for TaskTest

This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 98c20ce [FLINK-15550][runtime]

[flink-table-store] branch master updated: [FLINK-26293] Improve FileStoreCommitTest.testSnapshotAddLogOffset

This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git The following commit(s) were added to refs/heads/master by this push: new 89fce84 [FLINK-26293] Improve

[flink] branch master updated (281b8e7 -> 4907f5f)

This is an automated email from the ASF dual-hosted git repository. mapohl pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 281b8e7 [FLINK-26555][runtime] Adds closing and flushing to OutputStream add 4907f5f [FLINK-26484][fs] Introdu

[flink-table-store] branch master updated: [FLINK-26293] Store log offsets in snapshot

This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git The following commit(s) were added to refs/heads/master by this push: new e6037c9 [FLINK-26293] Store lo

[GitHub] [flink-kubernetes-operator] haoxins opened a new pull request #50: Helm: Replace operatorNamespace with Release Namespace

haoxins opened a new pull request #50: URL: https://github.com/apache/flink-kubernetes-operator/pull/50 It will be more natural for the end users to customize the namespace with Helm's built-in objects. -- This is an automated message from the Apache Git Service. To respond to the messag

[flink-table-store] branch master updated (36c365d -> 341dfe2)

This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git. from 36c365d [FLINK-26562] Introduce table.path option for FileStoreOptions add 341dfe2 [FLINK-265

[flink] branch master updated (22b025a -> 281b8e7)

This is an automated email from the ASF dual-hosted git repository. mapohl pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 22b025a [FLINK-26557][docs] Extend CsvFormat documentation based on release-testing feedback add 281b8e7 [FLIN

[flink] branch master updated (4f233f8 -> 22b025a)

This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4f233f8 [FLINK-26492][kinesis] deprecate numRecordsOutErrorsCounter, replace it with umRecordsSendErrorsCounter

[flink] branch master updated (4d42c64 -> 4f233f8)

This is an automated email from the ASF dual-hosted git repository. fpaul pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4d42c64 [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler.