[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] ZhijieYang commented on a change in pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
ZhijieYang commented on a change in pull request #17902: URL: https://github.com/apache/flink/pull/17902#discussion_r759015168 ## File path: docs/content.zh/docs/ops/metrics.md ## @@ -28,26 +28,26 @@ under the License. # 指标 -Flink exposes a metric system that allows

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

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

2021-11-29 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r759012504 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-24348) Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed"

2021-11-29 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450930#comment-17450930 ] Arvid Heise commented on FLINK-24348: - Okay the script "testcontainers_start.sh" is generated in

[jira] [Assigned] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2021-11-29 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-18634: --- Assignee: (was: Fabian Paul) >

[jira] [Assigned] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

2021-11-29 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-22342: --- Assignee: (was: Fabian Paul) > FlinkKafkaProducerITCase fails with producer leak >

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

2021-11-29 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r759008827 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

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

2021-11-29 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r759007852 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

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

2021-11-29 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r759003838 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17949: [hotfix][docs] Fix Scala example for MiniCluster test

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17949: URL: https://github.com/apache/flink/pull/17949#issuecomment-982158256 ## CI report: * a787ab271f51e7152894777d4740113b8070c011 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17949: [hotfix][docs] Fix Scala example for MiniCluster test

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17949: URL: https://github.com/apache/flink/pull/17949#issuecomment-982158256 ## CI report: * a787ab271f51e7152894777d4740113b8070c011 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17878: [FLINK-24507][table] Cleanup DateTimeUtils

2021-11-29 Thread GitBox
twalthr commented on a change in pull request #17878: URL: https://github.com/apache/flink/pull/17878#discussion_r758998441 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DateSerializer.java ## @@ -39,6 +41,11 @@

[jira] [Commented] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

2021-11-29 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450921#comment-17450921 ] Arvid Heise commented on FLINK-22300: - Okay I see, so Flink would never evict the data. That is

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17952: [FLINK-25011] Introduce vertex parallelism decider and the default implementation.

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17952: URL: https://github.com/apache/flink/pull/17952#issuecomment-982356774 ## CI report: * 53241c7762943233cafc115a929c73a9e4abd878 Azure:

[GitHub] [flink] flinkbot commented on pull request #17952: [FLINK-25011] Introduce vertex parallelism decider and the default implementation.

2021-11-29 Thread GitBox
flinkbot commented on pull request #17952: URL: https://github.com/apache/flink/pull/17952#issuecomment-982357716 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] Airblader commented on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

2021-11-29 Thread GitBox
Airblader commented on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-982357283 @shenzhu My PR was merged now. If you rebase I think those violations should not show up anymore. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on pull request #17952: [FLINK-25011] Introduce vertex parallelism decider and the default implementation.

2021-11-29 Thread GitBox
flinkbot commented on pull request #17952: URL: https://github.com/apache/flink/pull/17952#issuecomment-982356774 ## CI report: * 53241c7762943233cafc115a929c73a9e4abd878 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[jira] [Closed] (FLINK-25047) Resolve most (trivial) architectural violations in flink-table

2021-11-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25047. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Updated] (FLINK-25011) Introduce VertexParallelismDecider

2021-11-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25011: --- Labels: pull-request-available (was: ) > Introduce VertexParallelismDecider >

[GitHub] [flink] twalthr closed pull request #17898: [FLINK-25047][table] Resolve architectural violations

2021-11-29 Thread GitBox
twalthr closed pull request #17898: URL: https://github.com/apache/flink/pull/17898 -- 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] wanglijie95 opened a new pull request #17952: [FLINK-25011] Introduce vertex parallelism decider and the default implementation.

2021-11-29 Thread GitBox
wanglijie95 opened a new pull request #17952: URL: https://github.com/apache/flink/pull/17952 ## What is the purpose of the change Introduce VertexParallelismDecider and default implementation for adaptive batch scheduler. ## Brief change log Introduce

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17749: URL: https://github.com/apache/flink/pull/17749#issuecomment-965029957 ## CI report: * 2ce453d313fcea2e1fae39900e6ba97b7a129246 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[jira] [Commented] (FLINK-24348) Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed"

2021-11-29 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450912#comment-17450912 ] Arvid Heise commented on FLINK-24348: - I have not found out much yesterday. It is a standard Unix

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] ZhijieYang commented on a change in pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
ZhijieYang commented on a change in pull request #17902: URL: https://github.com/apache/flink/pull/17902#discussion_r758982717 ## File path: docs/content.zh/docs/ops/metrics.md ## @@ -28,26 +28,26 @@ under the License. # 指标 -Flink exposes a metric system that allows

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[jira] [Commented] (FLINK-25104) Kafka table source cannot be used as bounded

2021-11-29 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450908#comment-17450908 ] Hang Ruan commented on FLINK-25104: --- I will add stoppingOffsetsInitializer setting in the table

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[jira] [Created] (FLINK-25105) Enables final checkpoint by default

