[jira] [Commented] (FLINK-21966) Support Kinesis connector in Python DataStream API.

2022-05-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543794#comment-17543794 ] Dian Fu commented on FLINK-21966: - [~pemide] Thanks for the offering. I have assigned it

[jira] [Assigned] (FLINK-21966) Support Kinesis connector in Python DataStream API.

2022-05-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-21966: --- Assignee: pengmd > Support Kinesis connector in Python DataStream API. > --

[GitHub] [flink] chucheng92 commented on pull request #19827: [FLINK-27806][table] Support binary & varbinary types in datagen connector

2022-05-29 Thread GitBox
chucheng92 commented on PR #19827: URL: https://github.com/apache/flink/pull/19827#issuecomment-1140769198 @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] chucheng92 commented on pull request #19827: [FLINK-27806][table] Support binary & varbinary types in datagen connector

2022-05-29 Thread GitBox
chucheng92 commented on PR #19827: URL: https://github.com/apache/flink/pull/19827#issuecomment-1140768985 @wuchong can u help me to review this pr? -- 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 t

[GitHub] [flink] chucheng92 commented on pull request #19827: [FLINK-27806][table] Support binary & varbinary types in datagen connector

2022-05-29 Thread GitBox
chucheng92 commented on PR #19827: URL: https://github.com/apache/flink/pull/19827#issuecomment-1140768703 @flinkbot attention @wuchong @lirui-apache -- 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

[jira] [Commented] (FLINK-21966) Support Kinesis connector in Python DataStream API.

2022-05-29 Thread pengmd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543792#comment-17543792 ] pengmd commented on FLINK-21966: [~dianfu] I am very interested in this issue. Could you

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #138: [FLINK-27707] Implement ManagedTableFactory#onCompactTable

2022-05-29 Thread GitBox
LadyForest commented on code in PR #138: URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884472377 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreManagedFactory.java: ## @@ -183,6 +204,84 @@ public void onDropT

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #138: [FLINK-27707] Implement ManagedTableFactory#onCompactTable

2022-05-29 Thread GitBox
LadyForest commented on code in PR #138: URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884472377 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreManagedFactory.java: ## @@ -183,6 +204,84 @@ public void onDropT

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #138: [FLINK-27707] Implement ManagedTableFactory#onCompactTable

2022-05-29 Thread GitBox
LadyForest commented on code in PR #138: URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884456680 ## flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/TableStoreManagedFactoryTest.java: ## @@ -256,9 +284,288 @@ public void te

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #244: [FLINK-27520] Use admission-controller-framework in Webhook

2022-05-29 Thread GitBox
morhidi commented on code in PR #244: URL: https://github.com/apache/flink-kubernetes-operator/pull/244#discussion_r884442238 ## flink-kubernetes-webhook/pom.xml: ## @@ -36,6 +36,19 @@ under the License. org.apache.flink flink-kubernetes-operator

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #237: [FLINK-27257] Flink kubernetes operator triggers savepoint failed because of not all tasks running

2022-05-29 Thread GitBox
wangyang0918 commented on PR #237: URL: https://github.com/apache/flink-kubernetes-operator/pull/237#issuecomment-1140726331 For Flink batch jobs, we do not require all the tasks running to indicate that the Flink job is running. So it does not make sense when we want to use `getJobDetails

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #244: [FLINK-27520] Use admission-controller-framework in Webhook

2022-05-29 Thread GitBox
morhidi commented on code in PR #244: URL: https://github.com/apache/flink-kubernetes-operator/pull/244#discussion_r884434216 ## flink-kubernetes-webhook/pom.xml: ## @@ -36,6 +36,19 @@ under the License. org.apache.flink flink-kubernetes-operator

[GitHub] [flink] zou-can commented on pull request #19828: [FLINK-27762][connector/kafka] KafkaPartitionSplitReader#wakeup should only unblock KafkaConsumer#poll invocation

2022-05-29 Thread GitBox
zou-can commented on PR #19828: URL: https://github.com/apache/flink/pull/19828#issuecomment-1140717266 As i commented on https://issues.apache.org/jira/browse/FLINK-27762 The exception we met is in method **KafkaPartitionSplitReader#removeEmptySplits**. But i can't find any action f

[jira] [Commented] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

2022-05-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543770#comment-17543770 ] Márton Balassi commented on FLINK-27009: [~wangyang0918] I do not have well-form

