[jira] [Updated] (FLINK-24354) FLIP-174: Improve the WithParam interface

2021-12-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-24354: - Issue Type: New Feature (was: Improvement) > FLIP-174: Improve the WithParam interface >

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

2021-12-28 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466005#comment-17466005 ] Till Rohrmann commented on FLINK-25426: ---

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

2021-12-28 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466004#comment-17466004 ] Till Rohrmann commented on FLINK-25426: ---

[jira] [Updated] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

2021-12-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25427: Priority: Blocker (was: Critical) > SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on

[jira] [Updated] (FLINK-18295) Remove the hack logics of result consumers

2021-12-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18295: Description: Currently an {{IntermediateDataSet}} can have multiple consumer {{JobEdge}}. That's why the

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

2021-12-28 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466016#comment-17466016 ] Till Rohrmann commented on FLINK-25426: --- Disabled test on 1.15.0 via

[GitHub] [flink] flinkbot edited a comment on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 1ebbbf86214cd4fefc1432ea6f0f25320df95542 Azure:

[jira] [Updated] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-5241: Component/s: Runtime / Task (was: Runtime / State Backends) > Introduce

[jira] [Updated] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-5241: Priority: Minor (was: Not a Priority) > Introduce AbstractStreamOperator get CloseableRegistry >

[jira] [Commented] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466019#comment-17466019 ] Yuan Mei commented on FLINK-5241: - [~pnowojski] [~dwysakowicz] [~akalashnikov]  Could you verify whether

[jira] [Closed] (FLINK-4511) Schedule periodic savepoints

2021-12-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei closed FLINK-4511. --- Resolution: Invalid > Schedule periodic savepoints > > > Key:

[GitHub] [flink] flinkbot edited a comment on pull request #18164: [FLINK-25404] Let blob.storage.directory default to /blobStorage

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18164: URL: https://github.com/apache/flink/pull/18164#issuecomment-998893805 ## CI report: * b7120f6165444742957a4e9fc9176c64a7d4e418 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18191: [FLINK-25405] Let BlobServer/BlobCache check and delete corrupted blobs at start up

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18191: URL: https://github.com/apache/flink/pull/18191#issuecomment-1000337022 ## CI report: * 1d1f3053070c92cb092ebb3e677c6f4a95d316b1 Azure:

[jira] [Updated] (FLINK-25178) Throw exception when managed table sink needs checkpointing

2021-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25178: --- Labels: pull-request-available (was: ) > Throw exception when managed table sink needs

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 15a426ccd5aca76c566f437e3a9ab5e3fe9fcc11 Azure:

[GitHub] [flink] flinkbot commented on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2021-12-28 Thread GitBox
flinkbot commented on pull request #18219: URL: https://github.com/apache/flink/pull/18219#issuecomment-1001966453 ## CI report: * 8a899ba056ab6b0b34ab2e9dbe98639c7ba97a70 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2021-12-28 Thread GitBox
flinkbot commented on pull request #18219: URL: https://github.com/apache/flink/pull/18219#issuecomment-1001966256 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

[GitHub] [flink] flinkbot edited a comment on pull request #18216: [FLINK-25465][state] Correct the logic of materizating wrapped changelog state

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18216: URL: https://github.com/apache/flink/pull/18216#issuecomment-1001908812 ## CI report: * f2a4393f2e4dc3e49f417baaf5723fefd88505a0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18212: There is a link redirection problem in the document of ‘overview’

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18212: URL: https://github.com/apache/flink/pull/18212#issuecomment-1001842363 ## CI report: * f303797e4abd7a71e40e193ddbf273f2178f41c6 Azure:

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

2021-12-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466044#comment-17466044 ] Yun Tang commented on FLINK-25426: -- Another instance:

