Aitozi closed pull request #19786: [FLINK-24713][Runtime/Coordination] Postpone
resourceManager serving …
URL: https://github.com/apache/flink/pull/19786
--
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
flinkbot commented on PR #19840:
URL: https://github.com/apache/flink/pull/19840#issuecomment-1140382750
## CI report:
* 38bf7a8b283a7f033f7e0ca38cd8ca032fe496ca UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Aitozi commented on PR #19786:
URL: https://github.com/apache/flink/pull/19786#issuecomment-1140382387
Closed in favor of https://github.com/apache/flink/pull/19840
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Aitozi opened a new pull request, #19840:
URL: https://github.com/apache/flink/pull/19840
…r taskManager to register
## What is the purpose of the change
This PR is another solution to solve the problem of request the extra worker
after JobManager failover. After the
[
https://issues.apache.org/jira/browse/FLINK-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangfei Liu updated FLINK-27828:
-
Attachment: Snipaste_2022-05-25_19-52-11.png
> FlinkKafkaProducer VS KafkaSink
>
Jiangfei Liu created FLINK-27828:
Summary: FlinkKafkaProducer VS KafkaSink
Key: FLINK-27828
URL: https://issues.apache.org/jira/browse/FLINK-27828
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-27593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543551#comment-17543551
]
Jing Ge commented on FLINK-27593:
-
[~lsy] would you please describe what are the issues and what should
[
https://issues.apache.org/jira/browse/FLINK-27822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543550#comment-17543550
]
Jing Ge commented on FLINK-27822:
-
Thanks [~Feifan Wang], ticket has been assigned to you. You might
[
https://issues.apache.org/jira/browse/FLINK-27822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-27822:
---
Assignee: Feifan Wang
> Translate the doc of checkpoint/savepoint guarantees
>
[
https://issues.apache.org/jira/browse/FLINK-27668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-27668:
--
Assignee: Nicholas Jiang
> Document dynamic operator configuration
>
[
https://issues.apache.org/jira/browse/FLINK-27822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543505#comment-17543505
]
Feifan Wang commented on FLINK-27822:
-
Hi [~fanrui] , I am a Chinese speaker and be glad to do this
[
https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543488#comment-17543488
]
Feifan Wang commented on FLINK-27734:
-
Hi [~Zsigner] , I updated the pr with modify eslint
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-26179:
---
Parent: (was: FLINK-25963)
Issue Type: New Feature (was: Sub-task)
> Support periodic
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-26179:
---
Description: Automatic triggering of savepoints is a commonly requested
feature. (was: Automatic
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-26179:
---
Fix Version/s: kubernetes-operator-1.1.0
(was: kubernetes-operator-0.1.0)
>
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543484#comment-17543484
]
Gyula Fora commented on FLINK-26179:
While user's could theoretically cron/schedule the manual
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reopened FLINK-26179:
Assignee: Gyula Fora
Re-openning this ticket as basically all current production users
[
https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543480#comment-17543480
]
Feifan Wang commented on FLINK-27734:
-
Hi [~Zsigner] , I tried changing "===" to "==", but there is
[
https://issues.apache.org/jira/browse/FLINK-27827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543479#comment-17543479
]
Andreas Hailu commented on FLINK-27827:
---
If this is something that the community finds useful, I'm
Andreas Hailu created FLINK-27827:
-
Summary: StreamExecutionEnvironment method supporting explicit
Boundedness
Key: FLINK-27827
URL: https://issues.apache.org/jira/browse/FLINK-27827
Project: Flink
1996fanrui commented on PR #19839:
URL: https://github.com/apache/flink/pull/19839#issuecomment-1140279938
@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
1996fanrui commented on PR #19838:
URL: https://github.com/apache/flink/pull/19838#issuecomment-1140271032
@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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-27826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang updated FLINK-27826:
--
Summary: Support machine learning training for very high dimesional models
(was: Support
Zhipeng Zhang created FLINK-27826:
-
Summary: Support machine learning training for high dimesional
models
Key: FLINK-27826
URL: https://issues.apache.org/jira/browse/FLINK-27826
Project: Flink
JingsongLi commented on PR #142:
URL:
https://github.com/apache/flink-table-store/pull/142#issuecomment-1140251177
I think the first thing we can do is:
We can start with a design document in PR comments which gives a general
description of the APIs that the Hive connector needs to use.
JingsongLi commented on PR #142:
URL:
https://github.com/apache/flink-table-store/pull/142#issuecomment-1140250702
Thanks @tsreaper for the contribution.
--
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
flinkbot commented on PR #19839:
URL: https://github.com/apache/flink/pull/19839#issuecomment-1140227893
## CI report:
* b3537b67138f8db6d8501fd56c4c892da8f4ce98 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27825:
---
Labels: pull-request-available (was: )
> Update the doc of aligned checkpoint timeout
>
1996fanrui opened a new pull request, #19839:
URL: https://github.com/apache/flink/pull/19839
## What is the purpose of the change
Update the doc of aligned checkpoint timeout.
## Brief change log
Update the doc of aligned checkpoint timeout.
## Verifying this
fanrui created FLINK-27825:
--
Summary: Update the doc of aligned checkpoint timeout
Key: FLINK-27825
URL: https://issues.apache.org/jira/browse/FLINK-27825
Project: Flink
Issue Type: Improvement
flinkbot commented on PR #19838:
URL: https://github.com/apache/flink/pull/19838#issuecomment-1140220924
## CI report:
* c485ba2af7e2d57513a850c24f3b11fbf1e60a2f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1996fanrui opened a new pull request, #19838:
URL: https://github.com/apache/flink/pull/19838
## What is the purpose of the change
Fix the typo about subpartition
## Brief change log
Fix the typo about subpartition
## Verifying this change
This change is a
Zixuan Rao created FLINK-27824:
--
Summary: Implement Pyflink KeyedSchema
Key: FLINK-27824
URL: https://issues.apache.org/jira/browse/FLINK-27824
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suheng.cloud updated FLINK-27823:
-
Description:
Hi, community
When I build up a standalone job to read from kafka topic and sink
[
https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suheng.cloud updated FLINK-27823:
-
Attachment: image-2022-05-28-15-35-02-186.png
> Standalone Job continously restart by illegal
[
https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suheng.cloud updated FLINK-27823:
-
Attachment: image-2022-05-28-15-35-23-708.png
> Standalone Job continously restart by illegal
[
https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suheng.cloud updated FLINK-27823:
-
Attachment: image-2022-05-28-15-35-09-874.png
> Standalone Job continously restart by illegal
[
https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suheng.cloud updated FLINK-27823:
-
Description:
Hi, community
When I build up a standalone job to read from kafka topic and sink
[
https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suheng.cloud updated FLINK-27823:
-
Attachment: image-2022-05-28-15-34-46-698.png
> Standalone Job continously restart by illegal
[
https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suheng.cloud updated FLINK-27823:
-
Attachment: image-2022-05-28-15-34-23-397.png
> Standalone Job continously restart by illegal
[
https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suheng.cloud updated FLINK-27823:
-
Attachment: image-2022-05-28-15-33-04-632.png
> Standalone Job continously restart by illegal
[
https://issues.apache.org/jira/browse/FLINK-27823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suheng.cloud updated FLINK-27823:
-
Description:
Hi, community
When I build up a standalone job to read from kafka topic and sink
suheng.cloud created FLINK-27823:
Summary: Standalone Job continously restart by illegal
checkpointId check on PartitionTimeCommitTrigger when use FilesystemTableSink
Key: FLINK-27823
URL:
45 matches
Mail list logo