[jira] [Commented] (FLINK-27831) Provide example of Beam on the k8s operator

2022-05-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543769#comment-17543769 ] Márton Balassi commented on FLINK-27831: On second thought the example has heavy

[jira] [Comment Edited] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

2022-05-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543768#comment-17543768 ] Zili Chen edited comment on FLINK-27834 at 5/30/22 3:42 AM:

[jira] [Commented] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

2022-05-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543768#comment-17543768 ] Zili Chen commented on FLINK-27834: --- Thanks for your notification [~wangyang0918]. I'l

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #138: [FLINK-27707] Implement ManagedTableFactory#onCompactTable

2022-05-29 Thread GitBox
LadyForest commented on code in PR #138: URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884394501 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreManagedFactory.java: ## @@ -183,6 +204,84 @@ public void onDropT

[jira] [Commented] (FLINK-27831) Provide example of Beam on the k8s operator

2022-05-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543767#comment-17543767 ] Márton Balassi commented on FLINK-27831: I managed to get the Beam [WordCount|h

[jira] [Commented] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-29 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543766#comment-17543766 ] Qingsheng Ren commented on FLINK-27762: --- Thanks a lot for the review [~zoucan] ! W

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #138: [FLINK-27707] Implement ManagedTableFactory#onCompactTable

2022-05-29 Thread GitBox
LadyForest commented on code in PR #138: URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884390344 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileStorePathFactory.java: ## @@ -61,20 +61,24 @@ public FileStorePathFactory(

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #138: [FLINK-27707] Implement ManagedTableFactory#onCompactTable

2022-05-29 Thread GitBox
JingsongLi commented on code in PR #138: URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884388037 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreManagedFactory.java: ## @@ -183,6 +204,84 @@ public void onDropT

[jira] [Commented] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

2022-05-29 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543762#comment-17543762 ] Yang Wang commented on FLINK-27834: --- cc [~Tison] I remember you also have the same ide

[jira] [Commented] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

2022-05-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543761#comment-17543761 ] Gyula Fora commented on FLINK-27834: Maybe this is not a big concern, would love to

[jira] [Commented] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

2022-05-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543760#comment-17543760 ] Gyula Fora commented on FLINK-27834: yes, the user can have anything in their local

[jira] [Commented] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

2022-05-29 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543759#comment-17543759 ] Yang Wang commented on FLINK-27834: --- Do you mean we might accidentally bundle the cred

[jira] [Assigned] (FLINK-25865) Support to set restart policy of TaskManager pod for native K8s integration

2022-05-29 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-25865: - Assignee: Aitozi > Support to set restart policy of TaskManager pod for native K8s integration

[jira] [Commented] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

2022-05-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543758#comment-17543758 ] Gyula Fora commented on FLINK-27834: I have bad feelings about this, it might lead t

[jira] [Comment Edited] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-29 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543756#comment-17543756 ] zoucan edited comment on FLINK-27762 at 5/30/22 2:50 AM: - [~renq

[GitHub] [flink] flinkbot commented on pull request #19843: [hotfix] Fix comment typo in TypeExtractor class

2022-05-29 Thread GitBox
flinkbot commented on PR #19843: URL: https://github.com/apache/flink/pull/19843#issuecomment-1140628091 ## CI report: * 056a8e7e0028e39bd5428a8b40b22454e01a0560 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-29 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543756#comment-17543756 ] zoucan edited comment on FLINK-27762 at 5/30/22 2:46 AM: - [~renq

[jira] [Comment Edited] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-29 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543756#comment-17543756 ] zoucan edited comment on FLINK-27762 at 5/30/22 2:45 AM: - [~renq

[GitHub] [flink] deadwind4 opened a new pull request, #19843: [hotfix] Fix comment typo in TypeExtractor class

2022-05-29 Thread GitBox
deadwind4 opened a new pull request, #19843: URL: https://github.com/apache/flink/pull/19843 Fix comment typo in TypeExtractor class. Add a `the` before `highest`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #138: [FLINK-27707] Implement ManagedTableFactory#onCompactTable

2022-05-29 Thread GitBox
JingsongLi commented on code in PR #138: URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884378698 ## flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/TableStoreManagedFactoryTest.java: ## @@ -256,9 +284,288 @@ public void te