[GitHub] [flink] flinkbot commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-28 Thread GitBox
flinkbot commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * 3c906b980750bbd34d9fb4c9732acc73e77c40db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 1ebbbf86214cd4fefc1432ea6f0f25320df95542 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-28 Thread GitBox
tillrohrmann commented on a change in pull request #18220: URL: https://github.com/apache/flink/pull/18220#discussion_r775870364 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/AsyncClusterClientProvider.java ## @@ -0,0 +1,44 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #18203: [FLINK-25460][core] Update slf4j-api dependency to 1.7.32

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18203: URL: https://github.com/apache/flink/pull/18203#issuecomment-1001460756 ## CI report: * 766445d2c9108cc2cca0b2a0231b172eb76a7b62 UNKNOWN * 333b991392c6834570ee50189b6e687bcd07f4c9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18191: [FLINK-25405] Let BlobServer/BlobCache check and delete corrupted blobs at start up

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18191: URL: https://github.com/apache/flink/pull/18191#issuecomment-1000337022 ## CI report: * 3ee23355516dc889194a7b8986e0a2a70e796980 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

2021-12-28 Thread GitBox
tillrohrmann commented on a change in pull request #18158: URL: https://github.com/apache/flink/pull/18158#discussion_r775874786 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfoTest.java ## @@ -20,13 +20,27 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18221: [FLINK-24803][table-planner] Fix cast BINARY/VARBINARY to STRING

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18221: URL: https://github.com/apache/flink/pull/18221#issuecomment-1002058286 ## CI report: * 1d9f84192c1f7940daf0c15253cd58d32d85c5d8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18203: [FLINK-25460][core] Update slf4j-api dependency to 1.7.32

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18203: URL: https://github.com/apache/flink/pull/18203#issuecomment-1001460756 ## CI report: * 766445d2c9108cc2cca0b2a0231b172eb76a7b62 UNKNOWN * 333b991392c6834570ee50189b6e687bcd07f4c9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18192: [FLINK-25406] Let FileSystemBlobStore sync output stream

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18192: URL: https://github.com/apache/flink/pull/18192#issuecomment-1000394190 ## CI report: * 3181df1d1f9ae281b74efd96f40d7f60ee8bc269 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18191: [FLINK-25405] Let BlobServer/BlobCache check and delete corrupted blobs at start up

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18191: URL: https://github.com/apache/flink/pull/18191#issuecomment-1000337022 ## CI report: * 3ee23355516dc889194a7b8986e0a2a70e796980 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18194: URL: https://github.com/apache/flink/pull/18194#issuecomment-1000443947 ## CI report: * d111c3d078423a6a90e33d91fe2a8cbc1a4d1bbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18192: [FLINK-25406] Let FileSystemBlobStore sync output stream

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18192: URL: https://github.com/apache/flink/pull/18192#issuecomment-1000394190 ## CI report: * 6b324bf9c123dd1def4ef2345d37657534c53ca9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * b7283bf3bb378559403df63696ccf1effd5e080c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18202: [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18202: URL: https://github.com/apache/flink/pull/18202#issuecomment-1001318347 ## CI report: * c571034a5f0c9c830f8f38765d59bd91d086872d Azure:

[GitHub] [flink] MonsterChenzhuo removed a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-12-28 Thread GitBox
MonsterChenzhuo removed a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-983655508 The next few days work on: 1.AsyncSource for Streaming 2. Implement Flink to use the primary key defined in the DDL when writing data to the external

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 25f2a6176bb47749c07f1e9452d69fe80d21bbc6 Azure:

[GitHub] [flink] flinkbot commented on pull request #18217: [FLINK-25466][state] Enable state descriptor to handle StateTtlConfig#DISABLED

2021-12-28 Thread GitBox
flinkbot commented on pull request #18217: URL: https://github.com/apache/flink/pull/18217#issuecomment-1001925740 ## CI report: * 7c60f02cecae1e2d06404f39390147803add396b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18217: [FLINK-25466][state] Enable state descriptor to handle StateTtlConfig#DISABLED

2021-12-28 Thread GitBox
flinkbot commented on pull request #18217: URL: https://github.com/apache/flink/pull/18217#issuecomment-1001925608 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

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 31e2390d189b7dd08bf1e1099138b81b4524ce70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18180: [hotfix][doc] fix typo of 'note that' and 'now that'

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-999581101 ## CI report: * Unknown: [CANCELED](TBD) * 485acda72617d08437759e906d2a20d3cd3984c1 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] hackergin commented on pull request #18180: [hotfix][doc] fix typo of 'note that' and 'now that'

