dianfu commented on code in PR #20120:
URL: https://github.com/apache/flink/pull/20120#discussion_r911637191
##
flink-python/pyflink/datastream/connectors/cassandra.py:
##
@@ -126,6 +127,149 @@ def if_not_exists(self, enabled: bool) -> 'MapperOptions':
return self
[
https://issues.apache.org/jira/browse/FLINK-28140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28140:
Description:
There are still quite a few documentations only having Java/Scala examples. The
aim of this
[
https://issues.apache.org/jira/browse/FLINK-28140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561290#comment-17561290
]
Dian Fu commented on FLINK-28140:
-
Updated page:
[
https://issues.apache.org/jira/browse/FLINK-28140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28140:
Description:
There are still quite a few documentations only having Java/Scala examples. The
aim of this
dianfu closed pull request #20121: [FLINK-28140][python][docs] Improve the
documentation by adding Python examples
URL: https://github.com/apache/flink/pull/20121
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
morhidi commented on code in PR #288:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/288#discussion_r911623792
##
helm/flink-kubernetes-operator/templates/rbac.yaml:
##
@@ -21,23 +21,14 @@ RBAC rules used to create the operator (cluster)role based
on the scope
morhidi commented on code in PR #288:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/288#discussion_r911624111
##
helm/flink-kubernetes-operator/templates/rbac.yaml:
##
@@ -21,23 +21,14 @@ RBAC rules used to create the operator (cluster)role based
on the scope
zhuzhurk commented on PR #20087:
URL: https://github.com/apache/flink/pull/20087#issuecomment-1171949278
@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.
morhidi commented on code in PR #288:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/288#discussion_r911623792
##
helm/flink-kubernetes-operator/templates/rbac.yaml:
##
@@ -21,23 +21,14 @@ RBAC rules used to create the operator (cluster)role based
on the scope
morhidi commented on code in PR #288:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/288#discussion_r911621447
##
helm/flink-kubernetes-operator/templates/rbac.yaml:
##
@@ -21,23 +21,14 @@ RBAC rules used to create the operator (cluster)role based
on the scope
[
https://issues.apache.org/jira/browse/FLINK-28288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28288.
---
Assignee: LuNing Wang
Resolution: Fixed
Merged to master via 2f4f46219d09f261539a0aa47f915ee74c4721db
[
https://issues.apache.org/jira/browse/FLINK-28288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28288:
Affects Version/s: (was: 1.15.0)
> Support decode and encode built-in function in the Table API
>
morhidi commented on code in PR #288:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/288#discussion_r911620631
##
helm/flink-kubernetes-operator/templates/rbac.yaml:
##
@@ -21,23 +21,14 @@ RBAC rules used to create the operator (cluster)role based
on the scope
dianfu merged PR #20098:
URL: https://github.com/apache/flink/pull/20098
--
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:
dianfu commented on PR #20098:
URL: https://github.com/apache/flink/pull/20098#issuecomment-1171945071
@alpinegizmo @MartijnVisser Thanks for the review. LGTM as well. Merging...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-28323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-28323:
Affects Version/s: (was: 1.15.0)
> Support using new KafkaSource in PyFlink
>
[
https://issues.apache.org/jira/browse/FLINK-28323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28323.
---
Assignee: Juntao Hu
Resolution: Fixed
Merged to master via ea0368e7ee0c56e0c9ad45233cb1e12ce458be1b
dianfu closed pull request #20113: [FLINK-28323][python][connector] Support
using new KafkaSource in PyFlink
URL: https://github.com/apache/flink/pull/20113
--
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
fredia commented on code in PR #20091:
URL: https://github.com/apache/flink/pull/20091#discussion_r911611532
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageAccess.java:
##
@@ -113,8 +113,12 @@ public boolean
fredia commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1171930223
@JesseAtSZ Thanks for your explanation, `fileSystem.mkdirs()` not only
returns `false` when the directory exists, but also returns `false` when there
is no permission to write. This PR
[
https://issues.apache.org/jira/browse/FLINK-28062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-28062.
-
Resolution: Duplicate
Mark as duplicating FLINK-28037
> Flink SQL Upsert-Kafka can not support
reswqa commented on code in PR #19960:
URL: https://github.com/apache/flink/pull/19960#discussion_r911601331
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReader.java:
##
@@ -0,0 +1,379 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-28037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-28037:
-
Assignee: Qingsheng Ren
> Flink SQL Upsert-Kafka can not support Flink1.14.x
>
[
https://issues.apache.org/jira/browse/FLINK-28037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561261#comment-17561261
]
Qingsheng Ren commented on FLINK-28037:
---
Thanks for reporting this issue [~Jiangfei Liu] . I think
flinkbot commented on PR #20124:
URL: https://github.com/apache/flink/pull/20124#issuecomment-1171906046
## CI report:
* 54d29e93242f5488b28382e0bd1a91976456ea81 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JesseAtSZ commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1171905414
@fredia In my example, I specify the path of checkpoint in CentOS as /D/,
fileSystem.mkdirs() will return false, and the file creation fails, so the
checkpoint initialize fails. In
Jingsong Lee created FLINK-28339:
Summary: Introduce SparkCatalog in table store
Key: FLINK-28339
URL: https://issues.apache.org/jira/browse/FLINK-28339
Project: Flink
Issue Type: New
LadyForest commented on code in PR #182:
URL: https://github.com/apache/flink-table-store/pull/182#discussion_r911595201
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/compact/CompactManager.java:
##
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Apache
LadyForest commented on code in PR #182:
URL: https://github.com/apache/flink-table-store/pull/182#discussion_r911595201
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/compact/CompactManager.java:
##
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-28336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28336:
---
Labels: pull-request-available (was: )
> Support parquet-avro format in PyFlink DataStream
Vancior opened a new pull request, #20124:
URL: https://github.com/apache/flink/pull/20124
## What is the purpose of the change
This PR supports parquet-avro format for FileSource in PyFlink DataStream
API.
## Brief change log
- shade optional dependency
[
https://issues.apache.org/jira/browse/FLINK-28142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28142.
---
Fix Version/s: 1.16.0
Resolution: Done
Done via:
51c139b601806cc4f4272fb678f4d1bed4cf06ab
zhuzhurk closed pull request #20056: [FLINK-28142][runtime] Enrich
TaskManagerLocation and TaskExecutorRegistration with node information
URL: https://github.com/apache/flink/pull/20056
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot commented on PR #20122:
URL: https://github.com/apache/flink/pull/20122#issuecomment-1171902675
## CI report:
* ef0b6dcaf0217682fd86671c0a90951dfa5adedb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28310:
---
Labels: pull-request-available (was: )
> Introduce aggregating task metrics
>
zhuzhurk commented on PR #20056:
URL: https://github.com/apache/flink/pull/20056#issuecomment-1171902128
Merging.
--
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
KarmaGYZ opened a new pull request, #20123:
URL: https://github.com/apache/flink/pull/20123
We add AggregatedTaskDetailsInfo to JobVertexTaskManagersHandler and
JobVertexDetailsHandler
## What is the purpose of the change
*(For example: This pull request makes task
[
https://issues.apache.org/jira/browse/FLINK-28136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28136.
---
Resolution: Done
Done via ef07590403ad7448a523ef5da78da0306cccdae7
> Implement
[
https://issues.apache.org/jira/browse/FLINK-28135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28135.
---
Resolution: Done
Done via a0e8818d6967e5b0d14367d2095c91a05cadfe1f
> Introduce SlowTaskDetector
>
zhuzhurk closed pull request #20072: [FLINK-28136][runtime] Implement
ExecutionTimeBasedSlowTaskDetector
URL: https://github.com/apache/flink/pull/20072
--
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
zhuzhurk closed pull request #20054: [FLINK-28135][runtime] Introduce
SlowTaskDetector
URL: https://github.com/apache/flink/pull/20054
--
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
GOODBOY008 opened a new pull request, #20122:
URL: https://github.com/apache/flink/pull/20122
## What is the purpose of the change
Update the flink-connector-files module to AssertJ and JUnit 5 following the
[JUnit 5 Migration
fredia commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1171898497
Thanks for creating this PR @JesseAtSZ. IIUC, you expect an IOException
when the checkpoint directory exists(`fileSystem.mkdir()` return `false`)? I
think it's a little wired, could
flinkbot commented on PR #20121:
URL: https://github.com/apache/flink/pull/20121#issuecomment-1171897135
## CI report:
* f6495314d656a8bf5b7a06745f145985f095a94d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhuzhurk commented on PR #20072:
URL: https://github.com/apache/flink/pull/20072#issuecomment-1171897066
Merging.
--
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
[
https://issues.apache.org/jira/browse/FLINK-28309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo closed FLINK-28309.
--
Resolution: Fixed
> Introduce metrics of the duration that a task stays in each status
>
[
https://issues.apache.org/jira/browse/FLINK-28309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561252#comment-17561252
]
Yangze Guo commented on FLINK-28309:
master: bb8e1d14f05aca186ec874437eba3d44fbb3bd97
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-28308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo closed FLINK-28308.
--
Resolution: Fixed
> Introduce accumulated time metrics that a running task is busy / idle /
>
[
https://issues.apache.org/jira/browse/FLINK-28308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561251#comment-17561251
]
Yangze Guo commented on FLINK-28308:
master: 6b8230cf83fd33c4fdd3d7cc99e6a90d9839a350
[
https://issues.apache.org/jira/browse/FLINK-28338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561250#comment-17561250
]
wangkang commented on FLINK-28338:
--
解决方法是添加一个类似 spring.jackson.parser.allow-numeric-leading-zeros=true
KarmaGYZ closed pull request #20110: [FLINK-28308] Introduce metrics of the
accumulated time that a running task is busy / idle / back-pressured
URL: https://github.com/apache/flink/pull/20110
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
KarmaGYZ closed pull request #20111: [FLINK-28309][rest] Introduce metrics of
the duration that a task sta…
URL: https://github.com/apache/flink/pull/20111
--
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
[
https://issues.apache.org/jira/browse/FLINK-28140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28140:
---
Labels: pull-request-available (was: )
> Improve the documentation by adding Python
wangkang created FLINK-28338:
Summary:
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParseException:
Invalid numeric value: Leading zeroes not allowed
Key: FLINK-28338
URL:
pengmide opened a new pull request, #20121:
URL: https://github.com/apache/flink/pull/20121
## What is the purpose of the change
Improve the documentation by adding Python examples.
## Brief change log
- Improve the data stream api documentation by adding Python
wei created FLINK-28337:
---
Summary: java.lang.IllegalArgumentException: Table identifier not
set
Key: FLINK-28337
URL: https://issues.apache.org/jira/browse/FLINK-28337
Project: Flink
Issue Type: Bug
luoyuxia commented on PR #18975:
URL: https://github.com/apache/flink/pull/18975#issuecomment-1171885691
@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.
flinkbot commented on PR #20120:
URL: https://github.com/apache/flink/pull/20120#issuecomment-1171884235
## CI report:
* 5ce536787b928c5434d228219b25f47f475e48f7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
6591812 commented on PR #20082:
URL: https://github.com/apache/flink/pull/20082#issuecomment-1171884006
After @zhuzhurk 's good job I have no other questions.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
pengmide opened a new pull request, #20120:
URL: https://github.com/apache/flink/pull/20120
## What is the purpose of the change
Support Cassandra connector in Python DataStream API.
## Brief change log
- Introduces policy methods in `ClusterBuilder`.
##
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wei resolved FLINK-28276.
-
Resolution: Fixed
> org.apache.flink.connectors.hive.FlinkHiveException: Unable to instantiate
> the hadoop
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561241#comment-17561241
]
wei commented on FLINK-28276:
-
I add `table.updateProperties().set("engine.hive.enabled",
[
https://issues.apache.org/jira/browse/FLINK-28276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wei updated FLINK-28276:
Attachment: image-2022-07-01-11-05-01-238.png
> org.apache.flink.connectors.hive.FlinkHiveException: Unable to
zhuyufeng0809 closed pull request #19991: [FLINK-28065][Runtime/Configuration]
Fix a never reached code in ProcessMemoryUtils Class
URL: https://github.com/apache/flink/pull/19991
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
zhuyufeng0809 closed pull request #19992: [hotfix][Runtime/Configuration] Fix
typo in ProcessMemoryUtils Class
URL: https://github.com/apache/flink/pull/19992
--
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
Juntao Hu created FLINK-28336:
-
Summary: Support parquet-avro format in PyFlink DataStream
Key: FLINK-28336
URL: https://issues.apache.org/jira/browse/FLINK-28336
Project: Flink
Issue Type: New
Aitozi commented on code in PR #283:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/283#discussion_r911568620
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -99,15
gaoyunhaii commented on PR #20108:
URL: https://github.com/apache/flink/pull/20108#issuecomment-1171870337
@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-28265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561240#comment-17561240
]
MAU CHEE YEN commented on FLINK-28265:
--
[~martijnvisser] We had another incident where we hit this
zhuzhurk commented on PR #20082:
URL: https://github.com/apache/flink/pull/20082#issuecomment-1171864156
@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.
[
https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561237#comment-17561237
]
Zhu Zhu commented on FLINK-28324:
-
Thanks for volunteering to take it. [~Leo Zhou]
I have assigned you
[
https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28324:
---
Assignee: zl
> JUnit5 Migration] Module: flink-sql-client
>
zhuzhurk commented on PR #20072:
URL: https://github.com/apache/flink/pull/20072#issuecomment-1171861384
@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.
[
https://issues.apache.org/jira/browse/FLINK-26361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-26361.
-
Resolution: Fixed
> "Unexpected correlate variable $cor0" when using hive dialect to write a
>
[
https://issues.apache.org/jira/browse/FLINK-26361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-26361:
-
Assignee: luoyuxia
> "Unexpected correlate variable $cor0" when using hive dialect to
[
https://issues.apache.org/jira/browse/FLINK-26361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561234#comment-17561234
]
Shengkai Fang commented on FLINK-26361:
---
Fixed in the master:
fsk119 merged PR #18920:
URL: https://github.com/apache/flink/pull/18920
--
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:
lindong28 closed pull request #125: [FLINK-27084] Fix classloader for per-round
operators
URL: https://github.com/apache/flink-ml/pull/125
--
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
lindong28 commented on PR #125:
URL: https://github.com/apache/flink-ml/pull/125#issuecomment-1171849677
Thanks for the PR! LGTM.
--
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
xintongsong commented on PR #20111:
URL: https://github.com/apache/flink/pull/20111#issuecomment-1171848572
@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
lindong28 closed pull request #127: [FLINK-27084] Fix classloader for per-round
operators
URL: https://github.com/apache/flink-ml/pull/127
--
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
[
https://issues.apache.org/jira/browse/FLINK-27084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-27084.
Resolution: Fixed
> Perround mode recreating operator fails
> ---
>
>
xintongsong commented on PR #20110:
URL: https://github.com/apache/flink/pull/20110#issuecomment-1171846463
@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
xintongsong commented on code in PR #20110:
URL: https://github.com/apache/flink/pull/20110#discussion_r911560015
##
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java:
##
@@ -169,6 +186,15 @@ public long getBackPressuredTimeMsPerSecond()
[
https://issues.apache.org/jira/browse/FLINK-27084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-27084:
Assignee: Yunfeng Zhou
> Perround mode recreating operator fails
>
[
https://issues.apache.org/jira/browse/FLINK-27084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-27084:
-
Fix Version/s: ml-2.1.0
> Perround mode recreating operator fails
>
lindong28 commented on PR #127:
URL: https://github.com/apache/flink-ml/pull/127#issuecomment-1171844830
Merged to the release 2.1 branch.
--
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
lindong28 closed pull request #126: test
URL: https://github.com/apache/flink-ml/pull/126
--
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:
wanglijie95 commented on PR #20056:
URL: https://github.com/apache/flink/pull/20056#issuecomment-1171843292
@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-28182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28182.
---
Resolution: Fixed
Merged to master via ae409d04e3b4398925e9bd53ef559ca81b7486c6
> Support Avro generic
dianfu closed pull request #20040: [FLINK-28182][python][format] Support Avro
generic record decoder
URL: https://github.com/apache/flink/pull/20040
--
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
lindong28 commented on PR #127:
URL: https://github.com/apache/flink-ml/pull/127#issuecomment-1171831340
Thanks for the PR! LGTM.
--
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
lincoln-lil commented on PR #20118:
URL: https://github.com/apache/flink/pull/20118#issuecomment-1171824806
@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-28299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28299.
Resolution: Fixed
master: e5a37fd07aa7996b037f88e48b1a19ba5b6ab89d
> Get rid of Sink v2
>
JingsongLi merged PR #183:
URL: https://github.com/apache/flink-table-store/pull/183
--
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:
JingsongLi commented on PR #183:
URL:
https://github.com/apache/flink-table-store/pull/183#issuecomment-1171822135
Thanks @LadyForest for the review, let's move on to complete the 1.14
compatibility.
--
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot commented on PR #20119:
URL: https://github.com/apache/flink/pull/20119#issuecomment-1171812883
## CI report:
* a4a333089ada574fcc22e5a0de3d10df3292bdad UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28322:
---
Labels: pull-request-available (was: )
> DataStreamScanProvider's new method is not
JingsongLi opened a new pull request, #20119:
URL: https://github.com/apache/flink/pull/20119
## What is the purpose of the change
In [FLINK-25990](https://issues.apache.org/jira/browse/FLINK-25990) ,
Add a method "DataStream produceDataStream(ProviderContext
providerContext,
[
https://issues.apache.org/jira/browse/FLINK-28322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28322:
Assignee: Jingsong Lee
> DataStreamScanProvider's new method is not compatible
>
1 - 100 of 375 matches
Mail list logo