[jira] [Commented] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-29 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543756#comment-17543756 ] zoucan commented on FLINK-27762: [~renqs]  Thanks for your effort for this issue. I‘ve

[jira] [Comment Edited] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-29 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543756#comment-17543756 ] zoucan edited comment on FLINK-27762 at 5/30/22 2:44 AM: - [~renq

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #138: [FLINK-27707] Implement ManagedTableFactory#onCompactTable

2022-05-29 Thread GitBox
JingsongLi commented on code in PR #138: URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884379183 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreReadImpl.java: ## @@ -55,14 +56,14 @@ public FileStoreReadImpl(

[jira] [Commented] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

2022-05-29 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543753#comment-17543753 ] Yang Wang commented on FLINK-27834: --- [~gyfora] Given that the copied directory is only

[jira] [Created] (FLINK-27834) Flink kubernetes operator dockerfile could not work with podman

2022-05-29 Thread Yang Wang (Jira)
Yang Wang created FLINK-27834: - Summary: Flink kubernetes operator dockerfile could not work with podman Key: FLINK-27834 URL: https://issues.apache.org/jira/browse/FLINK-27834 Project: Flink Is

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #121: [FLINK-27626] Introduce AggregatuibMergeFunction

2022-05-29 Thread GitBox
tsreaper commented on code in PR #121: URL: https://github.com/apache/flink-table-store/pull/121#discussion_r884370488 ## flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/AggregationITCase.java: ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #138: [FLINK-27707] Implement ManagedTableFactory#onCompactTable

2022-05-29 Thread GitBox
JingsongLi commented on code in PR #138: URL: https://github.com/apache/flink-table-store/pull/138#discussion_r884375368 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/AbstractTableStoreFactory.java: ## @@ -155,7 +155,7 @@ static Map filterL

[GitHub] [flink] Aitozi commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

2022-05-29 Thread GitBox
Aitozi commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r884374610 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java: ## @@ -79,8 +81,19 @@ public class DeclarativeSlotManager

[jira] [Commented] (FLINK-26179) Support periodic savepointing in the operator

2022-05-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543748#comment-17543748 ] Gyula Fora commented on FLINK-26179: I think the question of configurable native/can

[jira] [Commented] (FLINK-26179) Support periodic savepointing in the operator

2022-05-29 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543744#comment-17543744 ] Yang Wang commented on FLINK-26179: --- It is harmless to introduce such a new feature. D

[jira] [Created] (FLINK-27833) PulsarSourceITCase.testTaskManagerFailure failed with AssertionError

2022-05-29 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-27833: Summary: PulsarSourceITCase.testTaskManagerFailure failed with AssertionError Key: FLINK-27833 URL: https://issues.apache.org/jira/browse/FLINK-27833 Project: Flink

[jira] [Commented] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

2022-05-29 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543743#comment-17543743 ] Yang Wang commented on FLINK-27009: --- [~mbalassi] Maybe you could also share some use c

[GitHub] [flink-table-store] JingsongLi commented on pull request #133: [FLINK-27502] Add file Suffix to data files

2022-05-29 Thread GitBox
JingsongLi commented on PR #133: URL: https://github.com/apache/flink-table-store/pull/133#issuecomment-1140603513 ``` Error: Failures: Error:DataFilePathFactoryTest.testNoPartition:46 expected: /tmp/junit13044672734532131/bucket-123/data-de33b78b-2802-49a0-8ec7-cbeeed7af049

[jira] [Created] (FLINK-27832) SplitAggregateITCase tests failed with Could not acquire the minimum required resources

2022-05-29 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-27832: Summary: SplitAggregateITCase tests failed with Could not acquire the minimum required resources Key: FLINK-27832 URL: https://issues.apache.org/jira/browse/FLINK-27832

[jira] [Updated] (FLINK-27625) Add query hint for async lookup join

2022-05-29 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27625: Description: The hint name discuss thread: https://lists.apache.org/thread/jm9kg33wk9z2bvo2b0g5bp

[jira] [Updated] (FLINK-27625) Add query hint for async lookup join

2022-05-29 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27625: Description: The hint name discuss thread: https://lists.apache.org/thread/jm9kg33wk9z2bvo2b0g5bp

[GitHub] [flink] flinkbot commented on pull request #19842: [FLINK-27522][network] Ignore max buffers per channel when allocate buffer

