[GitHub] [flink] AHeise commented on a change in pull request #13604: [FLINK-19585][tests] Waiting for job to run before savepointing in UnalignedCheckpointCompatibilityITCase.

2020-10-14 Thread GitBox
AHeise commented on a change in pull request #13604: URL: https://github.com/apache/flink/pull/13604#discussion_r504931519 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java ## @@ -102,6 +116,24 @@ private static

[GitHub] [flink] flinkbot commented on pull request #13642: [task][hotfix] Remove PipelinedSubpartition.addBufferConsumer method

2020-10-14 Thread GitBox
flinkbot commented on pull request #13642: URL: https://github.com/apache/flink/pull/13642#issuecomment-708665953 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-19540) How to reduce or disable checkpoint logs in Flink

2020-10-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214304#comment-17214304 ] Chesnay Schepler commented on FLINK-19540: -- [~jeromexlee] You can also use [log4j

[GitHub] [flink] flinkbot edited a comment on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828 ## CI report: * 1d5b26fb70f7cdc2f562dcc72f6d4b0b0eff716e UNKNOWN * 9c59fc9385d7843f2ba7f818d88c99d6d1450d70 Azure:

[GitHub] [flink] dianfu commented on a change in pull request #13611: [FLINK-19480][python] Support RichFunction in Python DataStream API

2020-10-14 Thread GitBox
dianfu commented on a change in pull request #13611: URL: https://github.com/apache/flink/pull/13611#discussion_r505105967 ## File path: flink-python/pyflink/fn_execution/beam/beam_operations_slow.py ## @@ -162,23 +165,36 @@ def __init__(self, name, spec, counter_factory,

[jira] [Created] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

2020-10-14 Thread Dian Fu (Jira)
Dian Fu created FLINK-19645: --- Summary: ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable Key: FLINK-19645 URL: https://issues.apache.org/jira/browse/FLINK-19645 Project: Flink

[jira] [Updated] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

2020-10-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19645: Labels: test-stability (was: ) > ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is

[jira] [Created] (FLINK-19646) StreamExecutionEnvironment support new Source interface based on FLIP-27

2020-10-14 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-19646: -- Summary: StreamExecutionEnvironment support new Source interface based on FLIP-27 Key: FLINK-19646 URL: https://issues.apache.org/jira/browse/FLINK-19646

[GitHub] [flink] shuiqiangchen commented on a change in pull request #12902: [FLINK-18415][python] Support TableResult#collect in the Python Table…

2020-10-14 Thread GitBox
shuiqiangchen commented on a change in pull request #12902: URL: https://github.com/apache/flink/pull/12902#discussion_r505124256 ## File path: flink-python/src/main/java/org/apache/flink/api/common/python/PythonBridgeUtils.java ## @@ -162,7 +171,42 @@ return

[GitHub] [flink] JingsongLi commented on pull request #13605: [FLINK-19599][table] Introduce BulkFormatFactory to integrate new FileSource to table

2020-10-14 Thread GitBox
JingsongLi commented on pull request #13605: URL: https://github.com/apache/flink/pull/13605#issuecomment-708865098 After discussed with Jark, I think we should try to `EncodingFormatFactory` and `DecodingFormatFactory`.

