[
https://issues.apache.org/jira/browse/FLINK-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19114:
Labels: pull-request-available (was: )
> Introduce Expression class in the Python Table API
>
[
https://issues.apache.org/jira/browse/FLINK-19091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19091:
Labels: (was: pull-request-available)
> Introduce expression DSL for Python Table API
>
[
https://issues.apache.org/jira/browse/FLINK-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19114:
Attachment: (was: image-2020-09-02-09-51-07-798.png)
> Introduce Expression class in the Python Table
[
https://issues.apache.org/jira/browse/FLINK-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19114:
Attachment: (was: image-2020-09-02-09-51-06-754.png)
> Introduce Expression class in the Python Table
Dian Fu created FLINK-19114:
---
Summary: Introduce Expression class in the Python Table API
Key: FLINK-19114
URL: https://issues.apache.org/jira/browse/FLINK-19114
Project: Flink
Issue Type:
Dian Fu created FLINK-19119:
---
Summary: Update the documentation to use Expression instead of
strings in the Python Table API
Key: FLINK-19119
URL: https://issues.apache.org/jira/browse/FLINK-19119
Project:
leonardBang edited a comment on pull request #13245:
URL: https://github.com/apache/flink/pull/13245#issuecomment-685239670
> LGTM. It could be worth to mention in the documentation that when
**scan.query** is present then **table-name** is ignored
Thanks @fpompermaier for the
tzulitai opened a new pull request #6:
URL: https://github.com/apache/flink-statefun-docker/pull/6
This also removes some no longer required configuration, like max concurrent
checkpoints = 1 and legacy scheduler.
This is
flinkbot edited a comment on pull request #13288:
URL: https://github.com/apache/flink/pull/13288#issuecomment-683810782
## CI report:
* 40a28918bfb1a79f700fd35a916999d83d36acb8 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuiqiang Chen updated FLINK-19097:
---
Description: Add add_jars() interface in Python StreamExecutionEnvironment
to enable users
[
https://issues.apache.org/jira/browse/FLINK-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuiqiang Chen updated FLINK-19097:
---
Summary: Support add_jars() for Python StreamExecutionEnvironment (was:
Support add_jar()
zhijiangW commented on a change in pull request #13286:
URL: https://github.com/apache/flink/pull/13286#discussion_r480904057
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
##
@@ -366,11 +366,10
[
https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-19109:
---
Description:
Attempting to generate watermarks chained to the Split Reader /
flinkbot edited a comment on pull request #13288:
URL: https://github.com/apache/flink/pull/13288#issuecomment-683810782
## CI report:
* 40a28918bfb1a79f700fd35a916999d83d36acb8 Azure:
flinkbot commented on pull request #13293:
URL: https://github.com/apache/flink/pull/13293#issuecomment-684516967
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-19109:
---
Description:
Attempting to generate watermarks chained to the Split Reader /
flinkbot edited a comment on pull request #13003:
URL: https://github.com/apache/flink/pull/13003#issuecomment-664844064
## CI report:
* 565d353b41557312917ef867210bb731dd972fe7 UNKNOWN
* 7892181dbf2f1c3146cec80956cf88f2dff39957 Azure:
flinkbot commented on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-684516974
## CI report:
* 81162c9ed4c9b178e093393cf88e2d16709553de UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13003:
URL: https://github.com/apache/flink/pull/13003#issuecomment-664844064
## CI report:
* 565d353b41557312917ef867210bb731dd972fe7 UNKNOWN
* 7892181dbf2f1c3146cec80956cf88f2dff39957 Azure:
flinkbot edited a comment on pull request #13209:
URL: https://github.com/apache/flink/pull/13209#issuecomment-677744672
## CI report:
* a343c2c3bf36c97dca7045c65eccbcccfbbef5bf UNKNOWN
* 895da41424f7b688b26c469b61e3d024b0e325ed Azure:
tillrohrmann commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r480001862
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java
##
@@ -169,44 +146,12 @@ public
twalthr commented on a change in pull request #13291:
URL: https://github.com/apache/flink/pull/13291#discussion_r480977253
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.scala
##
@@
[
https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-12884:
--
Parent: FLINK-17709
Issue Type: Sub-task (was: New Feature)
> Implement
Tzu-Li (Gordon) Tai created FLINK-19107:
---
Summary: Add basic checkpoint and recovery config keys to template
flink-conf.yaml
Key: FLINK-19107
URL: https://issues.apache.org/jira/browse/FLINK-19107
igalshilman commented on a change in pull request #137:
URL: https://github.com/apache/flink-statefun/pull/137#discussion_r480276203
##
File path:
statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/PersistedAppendingBuffer.java
##
@@ -160,6 +160,13 @@ public void
danny0405 opened a new pull request #13293:
URL: https://github.com/apache/flink/pull/13293
…d by the system with 'EXPR$' prefix
## What is the purpose of the change
For query
```sql
create view tmp_view as
select * from (
select f0,
row_number() over
[
https://issues.apache.org/jira/browse/FLINK-19108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19108:
---
Labels: pull-request-available (was: )
> Stop expanding the identifiers with scope aliased
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188277#comment-17188277
]
Aljoscha Krettek commented on FLINK-18959:
--
Agreed on everything. But that's a new Jira issue,
rmetzger commented on pull request #13217:
URL: https://github.com/apache/flink/pull/13217#issuecomment-684635708
Thanks a lot for this extensive review. I believe I have addressed all
comments. I'm looking forward to more feedback.
tzulitai opened a new pull request #138:
URL: https://github.com/apache/flink-statefun/pull/138
Prior to this PR, we only support setting the call timeout for remote
functions, which spans a complete call including connection, writing request,
server-side processing, and reading response.
twalthr commented on a change in pull request #13291:
URL: https://github.com/apache/flink/pull/13291#discussion_r480880262
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.scala
##
@@
twalthr commented on pull request #13288:
URL: https://github.com/apache/flink/pull/13288#issuecomment-684484807
`'Flink CLI end-to-end test' failed`
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-13857.
Assignee: Dawid Wysakowicz
Resolution: Fixed
Implemented in
[
https://issues.apache.org/jira/browse/FLINK-19108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen updated FLINK-19108:
---
Description:
For query
{code:sql}
create view tmp_view as
select * from (
select f0,
David Anderson created FLINK-19109:
--
Summary: Split Reader eats chained periodic watermarks
Key: FLINK-19109
URL: https://issues.apache.org/jira/browse/FLINK-19109
Project: Flink
Issue
rkhachatryan commented on a change in pull request #13286:
URL: https://github.com/apache/flink/pull/13286#discussion_r480921088
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
##
@@ -366,11
tzulitai commented on a change in pull request #12944:
URL: https://github.com/apache/flink/pull/12944#discussion_r480921657
##
File path:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/util/AwsV2UtilTest.java
##
@@ -0,0
rkhachatryan commented on pull request #13286:
URL: https://github.com/apache/flink/pull/13286#issuecomment-684516123
Thanks for reviewing @zhijiangW, I've updated the PR (the error message).
This is an automated message
flinkbot edited a comment on pull request #13293:
URL: https://github.com/apache/flink/pull/13293#issuecomment-684526091
## CI report:
* b0524b7153e6a3b04a1dd84c4a98f84a06837f75 Azure:
[
https://issues.apache.org/jira/browse/FLINK-14986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188280#comment-17188280
]
Yang Wang commented on FLINK-14986:
---
[~ouyangwuli] Thanks for working on this. Ping me if you have
flinkbot commented on pull request #13296:
URL: https://github.com/apache/flink/pull/13296#issuecomment-684611193
## CI report:
* 83b63305bf9953e98355465c51a584fc3ec813e8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188158#comment-17188158
]
Yun Gao commented on FLINK-18915:
-
Very thanks for reporting this issue! I'll have a look, and I think
dianfu commented on pull request #13273:
URL: https://github.com/apache/flink/pull/13273#issuecomment-684421179
@WeiZhong94 Thanks for the update. LGTM.
@alpinegizmo and @HuangXingBo It would be great if you could take a look at
the latest PR.
HuangXingBo commented on pull request #13273:
URL: https://github.com/apache/flink/pull/13273#issuecomment-684437908
@dianfu @WeiZhong94 LGTM
This is an automated message from the Apache Git Service.
To respond to the
flinkbot edited a comment on pull request #13278:
URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857
## CI report:
* ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN
* 936c094040301f3eb23058dfd3fa24fc5f89cd6a Azure:
[
https://issues.apache.org/jira/browse/FLINK-10211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10211:
-
Component/s: Table SQL / Planner
> Time indicators are not correctly materialized for
[
https://issues.apache.org/jira/browse/FLINK-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19097:
---
Labels: pull-request-available (was: )
> Support add_jars() for Python
shuiqiangchen opened a new pull request #13292:
URL: https://github.com/apache/flink/pull/13292
## What is the purpose of the change
Add add_jars() interface in Python StreamExecutionEnvironment to enable
users to specify jar dependencies in their Python DataStream Job.
danny0405 commented on a change in pull request #13291:
URL: https://github.com/apache/flink/pull/13291#discussion_r480913964
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.scala
##
tzulitai closed pull request #137:
URL: https://github.com/apache/flink-statefun/pull/137
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
tzulitai closed pull request #136:
URL: https://github.com/apache/flink-statefun/pull/136
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
liuyufei9527 commented on pull request #13280:
URL: https://github.com/apache/flink/pull/13280#issuecomment-684531845
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
danny0405 commented on a change in pull request #13291:
URL: https://github.com/apache/flink/pull/13291#discussion_r480978916
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.scala
##
flinkbot edited a comment on pull request #13273:
URL: https://github.com/apache/flink/pull/13273#issuecomment-682353427
## CI report:
* f71ac48908f7dbf2f10a9145262b8438d1f051c4 Azure:
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* fb66f2e5d16daeabafaa62eab9493112997b9f74 Azure:
flinkbot edited a comment on pull request #13278:
URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857
## CI report:
* ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN
* 936c094040301f3eb23058dfd3fa24fc5f89cd6a Azure:
dawidwys merged pull request #13287:
URL: https://github.com/apache/flink/pull/13287
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
flinkbot commented on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-684508363
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* fb66f2e5d16daeabafaa62eab9493112997b9f74 Azure:
flinkbot edited a comment on pull request #13273:
URL: https://github.com/apache/flink/pull/13273#issuecomment-682353427
## CI report:
* 7307a02f70f288ff9857bb74bd1a49e60fe5a497 Azure:
flinkbot edited a comment on pull request #13286:
URL: https://github.com/apache/flink/pull/13286#issuecomment-683777071
## CI report:
* 358ebf0c0aaffb505bc95a97d6133183ec749d7a Azure:
flinkbot commented on pull request #13293:
URL: https://github.com/apache/flink/pull/13293#issuecomment-684526091
## CI report:
* b0524b7153e6a3b04a1dd84c4a98f84a06837f75 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-684516974
## CI report:
* 81162c9ed4c9b178e093393cf88e2d16709553de Azure:
tzulitai commented on a change in pull request #138:
URL: https://github.com/apache/flink-statefun/pull/138#discussion_r480937709
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionSpec.java
##
@@ -111,14
tzulitai commented on a change in pull request #138:
URL: https://github.com/apache/flink-statefun/pull/138#discussion_r480937709
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionSpec.java
##
@@ -111,14
flinkbot edited a comment on pull request #13284:
URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000
## CI report:
* 6e68f6bd327d805261acdc9005a9cfc099f595ae Azure:
flinkbot edited a comment on pull request #13286:
URL: https://github.com/apache/flink/pull/13286#issuecomment-683777071
## CI report:
* 358ebf0c0aaffb505bc95a97d6133183ec749d7a Azure:
flinkbot edited a comment on pull request #13280:
URL: https://github.com/apache/flink/pull/13280#issuecomment-683394013
## CI report:
* 559294f51238f10a9107d50074ed33c41801ae8b Azure:
flinkbot edited a comment on pull request #13280:
URL: https://github.com/apache/flink/pull/13280#issuecomment-683394013
## CI report:
* 559294f51238f10a9107d50074ed33c41801ae8b Azure:
flinkbot edited a comment on pull request #13278:
URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857
## CI report:
* ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN
* 23c61fffdf54d684e8346d7509846170f7151053 Azure:
[
https://issues.apache.org/jira/browse/FLINK-18598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18598:
---
Labels: pull-request-available (was: )
> Add instructions for asynchronous execute in
shuiqiangchen opened a new pull request #13295:
URL: https://github.com/apache/flink/pull/13295
## What is the purpose of the change
Add instructions for asynchronous execute in PyFlink doc
## Brief change log
- Added brief instructions for asynchronous execute
[
https://issues.apache.org/jira/browse/FLINK-19002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19002:
---
Labels: pull-request-available (was: )
> Support to only read changelogs of specific
caozhen1937 opened a new pull request #13296:
URL: https://github.com/apache/flink/pull/13296
## What is the purpose of the change
Support debezium-avro format
## Brief change log
- add DeserializationSchema for deserialize byte[]
- add SerializationSchema
twalthr commented on a change in pull request #13291:
URL: https://github.com/apache/flink/pull/13291#discussion_r480979229
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/CorrelateSortToRankRule.scala
##
@@
[
https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188291#comment-17188291
]
Till Rohrmann commented on FLINK-17075:
---
[~chesnay] should we go ahead with merging this feature
[
https://issues.apache.org/jira/browse/FLINK-19106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19106:
---
Labels: pull-request-available (was: )
> Add more timeout options for remote function
flinkbot edited a comment on pull request #13273:
URL: https://github.com/apache/flink/pull/13273#issuecomment-682353427
## CI report:
* f71ac48908f7dbf2f10a9145262b8438d1f051c4 Azure:
dianfu edited a comment on pull request #13273:
URL: https://github.com/apache/flink/pull/13273#issuecomment-684421179
@WeiZhong94 Thanks for the update. LGTM.
@alpinegizmo and @HuangXingBo It would be great if you could take a look at
the latest PR. Thanks a lot~
igalshilman commented on a change in pull request #138:
URL: https://github.com/apache/flink-statefun/pull/138#discussion_r480890517
##
File path:
statefun-flink/statefun-flink-core/src/test/resources/module-v2_0/module.yaml
##
@@ -37,6 +37,10 @@ module:
-
pnowojski commented on a change in pull request #3:
URL: https://github.com/apache/flink-benchmarks/pull/3#discussion_r480893656
##
File path: src/main/java/org/apache/flink/benchmark/MultipleInputBenchmark.java
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-19108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen updated FLINK-19108:
---
Description:
For query
{code:sql}
create view tmp_view as
select * from (
select f0,
zhijiangW commented on a change in pull request #13286:
URL: https://github.com/apache/flink/pull/13286#discussion_r480911091
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
##
@@ -366,11 +366,10
Danny Chen created FLINK-19108:
--
Summary: Stop expanding the identifiers with scope aliased by the
system with 'EXPR$' prefix
Key: FLINK-19108
URL: https://issues.apache.org/jira/browse/FLINK-19108
pnowojski commented on a change in pull request #3:
URL: https://github.com/apache/flink-benchmarks/pull/3#discussion_r480893656
##
File path: src/main/java/org/apache/flink/benchmark/MultipleInputBenchmark.java
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to the Apache Software
pnowojski merged pull request #3:
URL: https://github.com/apache/flink-benchmarks/pull/3
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 pull request #13294:
URL: https://github.com/apache/flink/pull/13294#issuecomment-684564615
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot commented on pull request #13295:
URL: https://github.com/apache/flink/pull/13295#issuecomment-684564557
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
tzulitai commented on a change in pull request #138:
URL: https://github.com/apache/flink-statefun/pull/138#discussion_r480937709
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionSpec.java
##
@@ -111,14
flinkbot edited a comment on pull request #13295:
URL: https://github.com/apache/flink/pull/13295#issuecomment-684586420
## CI report:
* 9f2e570c493ec1ca97e2c2ef1e73a6e227117016 Azure:
flinkbot edited a comment on pull request #13294:
URL: https://github.com/apache/flink/pull/13294#issuecomment-684586137
## CI report:
* d9ce2f0083bbf6e00e4782c3ab2f7dd686d07e55 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188167#comment-17188167
]
Yang Wang commented on FLINK-17480:
---
[~felixzheng] I appreciate a a lot for your quick response and
tzulitai opened a new pull request #139:
URL: https://github.com/apache/flink-statefun/pull/139
A corresponding change for the template flink-conf.yaml used in distributed
Docker images can be found at
https://github.com/apache/flink-statefun-docker/pull/6.
This also changes the
[
https://issues.apache.org/jira/browse/FLINK-19093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-19093:
---
Priority: Critical (was: Major)
> "Elasticsearch (v6.3.1) sink end-to-end test" failed
[
https://issues.apache.org/jira/browse/FLINK-18651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188185#comment-17188185
]
Timo Walther commented on FLINK-18651:
--
A proper solution is described in FLINK-10211. I don't know
[
https://issues.apache.org/jira/browse/FLINK-19107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19107:
---
Labels: pull-request-available (was: )
> Add basic checkpoint and recovery config keys to
morsapaes commented on pull request #13203:
URL: https://github.com/apache/flink/pull/13203#issuecomment-684512433
LGTM, @hequn8128, thanks!
This is an automated message from the Apache Git Service.
To respond to the
wuchong commented on pull request #13294:
URL: https://github.com/apache/flink/pull/13294#issuecomment-684560175
cc @leonardBang
This is an automated message from the Apache Git Service.
To respond to the message, please
wuchong opened a new pull request #13294:
URL: https://github.com/apache/flink/pull/13294
## What is the purpose of the change
Usually, users use Canal to synchronize binlog data from various MySQL
databases and tables into a single Kafka topic. However, currently,
qinjunjerry commented on pull request #12747:
URL: https://github.com/apache/flink/pull/12747#issuecomment-684585282
Anything blocking here?
This is an automated message from the Apache Git Service.
To respond to the
1 - 100 of 383 matches
Mail list logo