2022-05-29 Thread GitBox
flinkbot commented on PR #19842: URL: https://github.com/apache/flink/pull/19842#issuecomment-1140596253 ## CI report: * aa380f29ca66553b6f168a177dcedb4563efb05a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27826) Support machine learning training for very high dimesional models

2022-05-29 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-27826: -- Description: There is limited support for training high dimensional machine learning models i

[jira] [Updated] (FLINK-27522) Ignore max buffers per channel when allocate buffer

2022-05-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27522: --- Labels: pull-request-available (was: ) > Ignore max buffers per channel when allocate buffe

[GitHub] [flink] 1996fanrui opened a new pull request, #19842: [FLINK-27522][network] Ignore max buffers per channel when allocate buffer

2022-05-29 Thread GitBox
1996fanrui opened a new pull request, #19842: URL: https://github.com/apache/flink/pull/19842 ## What is the purpose of the change Ignore max buffers per channel when allocate buffer ## Brief change log Ignore max buffers per channel when allocate buffer ## Ver

[jira] [Created] (FLINK-27831) Provide example of Beam on the k8s operator

2022-05-29 Thread Jira
Márton Balassi created FLINK-27831: -- Summary: Provide example of Beam on the k8s operator Key: FLINK-27831 URL: https://issues.apache.org/jira/browse/FLINK-27831 Project: Flink Issue Type: I

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

2022-05-29 Thread GitBox
KarmaGYZ commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r884357127 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java: ## @@ -79,8 +81,19 @@ public class DeclarativeSlotManag

[jira] [Updated] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness

2022-05-29 Thread Andreas Hailu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andreas Hailu updated FLINK-27827: -- Description: When creating a {{{}DataStreamSource{}}}, an explicitly bounded input is only re

[jira] [Updated] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness

2022-05-29 Thread Andreas Hailu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andreas Hailu updated FLINK-27827: -- Description: When creating a {{{}DataStreamSource{}}}, an explicitly bounded input is only re

[jira] [Updated] (FLINK-27827) StreamExecutionEnvironment method supporting explicit Boundedness

2022-05-29 Thread Andreas Hailu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andreas Hailu updated FLINK-27827: -- Description: When creating a {{{}DataStreamSource{}}}, an explicitly bounded input is only re

[jira] [Comment Edited] (FLINK-27593) Parquet/Orc format reader optimization

2022-05-29 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543551#comment-17543551 ] Jing Ge edited comment on FLINK-27593 at 5/29/22 9:13 PM: -- [~ls

[GitHub] [flink] NicoK closed pull request #10607: [FLINK-15298][docs] Fix dependences in the DataStream API Tutorial doc

2022-05-29 Thread GitBox
NicoK closed pull request #10607: [FLINK-15298][docs] Fix dependences in the DataStream API Tutorial doc URL: https://github.com/apache/flink/pull/10607 -- 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] NicoK commented on pull request #10607: [FLINK-15298][docs] Fix dependences in the DataStream API Tutorial doc

2022-05-29 Thread GitBox
NicoK commented on PR #10607: URL: https://github.com/apache/flink/pull/10607#issuecomment-1140516269 sorry for not re-reviewing it earlier - since 1.9 is a bit too old now, let me close this PR -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-27830) My Pyflink job could not submit to Flink cluster

2022-05-29 Thread TongMeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TongMeng updated FLINK-27830: - Environment: python 3.6.9 Flink 1.13.0 PyFlink 1.13.0 zookeeper 3.4.14 hadoop 2.10.1 > My Pyflink j

[jira] [Updated] (FLINK-27830) My Pyflink job could not submit to Flink cluster

2022-05-29 Thread TongMeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TongMeng updated FLINK-27830: - Description: I use commd {code:java} ./flink run --python /home/ubuntu/pyflink/main.py /home/ubuntu/pyf

[jira] [Updated] (FLINK-27830) My Pyflink job could not submit to Flink cluster

2022-05-29 Thread TongMeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TongMeng updated FLINK-27830: - Description: I use commd {code:java} ./flink run --python /home/ubuntu/pyflink/main.py /home/ubuntu/pyf

[jira] [Created] (FLINK-27830) My Pyflink job could not submit to Flink cluster

