[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 9f753e43ae9f1ca2831848ef996c6fb851b62bd0 Azure:

[jira] [Commented] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453518#comment-17453518 ] Lsw_aka_laplace commented on FLINK-25167: - [~arvid] Would you mind taking a glance~  > Support

[jira] [Updated] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-25167: Description:   From my side, it is necessary to set my custom `StreamOperatorFactory`

[jira] [Updated] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-25167: Description:   From my side, it is necessary to set my custom `StreamOperatorFactory`

[jira] [Updated] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-25167: Description: Currently, from my side, it is necessary to set my custom

[jira] [Updated] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-25167: Description: Currently, from my side, it is necessary to set my custom  > Support

[jira] [Created] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

Lsw_aka_laplace created FLINK-25167: --- Summary: Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform Key: FLINK-25167 URL: https://issues.apache.org/jira/browse/FLINK-25167

[GitHub] [flink] flinkbot edited a comment on pull request #17969: [FLINK-25031][runtime] Job finishes iff all job vertices finish.

flinkbot edited a comment on pull request #17969: URL: https://github.com/apache/flink/pull/17969#issuecomment-983248559 ## CI report: * 33055704ee56e47dcb2403055def3bacf3840cb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17969: [FLINK-25031][runtime] Job finishes iff all job vertices finish.

flinkbot edited a comment on pull request #17969: URL: https://github.com/apache/flink/pull/17969#issuecomment-983248559 ## CI report: * 33055704ee56e47dcb2403055def3bacf3840cb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17969: [FLINK-25031][runtime] Job finishes iff all job vertices finish.

flinkbot edited a comment on pull request #17969: URL: https://github.com/apache/flink/pull/17969#issuecomment-983248559 ## CI report: * 33055704ee56e47dcb2403055def3bacf3840cb8 Azure:

[GitHub] [flink] wanglijie95 commented on pull request #17969: [FLINK-25031][runtime] Job finishes iff all job vertices finish.

wanglijie95 commented on pull request #17969: URL: https://github.com/apache/flink/pull/17969#issuecomment-986151028 @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

[GitHub] [flink] baisui1981 commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

baisui1981 commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-986148674 > Hi, @baisui1981 , Would you mind checking the CI result 'src/main/java/org/apache/flink/runtime/execution/librarycache/ClassLoaderFactoryBuilder.java:[22,8] (imports)

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 48cb6c3fc074ded9400bbb8ed804cee73af51801 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 48cb6c3fc074ded9400bbb8ed804cee73af51801 Azure:

[jira] [Updated] (FLINK-19999) State Processor API classes leaking into savepoint

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-1: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-6485) Use buffering to avoid frequent memtable flushes for short intervals in RockdDB incremental checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6485: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-6626) Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6626: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-10280) json that contains an object can not be parsed

