[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841271#comment-17841271
]
Alexander Fedulov commented on FLINK-35240:
---
[~gongzhongqiang] and [~robyoung] you are right!
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-35240:
--
Attachment: image-2024-04-26-17-16-20-647.png
> Disable FLUSH_AFTER_WRITE_VALUE to
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-35240:
--
Attachment: image-2024-04-26-17-16-30-293.png
> Disable FLUSH_AFTER_WRITE_VALUE to
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-35240:
--
Attachment: image-2024-04-26-17-16-07-925.png
> Disable FLUSH_AFTER_WRITE_VALUE to
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841117#comment-17841117
]
Alexander Fedulov commented on FLINK-35240:
---
I don't think touching any of the flush-specific
[
https://issues.apache.org/jira/browse/FLINK-35240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840935#comment-17840935
]
Alexander Fedulov commented on FLINK-35240:
---
[~gongzhongqiang] this is pretty strange, because
Alexander Fedulov created FLINK-35052:
-
Summary: Webhook validator should reject unsupported Flink versions
Key: FLINK-35052
URL: https://issues.apache.org/jira/browse/FLINK-35052
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810848#comment-17810848
]
Alexander Fedulov commented on FLINK-34117:
---
[~leonard] thanks! Here is the backport PR
[
https://issues.apache.org/jira/browse/FLINK-33694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33694:
--
Release Note: This fix resolves the issue where the `gs.storage.root.url`
setting in
Alexander Fedulov created FLINK-34117:
-
Summary: CompactCoordinator for table file sink loses data upon
job termination
Key: FLINK-34117
URL: https://issues.apache.org/jira/browse/FLINK-34117
[
https://issues.apache.org/jira/browse/FLINK-33789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33789:
--
Summary: Expose restart time as a metric (was: Expose restart time as
metric)
>
[
https://issues.apache.org/jira/browse/FLINK-33789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33789:
--
Description: FLINK-30593 added restart time tracking. It would be
convenient to also
[
https://issues.apache.org/jira/browse/FLINK-33789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33789:
--
Description: FLINK-30593 added restart time tracking. It would be
convenient to also
Alexander Fedulov created FLINK-33789:
-
Summary: Expose restart time as metric
Key: FLINK-33789
URL: https://issues.apache.org/jira/browse/FLINK-33789
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28229:
--
Labels: pull-request-available (was: pull-request-available stale-assigned)
>
[
https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17790034#comment-17790034
]
Alexander Fedulov commented on FLINK-28051:
---
[~Brian Zhou] can I assign this ticket to you or
[
https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17790032#comment-17790032
]
Alexander Fedulov commented on FLINK-28051:
---
Hi [~Brian Zhou], thanks a lot for the
[
https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28051:
--
Summary: Promote ExternallyInducedSourceReader to non-experimental @Public
(was:
Alexander Fedulov created FLINK-33525:
-
Summary: Migrate LoadSimulationPipeline in Flink K8S Operator to
the new Source API
Key: FLINK-33525
URL: https://issues.apache.org/jira/browse/FLINK-33525
[
https://issues.apache.org/jira/browse/FLINK-33525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-33525:
-
Assignee: (was: Alexander Fedulov)
> Migrate LoadSimulationPipeline in
[
https://issues.apache.org/jira/browse/FLINK-33525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-33525:
-
Assignee: Alexander Fedulov
> Migrate LoadSimulationPipeline in Flink K8S
[
https://issues.apache.org/jira/browse/FLINK-30593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-30593:
-
Assignee: Alexander Fedulov
> Determine restart time on the fly for Autoscaler
[
https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32694:
--
Description:
* SimpleEndlessSourceWithBloatedState in
[
https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32694:
--
Summary: Migrate ParallelSourceFunction classes to Source V2 API or prepare
for
[
https://issues.apache.org/jira/browse/FLINK-33367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov closed FLINK-33367.
-
Release Note: Not an actual issue.
Resolution: Won't Fix
I am closing this as
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-5:
--
Summary: Reactivate missing e2e tests (was: Remove unused e2e tests)
> Reactivate
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779442#comment-17779442
]
Alexander Fedulov commented on FLINK-5:
---
[~rmetzger] thanks for the clarification! I am
[
https://issues.apache.org/jira/browse/FLINK-33058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-33058:
-
Assignee: Dale Lane
> Support for JSON-encoded Avro
>
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-5:
--
Description:
FLINK-17375 removed _run-pre-commit-tests.sh_ in Flink 1.12 [1]. Since
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778126#comment-17778126
]
Alexander Fedulov edited comment on FLINK-5 at 10/22/23 10:07 AM:
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-5:
--
Description:
FLINK-17375 removed run-pre-commit-tests.sh in Flink 1.12 [1]. Since
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-5:
--
Description:
FLINK-17375 removed run-pre-commit-tests.sh in Flink 1.12 [1]. Since
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-5:
--
Description:
FLINK-17375 removed _run-pre-commit-tests.sh_ in Flink 1.12 [1]. Since
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-5:
--
Description:
FLINK-17375
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-5:
--
Description:
FLINK-17375
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-5:
-
Assignee: Alexander Fedulov
> Remove unused e2e tests
>
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778126#comment-17778126
]
Alexander Fedulov commented on FLINK-5:
---
[~rmetzger] [~chesnay]
Could you please confirm
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-5:
--
Description:
FLINK-17375
Alexander Fedulov created FLINK-5:
-
Summary: Remove unused e2e tests
Key: FLINK-5
URL: https://issues.apache.org/jira/browse/FLINK-5
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32694:
--
Description:
* SimpleEndlessSourceWithBloatedState in
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description:
This ticket should only contain items where SourceFunction is already
Alexander Fedulov created FLINK-33326:
-
Summary: Remove usage of FromElementsFunction
Key: FLINK-33326
URL: https://issues.apache.org/jira/browse/FLINK-33326
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33286:
--
Description:
Currently, DataGeneratorSource requires both GeneratorFunction and
[
https://issues.apache.org/jira/browse/FLINK-33286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-33286:
-
Assignee: Alexander Fedulov
> DataGeneratorSource should support automatic
[
https://issues.apache.org/jira/browse/FLINK-33286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775923#comment-17775923
]
Alexander Fedulov commented on FLINK-33286:
---
Connectors / DataGen component is missing. If you
Alexander Fedulov created FLINK-33286:
-
Summary: DataGeneratorSource should support automatic return type
detection
Key: FLINK-33286
URL: https://issues.apache.org/jira/browse/FLINK-33286
[
https://issues.apache.org/jira/browse/FLINK-33218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-33218:
-
Assignee: Robin Moffatt
> First Steps - error when run with zsh
>
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772852#comment-17772852
]
Alexander Fedulov commented on FLINK-31278:
---
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772849#comment-17772849
]
Alexander Fedulov commented on FLINK-31278:
---
[
https://issues.apache.org/jira/browse/FLINK-33199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33199:
--
Summary: ArchitectureTests should test for fully qualified class names
instead of
[
https://issues.apache.org/jira/browse/FLINK-33199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-33199:
-
Assignee: Alexander Fedulov
> ArchitectureTests should test for canonical
Alexander Fedulov created FLINK-33199:
-
Summary: ArchitectureTests should test for canonical class names
instead of Class objects
Key: FLINK-33199
URL: https://issues.apache.org/jira/browse/FLINK-33199
[
https://issues.apache.org/jira/browse/FLINK-32904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32904:
--
Description: Current functionality to trigger savepoints and checkpoints is
based on
Alexander Fedulov created FLINK-32904:
-
Summary: Support cron expressions for periodic snapshots triggering
Key: FLINK-32904
URL: https://issues.apache.org/jira/browse/FLINK-32904
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756913#comment-17756913
]
Alexander Fedulov commented on FLINK-32821:
---
[~huweihua] Oh, I see, good catch!
Ideally we
[
https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755534#comment-17755534
]
Alexander Fedulov commented on FLINK-32821:
---
[~Zhanghao Chen] I am still not sure why you
[
https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752918#comment-17752918
]
Alexander Fedulov commented on FLINK-32821:
---
[~Zhanghao Chen] I cannot reproduce the listed
[
https://issues.apache.org/jira/browse/FLINK-32195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov closed FLINK-32195.
-
Release Note: Duplicate of FLINK-32373
Resolution: Duplicate
> Add SQL Gateway
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32693:
--
Parent: (was: FLINK-28045)
Issue Type: Technical Debt (was: Sub-task)
>
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov closed FLINK-32693.
-
Release Note: Subsumed by FLINK-32670
Resolution: Duplicate
> Cascade deprecation
Alexander Fedulov created FLINK-32719:
-
Summary: Block upgrades during checkpoints when LATEST_STATE
recovery is configured
Key: FLINK-32719
URL: https://issues.apache.org/jira/browse/FLINK-32719
[
https://issues.apache.org/jira/browse/FLINK-32713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-32713:
-
Assignee: Alexander Fedulov
> Cascade deprecation to non-private methods that
Alexander Fedulov created FLINK-32713:
-
Summary: Cascade deprecation to non-private methods that reference
SourceFunction
Key: FLINK-32713
URL: https://issues.apache.org/jira/browse/FLINK-32713
[
https://issues.apache.org/jira/browse/FLINK-32670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32670:
--
Description: (was: ParallelSourceFunction, RichParallelSourceFunction,
[
https://issues.apache.org/jira/browse/FLINK-32670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32670:
--
Summary: Cascade deprecation to classes that implement SourceFunction
(was: Annotate
[
https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32694:
--
Summary: Migrate classes that implement ParallelSourceFunction to Source V2
API
[
https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-32694:
-
Assignee: Alexander Fedulov
> Cascade deprecation to classes that implement
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32693:
--
Description:
* SocketTextStreamFunction
[
https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32695:
--
Description:
* ProcessingTimeServiceSource in StreamSourceOperatorLatencyMetricsTest
[
https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32694:
--
Description:
* SimpleEndlessSourceWithBloatedState in
[
https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32695:
--
Description:
* ProcessingTimeServiceSource in StreamSourceOperatorLatencyMetricsTest
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description:
This ticket should only contain items where SourceFunction is already
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747894#comment-17747894
]
Alexander Fedulov commented on FLINK-28045:
---
Hi [~dannycranmer], thanks for the confirmation!
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747665#comment-17747665
]
Alexander Fedulov commented on FLINK-28045:
---
[~danny.cranmer] I see that Kinesis Source V2
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Summary: [umbrella] Blockers for SourceFunction API (in Flink 2.0) (was:
[umbrella]
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Summary: [umbrella] Blockers for SourceFunction API removal (in Flink 2.0)
(was:
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description:
This ticket should only contain items where SourceFunction is already
Alexander Fedulov created FLINK-32696:
-
Summary: Promote Kinesis connector support to PublicEvolving
Key: FLINK-32696
URL: https://issues.apache.org/jira/browse/FLINK-32696
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description:
This ticket should only contain items where SourceFunction is already
[
https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32695:
--
Summary: Migrate SourceFunction in Tests to Source V2 API (was: Migrate
[
https://issues.apache.org/jira/browse/FLINK-32692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32692:
--
Description: See also FLINK-28045 (was: See also
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description: This ticket should only contain items where SourceFunction is
already
[
https://issues.apache.org/jira/browse/FLINK-32692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32692:
--
Description: See also https://issues.apache.org/jira/browse/FLINK-28045
> [umbrella]
[
https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28051:
--
Summary: Introduce Source API alternative to ExternallyInducedSource (was:
Introduce
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description: This ticket should only contain items where SourceFunction is
already
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description: Should only contain items where SourceFunction is used in the
existing
[
https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28045:
--
Description: This ticket should only contain items where SourceFunction is
used in
Alexander Fedulov created FLINK-32695:
-
Summary: Migrate SourceFunction in Tests to Source API
Key: FLINK-32695
URL: https://issues.apache.org/jira/browse/FLINK-32695
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28048:
--
Description: This also has to verify that Iceberg connector tests mentioned
in
Alexander Fedulov created FLINK-32694:
-
Summary: Cascade deprecation to classes that implement
ParallelSourceFunction
Key: FLINK-32694
URL: https://issues.apache.org/jira/browse/FLINK-32694
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32693:
--
Description:
* SocketTextStreamFunction
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-32693:
-
Assignee: Alexander Fedulov
> Cascade deprecation to classes that directly
[
https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32693:
--
Description:
* SocketTextStreamFunction
Alexander Fedulov created FLINK-32693:
-
Summary: Cascade deprecation to classes that directly implement
SourceFunction
Key: FLINK-32693
URL: https://issues.apache.org/jira/browse/FLINK-32693
[
https://issues.apache.org/jira/browse/FLINK-28050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28050:
--
Summary: Introduce Source API alternative to
SourceExecutionContext#fromElements(*)
[
https://issues.apache.org/jira/browse/FLINK-28054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28054:
--
Parent: (was: FLINK-28045)
Issue Type: Improvement (was: Sub-task)
>
[
https://issues.apache.org/jira/browse/FLINK-28056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28056:
--
Parent: FLINK-32692
Issue Type: Sub-task (was: Improvement)
> Introduce high
[
https://issues.apache.org/jira/browse/FLINK-28056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28056:
--
Parent: (was: FLINK-28045)
Issue Type: Improvement (was: Sub-task)
>
[
https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28049:
--
Parent: FLINK-32692
Issue Type: Sub-task (was: Improvement)
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-28049:
--
Parent: (was: FLINK-28045)
Issue Type: Improvement (was: Sub-task)
>
1 - 100 of 313 matches
Mail list logo
