[GitHub] [flink] flinkbot edited a comment on pull request #18696: [hotfix][docs] project config pages

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18696: URL: https://github.com/apache/flink/pull/18696#issuecomment-1034481691 ## CI report: * 2921ed917d22b64cb99f05dfdd0f7e119dd86880 Azure:

[jira] [Commented] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490015#comment-17490015 ] Yun Gao commented on FLINK-26036: - Hi [~trohrmann]~ there seems to be an occurrence of this issue after

[jira] [Reopened] (FLINK-26036) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory timeout on azure

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-26036: - > LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory > timeout on azure >

[jira] [Updated] (FLINK-26004) Introduce ForwardForConsecutiveHashPartitioner

2022-02-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-26004: Description: If there are multiple consecutive and the same hash shuffles, SQL planner will change them

[GitHub] [flink] flinkbot edited a comment on pull request #18675: [FLINK-25491][table-planner] Fix bug: generated code for a large IN filter can't be compiled

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18675: URL: https://github.com/apache/flink/pull/18675#issuecomment-1033442210 ## CI report: * 2448efd3a0c18a24860160ae8bb4faec0d0636be Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534 ## CI report: * 60ff1ee473b47a6fad8440dd6b9cc635633c56b8 Azure:

[jira] [Updated] (FLINK-26004) Introduce ForwardForConsecutiveHashPartitioner

2022-02-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-26004: Description: If there are multiple consecutive the same hash shuffle(i.e. keyBy), SQL planner will