2021-11-29 Thread Yun Gao (Jira)
Yun Gao created FLINK-25105: --- Summary: Enables final checkpoint by default Key: FLINK-25105 URL: https://issues.apache.org/jira/browse/FLINK-25105 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-25105) Enables final checkpoint by default

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-25105: --- Assignee: Yun Gao > Enables final checkpoint by default > --- > >

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17951: [FLINK-25095][table-planner] Fix generateComparison returnType

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17951: URL: https://github.com/apache/flink/pull/17951#issuecomment-982270439 ## CI report: * db68caf8d0edcbc8acb022cd2832d3ba56854eb9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[jira] [Updated] (FLINK-25103) KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A, could you tell me how to store in the six tasks A

2021-11-29 Thread wangbaohua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangbaohua updated FLINK-25103: --- Issue Type: Improvement (was: Bug) > KeyedBroadcastProcessFunction run set 6, parallelism

[jira] [Created] (FLINK-25104) Kafka table source cannot be used as bounded

2021-11-29 Thread Hang Ruan (Jira)
Hang Ruan created FLINK-25104: - Summary: Kafka table source cannot be used as bounded Key: FLINK-25104 URL: https://issues.apache.org/jira/browse/FLINK-25104 Project: Flink Issue Type:

[jira] [Updated] (FLINK-25085) Add a scheduled thread pool in Endpoint and close it when job terminates

2021-11-29 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-25085: Description: Add a dedicated thread pool in Endpoint to schedule tasks that have a long delay such as

[jira] [Updated] (FLINK-25085) Add a scheduled thread pool in Endpoint and close it when job terminates