2021-12-28 Thread GitBox
hackergin commented on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-1001929320 @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

[jira] [Updated] (FLINK-24557) Support Knn in FlinkML

2021-12-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-24557: - Fix Version/s: ml-2.0.0 > Support Knn in FlinkML > -- > > Key:

[jira] [Updated] (FLINK-24557) Support Knn in FlinkML

2021-12-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-24557: - Issue Type: New Feature (was: Bug) > Support Knn in FlinkML > -- > >

[GitHub] [flink-web] crazyzhou commented on a change in pull request #484: Add Pravega Flink connector 101 blog

2021-12-28 Thread GitBox
crazyzhou commented on a change in pull request #484: URL: https://github.com/apache/flink-web/pull/484#discussion_r775806152 ## File path: _posts/2021-12-27-pravega-connector-101.md ## @@ -0,0 +1,221 @@ +--- +layout: post +title: "Pravega Flink Connector 101" +date:

[jira] [Resolved] (FLINK-24772) Update user document for individual window table-valued function

2021-12-28 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang resolved FLINK-24772. Release Note: Flink now supports evaluating individual window table-valued functions, so there's

[jira] [Closed] (FLINK-24772) Update user document for individual window table-valued function

2021-12-28 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-24772. -- > Update user document for individual window table-valued function >

[GitHub] [flink] flinkbot edited a comment on pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #17684: URL: https://github.com/apache/flink/pull/17684#issuecomment-961007710 ## CI report: * 966d66f1a73207b2d2ed1689664ada26b55f9b7a Azure:

[GitHub] [flink] SteNicholas opened a new pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

2021-12-28 Thread GitBox
SteNicholas opened a new pull request #18219: URL: https://github.com/apache/flink/pull/18219 ## What is the purpose of the change *In the past, many users encountered the problem that the sink did not output because they did not open the checkpoint. For the managed table: The

[GitHub] [flink] flinkbot edited a comment on pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18162: URL: https://github.com/apache/flink/pull/18162#issuecomment-998843801 ## CI report: * 5333d13bb184a2f477be0a9b246f1ec06eca1c96 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18135: [FLINK-24809][table-common][table-planner] Fix precision for aggs on DECIMAL types

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18135: URL: https://github.com/apache/flink/pull/18135#issuecomment-995929870 ## CI report: * dee9315b9030fa2ed4cd75b67622f0ed68fe632a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18191: [FLINK-25405] Let BlobServer/BlobCache check and delete corrupted blobs at start up

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18191: URL: https://github.com/apache/flink/pull/18191#issuecomment-1000337022 ## CI report: * 1d1f3053070c92cb092ebb3e677c6f4a95d316b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18192: [FLINK-25406] Let FileSystemBlobStore sync output stream

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18192: URL: https://github.com/apache/flink/pull/18192#issuecomment-1000394190 ## CI report: * 3181df1d1f9ae281b74efd96f40d7f60ee8bc269 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 91439cd36075e088b954ca4e64faca9f2f524202 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18203: [FLINK-25460][core] Update slf4j-api dependency to 1.7.32

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18203: URL: https://github.com/apache/flink/pull/18203#issuecomment-1001460756 ## CI report: * 766445d2c9108cc2cca0b2a0231b172eb76a7b62 UNKNOWN * 333b991392c6834570ee50189b6e687bcd07f4c9 Azure:

[GitHub] [flink] zuston opened a new pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2021-12-28 Thread GitBox
zuston opened a new pull request #18220: URL: https://github.com/apache/flink/pull/18220 …mode on Yarn ## What is the purpose of the change ### Why In our internal streaming platform, we will use flink-cli tool to submit Flink streaming application on Yarn. However

[GitHub] [flink] tillrohrmann commented on a change in pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

2021-12-28 Thread GitBox
tillrohrmann commented on a change in pull request #18158: URL: https://github.com/apache/flink/pull/18158#discussion_r775836504 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java ## @@ -106,5 +112,87 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18162: URL: https://github.com/apache/flink/pull/18162#issuecomment-998843801 ## CI report: * 5333d13bb184a2f477be0a9b246f1ec06eca1c96 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18180: [hotfix][doc] fix typo of 'note that' and 'now that'

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-999581101 ## CI report: * 485acda72617d08437759e906d2a20d3cd3984c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18194: URL: https://github.com/apache/flink/pull/18194#issuecomment-1000443947 ## CI report: * d111c3d078423a6a90e33d91fe2a8cbc1a4d1bbc Azure:

