flinkbot edited a comment on pull request #18201:
URL: https://github.com/apache/flink/pull/18201#issuecomment-1000767373
## CI report:
* 1de7c1375311b176f36751bde15ea8f763f75ead Azure:
flinkbot edited a comment on pull request #18268:
URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356
## CI report:
* 3c8576341becb677e123b27eb9efbc280211b7a1 Azure:
Till Rohrmann created FLINK-25523:
-
Summary: KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails
on AZP
Key: FLINK-25523
URL: https://issues.apache.org/jira/browse/FLINK-25523
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469119#comment-17469119
]
Till Rohrmann commented on FLINK-25523:
---
cc [~fpaul]
>
flinkbot edited a comment on pull request #18119:
URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000
## CI report:
* b7a75d465d4169404b115e8f500f30c4e038a0c1 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
刘方奇 updated FLINK-25528:
Description:
As the title, in the state-processor-api, we use the savepoint opition to
snapshot state defaultly
[
https://issues.apache.org/jira/browse/FLINK-25525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469151#comment-17469151
]
Francesco Guardiani commented on FLINK-25525:
-
I tried to change both table-runtime and
flinkbot edited a comment on pull request #18119:
URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000
## CI report:
* b647d5baf11293d42f4c8cf590cc387d7404b836 Azure:
flinkbot commented on pull request #18267:
URL: https://github.com/apache/flink/pull/18267#issuecomment-1005467469
## CI report:
* 00ea220061040aa2869de411734880fdd6c82bc5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18059:
URL: https://github.com/apache/flink/pull/18059#issuecomment-989489342
## CI report:
* ccc017c8d4b6f7d556039a2bdab54d970c971374 Azure:
flinkbot edited a comment on pull request #18215:
URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080
## CI report:
* 2d628bd92cfdd89fe98d74c151a7f52e45d47b26 Azure:
ranqiqiang opened a new pull request #18268:
URL: https://github.com/apache/flink/pull/18268
## **What is the purpose of the change**
JdbcTableSource supports jdbc async look up join
## **Brief change log**
1.add class JdbcRowDataAsyncLookupFunction
2.add class
[
https://issues.apache.org/jira/browse/FLINK-25522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469116#comment-17469116
]
Till Rohrmann commented on FLINK-25522:
---
cc [~fpaul]
>
[
https://issues.apache.org/jira/browse/FLINK-25464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469118#comment-17469118
]
Till Rohrmann commented on FLINK-25464:
---
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-25464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469117#comment-17469117
]
Till Rohrmann commented on FLINK-25464:
---
Thanks for the updates [~hxbks2ks]. Hopefully, you find
MartijnVisser commented on pull request #15599:
URL: https://github.com/apache/flink/pull/15599#issuecomment-1005489816
@galenwarren I'll try to run your PR against my local Azure CI, to see if it
also fails there.
--
This is an automated message from the Apache Git Service.
To respond
Timo Walther created FLINK-25525:
Summary: flink-examples-table is not runnable in the IDE
Key: FLINK-25525
URL: https://issues.apache.org/jira/browse/FLINK-25525
Project: Flink
Issue Type:
刘方奇 created FLINK-25528:
---
Summary: state processor api do not support increment checkpoint
Key: FLINK-25528
URL: https://issues.apache.org/jira/browse/FLINK-25528
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-25528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469140#comment-17469140
]
刘方奇 commented on FLINK-25528:
-
[~sjwiesman] Could you help to take a glance?
> state processor api do not
gaoyunhaii commented on pull request #18157:
URL: https://github.com/apache/flink/pull/18157#issuecomment-1005506608
Very thanks @zuston for drafting the PR! I'll also try to have a look~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
flinkbot edited a comment on pull request #18266:
URL: https://github.com/apache/flink/pull/18266#issuecomment-1005342823
## CI report:
* 6699bd3e79897191a2e275cf0d78cb6c320edd95 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25521:
---
Labels: pull-request-available (was: )
> The composition description of 'INTERVAL DAY TO
flinkbot commented on pull request #18268:
URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356
## CI report:
* 3c8576341becb677e123b27eb9efbc280211b7a1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18215:
URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080
## CI report:
* 2d628bd92cfdd89fe98d74c151a7f52e45d47b26 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-25464:
--
Fix Version/s: 1.15.0
> Python tests hangs on install dependencies
>
Francesco Guardiani created FLINK-25526:
---
Summary: Deprecate TableSinkFactory, TableSourceFactory and
TableFormatFactory
Key: FLINK-25526
URL: https://issues.apache.org/jira/browse/FLINK-25526
[
https://issues.apache.org/jira/browse/FLINK-25525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francesco Guardiani reassigned FLINK-25525:
---
Assignee: Francesco Guardiani
> flink-examples-table is not runnable in
[
https://issues.apache.org/jira/browse/FLINK-20729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469144#comment-17469144
]
Ada Wong commented on FLINK-20729:
--
To achieve this, could we add a new 'flink-sql-connector-pulsar'
[
https://issues.apache.org/jira/browse/FLINK-20729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469144#comment-17469144
]
Ada Wong edited comment on FLINK-20729 at 1/5/22, 9:17 AM:
---
To achieve this,
[
https://issues.apache.org/jira/browse/FLINK-20729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469144#comment-17469144
]
Ada Wong edited comment on FLINK-20729 at 1/5/22, 9:17 AM:
---
To achieve this,
ashulin opened a new pull request #18267:
URL: https://github.com/apache/flink/pull/18267
## What is the purpose of the change
Fix the composition description of `INTERVAL DAY TO SECOND` in the data type.
## Brief change log
Fix the description of `INTERVAL DAY
flinkbot edited a comment on pull request #18267:
URL: https://github.com/apache/flink/pull/18267#issuecomment-1005467469
## CI report:
* 00ea220061040aa2869de411734880fdd6c82bc5 Azure:
flinkbot edited a comment on pull request #18201:
URL: https://github.com/apache/flink/pull/18201#issuecomment-1000767373
## CI report:
* 1de7c1375311b176f36751bde15ea8f763f75ead Azure:
WTZ468071157 closed pull request #18183:
URL: https://github.com/apache/flink/pull/18183
--
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:
flinkbot commented on pull request #18268:
URL: https://github.com/apache/flink/pull/18268#issuecomment-1005478837
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 #18119:
URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000
## CI report:
* b7a75d465d4169404b115e8f500f30c4e038a0c1 Azure:
Yun Tang created FLINK-25524:
Summary: If enabled changelog, RocksDB incremental checkpoint
would always be full
Key: FLINK-25524
URL: https://issues.apache.org/jira/browse/FLINK-25524
Project: Flink
Zhipeng Zhang created FLINK-25527:
-
Summary: Add StringIndexer in FlinkML
Key: FLINK-25527
URL: https://issues.apache.org/jira/browse/FLINK-25527
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-25327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-25327.
--
Resolution: Cannot Reproduce
> ApplicationMode "DELETE /cluster" REST call leads to exit code
flinkbot commented on pull request #18267:
URL: https://github.com/apache/flink/pull/18267#issuecomment-1005467963
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
Till Rohrmann created FLINK-25522:
-
Summary:
KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryProcessingTime
Key: FLINK-25522
URL: https://issues.apache.org/jira/browse/FLINK-25522
[
https://issues.apache.org/jira/browse/FLINK-25526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469138#comment-17469138
]
Martijn Visser commented on FLINK-25526:
Big +1 for opening tickets like this one
[
https://issues.apache.org/jira/browse/FLINK-25327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469100#comment-17469100
]
Robert Metzger commented on FLINK-25327:
Thanks for taking a look at the issue. I'm checking if
[
https://issues.apache.org/jira/browse/FLINK-25450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469102#comment-17469102
]
David Morávek commented on FLINK-25450:
---
Failed again on internal build based on master
>
twalthr closed pull request #18262:
URL: https://github.com/apache/flink/pull/18262
--
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-25516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-25516.
Fix Version/s: 1.15.0
Resolution: Fixed
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-25515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469122#comment-17469122
]
Ada Wong commented on FLINK-25515:
--
https://issues.apache.org/jira/browse/FLINK-20170?filter=-2
[
https://issues.apache.org/jira/browse/FLINK-24697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Paul reassigned FLINK-24697:
---
Assignee: Hang Ruan
> Kafka table source cannot change the auto.offset.reset setting for
slinkydeveloper commented on a change in pull request #18055:
URL: https://github.com/apache/flink/pull/18055#discussion_r778641188
##
File path: docs/content/docs/try-flink/write_flink_program_with_sql.md
##
@@ -0,0 +1,262 @@
+---
+title: 'Write your first Flink program with
slinkydeveloper commented on a change in pull request #18055:
URL: https://github.com/apache/flink/pull/18055#discussion_r778641188
##
File path: docs/content/docs/try-flink/write_flink_program_with_sql.md
##
@@ -0,0 +1,262 @@
+---
+title: 'Write your first Flink program with
[
https://issues.apache.org/jira/browse/FLINK-25327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469137#comment-17469137
]
Robert Metzger commented on FLINK-25327:
You were right, the issue was caused by FLINK-23946. I
Yuan Zhu created FLINK-25529:
Summary: java.lang.ClassNotFoundException:
org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table
Key: FLINK-25529
URL:
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* 473681213b08ac2dc58ad13f8490542d777f3915 Azure:
flinkbot edited a comment on pull request #18125:
URL: https://github.com/apache/flink/pull/18125#issuecomment-995378571
## CI report:
* f980d9084d916f3354067aa4119e2705f44c596a Azure:
flinkbot edited a comment on pull request #18267:
URL: https://github.com/apache/flink/pull/18267#issuecomment-1005467469
## CI report:
* 00ea220061040aa2869de411734880fdd6c82bc5 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469180#comment-17469180
]
Yun Gao commented on FLINK-25105:
-
Hi [~akalashnikov] sorry for forgetting to close this issue, it is
[
https://issues.apache.org/jira/browse/FLINK-25239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-25239:
-
Assignee: Ada Wong
> Delete useless variables
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-25526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francesco Guardiani reassigned FLINK-25526:
---
Assignee: Francesco Guardiani
> Deprecate TableSinkFactory,
flinkbot edited a comment on pull request #18264:
URL: https://github.com/apache/flink/pull/18264#issuecomment-1004894702
## CI report:
* eb5e1b5f6e345c1cf1ca64a429b1426ef71cb358 Azure:
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* c35e17c973e2e77d25d5943069df96d4ec64aae3 Azure:
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* c35e17c973e2e77d25d5943069df96d4ec64aae3 Azure:
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* c35e17c973e2e77d25d5943069df96d4ec64aae3 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-25486:
--
Priority: Critical (was: Major)
> Perjob can not recover from checkpoint when zookeeper
[
https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469226#comment-17469226
]
Till Rohrmann commented on FLINK-25486:
---
Hi [~Jiangang], thanks for reporting this issue. I think
[
https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-25486:
--
Component/s: Runtime / Coordination
(was: Runtime / Checkpointing)
>
[
https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-25486:
--
Affects Version/s: 1.14.2
1.13.5
1.15.0
>
[
https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-25486:
--
Fix Version/s: 1.15.0
1.13.6
1.14.3
> Perjob can not
[
https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-25486:
-
Assignee: Liu
> Perjob can not recover from checkpoint when zookeeper leader changes
>
[
https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-25486:
--
Issue Type: Bug (was: Improvement)
> Perjob can not recover from checkpoint when zookeeper
[
https://issues.apache.org/jira/browse/FLINK-25515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469233#comment-17469233
]
宇宙先生 commented on FLINK-25515:
--
yes， It's the same problem ，thanks a lot,Sincere blessings for you ，
so
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* c35e17c973e2e77d25d5943069df96d4ec64aae3 Azure:
MartijnVisser commented on pull request #15599:
URL: https://github.com/apache/flink/pull/15599#issuecomment-1005615275
@galenwarren Both `e2e_1_ci` and `e2e_2_ci` passed on my local CI, I had a
failure on `test_ci_build table` (which is expected, because that was broken on
master for
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* c35e17c973e2e77d25d5943069df96d4ec64aae3 Azure:
[
https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469259#comment-17469259
]
Martijn Visser commented on FLINK-21407:
[~echauchot] Did something go wrong, since I now see
[
https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469259#comment-17469259
]
Martijn Visser edited comment on FLINK-21407 at 1/5/22, 12:17 PM:
--
Ada Wong created FLINK-25530:
Summary: Support Pulsar source connector in Python DataStream API.
Key: FLINK-25530
URL: https://issues.apache.org/jira/browse/FLINK-25530
Project: Flink
Issue
MartijnVisser commented on pull request #15152:
URL: https://github.com/apache/flink/pull/15152#issuecomment-1005523318
@jakob-ed What do you think is the status of this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-25527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25527:
---
Labels: pull-request-available (was: )
> Add StringIndexer in FlinkML
>
flinkbot edited a comment on pull request #18125:
URL: https://github.com/apache/flink/pull/18125#issuecomment-995378571
## CI report:
* f980d9084d916f3354067aa4119e2705f44c596a Azure:
zhipeng93 opened a new pull request #53:
URL: https://github.com/apache/flink-ml/pull/53
## What is the purpose of the change
- Add scala suffix for dependencies in flink-ml-uber and flink-ml-lib as a
dependency of flink-ml-uber.
## Brief change log
- Add scala suffix for
MartijnVisser commented on pull request #18105:
URL: https://github.com/apache/flink/pull/18105#issuecomment-1005570770
> Sure in all the happy path cases but as I wrote earlier the user can load
classes in almost every situation. So the smoke test won't prevent all CNFE.
That makes
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* 473681213b08ac2dc58ad13f8490542d777f3915 Azure:
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* 473681213b08ac2dc58ad13f8490542d777f3915 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469196#comment-17469196
]
Liu commented on FLINK-25486:
-
Hello, [~trohrmann]. Can you verify the problem? If this is a problem, I
flinkbot edited a comment on pull request #18264:
URL: https://github.com/apache/flink/pull/18264#issuecomment-1004894702
## CI report:
* eb5e1b5f6e345c1cf1ca64a429b1426ef71cb358 Azure:
rkhachatryan merged pull request #18061:
URL: https://github.com/apache/flink/pull/18061
--
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:
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* 473681213b08ac2dc58ad13f8490542d777f3915 Azure:
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* 473681213b08ac2dc58ad13f8490542d777f3915 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25526:
---
Labels: pull-request-available (was: )
> Deprecate TableSinkFactory, TableSourceFactory
slinkydeveloper opened a new pull request #18269:
URL: https://github.com/apache/flink/pull/18269
## What is the purpose of the change
Deprecate the interfaces and related classes of the old factory stack and
source/sink stack
## Brief change log
* Deprecate
[
https://issues.apache.org/jira/browse/FLINK-17321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469224#comment-17469224
]
Francesco Guardiani commented on FLINK-17321:
-
Hi [~Sergey Nuyanzin] any updates on this
[
https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469226#comment-17469226
]
Till Rohrmann edited comment on FLINK-25486 at 1/5/22, 11:38 AM:
-
Hi
flinkbot edited a comment on pull request #18169:
URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832
## CI report:
* c35e17c973e2e77d25d5943069df96d4ec64aae3 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
宇宙先生 updated FLINK-25515:
-
Description:
my flink version flink 1.11.2,the data in kafka
!image-2022-01-04-17-55-54-810.png!
program
[
https://issues.apache.org/jira/browse/FLINK-25464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25464:
---
Labels: pull-request-available test-stability (was: test-stability)
> Python tests hangs
HuangXingBo opened a new pull request #18270:
URL: https://github.com/apache/flink/pull/18270
## What is the purpose of the change
*This pull request will turn on output infos for package installation in tox*
## Brief change log
- *Turn on output infos for package
flinkbot edited a comment on pull request #18270:
URL: https://github.com/apache/flink/pull/18270#issuecomment-1005631377
## CI report:
* 50bb38f24682c64a8ecbcdc51df833b45446ee1b Azure:
[
https://issues.apache.org/jira/browse/FLINK-25530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-25530:
---
Parent: FLINK-20726
Issue Type: Sub-task (was: New Feature)
> Support Pulsar
[
https://issues.apache.org/jira/browse/FLINK-15017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-15017:
Priority: Major (was: Not a Priority)
> add a thrift server for Flink
> -
>
fapaul commented on pull request #18145:
URL: https://github.com/apache/flink/pull/18145#issuecomment-100912
I agree with @lindong28 if we want to change the
`OffsetsInitializer#PartitionOffsetsRetriever` we need a FLIP. In this case,
there might be also a different alternative. We
1 - 100 of 485 matches
Mail list logo