2021-11-29 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-25085: Summary: Add a scheduled thread pool in Endpoint and close it when job terminates (was: Add a scheduled

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

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

2021-11-29 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r758973297 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

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

2021-11-29 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r758973059 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-978895303 ## CI report: * 8a398a42490ca1ab93a23b93d9e8c3c2abf14670 Azure:

[GitHub] [flink] JasonLeeCoding commented on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

2021-11-29 Thread GitBox
JasonLeeCoding commented on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-982329624 @wuchong please help me take a look on this issue,thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot edited a comment on pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17874: URL: https://github.com/apache/flink/pull/17874#issuecomment-976109395 ## CI report: * 060e52ce536943d38d0acbf1899aecd5e3ac5ed8 Azure:

[jira] [Assigned] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP

2021-11-29 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-25025: Assignee: Huang Xingbo >

[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP

2021-11-29 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450887#comment-17450887 ] Huang Xingbo commented on FLINK-25025: -- Ok. I will take a look. >

[jira] [Created] (FLINK-25103) KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A, could you tell me how to store in the six tasks A

2021-11-29 Thread wangbaohua (Jira)
wangbaohua created FLINK-25103: -- Summary: KeyedBroadcastProcessFunction run set 6, parallelism ValueState variables A, could you tell me how to store in the six tasks A Key: FLINK-25103 URL:

[jira] [Commented] (FLINK-24348) Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed"

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450886#comment-17450886 ] Yun Gao commented on FLINK-24348: - I copied some detailed log found be [~arvid]  in another repeat issue

[jira] [Commented] (FLINK-25088) KafkaSinkITCase failed on azure due to Container did not start correctly

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450885#comment-17450885 ] Yun Gao commented on FLINK-25088: -  Very thanks [~arvid] ! I'll also copy the above detailed log to

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

2021-11-29 Thread GitBox
zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r758968020 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-25102) ParquetFileSystemITCase.testPartialDynamicPartition failed on azure

2021-11-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450881#comment-17450881 ] Jingsong Lee commented on FLINK-25102: -- Thanks [~gaoyunhaii] for reporting, I will take a look~ >

[GitHub] [flink] flinkbot edited a comment on pull request #17939: [FLINK-20370][table] part2: introduce 'table.exec.sink.pk-shuffle' option to auto keyby on sink's pk if parallelism are not the same

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17939: URL: https://github.com/apache/flink/pull/17939#issuecomment-981420515 ## CI report: * 9ccb311aec0b5f0d14197c5de37a171ea15c6097 Azure:

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

2021-11-29 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450880#comment-17450880 ] Wenlong Lyu commented on FLINK-20370: - [~lincoln.86xy] Even sink implements ParallelismProvider,

[GitHub] [flink] MyLanPangzi commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-29 Thread GitBox
MyLanPangzi commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-982321397 @maosuhan This would be a good option for users if it could be converted automatically. like this PbCodegenSimpleDeserializer#codegen ```java if(type

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

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17684: URL: https://github.com/apache/flink/pull/17684#issuecomment-961007710 ## CI report: * 14a1758e9482b8f3319fb39775429d22f7a62b97 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * cd6fdccd8986b45c43d05bde8efc226a8487d139 Azure:

[jira] [Commented] (FLINK-24935) Python module failed to compile due to "Could not create local repository"

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450878#comment-17450878 ] Yun Gao commented on FLINK-24935: -

[jira] [Commented] (FLINK-25102) ParquetFileSystemITCase.testPartialDynamicPartition failed on azure

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450877#comment-17450877 ] Yun Gao commented on FLINK-25102: - Hi [~lzljs3620320] this issue seems to have the same cause with

[GitHub] [flink] maosuhan commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-29 Thread GitBox
maosuhan commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-982317036 @MyLanPangzi Thanks for your feedback. I think it is doable, what about adding a new option like 'protobuf.enum-as-int'? -- This is an automated message from the Apache Git

[jira] [Created] (FLINK-25102) ParquetFileSystemITCase.testPartialDynamicPartition failed on azure

2021-11-29 Thread Yun Gao (Jira)
Yun Gao created FLINK-25102: --- Summary: ParquetFileSystemITCase.testPartialDynamicPartition failed on azure Key: FLINK-25102 URL: https://issues.apache.org/jira/browse/FLINK-25102 Project: Flink

[jira] [Comment Edited] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-29 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450876#comment-17450876 ] chenqizhu edited comment on FLINK-25099 at 11/30/21, 6:04 AM: --  [~zuston] 

[jira] [Comment Edited] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-29 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450876#comment-17450876 ] chenqizhu edited comment on FLINK-25099 at 11/30/21, 6:03 AM: --  [~zuston] 

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-29 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450876#comment-17450876 ] chenqizhu commented on FLINK-25099: ---  [~zuston]  This is all the client logs    

[jira] [Updated] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-29 Thread chenqizhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenqizhu updated FLINK-25099: -- Attachment: flink-chenqizhu-client-hdfsn21n163.log > flink on yarn Accessing two HDFS Clusters >

[jira] [Commented] (FLINK-24926) Key group is not in KeyGroupRange when joining two streams with table API

2021-11-29 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450874#comment-17450874 ] Yun Tang commented on FLINK-24926: -- Thanks for the explanation [~lincoln.86xy]. You might need to pick

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

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23047: Affects Version/s: 1.15.0 > CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure >

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

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450872#comment-17450872 ] Yun Gao commented on FLINK-23047: -

[GitHub] [flink] Airblader commented on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

2021-11-29 Thread GitBox
Airblader commented on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-982311002 @shenzhu I'm addressing those in https://github.com/apache/flink/pull/17898. In the meantime for this PR you can add the violations to the file since you're only exposing

[GitHub] [flink] shenzhu commented on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

2021-11-29 Thread GitBox
shenzhu commented on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-982309892 Hey @Airblader , I got some architecture tests failing for this PR, the failing messages are as follows ``` java.lang.AssertionError: Architecture Violation

[jira] [Updated] (FLINK-25101) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed due to CorrelationIdMismatchException

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25101: Summary: FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed due to

[jira] [Updated] (FLINK-25101) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed due to CorrelationIdMismatchException

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25101: Labels: test-stability (was: ) > FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed

[jira] [Created] (FLINK-25101) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed due to

2021-11-29 Thread Yun Gao (Jira)
Yun Gao created FLINK-25101: --- Summary: FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed due to Key: FLINK-25101 URL: https://issues.apache.org/jira/browse/FLINK-25101 Project: Flink

[GitHub] [flink] shenzhu commented on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

2021-11-29 Thread GitBox
shenzhu commented on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-982304022 > Hi @shenzhu I left a couple more comments, but overall the approach is not 100% correct, because it applies the trimming only when casting from string types. It should also

[jira] [Created] (FLINK-25100) RMQSourceITCase failed on azure due to java.io.EOFException

2021-11-29 Thread Yun Gao (Jira)
Yun Gao created FLINK-25100: --- Summary: RMQSourceITCase failed on azure due to java.io.EOFException Key: FLINK-25100 URL: https://issues.apache.org/jira/browse/FLINK-25100 Project: Flink Issue

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

2021-11-29 Thread GitBox
lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r758920274 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

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

2021-11-29 Thread GitBox
lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r758920274 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,653 @@ +/* + * Licensed to the

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

2021-11-29 Thread GitBox
lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r758946526 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,244 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17950: [FLINK-25091] change Official website document "FileSink" orc compression attribute reference error

2021-11-29 Thread GitBox
flinkbot edited a comment on pull request #17950: URL: https://github.com/apache/flink/pull/17950#issuecomment-982256290 ## CI report: * e8633bd19b6636319a85835ad9949754d93a9dbd Azure:

[GitHub] [flink] shenzhu commented on a change in pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

2021-11-29 Thread GitBox
shenzhu commented on a change in pull request #17919: URL: https://github.com/apache/flink/pull/17919#discussion_r758942835 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/StringToBinaryCastRule.java ## @@ -45,6

[jira] [Commented] (FLINK-23390) FlinkKafkaInternalProducerITCase.testResumeTransactionAfterClosed

2021-11-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450859#comment-17450859 ] Yun Gao commented on FLINK-23390: -

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

2021-11-29 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450853#comment-17450853 ] Junfan Zhang commented on FLINK-25099: -- Could you make the log level debug and attach more logs ?

  1   2   3   4   5   6   >