[jira] [Updated] (FLINK-15219) LocalEnvironment is not initializing plugins

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

[jira] [Updated] (FLINK-15786) Load connector code with separate classloader

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

[jira] [Updated] (FLINK-19382) Introducing ReplayableSourceStateBackend

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

[GitHub] [flink] zuston commented on a change in pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

2021-12-28 Thread GitBox
zuston commented on a change in pull request #18158: URL: https://github.com/apache/flink/pull/18158#discussion_r775853926 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java ## @@ -106,5 +112,87 @@ public boolean

[jira] [Closed] (FLINK-25121) Support ML Python API

2021-12-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25121. --- Resolution: Fixed > Support ML Python API > - > > Key: FLINK-25121 >

[jira] [Closed] (FLINK-24557) Support Knn in FlinkML

2021-12-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24557. --- Resolution: Fixed > Support Knn in FlinkML > -- > > Key: FLINK-24557 >

[jira] [Updated] (FLINK-24354) FLIP-174: Improve the WithParam interface

2021-12-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24354: Fix Version/s: ml-2.0.0 > FLIP-174: Improve the WithParam interface >

[jira] [Closed] (FLINK-24354) FLIP-174: Improve the WithParam interface

2021-12-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24354. --- Resolution: Fixed > FLIP-174: Improve the WithParam interface > - >

[GitHub] [flink] matriv commented on a change in pull request #17900: [FLINK-24803][Table SQL/Planner] Fix cast BINARY/VARBINARY to STRING

2021-12-28 Thread GitBox
matriv commented on a change in pull request #17900: URL: https://github.com/apache/flink/pull/17900#discussion_r765915976 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionITCase.java ## @@ -153,11 +153,11 @@

[GitHub] [flink] echauchot commented on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
echauchot commented on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1002038682 @tillrohrmann thanks for the prompt review ! I addressed the nit comment and squashed and answered your other comment. PTAL -- This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #18217: [FLINK-25466][state] Enable state descriptor to handle StateTtlConfig#DISABLED

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18217: URL: https://github.com/apache/flink/pull/18217#issuecomment-1001925740 ## CI report: * 7c60f02cecae1e2d06404f39390147803add396b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1001691194 ## CI report: * 4f86089ac0d0aadfa343f90d40843fc77365a3fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 1ebbbf86214cd4fefc1432ea6f0f25320df95542 Azure:

[GitHub] [flink] flinkbot commented on pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

2021-12-28 Thread GitBox
flinkbot commented on pull request #18218: URL: https://github.com/apache/flink/pull/18218#issuecomment-1001948175 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

[GitHub] [flink-web] infoverload commented on a change in pull request #484: Add Pravega Flink connector 101 blog

2021-12-28 Thread GitBox
infoverload commented on a change in pull request #484: URL: https://github.com/apache/flink-web/pull/484#discussion_r775805493 ## File path: _posts/2021-12-27-pravega-connector-101.md ## @@ -0,0 +1,221 @@ +--- +layout: post +title: "Pravega Flink Connector 101" +date:

[GitHub] [flink] flinkbot edited a comment on pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #17684: URL: https://github.com/apache/flink/pull/17684#issuecomment-961007710 ## CI report: * 966d66f1a73207b2d2ed1689664ada26b55f9b7a Azure:

[jira] [Commented] (FLINK-24772) Update user document for individual window table-valued function

2021-12-28 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466023#comment-17466023 ] Jing Zhang commented on FLINK-24772: Fixed in master: 07977083736af1e23f00a4ff6c2134886a0e51d9 >

[GitHub] [flink] beyond1920 merged pull request #17885: [FLINK-24772][docs] Update documentation for individual window table-value function

