[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685744#comment-17685744
]
Matthias Pohl commented on FLINK-18356:
---
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685745#comment-17685745
]
Matthias Pohl commented on FLINK-18356:
---
[~337361...@qq.com] did you manage to look into it?
>
[
https://issues.apache.org/jira/browse/FLINK-30910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-30910.
---
Fix Version/s: 1.17.0
1.15.4
1.16.2
XComp merged PR #21882:
URL: https://github.com/apache/flink/pull/21882
--
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:
XComp commented on PR #21882:
URL: https://github.com/apache/flink/pull/21882#issuecomment-1422174383
The review of this PR happened in the parent PR
https://github.com/apache/flink/pull/21869. No conflicts arose while
cherry-picking the commit.
--
This is an automated message from the
XComp merged PR #21881:
URL: https://github.com/apache/flink/pull/21881
--
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:
XComp commented on PR #21881:
URL: https://github.com/apache/flink/pull/21881#issuecomment-1422174107
The review of this PR happened in the parent PR
https://github.com/apache/flink/pull/21869. No conflicts arose while
cherry-picking the commit.
--
This is an automated message from the
XComp commented on PR #21881:
URL: https://github.com/apache/flink/pull/21881#issuecomment-1422173499
Failure is caused by FLINK-25813
--
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-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685737#comment-17685737
]
Matthias Pohl commented on FLINK-28440:
---
XComp merged PR #21883:
URL: https://github.com/apache/flink/pull/21883
--
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:
XComp commented on PR #21883:
URL: https://github.com/apache/flink/pull/21883#issuecomment-1422171708
The review of this PR happened in the parent PR #21869. No conflicts arose
while cherry-picking the commit.
--
This is an automated message from the Apache Git Service.
To respond to the
AraiYuno opened a new pull request, #528:
URL: https://github.com/apache/flink-kubernetes-operator/pull/528
## What is the purpose of the change
This pull request increases the default value of
`kubernetes.operator.deployment.readiness.timeout` to 5 minutes from 1 minute.
flinkbot commented on PR #21890:
URL: https://github.com/apache/flink/pull/21890#issuecomment-1422164243
## CI report:
* 8aeaf0001bf4c156427acc1202a060507871532e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30860:
---
Description:
Add document for hybrid shuffle with adaptive batch scheduler and index
spilling.
>
[
https://issues.apache.org/jira/browse/FLINK-30860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30860:
---
Component/s: Documentation
> Add document for hybrid shuffle with adaptive batch scheduler
>
[
https://issues.apache.org/jira/browse/FLINK-30860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30860:
---
Labels: pull-request-available (was: )
> Add document for hybrid shuffle with adaptive
reswqa opened a new pull request, #21890:
URL: https://github.com/apache/flink/pull/21890
## What is the purpose of the change
*Add document for hybrid shuffle with adaptive batch scheduler*
## Brief change log
- *Add document for hybrid shuffle with adaptive batch
chucheng92 commented on PR #21442:
URL: https://github.com/apache/flink/pull/21442#issuecomment-1422143809
@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
flinkbot commented on PR #21889:
URL: https://github.com/apache/flink/pull/21889#issuecomment-1422142949
## CI report:
* 91081f980a18127638ac86466497c3987841c44a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Yunfeng Zhou created FLINK-30959:
Summary: UNIX_TIMESTAMP's return value does not meet expected
Key: FLINK-30959
URL: https://issues.apache.org/jira/browse/FLINK-30959
Project: Flink
Issue
ruanhang1993 opened a new pull request, #21889:
URL: https://github.com/apache/flink/pull/21889
## What is the purpose of the change
This pull request provides the operator coordinator metric group.
## Brief change log
Please see the changes in the
[
https://issues.apache.org/jira/browse/FLINK-30274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685717#comment-17685717
]
Ran Tao commented on FLINK-30274:
-
[~martijnvisser] Hi, Martijn I have updated the pr.
> Upgrade
chucheng92 commented on PR #21442:
URL: https://github.com/apache/flink/pull/21442#issuecomment-1422114983
@MartijnVisser PTAL, thanks.
--
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
chucheng92 commented on PR #21442:
URL: https://github.com/apache/flink/pull/21442#issuecomment-1422113508
@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
chucheng92 commented on PR #21442:
URL: https://github.com/apache/flink/pull/21442#issuecomment-1422103023
@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
flinkbot commented on PR #21888:
URL: https://github.com/apache/flink/pull/21888#issuecomment-1422097051
## CI report:
* 589d2ba936bda80a06ff546ee586760e83f9ec94 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30958:
---
Labels: pull-request-available (was: )
> Rest API doc generation failure caused by
LadyForest opened a new pull request, #21888:
URL: https://github.com/apache/flink/pull/21888
## What is the purpose of the change
This pull request fixes the REST API doc generation failure caused by
`JobClientHeartbeatHeaders`. `JobClientHeartbeatHeaders` should override
[
https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685703#comment-17685703
]
luoyuxia edited comment on FLINK-30508 at 2/8/23 6:35 AM:
--
Hi, the reason maybe
Jane Chan created FLINK-30958:
-
Summary: Rest API doc generation failure caused by
JobClientHeartbeatHeaders
Key: FLINK-30958
URL: https://issues.apache.org/jira/browse/FLINK-30958
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685703#comment-17685703
]
luoyuxia commented on FLINK-30508:
--
Hi, the reason maybe ctas statement write data to files and rename
saLeox commented on PR #21149:
URL: https://github.com/apache/flink/pull/21149#issuecomment-1422086364
@luoyuxia Thanks for your comment, it sounds make sense to have similar
option to control whether if merge schema, I will try to add them later, and
notify here if make any progress.
--
[
https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685699#comment-17685699
]
Shengkai Fang commented on FLINK-30508:
---
I read recently failed tests are related to the CTAS
gaborgsomogyi commented on PR #21870:
URL: https://github.com/apache/flink/pull/21870#issuecomment-1422055349
cc @gyfora
--
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-28326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-28326:
Fix Version/s: 1.16.2
> ResultPartitionTest.testIdleAndBackPressuredTime failed with AssertError
[
https://issues.apache.org/jira/browse/FLINK-28326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao resolved FLINK-28326.
-
Resolution: Fixed
> ResultPartitionTest.testIdleAndBackPressuredTime failed with AssertError
>
[
https://issues.apache.org/jira/browse/FLINK-28326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685678#comment-17685678
]
Yingjie Cao commented on FLINK-28326:
-
1.16: 096c4a5e29cdffc8b4ed72f7bc6fc7b42dab2e9b
>
wsry merged PR #21844:
URL: https://github.com/apache/flink/pull/21844
--
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:
[
https://issues.apache.org/jira/browse/FLINK-27716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685673#comment-17685673
]
Dong Lin commented on FLINK-27716:
--
This is merged to the apache/flink-ml mater branch at
[
https://issues.apache.org/jira/browse/FLINK-27716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-27716.
Resolution: Fixed
> Add Flink ML Python API docs
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-27716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-27716:
-
Summary: Add Flink ML Python API docs (was: Add Python API docs in ML)
> Add Flink ML Python API docs
Fanoid closed pull request #207: [FLINK-30939][draft] Add public APIs of
GBTClassifier.
URL: https://github.com/apache/flink-ml/pull/207
--
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 merged PR #201:
URL: https://github.com/apache/flink-ml/pull/201
--
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 commented on PR #201:
URL: https://github.com/apache/flink-ml/pull/201#issuecomment-1421958739
Thanks for the update. 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
flinkbot commented on PR #21887:
URL: https://github.com/apache/flink/pull/21887#issuecomment-1421956269
## CI report:
* 803239fa8de807f5d5bf6235dc0687a78d874d32 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30944:
---
Labels: pull-request-available test-stability (was: test-stability)
>
reswqa opened a new pull request, #21887:
URL: https://github.com/apache/flink/pull/21887
## What is the purpose of the change
*`ExecutionGraphPartitionReleaseTest` leaks threads through
`ExecutionGraphPartitionReleaseTest.scheduledExecutorService`. The
`ScheduledExecutorService` is
[
https://issues.apache.org/jira/browse/FLINK-30944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-30944:
--
Assignee: Weijie Guo
> ExecutionGraphPartitionReleaseTest leaks threads
>
[
https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-30707.
---
Release Note: The slow task detecting is improved for speculative
execution. Previously, it only considers
[
https://issues.apache.org/jira/browse/FLINK-30944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685670#comment-17685670
]
Weijie Guo commented on FLINK-30944:
Thanks [~mapohl] for reporting this, I'd like to do this work.
[
https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reopened FLINK-30707:
-
> Let speculative execution take input data amount into account when detecting
> slow tasks
>
[
https://issues.apache.org/jira/browse/FLINK-27219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-27219.
-
Resolution: Fixed
> CliClientITCase.testSqlStatements failed on azure with jdk11
>
jiangxin369 commented on code in PR #201:
URL: https://github.com/apache/flink-ml/pull/201#discussion_r1099611012
##
flink-ml-python/docs/reference/pyflink.ml.core/api.rst:
##
@@ -0,0 +1,92 @@
+..
jiangxin369 commented on code in PR #201:
URL: https://github.com/apache/flink-ml/pull/201#discussion_r1099611012
##
flink-ml-python/docs/reference/pyflink.ml.core/api.rst:
##
@@ -0,0 +1,92 @@
+..
Myracle commented on PR #21661:
URL: https://github.com/apache/flink/pull/21661#issuecomment-1421917948
@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.
fredia commented on PR #63:
URL: https://github.com/apache/flink-benchmarks/pull/63#issuecomment-1421914703
Thanks for your review, I dropped the comment and squashed the commits.
The current notifications are as follows:
>
yyx-bigdata commented on PR #21886:
URL: https://github.com/apache/flink/pull/21886#issuecomment-1421911977
>
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
tsreaper commented on code in PR #21759:
URL: https://github.com/apache/flink/pull/21759#discussion_r1099591819
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/SearchOperatorGen.scala:
##
@@ -112,7 +114,7 @@ object
wangyang0918 commented on code in PR #21742:
URL: https://github.com/apache/flink/pull/21742#discussion_r1099582674
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java:
##
@@ -100,6 +100,7 @@ public final void stop() throws
[
https://issues.apache.org/jira/browse/FLINK-30957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30957:
-
Summary: Support other missing features (see description) (was: Support
other missing features)
>
Fan Hong created FLINK-30957:
Summary: Support other missing features
Key: FLINK-30957
URL: https://issues.apache.org/jira/browse/FLINK-30957
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-30956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30956:
-
Summary: Add Python implementation and documents of GBTClassifier and
GBTRegressor. (was: Add Python
[
https://issues.apache.org/jira/browse/FLINK-30925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-30925.
-
Fix Version/s: 1.18.0
Resolution: Implemented
Merged into master:
Fan Hong created FLINK-30956:
Summary: Add Python implementation of GBTClassifer and
GBTRegressor.
Key: FLINK-30956
URL: https://issues.apache.org/jira/browse/FLINK-30956
Project: Flink
Issue
zhipeng93 merged PR #208:
URL: https://github.com/apache/flink-ml/pull/208
--
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:
zhipeng93 commented on PR #208:
URL: https://github.com/apache/flink-ml/pull/208#issuecomment-1421896367
Thanks for the fix. 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
fsk119 closed pull request #21877: [FLINK-30925][docs] Add docs about SQL
Client remote mode
URL: https://github.com/apache/flink/pull/21877
--
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
Fan Hong created FLINK-30955:
Summary: Support early stopping with validation set.
Key: FLINK-30955
URL: https://issues.apache.org/jira/browse/FLINK-30955
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-30952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30952:
-
Summary: Add main training and transforming part (was: Add main training
and transforming part.)
>
[
https://issues.apache.org/jira/browse/FLINK-30954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30954:
-
Summary: Add estimator and transformer for GBTRegressor (was: Add
estimator and transformer for
[
https://issues.apache.org/jira/browse/FLINK-30953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30953:
-
Summary: Support checkpoint machanism and model save/load (was: Support
intermediate state management
[
https://issues.apache.org/jira/browse/FLINK-30954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30954:
-
Component/s: Library / Machine Learning
> Add estimator and transformer for GBTRegressor.
>
[
https://issues.apache.org/jira/browse/FLINK-30953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30953:
-
Component/s: Library / Machine Learning
> Support intermediate state management and model save/load.
>
[
https://issues.apache.org/jira/browse/FLINK-30952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30952:
-
Component/s: Library / Machine Learning
> Add main training and transforming part.
>
Fanoid commented on PR #208:
URL: https://github.com/apache/flink-ml/pull/208#issuecomment-1421881372
@zhipeng93 @jiangxin369 Could you help review this hotfix?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-30951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-30951:
-
Description:
The issue aims to verfiy FLINK-29635.
Please verify in batch mode, the document is in
yyx-bigdata closed pull request #21886: Update filesystem.md
URL: https://github.com/apache/flink/pull/21886
--
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,
flinkbot commented on PR #21886:
URL: https://github.com/apache/flink/pull/21886#issuecomment-1421846449
## CI report:
* e221ec486d3e90f2fb65fe8c511cd6e192ff27ba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Fan Hong created FLINK-30954:
Summary: Add estimator and transformer for GBTRegressor.
Key: FLINK-30954
URL: https://issues.apache.org/jira/browse/FLINK-30954
Project: Flink
Issue Type: Sub-task
Fan Hong created FLINK-30953:
Summary: Support intermediate state management and model save/load.
Key: FLINK-30953
URL: https://issues.apache.org/jira/browse/FLINK-30953
Project: Flink
Issue
Fan Hong created FLINK-30952:
Summary: Add main training and transforming part.
Key: FLINK-30952
URL: https://issues.apache.org/jira/browse/FLINK-30952
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-30939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30939:
-
Summary: Add public APIs for GBTClassifer (was: Add public APIs and
topmost framework for
yyx-bigdata opened a new pull request, #21886:
URL: https://github.com/apache/flink/pull/21886
修改文档代码MemorySize.ofMebiBytes(1024)，否则策略说明中文件大小应为1MB
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server,
luoyuxia created FLINK-30951:
Summary: Release Testing: Verify FLINK-29635 Hive sink should
support merge files in batch mode
Key: FLINK-30951
URL: https://issues.apache.org/jira/browse/FLINK-30951
[
https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685641#comment-17685641
]
Dong Lin commented on FLINK-29825:
--
Thanks [~Yanfei Lei] for implementing and evaluating the algorithm!
Fanoid opened a new pull request, #208:
URL: https://github.com/apache/flink-ml/pull/208
## What is the purpose of the change
Fix a failed test in StringIndexerTest, which is encountered with certain
probability.
## Brief change log
- Fixes the assertion in the failed
snuyanzin commented on code in PR #21759:
URL: https://github.com/apache/flink/pull/21759#discussion_r1099444836
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/SearchOperatorGen.scala:
##
@@ -112,7 +114,7 @@ object
snuyanzin commented on code in PR #21759:
URL: https://github.com/apache/flink/pull/21759#discussion_r1099441783
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/SearchOperatorGen.scala:
##
@@ -96,7 +96,9 @@ object SearchOperatorGen
Hong Liang Teoh created FLINK-30950:
---
Summary: Remove flink-connector-aws-base from Flink main repo
Key: FLINK-30950
URL: https://issues.apache.org/jira/browse/FLINK-30950
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-30950:
Component/s: Connectors / Common
> Remove flink-connector-aws-base from Flink main repo
>
Hong Liang Teoh created FLINK-30949:
---
Summary: Sync flink-connector-aws-base from Flink main to
flink-connector-aws
Key: FLINK-30949
URL: https://issues.apache.org/jira/browse/FLINK-30949
Project:
[
https://issues.apache.org/jira/browse/FLINK-30948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-30948:
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> Remove
Hong Liang Teoh created FLINK-30948:
---
Summary: Remove flink-avro-glue-schema-registry and
flink-json-glue-schema-registry from Flink main repo
Key: FLINK-30948
URL:
[
https://issues.apache.org/jira/browse/FLINK-30947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-30947:
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> Sync
Hong Liang Teoh created FLINK-30947:
---
Summary: Sync flink-avro-glue-schema-registry and
flink-json-glue-schema-registry to flink-connector-aws
Key: FLINK-30947
URL:
[
https://issues.apache.org/jira/browse/FLINK-30946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-30946:
Description:
Migrate flink-avro-glue-schema-registry and flink-json-glue-schema-registry
[
https://issues.apache.org/jira/browse/FLINK-30946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-30946:
Summary: Migrate AWS connector formats to flink-connector-aws (was: Sync
master Avro
Hong Liang Teoh created FLINK-30946:
---
Summary: Sync master Avro GlueSchemaRegistry formats
flink-connector-aws
Key: FLINK-30946
URL: https://issues.apache.org/jira/browse/FLINK-30946
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-30946:
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> Sync master Avro
hlteoh37 commented on code in PR #21798:
URL: https://github.com/apache/flink/pull/21798#discussion_r1099391455
##
flink-formats/flink-avro-glue-schema-registry/src/main/java/org/apache/flink/formats/avro/glue/schema/registry/GlueSchemaRegistryInputStreamDeserializer.java:
##
1 - 100 of 329 matches
Mail list logo