[ https://issues.apache.org/jira/browse/FLINK-10280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10280: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-19911) add read buffer for input stream

[ https://issues.apache.org/jira/browse/FLINK-19911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19911: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-6556) Include and expose Flink version in the savepoint data

[ https://issues.apache.org/jira/browse/FLINK-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6556: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6500: -- Labels: auto-deprioritized-major error stale-minor (was: auto-deprioritized-major error) I

[jira] [Updated] (FLINK-6647) Fail-fast on invalid RocksDBStateBackend configuration

[ https://issues.apache.org/jira/browse/FLINK-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6647: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-6607) Confusing statement in docs that Kafka 010 consumer does not require timestamp extractors

[ https://issues.apache.org/jira/browse/FLINK-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6607: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20386: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery

[ https://issues.apache.org/jira/browse/FLINK-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6503: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-17110) Make StreamExecutionEnvironment#configure also affects StreamExecutionEnvironment#configuration

[ https://issues.apache.org/jira/browse/FLINK-17110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17110: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-20503) Internal cpu configuration option is leaked in logs

[ https://issues.apache.org/jira/browse/FLINK-20503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20503: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10292: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-15825) Add renameDatabase() to Catalog

[ https://issues.apache.org/jira/browse/FLINK-15825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15825: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-19219) Run JobManager initialization in a separate thread, to make it cancellable

[ https://issues.apache.org/jira/browse/FLINK-19219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19219: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-21281) Support DELETE FROM for flink sql

[ https://issues.apache.org/jira/browse/FLINK-21281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21281: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21060) Could not create the DispatcherResourceManagerComponent

[ https://issues.apache.org/jira/browse/FLINK-21060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21060: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21015) Wait for checkpoint cleanup completion during shutdown

[ https://issues.apache.org/jira/browse/FLINK-21015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21015: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-17969) Enhance Flink (Task) logging to include job name as context diagnostic information

[ https://issues.apache.org/jira/browse/FLINK-17969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17969: --- Labels: auto-deprioritized-minor pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-21282) Support UPDATE for flink sql

[ https://issues.apache.org/jira/browse/FLINK-21282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21282: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Comment Edited] (FLINK-25164) DogStatsD Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-25164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453447#comment-17453447 ] Yaroslav Tkachenko edited comment on FLINK-25164 at 12/4/21, 4:36 PM:

[jira] [Commented] (FLINK-25164) DogStatsD Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-25164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453447#comment-17453447 ] Yaroslav Tkachenko commented on FLINK-25164: [~chesnay] yes! That,

[GitHub] [flink] XComp edited a comment on pull request #17967: [FLINK-25096][runtime] Fixes empty exception history for JobInitializationException

XComp edited a comment on pull request #17967: URL: https://github.com/apache/flink/pull/17967#issuecomment-985725105 @slinkydeveloper I refactored your code after I realized that there was some concurrent development on the same issue. I moved the code into `flink-test-utils-junit` to

[GitHub] [flink] flinkbot edited a comment on pull request #18006: [BP-1.14][FLINK-24506][config] Adds checkpoint directory to CheckpointConfig

flinkbot edited a comment on pull request #18006: URL: https://github.com/apache/flink/pull/18006#issuecomment-985405100 ## CI report: * 6ee9426bd1eef0dfc3896b494045a2e0edeea07c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18006: [BP-1.14][FLINK-24506][config] Adds checkpoint directory to CheckpointConfig

flinkbot edited a comment on pull request #18006: URL: https://github.com/apache/flink/pull/18006#issuecomment-985405100 ## CI report: * 6ee9426bd1eef0dfc3896b494045a2e0edeea07c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18006: [BP-1.14][FLINK-24506][config] Adds checkpoint directory to CheckpointConfig

flinkbot edited a comment on pull request #18006: URL: https://github.com/apache/flink/pull/18006#issuecomment-985405100 ## CI report: * 6ee9426bd1eef0dfc3896b494045a2e0edeea07c Azure:

[jira] [Commented] (FLINK-25164) DogStatsD Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-25164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453408#comment-17453408 ] Chesnay Schepler commented on FLINK-25164: -- Have you looked at

[jira] [Comment Edited] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-24506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452861#comment-17452861 ] Chesnay Schepler edited comment on FLINK-24506 at 12/4/21, 1:40 PM:

[jira] [Updated] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-24506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24506: - Fix Version/s: 1.13.4 > checkpoint directory is not configurable through the Flink

[GitHub] [flink] zentol commented on pull request #18006: [BP-1.14][FLINK-24506][config] Adds checkpoint directory to CheckpointConfig

zentol commented on pull request #18006: URL: https://github.com/apache/flink/pull/18006#issuecomment-986029155 @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

[GitHub] [flink] zentol merged pull request #18005: [BP-1.13][FLINK-24506][config] Adds checkpoint directory to CheckpointConfig

zentol merged pull request #18005: URL: https://github.com/apache/flink/pull/18005 -- 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:

[jira] [Closed] (FLINK-25161) Update dependency for japicmp-maven-plugin

[ https://issues.apache.org/jira/browse/FLINK-25161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25161. Fix Version/s: 1.15.0 Assignee: Sergey Nuyanzin Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #18008: [FLINK-25161][buildsystem] update jaxb-impl dependency for japicmp-maven-plugin

zentol merged pull request #18008: URL: https://github.com/apache/flink/pull/18008 -- 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:

[jira] [Commented] (FLINK-25022) ClassLoader leak with ThreadLocals on the JM when submitting a job through the REST API

[ https://issues.apache.org/jira/browse/FLINK-25022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453396#comment-17453396 ] Chesnay Schepler commented on FLINK-25022: -- master: 1f212f2ef04e36e0248098a26e7db43a6d65796a >

[jira] [Updated] (FLINK-25022) ClassLoader leak with ThreadLocals on the JM when submitting a job through the REST API

[ https://issues.apache.org/jira/browse/FLINK-25022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25022: - Fix Version/s: 1.13.4 > ClassLoader leak with ThreadLocals on the JM when submitting a

[GitHub] [flink] zentol merged pull request #17927: [FLINK-25022][rest] Run jars in separate threads

zentol merged pull request #17927: URL: https://github.com/apache/flink/pull/17927 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 81b1f4fc2328330f3d224ee2ecb9f3b09819e984 Azure:

[jira] [Updated] (FLINK-21468) ParquetTableSource: where clause on integer does not work

[ https://issues.apache.org/jira/browse/FLINK-21468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21468: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[GitHub] [flink] flinkbot edited a comment on pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis Data Sink Async Client

flinkbot edited a comment on pull request #18013: URL: https://github.com/apache/flink/pull/18013#issuecomment-985991840 ## CI report: * 894869b20f3dd3dbf7b1c3220c00ec181c1e87cb Azure:

[jira] [Updated] (FLINK-21858) TaskMetricGroup taskName is too long, especially in sql tasks.

[ https://issues.apache.org/jira/browse/FLINK-21858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21858: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-21228) [Kinesis][Producer] Deadlock in KinesisProducer

[ https://issues.apache.org/jira/browse/FLINK-21228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21228: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API

[ https://issues.apache.org/jira/browse/FLINK-21002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21002: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-21121) TaggedOperatorSubtaskState is missing when creating a new savepoint using state processor api

[ https://issues.apache.org/jira/browse/FLINK-21121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21121: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-21712) Extract interfaces for the Execution* (classes used by the DefaultExecutonGraph)

[ https://issues.apache.org/jira/browse/FLINK-21712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21712: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20811: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-22500) flink stop 命令找不到00000000000000000000000000000000

[ https://issues.apache.org/jira/browse/FLINK-22500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22500: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-21161) Investigate Datadog OOM on timeout

[ https://issues.apache.org/jira/browse/FLINK-21161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21161: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21427: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21359: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21424) Lookup Hive partitioned table throws exception

[ https://issues.apache.org/jira/browse/FLINK-21424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21424: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21450) Add local recovery support to adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-21450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21450: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-21830) [kinesis][auth] Add support for Session Token

[ https://issues.apache.org/jira/browse/FLINK-21830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21830: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-21376) Failed state might not provide failureCause

[ https://issues.apache.org/jira/browse/FLINK-21376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21376: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21447) Resuming Savepoint (file, async, scale up) end-to-end test Fail

[ https://issues.apache.org/jira/browse/FLINK-21447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21447: --- Labels: auto-deprioritized-major auto-deprioritized-minor test-stability (was:

[jira] [Updated] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

[ https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21520: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21285) Support MERGE INTO for flink sql

[ https://issues.apache.org/jira/browse/FLINK-21285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21285: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21286) Support BUCKET for flink sql CREATE TABLE

[ https://issues.apache.org/jira/browse/FLINK-21286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21286: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown.

[ https://issues.apache.org/jira/browse/FLINK-21995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21995: --- Labels: auto-deprioritized-major auto-deprioritized-minor test-stability (was:

[jira] [Updated] (FLINK-24721) Update the based on the Maven official indication

[ https://issues.apache.org/jira/browse/FLINK-24721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24721: --- Labels: stale-assigned starter (was: starter) I am the [Flink Jira

[jira] [Updated] (FLINK-21695) Increase default value for number of KeyGroups

[ https://issues.apache.org/jira/browse/FLINK-21695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21695: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-24660) Allow setting KafkaSubscriber in KafkaSourceBuilder

[ https://issues.apache.org/jira/browse/FLINK-24660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24660: --- Labels: stale-assigned starter (was: starter) I am the [Flink Jira

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 16ea7c54642b735ad38836efe314eb5d371e3a86 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure:

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762403691 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,184 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure:

[jira] [Created] (FLINK-25165) CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure

Yun Gao created FLINK-25165: --- Summary: CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure Key: FLINK-25165 URL: https://issues.apache.org/jira/browse/FLINK-25165 Project: Flink

[jira] [Created] (FLINK-25166) UpsertKafkaDynamicTableFactoryTest failed on azure

Yun Gao created FLINK-25166: --- Summary: UpsertKafkaDynamicTableFactoryTest failed on azure Key: FLINK-25166 URL: https://issues.apache.org/jira/browse/FLINK-25166 Project: Flink Issue Type: Bug

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762403551 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModelData.java ## @@ -0,0 +1,122 @@ +/* + * Licensed

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762403691 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,184 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453321#comment-17453321 ] Yun Gao commented on FLINK-23493: -

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762403551 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModelData.java ## @@ -0,0 +1,122 @@ +/* + * Licensed

[jira] [Updated] (FLINK-25165) CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25165: Component/s: Connectors / Cassandra > CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on

[jira] [Updated] (FLINK-25165) CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25165: Affects Version/s: 1.15.0 > CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure:

[GitHub] [flink] flinkbot commented on pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis Data Sink Async Client

flinkbot commented on pull request #18013: URL: https://github.com/apache/flink/pull/18013#issuecomment-985992261 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

[jira] [Updated] (FLINK-16956) Git fetch failed with exit code 128

[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16956: Affects Version/s: 1.14.0 > Git fetch failed with exit code 128 > --- > >

[jira] [Commented] (FLINK-16956) Git fetch failed with exit code 128

[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453320#comment-17453320 ] Yun Gao commented on FLINK-16956: -

[jira] [Commented] (FLINK-16956) Git fetch failed with exit code 128

[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453319#comment-17453319 ] Yun Gao commented on FLINK-16956: -

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 2500d604d97bdb67463c29fb71390568860a882f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18013: FLINK-24227][connectors/kinesis] Kinesis Data Sink Async Client

flinkbot edited a comment on pull request #18013: URL: https://github.com/apache/flink/pull/18013#issuecomment-985991840 ## CI report: * 894869b20f3dd3dbf7b1c3220c00ec181c1e87cb Azure:

  1   2   >