[jira] [Updated] (FLINK-19651) Support the filter push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19651: -- Summary: Support the filter push down for the Jdbc connector (was: Support filter push down

[GitHub] [flink] danny0405 commented on a change in pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-14 Thread GitBox
danny0405 commented on a change in pull request #13577: URL: https://github.com/apache/flink/pull/13577#discussion_r505141222 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/stream/table/CalcTest.scala ## @@ -114,11 +114,13 @@ class

[jira] [Updated] (FLINK-19650) Support the limit push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19650: -- Parent: FLINK-16987 Issue Type: Sub-task (was: New Feature) > Support the limit push

[jira] [Updated] (FLINK-19647) Support the limit push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19647: -- Parent: FLINK-16987 Issue Type: Sub-task (was: New Feature) > Support the limit push

[GitHub] [flink] dianfu closed pull request #13262: [FLINK-18921][python][doc] Add a SQL link in PyFlink Doc

2020-10-14 Thread GitBox
dianfu closed pull request #13262: URL: https://github.com/apache/flink/pull/13262 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

[jira] [Updated] (FLINK-19647) Support the limit push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19647: -- Summary: Support the limit push down for the hbase connector (was: Support limit push down

[GitHub] [flink] flinkbot edited a comment on pull request #13604: [FLINK-19585][tests] Waiting for job to run before savepointing in UnalignedCheckpointCompatibilityITCase.

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13604: URL: https://github.com/apache/flink/pull/13604#issuecomment-707513688 ## CI report: * 755d9eb83e7fa1f497fe083850ce369d8d1d5940 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13629: [FLINK-19616][tests][parquet] avoid re-generate the protobuf files due to time inconsistency

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13629: URL: https://github.com/apache/flink/pull/13629#issuecomment-708262130 ## CI report: * 548abe1c2b61698e8f8faf397b65864b5e367ed0 Azure:

[GitHub] [flink] flinkbot commented on pull request #13642: [task][hotfix] Remove PipelinedSubpartition.addBufferConsumer method

2020-10-14 Thread GitBox
flinkbot commented on pull request #13642: URL: https://github.com/apache/flink/pull/13642#issuecomment-708668367 ## CI report: * 04f8d715a9a672b0d832e9b9e067294376eae211 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13642: [task][hotfix] Remove PipelinedSubpartition.addBufferConsumer method

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13642: URL: https://github.com/apache/flink/pull/13642#issuecomment-708668367 ## CI report: * 04f8d715a9a672b0d832e9b9e067294376eae211 Azure:

[GitHub] [flink] SteNicholas removed a comment on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

2020-10-14 Thread GitBox
SteNicholas removed a comment on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-708376472 @StephanEwen @aljoscha Could you please help to review this adjust? This is an automated message

[GitHub] [flink] SteNicholas closed pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

2020-10-14 Thread GitBox
SteNicholas closed pull request #13637: URL: https://github.com/apache/flink/pull/13637 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] dianfu commented on pull request #13611: [FLINK-19480][python] Support RichFunction in Python DataStream API

2020-10-14 Thread GitBox
dianfu commented on pull request #13611: URL: https://github.com/apache/flink/pull/13611#issuecomment-708838823 @shuiqiangchen Thanks a lot for the review. Not sure why the tests are not triggered. The tests have passed in my personal azure pipeline:

[GitHub] [flink] flinkbot edited a comment on pull request #13622: [FLINK-19469][hbase] Exclude org.glassfish:javax.el transitive dependency from hbase-2.2 connector as it is unreliable

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13622: URL: https://github.com/apache/flink/pull/13622#issuecomment-708066181 ## CI report: * 116ea43b00eac6494d40cf8349a147ebf958439b Azure:

[jira] [Created] (FLINK-19647) Support limit push down for hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19647: - Summary: Support limit push down for hbase connector Key: FLINK-19647 URL: https://issues.apache.org/jira/browse/FLINK-19647 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * 59af0e9ec80df5072e44576882f8659db631e424 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13299: [FLINK-19072][table-planner] Import Temporal Table join rule for Stream

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13299: URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866 ## CI report: * d142b0a736b24b1d1d714da9c26bf89279e643c8 UNKNOWN * e7f001da22368aed31002c28199b4f97d2a2b63b Azure:

[GitHub] [flink] zentol commented on a change in pull request #13640: [FLINK-19617] Added new metric for monitoring the JVM's Metaspace memory pool usage.

2020-10-14 Thread GitBox
zentol commented on a change in pull request #13640: URL: https://github.com/apache/flink/pull/13640#discussion_r505038358 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java ## @@ -214,6 +216,15 @@ static void

[GitHub] [flink] zentol commented on a change in pull request #13640: [FLINK-19617] Added new metric for monitoring the JVM's Metaspace memory pool usage.

2020-10-14 Thread GitBox
zentol commented on a change in pull request #13640: URL: https://github.com/apache/flink/pull/13640#discussion_r505036909 ## File path: docs/monitoring/metrics.md ## @@ -847,6 +847,8 @@ Thus, in order to infer the metric identifier: ### Memory +The memory-related metrics

[GitHub] [flink] guoweiM commented on a change in pull request #13617: [FLINK-19531] Implement the sink writer operator

2020-10-14 Thread GitBox
guoweiM commented on a change in pull request #13617: URL: https://github.com/apache/flink/pull/13617#discussion_r505089210 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sink/AbstractWriterOperator.java ## @@ -0,0 +1,146 @@ +/* + *

[jira] [Closed] (FLINK-19480) Support RichFunction in Python DataStream API

2020-10-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19480. --- Resolution: Fixed Merged to master via c8938f9e238f8eb05430386d5bc3104b23d6c37c > Support RichFunction in

[GitHub] [flink] dianfu closed pull request #13611: [FLINK-19480][python] Support RichFunction in Python DataStream API

2020-10-14 Thread GitBox
dianfu closed pull request #13611: URL: https://github.com/apache/flink/pull/13611 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] wangxlong closed pull request #13619: [Hotfix][docs][checkstyle] Fix DummyInputFormat class lacks Javadoc

2020-10-14 Thread GitBox
wangxlong closed pull request #13619: URL: https://github.com/apache/flink/pull/13619 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

[jira] [Created] (FLINK-19651) Support filter push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19651: - Summary: Support filter push down for the Jdbc connector Key: FLINK-19651 URL: https://issues.apache.org/jira/browse/FLINK-19651 Project: Flink Issue

[jira] [Updated] (FLINK-19649) In Flink's module flink-sql-parser/sqlCreateTable/unparse, the tables without columns are not supported.

2020-10-14 Thread gsralex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gsralex updated FLINK-19649: Description: In Flink's module flink-sql-parser, the sqlCreateTable.class unparse method The create

[jira] [Created] (FLINK-19650) Support the limit push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19650: - Summary: Support the limit push down for the Jdbc connector Key: FLINK-19650 URL: https://issues.apache.org/jira/browse/FLINK-19650 Project: Flink Issue

[jira] [Commented] (FLINK-19384) Source API exception signatures are inconsistent

2020-10-14 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214242#comment-17214242 ] Stephan Ewen commented on FLINK-19384: -- The Josh Bloch guide is what I try to follow in Flink's

[GitHub] [flink] flinkbot edited a comment on pull request #13604: [FLINK-19585][tests] Waiting for job to run before savepointing in UnalignedCheckpointCompatibilityITCase.

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13604: URL: https://github.com/apache/flink/pull/13604#issuecomment-707513688 ## CI report: * 755d9eb83e7fa1f497fe083850ce369d8d1d5940 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [WIP][FLINK-17760][tests] Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * fef9bff28a988ffab789fc6bb0cbde754273a2e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828 ## CI report: * 4722a51a254a14cfec5a968214ca473de32179cb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13642: [task][hotfix] Remove PipelinedSubpartition.addBufferConsumer method

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13642: URL: https://github.com/apache/flink/pull/13642#issuecomment-708668367 ## CI report: * 04f8d715a9a672b0d832e9b9e067294376eae211 Azure:

[GitHub] [flink] guoweiM commented on a change in pull request #13617: [FLINK-19531] Implement the sink writer operator

2020-10-14 Thread GitBox
guoweiM commented on a change in pull request #13617: URL: https://github.com/apache/flink/pull/13617#discussion_r505088060 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sink/AbstractWriterOperator.java ## @@ -0,0 +1,146 @@ +/* + *

[GitHub] [flink] guoweiM commented on a change in pull request #13617: [FLINK-19531] Implement the sink writer operator

2020-10-14 Thread GitBox
guoweiM commented on a change in pull request #13617: URL: https://github.com/apache/flink/pull/13617#discussion_r505088576 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/AbstractWriterOperator.java ## @@ -0,0 +1,143 @@ +/*

[GitHub] [flink] dianfu commented on a change in pull request #13611: [FLINK-19480][python] Support RichFunction in Python DataStream API

2020-10-14 Thread GitBox
dianfu commented on a change in pull request #13611: URL: https://github.com/apache/flink/pull/13611#discussion_r505107742 ## File path: flink-python/pyflink/datastream/data_stream.py ## @@ -467,25 +466,26 @@ def partition_custom(self, partitioner: Union[Callable,

[GitHub] [flink] flinkbot edited a comment on pull request #13638: [hotfix][docs]Fix some typos in docs

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13638: URL: https://github.com/apache/flink/pull/13638#issuecomment-708460375 ## CI report: * 3520e47d79c50f5a3c528b7878549e116445fcb4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13617: [FLINK-19531] Implement the sink writer operator

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13617: URL: https://github.com/apache/flink/pull/13617#issuecomment-707791817 ## CI report: * 915e1ba014404cbbccbe49af1e86229fbca107ec UNKNOWN * 165ea9806e660d4f8fc6de0e93de9a38c9353fc2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13636: [FLINK-19641][hive] Optimize parallelism calculating of HiveTableSource by checking file number

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13636: URL: https://github.com/apache/flink/pull/13636#issuecomment-708378225 ## CI report: * 37a21996231887c5d5b7227d0c38ab07612f3209 Azure:

[jira] [Updated] (FLINK-19646) StreamExecutionEnvironment support new Source interface based on FLIP-27

2020-10-14 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19646: --- Priority: Minor (was: Major) > StreamExecutionEnvironment support new Source interface

[jira] [Updated] (FLINK-19647) Support limit push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19647: -- Summary: Support limit push down for the hbase connector (was: Support limit push down for

[jira] [Created] (FLINK-19648) Support nested projection push down for hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-19648: - Summary: Support nested projection push down for hbase connector Key: FLINK-19648 URL: https://issues.apache.org/jira/browse/FLINK-19648 Project: Flink

[jira] [Closed] (FLINK-18921) Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" -> "Table API" section

2020-10-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18921. --- Resolution: Fixed Merged to 1.12 via 9f0650f5e6e3cb18dbc20a8af9e4492c85f72bb5 > Add a "SQL" link (linked

[GitHub] [flink] gaoyunhaii commented on pull request #13629: [FLINK-19616][tests][parquet] avoid re-generate the protobuf files due to time inconsistency

2020-10-14 Thread GitBox
gaoyunhaii commented on pull request #13629: URL: https://github.com/apache/flink/pull/13629#issuecomment-708875979 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] stevenzwu commented on a change in pull request #13617: [FLINK-19531] Implement the sink writer operator

2020-10-14 Thread GitBox
stevenzwu commented on a change in pull request #13617: URL: https://github.com/apache/flink/pull/13617#discussion_r504999762 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sink/AbstractWriterOperator.java ## @@ -0,0 +1,146 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #13622: [FLINK-19469][hbase] Exclude org.glassfish:javax.el transitive dependency from hbase-2.2 connector as it is unreliable

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13622: URL: https://github.com/apache/flink/pull/13622#issuecomment-708066181 ## CI report: * 116ea43b00eac6494d40cf8349a147ebf958439b Azure:

[GitHub] [flink] stevenzwu commented on a change in pull request #13617: [FLINK-19531] Implement the sink writer operator

2020-10-14 Thread GitBox
stevenzwu commented on a change in pull request #13617: URL: https://github.com/apache/flink/pull/13617#discussion_r505019969 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/AbstractWriterOperator.java ## @@ -0,0 +1,143 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828 ## CI report: * 4722a51a254a14cfec5a968214ca473de32179cb Azure:

[jira] [Commented] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

2020-10-14 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214390#comment-17214390 ] Yingjie Cao commented on FLINK-19645: - >From the stack, we can see that the root cause is Akka RPC

[jira] [Updated] (FLINK-19648) Support the nested projection push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19648: -- Parent: FLINK-16987 Issue Type: Sub-task (was: New Feature) > Support the nested

[jira] [Updated] (FLINK-19648) Support nested projection push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19648: -- Summary: Support nested projection push down for the hbase connector (was: Support nested

[GitHub] [flink] danny0405 commented on a change in pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-14 Thread GitBox
danny0405 commented on a change in pull request #13577: URL: https://github.com/apache/flink/pull/13577#discussion_r505141774 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala ## @@ -2679,15 +2679,15 @@

[jira] [Updated] (FLINK-18921) Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" -> "Table API" section

2020-10-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18921: Component/s: API / Python > Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" ->

[jira] [Updated] (FLINK-18921) Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" -> "Table API" section

2020-10-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18921: Fix Version/s: 1.12.0 > Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> >

[jira] [Updated] (FLINK-19648) Support the nested projection push down for the hbase connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19648: -- Summary: Support the nested projection push down for the hbase connector (was: Support

[GitHub] [flink] curcur commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-14 Thread GitBox
curcur commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r504675916 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLength.java ## @@ -0,0 +1,120 @@ +/*

[GitHub] [flink] curcur commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-14 Thread GitBox
curcur commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r504675916 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLength.java ## @@ -0,0 +1,120 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #13299: [FLINK-19072][table-planner] Import Temporal Table join rule for Stream

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13299: URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866 ## CI report: * d142b0a736b24b1d1d714da9c26bf89279e643c8 UNKNOWN * e7f001da22368aed31002c28199b4f97d2a2b63b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13599: [FLINK-19459] Run certain maven-enforcer-plugin executions only in release profile

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13599: URL: https://github.com/apache/flink/pull/13599#issuecomment-707258177 ## CI report: * a419bd7f170482789f5e3c0bb0d279cc9fdf8244 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13560: [FLINK-19518] Show proper job duration for running jobs in web ui

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13560: URL: https://github.com/apache/flink/pull/13560#issuecomment-705391015 ## CI report: * 5000a1737c880c9b7fab1fcbca0a414d4881b891 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13640: [FLINK-19617] Added new metric for monitoring the JVM's Metaspace memory pool usage.

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13640: URL: https://github.com/apache/flink/pull/13640#issuecomment-708477385 ## CI report: * c295945375d779e056cd2503b878c5ea6544a7a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13639: [FLINK-19237] Fix rejected slot offer bug in JobMaster

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13639: URL: https://github.com/apache/flink/pull/13639#issuecomment-708476237 ## CI report: * 4bac1d3f88930c269cab61688034af64b0f20a10 Azure:

[GitHub] [flink] rkhachatryan opened a new pull request #13642: [task][hotfix] Remove PipelinedSubpartition.addBufferConsumer method

2020-10-14 Thread GitBox
rkhachatryan opened a new pull request #13642: URL: https://github.com/apache/flink/pull/13642 ## What is the purpose of the change *Remove duplicated `PipelinedSubpartition.addBufferConsumer` method and use `PipelinedSubpartition.add()` instead.* ## Verifying this change

[GitHub] [flink] flinkbot edited a comment on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828 ## CI report: * 4722a51a254a14cfec5a968214ca473de32179cb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-708397828 ## CI report: * 1d5b26fb70f7cdc2f562dcc72f6d4b0b0eff716e UNKNOWN * 9c59fc9385d7843f2ba7f818d88c99d6d1450d70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13617: [FLINK-19531] Implement the sink writer operator

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13617: URL: https://github.com/apache/flink/pull/13617#issuecomment-707791817 ## CI report: * 915e1ba014404cbbccbe49af1e86229fbca107ec UNKNOWN * 8de03dc540d21d631f2f606c5c4612d3e7937ad9 Azure:

[jira] [Commented] (FLINK-19202) HadoopS3FileSystemITCase.testSimpleFileWriteAndRead failed with "FileNotFoundException: No such file or directory: s3://***/temp/tests-7ebc11df-9160-4403-85a7-c484da44

2020-10-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214370#comment-17214370 ] Dian Fu commented on FLINK-19202: - Another instance:

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * 59af0e9ec80df5072e44576882f8659db631e424 UNKNOWN *

[jira] [Commented] (FLINK-19633) Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction

2020-10-14 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214374#comment-17214374 ] dalongliu commented on FLINK-19633: --- I can try it. > Fix ArrayIndexOutOfBoundsException in

[GitHub] [flink] flinkbot edited a comment on pull request #13492: [FLINK-19181][python] Make python processes respect the calculated managed memory fraction

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13492: URL: https://github.com/apache/flink/pull/13492#issuecomment-699626263 ## CI report: * af73558800083e341dcd9c89819cd00b0572696b UNKNOWN * 59af0e9ec80df5072e44576882f8659db631e424 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13299: [FLINK-19072][table-planner] Import Temporal Table join rule for Stream

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13299: URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866 ## CI report: * d142b0a736b24b1d1d714da9c26bf89279e643c8 UNKNOWN * e7f001da22368aed31002c28199b4f97d2a2b63b Azure:

[GitHub] [flink] danny0405 commented on a change in pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-14 Thread GitBox
danny0405 commented on a change in pull request #13577: URL: https://github.com/apache/flink/pull/13577#discussion_r505135126 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala ## @@ -40,12 +44,19 @@

[GitHub] [flink] danny0405 commented on a change in pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-14 Thread GitBox
danny0405 commented on a change in pull request #13577: URL: https://github.com/apache/flink/pull/13577#discussion_r505135294 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala ## @@ -372,6 +373,9

[jira] [Closed] (FLINK-19642) RocksDBListStatePerformanceTest.testRocksDbListStateAPIs is instable

2020-10-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19642. --- Resolution: Won't Fix Thanks [~yunta], I noticed that FLINK-18373 is already merged which has removed the

[GitHub] [flink] dianfu commented on pull request #13622: [FLINK-19469][hbase] Exclude org.glassfish:javax.el transitive dependency from hbase-2.2 connector as it is unreliable

2020-10-14 Thread GitBox
dianfu commented on pull request #13622: URL: https://github.com/apache/flink/pull/13622#issuecomment-708801267 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-19651) Support filter push down for the Jdbc connector

2020-10-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-19651: -- Parent: FLINK-16987 Issue Type: Sub-task (was: New Feature) > Support filter push

[GitHub] [flink] flinkbot commented on pull request #13643: [Hotfix][CheckStyle][Min] Fix DummyInputFormat class lacks Javadoc

2020-10-14 Thread GitBox
flinkbot commented on pull request #13643: URL: https://github.com/apache/flink/pull/13643#issuecomment-708870329 ## CI report: * bf793887fbcc0b4f83cc76eb0565833476da0348 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-19540) How to reduce or disable checkpoint logs in Flink

2020-10-14 Thread Xinhao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214248#comment-17214248 ] Xinhao Li commented on FLINK-19540: --- Thanks! I will give a try. Close the ticket for now.  > How to

[jira] [Closed] (FLINK-19540) How to reduce or disable checkpoint logs in Flink

2020-10-14 Thread Xinhao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinhao Li closed FLINK-19540. - Resolution: Resolved > How to reduce or disable checkpoint logs in Flink >

[GitHub] [flink] SteNicholas commented on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

2020-10-14 Thread GitBox
SteNicholas commented on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-708686284 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] shuiqiangchen commented on pull request #13611: [FLINK-19480][python] Support RichFunction in Python DataStream API

2020-10-14 Thread GitBox
shuiqiangchen commented on pull request #13611: URL: https://github.com/apache/flink/pull/13611#issuecomment-708838133 @dianfu Thank you for you clarification. The PR looks good to me now. +1 This is an automated message

[jira] [Updated] (FLINK-19644) Support read specific partition of Hive table in temporal join

2020-10-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19644: - Fix Version/s: 1.12.0 > Support read specific partition of Hive table in temporal join >

[jira] [Assigned] (FLINK-19644) Support read specific partition of Hive table in temporal join

2020-10-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19644: Assignee: Leonard Xu > Support read specific partition of Hive table in temporal join >

[jira] [Updated] (FLINK-19646) StreamExecutionEnvironment support new Source interface based on FLIP-27

2020-10-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19646: Priority: Major (was: Minor) > StreamExecutionEnvironment support new Source interface based on FLIP-27

[GitHub] [flink] danny0405 commented on a change in pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-14 Thread GitBox
danny0405 commented on a change in pull request #13577: URL: https://github.com/apache/flink/pull/13577#discussion_r505133379 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/calcite/schema/Statistic.java ## @@ -0,0 +1,73 @@ +/* + * Licensed to the

[GitHub] [flink] SteNicholas commented on pull request #13637: [FLINK-19494][DataStream API] Adjust StreamExecutionEnvironment.generateSequence() to new API Sources

2020-10-14 Thread GitBox
SteNicholas commented on pull request #13637: URL: https://github.com/apache/flink/pull/13637#issuecomment-708861482 @StephanEwen @aljoscha Could you please help to review this adjust? This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #13636: [FLINK-19641][hive] Optimize parallelism calculating of HiveTableSource by checking file number

2020-10-14 Thread GitBox
flinkbot edited a comment on pull request #13636: URL: https://github.com/apache/flink/pull/13636#issuecomment-708378225 ## CI report: * 37a21996231887c5d5b7227d0c38ab07612f3209 Azure:

[GitHub] [flink] wangxlong opened a new pull request #13643: [Hotfix][CheckStyle][Min] Fix DummyInputFormat class lacks Javadoc

2020-10-14 Thread GitBox
wangxlong opened a new pull request #13643: URL: https://github.com/apache/flink/pull/13643 ## What is the purpose of the change Fix DummyInputFormat class lacks Javadoc ## Brief change log Add Javadoc to DummyInputFormat class ## Verifying this change

[GitHub] [flink] curcur commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-14 Thread GitBox
curcur commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r504675916 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLength.java ## @@ -0,0 +1,120 @@ +/*

[jira] [Created] (FLINK-19649) In Flink's module flink-sql-parser/sqlCreateTable/unparse, the tables without columns are not supported.

2020-10-14 Thread gsralex (Jira)
gsralex created FLINK-19649: --- Summary: In Flink's module flink-sql-parser/sqlCreateTable/unparse, the tables without columns are not supported. Key: FLINK-19649 URL: https://issues.apache.org/jira/browse/FLINK-19649

[GitHub] [flink] scottxusayhi removed a comment on pull request #13555: [FLINK-17613][e2e][k8s] Test against multiple k8s versions

2020-10-14 Thread GitBox
scottxusayhi removed a comment on pull request #13555: URL: https://github.com/apache/flink/pull/13555#issuecomment-708233139 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] curcur commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

2020-10-14 Thread GitBox
curcur commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r504675916 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLength.java ## @@ -0,0 +1,120 @@ +/*

  1   2   3   4   5   6   >