[jira] [Commented] (FLINK-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

2022-02-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490010#comment-17490010 ] Danny Cranmer commented on FLINK-26064: --- [~CrynetLogistics] is working on this test failure. >

[GitHub] [flink] flinkbot edited a comment on pull request #18498: [FLINK-25801][ metrics]add cpu processor metric of taskmanager

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1020905745 ## CI report: * 966903ce9ef31c804b67f0731ea1be44a120f0e0 Azure:

[jira] [Assigned] (FLINK-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

2022-02-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-26064: - Assignee: Zichen Liu > KinesisFirehoseSinkITCase IllegalStateException: Trying to

[GitHub] [flink] XComp commented on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

2022-02-09 Thread GitBox
XComp commented on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1034597170 Looks like rebasing wasn't a good idea. There are failures on `master` covered by FLINK-26065. Additionally, the e2e tests stopped due to some problem that looks like an infra

[GitHub] [flink] rkhachatryan commented on pull request #18694: [FLINK-26062][state/changelog] Replace poll() with remove() for PQ states

2022-02-09 Thread GitBox
rkhachatryan commented on pull request #18694: URL: https://github.com/apache/flink/pull/18694#issuecomment-1034595589 Thanks for the review! I'll merge the PR after resolving the (unrelated) build failures (FLINK-26065). -- This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * 6ebf88715d326f8b6814478fcc30cb088999663f Azure:

[GitHub] [flink] MrWhiteSike commented on pull request #18698: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chinese.

2022-02-09 Thread GitBox
MrWhiteSike commented on pull request #18698: URL: https://github.com/apache/flink/pull/18698#issuecomment-1034594297 Hi, [@Thesharing](https://github.com/Thesharing) [@RocMarshal](https://github.com/RocMarshal) , May I get your help to review it? Thanks. -- This is an automated

[jira] [Commented] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490007#comment-17490007 ] Yun Gao commented on FLINK-25233: -

[jira] [Commented] (FLINK-26065) org.apache.flink.table.api.PlanReference$ContentPlanReference $FilePlanReference $ResourcePlanReference violation the api rules

2022-02-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490006#comment-17490006 ] Roman Khachatryan commented on FLINK-26065: ---

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * 6ebf88715d326f8b6814478fcc30cb088999663f Azure:

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490004#comment-17490004 ] Yun Gao commented on FLINK-25825: -

[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 56d378844fb46ed0957fb6a96f800a949eb31f11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18391: URL: https://github.com/apache/flink/pull/18391#issuecomment-1015282046 ## CI report: * 9aa06f3fde2b809a98943eeb7ae7851ec9a4009d Azure:

[jira] [Assigned] (FLINK-11813) Standby per job mode Dispatchers don't know job's JobSchedulingStatus

2022-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-11813: - Assignee: Matthias Pohl > Standby per job mode Dispatchers don't know job's

[jira] [Updated] (FLINK-25973) Rename ArchivedExecutionGraph.createFromInitializingJob into more generic createSparseArchivedExecutionGraph

2022-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-25973: -- Priority: Minor (was: Major) > Rename ArchivedExecutionGraph.createFromInitializingJob into

[jira] [Commented] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490003#comment-17490003 ] Yun Gao commented on FLINK-24573: -

[GitHub] [flink] MartijnVisser commented on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

2022-02-09 Thread GitBox
MartijnVisser commented on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1034588640 @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-26041) AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure hang on azure

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26041: Priority: Critical (was: Major) >

[jira] [Commented] (FLINK-26041) AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure hang on azure

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490002#comment-17490002 ] Yun Gao commented on FLINK-26041: -

[jira] [Updated] (FLINK-26069) KinesisFirehoseSinkITCase failed due to org.testcontainers.containers.ContainerLaunchException: Container startup failed

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26069: Labels: test-stability (was: ) > KinesisFirehoseSinkITCase failed due to >

[jira] [Created] (FLINK-26069) KinesisFirehoseSinkITCase failed due to org.testcontainers.containers.ContainerLaunchException: Container startup failed

2022-02-09 Thread Yun Gao (Jira)
Yun Gao created FLINK-26069: --- Summary: KinesisFirehoseSinkITCase failed due to org.testcontainers.containers.ContainerLaunchException: Container startup failed Key: FLINK-26069 URL:

[jira] [Commented] (FLINK-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1749#comment-1749 ] Yun Gao commented on FLINK-26064: -

[GitHub] [flink] flinkbot edited a comment on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18699: URL: https://github.com/apache/flink/pull/18699#issuecomment-1034581144 ## CI report: * 4a9ad6db0e1a01e9c33529b47053643721622eb7 Azure:

[jira] [Commented] (FLINK-25523) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1748#comment-1748 ] Yun Gao commented on FLINK-25523: -

[jira] [Updated] (FLINK-25523) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25523: Affects Version/s: 1.13.5 > KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP >

[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 42bf48fdbba63580ec0d5418579e2e65c413cf38 Azure:

[GitHub] [flink] flinkbot commented on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

2022-02-09 Thread GitBox
flinkbot commented on pull request #18699: URL: https://github.com/apache/flink/pull/18699#issuecomment-1034582784 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] [Commented] (FLINK-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489998#comment-17489998 ] Yun Gao commented on FLINK-26064: -

[GitHub] [flink] flinkbot commented on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

2022-02-09 Thread GitBox
flinkbot commented on pull request #18699: URL: https://github.com/apache/flink/pull/18699#issuecomment-1034581144 ## CI report: * 4a9ad6db0e1a01e9c33529b47053643721622eb7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-26068) ZooKeeperJobGraphsStoreITCase.testPutAndRemoveJobGraph failed on azure

2022-02-09 Thread Yun Gao (Jira)
Yun Gao created FLINK-26068: --- Summary: ZooKeeperJobGraphsStoreITCase.testPutAndRemoveJobGraph failed on azure Key: FLINK-26068 URL: https://issues.apache.org/jira/browse/FLINK-26068 Project: Flink

[jira] [Updated] (FLINK-26068) ZooKeeperJobGraphsStoreITCase.testPutAndRemoveJobGraph failed on azure

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26068: Labels: test-stability (was: ) > ZooKeeperJobGraphsStoreITCase.testPutAndRemoveJobGraph failed on azure

[jira] [Commented] (FLINK-25937) SQL Client end-to-end test e2e fails on AZP

2022-02-09 Thread Gen Luo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489997#comment-17489997 ] Gen Luo commented on FLINK-25937: - The reason has been identified.  Parallelism of a transformation

[GitHub] [flink] pltbkd opened a new pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

2022-02-09 Thread GitBox
pltbkd opened a new pull request #18699: URL: https://github.com/apache/flink/pull/18699 Parallelism of a transformation with default parallelism(-1) is set when transforming, using the default parallelism set in the environment. However, in SinkExpander#expand, the environment

[jira] [Commented] (FLINK-25940) pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state failed on AZP

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489996#comment-17489996 ] Yun Gao commented on FLINK-25940: -

[GitHub] [flink] flinkbot edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1022985542 ## CI report: * 3cd49ec96a15f95b0b9deb7b71b59038d7fe11ef Azure:

[jira] [Closed] (FLINK-24440) Announce and combine latest watermarks across SourceReaders

2022-02-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24440. -- Resolution: Fixed merged commit 10d6d4f into apache:master > Announce and combine latest

[jira] [Updated] (FLINK-26067) ZooKeeperLeaderElectionConnectionHandlingTest. testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled failed due to timeout

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26067: Labels: test-stability (was: ) > ZooKeeperLeaderElectionConnectionHandlingTest. >

[jira] [Created] (FLINK-26067) ZooKeeperLeaderElectionConnectionHandlingTest. testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled failed due to timeout

2022-02-09 Thread Yun Gao (Jira)
Yun Gao created FLINK-26067: --- Summary: ZooKeeperLeaderElectionConnectionHandlingTest. testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled failed due to timeout Key: FLINK-26067 URL:

[GitHub] [flink] pnowojski commented on pull request #18665: [FLINK-24440][source] Announce and combine latest watermarks across SourceOperators

2022-02-09 Thread GitBox
pnowojski commented on pull request #18665: URL: https://github.com/apache/flink/pull/18665#issuecomment-1034575742 private azure was green: https://dev.azure.com/pnowojski/Flink/_build/results?buildId=614=results -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] pnowojski merged pull request #18665: [FLINK-24440][source] Announce and combine latest watermarks across SourceOperators

2022-02-09 Thread GitBox
pnowojski merged pull request #18665: URL: https://github.com/apache/flink/pull/18665 -- 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-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489992#comment-17489992 ] Yun Gao commented on FLINK-26064: -

[jira] [Updated] (FLINK-26064) KinesisFirehoseSinkITCase IllegalStateException: Trying to access closed classloader

2022-02-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26064: Priority: Critical (was: Major) > KinesisFirehoseSinkITCase IllegalStateException: Trying to access

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 9261ad675d1c9e6f0ea94df829f94f25f18bafc4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForLocalKeyByPartitioner

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * ce93ea4f52aad9d4d7adfaecdb470f25fdf86689 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * c1c5037be96660918b0d342905087e9fa229a3b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForLocalKeyByPartitioner

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * ce93ea4f52aad9d4d7adfaecdb470f25fdf86689 Azure:

[jira] [Updated] (FLINK-26004) Introduce ForwardForConsecutiveHashPartitioner

2022-02-09 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-26004: --- Description: If there are multiple consecutive the same groupBy(i.e. keyBy), SQL planner will

[jira] [Updated] (FLINK-26004) Introduce ForwardForConsecutiveHashPartitioner

2022-02-09 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-26004: --- Description: If there are multiple consecutive the same groupBy(i.e. keyBy), SQL planner will

[jira] [Updated] (FLINK-26004) Introduce ForwardForConsecutiveHashPartitioner

2022-02-09 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-26004: --- Summary: Introduce ForwardForConsecutiveHashPartitioner (was: Introduce

[jira] [Assigned] (FLINK-26047) Support usrlib in HDFS for YARN application mode

2022-02-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26047: - Assignee: Biao Geng > Support usrlib in HDFS for YARN application mode >

[jira] [Assigned] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-02-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26030: - Assignee: Biao Geng > Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers >

[jira] [Commented] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-02-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489978#comment-17489978 ] Yang Wang commented on FLINK-26030: --- Setting the {{FLINK_LIB_DIR}} to workDir/usrlib makes sense to

[GitHub] [flink] flinkbot edited a comment on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608 ## CI report: * ff58bdbffdc38ea1af4fa5b270bef58fcfc0f74a Azure:

[jira] [Commented] (FLINK-26050) Too many small sst files in rocksdb state backend when using processing time window

2022-02-09 Thread shen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489977#comment-17489977 ] shen commented on FLINK-26050: -- Created a new [issue|https://github.com/facebook/rocksdb/issues/9540] in

[GitHub] [flink] flinkbot edited a comment on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608 ## CI report: * ff58bdbffdc38ea1af4fa5b270bef58fcfc0f74a Azure:

[jira] [Commented] (FLINK-26050) Too many small sst files in rocksdb state backend when using processing time window

2022-02-09 Thread shen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489976#comment-17489976 ] shen commented on FLINK-26050: -- [~mayuehappy] , Thx for suggestion. We are actually testing new flink job.

[GitHub] [flink] flinkbot edited a comment on pull request #18698: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chinese.

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18698: URL: https://github.com/apache/flink/pull/18698#issuecomment-1034521527 ## CI report: * 3e380541d698a93d71dbfc0f88723b22c50bccf5 Azure:

[GitHub] [flink] flinkbot commented on pull request #18698: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chinese.

2022-02-09 Thread GitBox
flinkbot commented on pull request #18698: URL: https://github.com/apache/flink/pull/18698#issuecomment-1034521527 -- 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

[jira] [Updated] (FLINK-25782) Translate datastream filesystem.md page into Chinese.

2022-02-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25782: --- Labels: chinese-translation pull-request-available (was: chinese-translation) > Translate

[GitHub] [flink] MrWhiteSike opened a new pull request #18698: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chinese.

2022-02-09 Thread GitBox
MrWhiteSike opened a new pull request #18698: URL: https://github.com/apache/flink/pull/18698 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[jira] [Updated] (FLINK-26066) Introduce FileStoreRead

2022-02-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26066: --- Labels: pull-request-available (was: ) > Introduce FileStoreRead > ---

[GitHub] [flink-table-store] tsreaper opened a new pull request #19: [FLINK-26066] Introduce FileStoreRead

2022-02-09 Thread GitBox
tsreaper opened a new pull request #19: URL: https://github.com/apache/flink-table-store/pull/19 Apart from FileStoreWrite, we also need a FileStoreRead operation to read actual key-values for a specific partition and bucket. This PR is waiting for #18 . Please review the last

[jira] [Created] (FLINK-26066) Introduce FileStoreRead

2022-02-09 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-26066: --- Summary: Introduce FileStoreRead Key: FLINK-26066 URL: https://issues.apache.org/jira/browse/FLINK-26066 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034510296 ## CI report: * 34a2b1811fd7bc75e2c1e9c8462ab9573d506559 Azure:

[GitHub] [flink] flinkbot commented on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-09 Thread GitBox
flinkbot commented on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034511681 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] GOODBOY008 commented on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-09 Thread GitBox
GOODBOY008 commented on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034510767 @tillrohrmann Please cc,Thank you. -- 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

[GitHub] [flink] flinkbot commented on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-09 Thread GitBox
flinkbot commented on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034510296 ## CI report: * 34a2b1811fd7bc75e2c1e9c8462ab9573d506559 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-26034) Add maven wrapper for flink

2022-02-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26034: --- Labels: pull-request-available (was: ) > Add maven wrapper for flink >

[GitHub] [flink] GOODBOY008 opened a new pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-09 Thread GitBox
GOODBOY008 opened a new pull request #18697: URL: https://github.com/apache/flink/pull/18697 ## What is the purpose of the change *Add maven wrapper for flink.* ## Does this pull request potentially affect one of the following parts: - Dependencies (does it

[jira] [Resolved] (FLINK-24682) Unify the -C option behavior in both yarn application and per-job mode

2022-02-09 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng resolved FLINK-24682. --- Resolution: Won't Do > Unify the -C option behavior in both yarn application and per-job mode >

[jira] [Commented] (FLINK-24682) Unify the -C option behavior in both yarn application and per-job mode

2022-02-09 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489959#comment-17489959 ] Biao Geng commented on FLINK-24682: --- Per-job mode will be deprecate due to

[jira] [Commented] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-02-09 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489957#comment-17489957 ] Biao Geng commented on FLINK-26030: --- Yes, it should be a bug. I believe to be consistent with the

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-02-09 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26030: -- Description: Currently, we utilize

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894 ## CI report: * 6408af3118bf294fdb704e36af7568756f3bd1c5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894 ## CI report: * 6408af3118bf294fdb704e36af7568756f3bd1c5 Azure:

[GitHub] [flink] KarmaGYZ commented on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

2022-02-09 Thread GitBox
KarmaGYZ commented on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1034493244 @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] [Commented] (FLINK-26047) Support usrlib in HDFS for YARN application mode

2022-02-09 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489955#comment-17489955 ] Biao Geng commented on FLINK-26047: --- hi [~wangyang0918] Sure. I would take the ticket and start

[GitHub] [flink] flinkbot edited a comment on pull request #18696: [hotfix][docs] project config pages

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18696: URL: https://github.com/apache/flink/pull/18696#issuecomment-1034481691 ## CI report: * 2921ed917d22b64cb99f05dfdd0f7e119dd86880 Azure:

[GitHub] [flink] flinkbot commented on pull request #18696: [hotfix][docs] project config pages

2022-02-09 Thread GitBox
flinkbot commented on pull request #18696: URL: https://github.com/apache/flink/pull/18696#issuecomment-1034481691 -- 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

[GitHub] [flink] infoverload opened a new pull request #18696: [hotfix][docs] project config pages

2022-02-09 Thread GitBox
infoverload opened a new pull request #18696: URL: https://github.com/apache/flink/pull/18696 ## What is the purpose of the change fixes for https://github.com/apache/flink/pull/18353 ## Brief change log - fixed typos - improved clarity - added missing

[jira] [Comment Edited] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

2022-02-09 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489948#comment-17489948 ] Chengkai Yang edited comment on FLINK-25705 at 2/10/22, 3:59 AM: - Hi

[jira] [Commented] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

2022-02-09 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489948#comment-17489948 ] Chengkai Yang commented on FLINK-25705: --- Hi [~jark] ,Another question,this issue is not a subtask

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894 ## CI report: * 6408af3118bf294fdb704e36af7568756f3bd1c5 Azure:

[jira] [Comment Edited] (FLINK-23545) Use new schema in SqlCreateTableConverter

2022-02-09 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489934#comment-17489934 ] zck edited comment on FLINK-23545 at 2/10/22, 3:50 AM: --- I like this feature. 1.15 

[jira] [Commented] (FLINK-26047) Support usrlib in HDFS for YARN application mode

2022-02-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489944#comment-17489944 ] Yang Wang commented on FLINK-26047: --- Nice feature. Would you like to work on this ticket? > Support

[jira] [Updated] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

2022-02-09 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-25705: -- Description: The page url is

[GitHub] [flink] zck573693104 edited a comment on pull request #16721: [FLINK-23545] Use new schema in SqlCreateTableConverter

2022-02-09 Thread GitBox
zck573693104 edited a comment on pull request #16721: URL: https://github.com/apache/flink/pull/16721#issuecomment-1034460519 1.15 publish it? -- 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

[GitHub] [flink] zck573693104 commented on pull request #16721: [FLINK-23545] Use new schema in SqlCreateTableConverter

2022-02-09 Thread GitBox
zck573693104 commented on pull request #16721: URL: https://github.com/apache/flink/pull/16721#issuecomment-1034460519 1.15 ok ? -- 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 #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

2022-02-09 Thread GitBox
flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * d28c15f6f42d4f5982199527f4a227fec0976406 Azure:

[jira] [Updated] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

2022-02-09 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-25705: -- Description: The page url is

[jira] [Comment Edited] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

2022-02-09 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489940#comment-17489940 ] Chengkai Yang edited comment on FLINK-25705 at 2/10/22, 3:39 AM: -

[jira] [Comment Edited] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

2022-02-09 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489940#comment-17489940 ] Chengkai Yang edited comment on FLINK-25705 at 2/10/22, 3:38 AM: -

[jira] [Commented] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

2022-02-09 Thread ChengKai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489940#comment-17489940 ] ChengKai Yang commented on FLINK-25705: --- [~xccui]  [~klion26]  [~jark] Hi,guys,we need to discuss

  1   2   3   4   5   6   7   8   9   10   >