2022-05-29 Thread TongMeng (Jira)
TongMeng created FLINK-27830: Summary: My Pyflink job could not submit to Flink cluster Key: FLINK-27830 URL: https://issues.apache.org/jira/browse/FLINK-27830 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-26179) Support periodic savepointing in the operator

2022-05-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543656#comment-17543656 ] Márton Balassi commented on FLINK-26179: Agreed, based on recent discussion with

[jira] [Commented] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

2022-05-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543655#comment-17543655 ] Márton Balassi commented on FLINK-27009: [~bgeng777] cool, I assigned the ticket

[jira] [Assigned] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

2022-05-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-27009: -- Assignee: Biao Geng > Support SQL job submission in flink kubernetes opeartor > -

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-29 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r884283585 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegressionParams.java: ## @@ -0,0 +1,66 @@ +/* + * Licensed to the Apach

[GitHub] [flink] itaykat commented on pull request #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types

2022-05-29 Thread GitBox
itaykat commented on PR #7598: URL: https://github.com/apache/flink/pull/7598#issuecomment-1140457071 Any updates regarding this one? -- 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

[jira] [Updated] (FLINK-27652) CompactManager.Rewriter cannot handle different partition keys invoked compaction

2022-05-29 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-27652: -- Description: h3. Issue Description When enabling {{commit.force-compact}} for the partitioned managed

[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-29 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543637#comment-17543637 ] Galen Warren commented on FLINK-27813: -- Cool! Glad it was something simple. > java

[jira] [Closed] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-29 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr closed FLINK-27813. - Resolution: Won't Fix > java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0 >

[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-29 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543624#comment-17543624 ] Oleksandr commented on FLINK-27813: --- [~galenwarren]  I found the issue in the configur

[jira] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-29 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813 ] Oleksandr deleted comment on FLINK-27813: --- was (Author: JIRAUSER290114): We have job manager running that is configured via module.yaml(egress and ingress for kafka topics). Our stateful funct

[jira] [Comment Edited] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-29 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543616#comment-17543616 ] Oleksandr edited comment on FLINK-27813 at 5/29/22 11:13 AM: -

[jira] [Comment Edited] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-29 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543616#comment-17543616 ] Oleksandr edited comment on FLINK-27813 at 5/29/22 11:06 AM: -

[jira] [Comment Edited] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-29 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543616#comment-17543616 ] Oleksandr edited comment on FLINK-27813 at 5/29/22 11:06 AM: -

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #244: [FLINK-27520] Use admission-controller-framework in Webhook

2022-05-29 Thread GitBox
gyfora commented on code in PR #244: URL: https://github.com/apache/flink-kubernetes-operator/pull/244#discussion_r884251881 ## flink-kubernetes-webhook/pom.xml: ## @@ -36,6 +36,19 @@ under the License. org.apache.flink flink-kubernetes-operator

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #239: [FLINK-27714] Migrate to java-operator-sdk v3

2022-05-29 Thread GitBox
gyfora commented on PR #239: URL: https://github.com/apache/flink-kubernetes-operator/pull/239#issuecomment-1140423713 +1 for waiting 1-2 days for the JOSDK fixes before merging -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-27813) java.lang.IllegalStateException: after migration from statefun-3.1.1 to 3.2.0

2022-05-29 Thread Oleksandr (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543616#comment-17543616 ] Oleksandr commented on FLINK-27813: --- We have job manager running that is configured vi

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #247: [FLINK-27668] Document dynamic operator configuration

2022-05-29 Thread GitBox
gyfora commented on code in PR #247: URL: https://github.com/apache/flink-kubernetes-operator/pull/247#discussion_r884250202 ## docs/content/docs/operations/configuration.md: ## @@ -50,11 +50,50 @@ defaultConfiguration: To learn more about metrics and logging configuration p

[GitHub] [flink] Aitozi commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

2022-05-29 Thread GitBox
Aitozi commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r884246309 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java: ## @@ -79,8 +81,19 @@ public class DeclarativeSlotManager

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

2022-05-29 Thread GitBox
KarmaGYZ commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r884242067 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java: ## @@ -79,8 +81,19 @@ public class DeclarativeSlotManag

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19681: [FLINK-27544][docs]Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run.

2022-05-29 Thread GitBox
ChengkaiYang2022 commented on PR #19681: URL: https://github.com/apache/flink/pull/19681#issuecomment-1140390388 Hi,Could you @MartijnVisser help to check it ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a