2021-12-28 Thread GitBox
beyond1920 merged pull request #17885: URL: https://github.com/apache/flink/pull/17885 -- 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] matriv commented on pull request #18162: [FLINK-25187][table-planner] Apply padding when CASTing to BINARY()

2021-12-28 Thread GitBox
matriv commented on pull request #18162: URL: https://github.com/apache/flink/pull/18162#issuecomment-1001968639 @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] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 91439cd36075e088b954ca4e64faca9f2f524202 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

2021-12-28 Thread GitBox
MartijnVisser commented on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1002021144 @HuangXingBo Do you want to take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #18212: There is a link redirection problem in the document of ‘overview’

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18212: URL: https://github.com/apache/flink/pull/18212#issuecomment-1001842363 ## CI report: * 35f726eb69726eac103e8e60e138bc56ad389c7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1001691194 ## CI report: * 4f86089ac0d0aadfa343f90d40843fc77365a3fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18135: [FLINK-24809][table-common][table-planner] Fix precision for aggs on DECIMAL types

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18135: URL: https://github.com/apache/flink/pull/18135#issuecomment-995929870 ## CI report: * ea55785db7837e828a39d84e79991a8f8a0cff6f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 25f2a6176bb47749c07f1e9452d69fe80d21bbc6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-974817636 ## CI report: * 25f2a6176bb47749c07f1e9452d69fe80d21bbc6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18215: URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080 ## CI report: * f7cd16ff3ada4685472693b8d6ad22b5aa1ea582 Azure:

[jira] [Updated] (FLINK-25121) Support ML Python API

2021-12-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-25121: - Fix Version/s: ml-2.0.0 > Support ML Python API > - > > Key:

[GitHub] [flink] MartijnVisser commented on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
MartijnVisser commented on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1001942981 @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] godfreyhe commented on a change in pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

2021-12-28 Thread GitBox
godfreyhe commented on a change in pull request #17684: URL: https://github.com/apache/flink/pull/17684#discussion_r775783419 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/WindowTableFunctionTest.scala ## @@ -86,6

[GitHub] [flink] MartijnVisser commented on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.

2021-12-28 Thread GitBox
MartijnVisser commented on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-1001943183 @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] zhuzhurk opened a new pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

2021-12-28 Thread GitBox
zhuzhurk opened a new pull request #18218: URL: https://github.com/apache/flink/pull/18218 ## What is the purpose of the change This change is to rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer. This can help to get rid of the hack

[GitHub] [flink] flinkbot edited a comment on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1001691194 ## CI report: * 4f86089ac0d0aadfa343f90d40843fc77365a3fc Azure:

[jira] [Updated] (FLINK-18295) Remove the hack logics of result consumers

2021-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18295: --- Labels: pull-request-available (was: ) > Remove the hack logics of result consumers >

[GitHub] [flink] beyond1920 commented on a change in pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

2021-12-28 Thread GitBox
beyond1920 commented on a change in pull request #17684: URL: https://github.com/apache/flink/pull/17684#discussion_r775808275 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/WindowTableFunctionTest.scala ## @@ -86,6

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * d6d02b1257a59f5c555dbec42e00f9152488d624 Azure:

[GitHub] [flink] zuston commented on a change in pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

2021-12-28 Thread GitBox
zuston commented on a change in pull request #18158: URL: https://github.com/apache/flink/pull/18158#discussion_r775827788 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfoTest.java ## @@ -20,13 +20,27 @@ import

[jira] [Commented] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator

2021-12-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466060#comment-17466060 ] Yun Tang commented on FLINK-5279: - Current error message has been "{{{}Keyed state can only be used on a

[GitHub] [flink] flinkbot edited a comment on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
flinkbot edited a comment on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1001691194 ## CI report: * 4f86089ac0d0aadfa343f90d40843fc77365a3fc Azure:

[jira] [Comment Edited] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2021-12-28 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466063#comment-17466063 ] Till Rohrmann edited comment on FLINK-23047 at 12/28/21, 10:32 AM: ---

[GitHub] [flink] tillrohrmann commented on a change in pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

2021-12-28 Thread GitBox
tillrohrmann commented on a change in pull request #18211: URL: https://github.com/apache/flink/pull/18211#discussion_r775841680 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java

  1   2   3   4   5   >