[GitHub] [flink] flinkbot edited a comment on pull request #17565: [FLINK-24630][avro] Implement row projection in AvroToRowDataConverters#createRowConverter

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17565: URL: https://github.com/apache/flink/pull/17565#issuecomment-951613012 ## CI report: * f0044e576bc1f41a9319196b69eee89dfe0c91e4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17565: [FLINK-24630][avro] Implement row projection in AvroToRowDataConverters#createRowConverter

2021-10-25 Thread GitBox
flinkbot commented on pull request #17565: URL: https://github.com/apache/flink/pull/17565#issuecomment-951614124 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 pro

[GitHub] [flink] flinkbot commented on pull request #17565: [FLINK-24630][avro] Implement row projection in AvroToRowDataConverters#createRowConverter

2021-10-25 Thread GitBox
flinkbot commented on pull request #17565: URL: https://github.com/apache/flink/pull/17565#issuecomment-951613012 ## CI report: * f0044e576bc1f41a9319196b69eee89dfe0c91e4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-24630) Implement row projection in AvroToRowDataConverters#createRowConverter

2021-10-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24630: --- Labels: pull-request-available (was: ) > Implement row projection in AvroToRowDataConverter

[GitHub] [flink] tsreaper opened a new pull request #17565: [FLINK-24630][avro] Implement row projection in AvroToRowDataConverters#createRowConverter

2021-10-25 Thread GitBox
tsreaper opened a new pull request #17565: URL: https://github.com/apache/flink/pull/17565 ## What is the purpose of the change Currently `AvroToRowDataConverters#createRowConverter` converts avro records to Flink row data directly without any projection. However users of this metho

[jira] [Commented] (FLINK-22316) Support MODIFY column/constraint/watermark for ALTER TABLE statement

2021-10-25 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434139#comment-17434139 ] Yuepeng Pan commented on FLINK-22316: - Could someone assign this ticket to me ? Than

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22732) Restrict ALTER TABLE from setting empty table options

2021-10-25 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434138#comment-17434138 ] Yuepeng Pan commented on FLINK-22732: - Hi, [~jark], Could you assign this ticket to

[GitHub] [flink] flinkbot edited a comment on pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17537: URL: https://github.com/apache/flink/pull/17537#issuecomment-948566240 ## CI report: * 3f5b75277f82eb706621be280fc7c12dbbbe3060 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24638) Unknown variable or type "org.apache.flink.table.utils.DateTimeUtils"

2021-10-25 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434137#comment-17434137 ] Francesco Guardiani commented on FLINK-24638: - Hi, are you testing with mast

[GitHub] [flink] flinkbot edited a comment on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-942425244 ## CI report: * 24f0a46cdfaecfa1ed2cb51b86f3f8b8acd14527 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17563: [hotfix][flink-connector-jdbc] Removed un-used variable from test fixture

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17563: URL: https://github.com/apache/flink/pull/17563#issuecomment-951350039 ## CI report: * ac1900b42fb04a42e58a297c2e1bef8f66f7f10a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17564: [FLINK-24640] CEIL, FLOOR built-in functions for Timestamp should res…

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17564: URL: https://github.com/apache/flink/pull/17564#issuecomment-951476287 ## CI report: * 6803fe5578e495e0ed28f38a35aa6fa4e6afff1a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2021-10-25 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434129#comment-17434129 ] Gabor Somogyi commented on FLINK-14055: --- Good to see this effort! I think it would

[GitHub] [flink] flinkbot edited a comment on pull request #17563: [hotfix][flink-connector-jdbc] Removed un-used variable from test fixture

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17563: URL: https://github.com/apache/flink/pull/17563#issuecomment-951350039 ## CI report: * ac1900b42fb04a42e58a297c2e1bef8f66f7f10a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17563: [hotfix][flink-connector-jdbc] Removed un-used variable from test fixture

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17563: URL: https://github.com/apache/flink/pull/17563#issuecomment-951350039 ## CI report: * ac1900b42fb04a42e58a297c2e1bef8f66f7f10a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] mans2singh commented on pull request #17563: [hotfix][flink-connector-jdbc] Removed un-used variable from test fixture

2021-10-25 Thread GitBox
mans2singh commented on pull request #17563: URL: https://github.com/apache/flink/pull/17563#issuecomment-951588971 @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 specif

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17556: URL: https://github.com/apache/flink/pull/17556#issuecomment-950605426 ## CI report: * 974ba5b8300fcb03b38a4762f50f246597ce7e92 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17556: URL: https://github.com/apache/flink/pull/17556#issuecomment-950605426 ## CI report: * 974ba5b8300fcb03b38a4762f50f246597ce7e92 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * bb80cf155d7e802f2b486dedf37d6e60dbf0a5d8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * d45a1f76630a03ec6a0efd3d38044ab925ab7533 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * d45a1f76630a03ec6a0efd3d38044ab925ab7533 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17563: [hotfix][flink-connector-jdbc] Removed un-used variable from test fixture

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17563: URL: https://github.com/apache/flink/pull/17563#issuecomment-951350039 ## CI report: * ac1900b42fb04a42e58a297c2e1bef8f66f7f10a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * a8cd28194ad50044279d895a36d08a84da8fb78e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] KarmaGYZ commented on pull request #17533: [FLINK-24541][runtime] Quoting the external resource list in generati…

2021-10-25 Thread GitBox
KarmaGYZ commented on pull request #17533: URL: https://github.com/apache/flink/pull/17533#issuecomment-951534765 @xintongsong Would you like to take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[GitHub] [flink] KarmaGYZ commented on a change in pull request #17533: [FLINK-24541][runtime] Quoting the external resource list in generati…

2021-10-25 Thread GitBox
KarmaGYZ commented on a change in pull request #17533: URL: https://github.com/apache/flink/pull/17533#discussion_r736122468 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessUtils.java ## @@ -128,7 +128,10 @@ public static

[GitHub] [flink] flinkbot edited a comment on pull request #17533: [FLINK-24541][runtime] Quoting the external resource list in generati…

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17533: URL: https://github.com/apache/flink/pull/17533#issuecomment-948396321 ## CI report: * 5d34492f1f5bafd4d725a6740640feac1c2434ea Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17533: [FLINK-24541][runtime] Quoting the external resource list in generati…

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17533: URL: https://github.com/apache/flink/pull/17533#issuecomment-948396321 ## CI report: * 5d34492f1f5bafd4d725a6740640feac1c2434ea Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * cac697f88dd20d6baadf9585f75f46407c6922c9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * cac697f88dd20d6baadf9585f75f46407c6922c9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-web] wsry commented on pull request #476: Add blog post "Sort-Based Blocking Shuffle Implementation in Flink"

2021-10-25 Thread GitBox
wsry commented on pull request #476: URL: https://github.com/apache/flink-web/pull/476#issuecomment-951525415 @infoverload Thanks for the review and feedback. I have updated the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [flink] RocMarshal edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-25 Thread GitBox
RocMarshal edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-948195266 @wuchong I really appreciate it. I make some change based on your suggestions. PTAL. -- This is an automated message from the Apache Git Service. To respond to the

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

2021-10-25 Thread GitBox
RocMarshal commented on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-951520003 Hi, @Airblader , I made some change based on your review comments. Could you help me to check it if you have free time? Thank you very much. -- This is an automated message

[GitHub] [flink-ml] guoweiM commented on a change in pull request #14: [FLINK-8][iteration] Add per-round operator wrappers

2021-10-25 Thread GitBox
guoweiM commented on a change in pull request #14: URL: https://github.com/apache/flink-ml/pull/14#discussion_r735447020 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/perround/PerRoundOperatorWrapper.java ## @@ -0,0 +1,80 @@ +/* + * License

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

2021-10-25 Thread GitBox
RocMarshal removed a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-943132915 Thanks @Airblader @twalthr @wuchong @xccui for the review. I updated it based on your comments. PTAL. Thx. -- This is an automated message from the Apache Git Ser

[GitHub] [flink] RocMarshal commented on a change in pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-10-25 Thread GitBox
RocMarshal commented on a change in pull request #17508: URL: https://github.com/apache/flink/pull/17508#discussion_r736107166 ## File path: docs/data/sql_functions_zh.yml ## @@ -707,11 +707,9 @@ json: - sql: IS JSON [ { VALUE | SCALAR | ARRAY | OBJECT } ] table: STRING

[GitHub] [flink] xmarker commented on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-25 Thread GitBox
xmarker commented on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-951501239 @fapaul OK,I squashed commits and pushed again. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17537: URL: https://github.com/apache/flink/pull/17537#issuecomment-948566240 ## CI report: * Unknown: [CANCELED](TBD) * 3f5b75277f82eb706621be280fc7c12dbbbe3060 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[jira] [Closed] (FLINK-21474) Migrate ParquetTableSource to use DynamicTableSource Interface

2021-10-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-21474. Resolution: Invalid We have FileSystemTableSource now. Parquet as a format. > Migrate ParquetTabl

[GitHub] [flink] flinkbot edited a comment on pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17537: URL: https://github.com/apache/flink/pull/17537#issuecomment-948566240 ## CI report: * Unknown: [CANCELED](TBD) * 3f5b75277f82eb706621be280fc7c12dbbbe3060 UNKNOWN Bot commands The @flinkbot bot supports the fol

[jira] [Commented] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

2021-10-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434082#comment-17434082 ] Ada Wong commented on FLINK-24381: -- So I create a new ticket and PR to add support for

[jira] [Comment Edited] (FLINK-24381) Hidden password value when Flink SQL connector throw exception.

2021-10-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434082#comment-17434082 ] Ada Wong edited comment on FLINK-24381 at 10/26/21, 2:26 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17556: URL: https://github.com/apache/flink/pull/17556#issuecomment-950605426 ## CI report: * 974ba5b8300fcb03b38a4762f50f246597ce7e92 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xuyangzhong commented on pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

2021-10-25 Thread GitBox
xuyangzhong commented on pull request #17537: URL: https://github.com/apache/flink/pull/17537#issuecomment-951496047 @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 speci

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17556: URL: https://github.com/apache/flink/pull/17556#issuecomment-950605426 ## CI report: * 974ba5b8300fcb03b38a4762f50f246597ce7e92 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17556: URL: https://github.com/apache/flink/pull/17556#issuecomment-950605426 ## CI report: * 974ba5b8300fcb03b38a4762f50f246597ce7e92 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24624) Add clean up phase when kubernetes session start failed

2021-10-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434081#comment-17434081 ] Aitozi commented on FLINK-24624: [~wangyang0918] Besides that, I create this issue also

[GitHub] [flink] ruanhang1993 commented on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-10-25 Thread GitBox
ruanhang1993 commented on pull request #17556: URL: https://github.com/apache/flink/pull/17556#issuecomment-951492768 @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 spec

[GitHub] [flink] flinkbot edited a comment on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-942425244 ## CI report: * 915e5f96c182f7ece0b1a5f1ed6452973fff8fa2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-942425244 ## CI report: * 915e5f96c182f7ece0b1a5f1ed6452973fff8fa2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24624) Add clean up phase when kubernetes session start failed

2021-10-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434076#comment-17434076 ] Aitozi commented on FLINK-24624: Thanks for pointing that [~wangyang0918]. I think I can

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-10-25 Thread GitBox
ruanhang1993 commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r736086843 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterExtension.java ## @@ -0,0 +1,215 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #17564: [FLINK-24640] CEIL, FLOOR built-in functions for Timestamp should res…

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17564: URL: https://github.com/apache/flink/pull/17564#issuecomment-951476287 ## CI report: * 6803fe5578e495e0ed28f38a35aa6fa4e6afff1a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17564: [FLINK-24640] CEIL, FLOOR built-in functions for Timestamp should res…

2021-10-25 Thread GitBox
flinkbot commented on pull request #17564: URL: https://github.com/apache/flink/pull/17564#issuecomment-951476874 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 pro

[GitHub] [flink] flinkbot commented on pull request #17564: [FLINK-24640] CEIL, FLOOR built-in functions for Timestamp should res…

2021-10-25 Thread GitBox
flinkbot commented on pull request #17564: URL: https://github.com/apache/flink/pull/17564#issuecomment-951476287 ## CI report: * 6803fe5578e495e0ed28f38a35aa6fa4e6afff1a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-24640) CEIL, FLOOR built-in functions for Timestamp should respect DST

2021-10-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24640: --- Labels: pull-request-available (was: ) > CEIL, FLOOR built-in functions for Timestamp shoul

[GitHub] [flink] snuyanzin opened a new pull request #17564: [FLINK-24640] CEIL, FLOOR built-in functions for Timestamp should res…

2021-10-25 Thread GitBox
snuyanzin opened a new pull request #17564: URL: https://github.com/apache/flink/pull/17564 ## What is the purpose of the change The PR makes `org.apache.flink.table.utils.DateTimeUtils#timestampCeil` and `org.apache.flink.table.utils.DateTimeUtils#timestampFloor` respecting DST

[jira] [Created] (FLINK-24640) CEIL, FLOOR built-in functions for Timestamp should respect DST

2021-10-25 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-24640: --- Summary: CEIL, FLOOR built-in functions for Timestamp should respect DST Key: FLINK-24640 URL: https://issues.apache.org/jira/browse/FLINK-24640 Project: Flink

[jira] [Commented] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

2021-10-25 Thread Padarn Wilson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434053#comment-17434053 ] Padarn Wilson commented on FLINK-19589: --- Sorry I can't make time to do this myself

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 97737102fdbf40713cdb7cb47285a82ece786934 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Closed] (FLINK-24634) Java 11 profile should target JDK 8

2021-10-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24634. Resolution: Fixed master: a392d19ae9f2693e66f73fcf73e5a2940b3dd6d2 > Java 11 profile shou

[GitHub] [flink] zentol merged pull request #17561: [FLINK-24634][build] Make Java 11 target opt-in

2021-10-25 Thread GitBox
zentol merged pull request #17561: URL: https://github.com/apache/flink/pull/17561 -- 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: issues-unsubscr

[jira] [Closed] (FLINK-24018) Remove Scala dependencies from flink-cep/flink-streaming-java

2021-10-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24018. Resolution: Fixed master: dd48d058c6b745f505870836048284a76a23f7cc > Remove Scala depende

[GitHub] [flink] zentol merged pull request #17518: [FLINK-24018][build] Remove Scala dependencies from Java APIs

2021-10-25 Thread GitBox
zentol merged pull request #17518: URL: https://github.com/apache/flink/pull/17518 -- 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: issues-unsubscr

[jira] [Updated] (FLINK-9631) use Files.createDirectories instead of directory.mkdirs

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9631: -- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https://gi

[jira] [Updated] (FLINK-7957) Add MetricGroup#getLogicalScope

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7957: -- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https://gi

[jira] [Updated] (FLINK-24482) KafkaShuffleTestBase.testMetrics fails on Azure

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24482: --- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira Bot|https:

[jira] [Updated] (FLINK-13035) LocalStreamEnvironment shall launch actuall task solts

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13035: --- Labels: auto-unassigned pull-request-available stale-minor (was: auto-unassigned pull-reque

[jira] [Updated] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19589: --- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-12637) Add metrics for floatingBufferUsage and exclusiveBufferUsage for credit based mode

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12637: --- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-8513) Add documentation for connecting to non-AWS S3 endpoints

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8513: -- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https://gi

[jira] [Updated] (FLINK-21441) FlinkKinesisProducer does not forward custom endpoint

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21441: --- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21473: --- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-13259) Typos about "access"

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13259: --- Labels: auto-unassigned pull-request-available stale-minor (was: auto-unassigned pull-reque

[jira] [Updated] (FLINK-20004) UpperLimitExceptionParameter description is misleading

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20004: --- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-21474) Migrate ParquetTableSource to use DynamicTableSource Interface

2021-10-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21474: --- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Created] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

2021-10-25 Thread John Karp (Jira)
John Karp created FLINK-24639: - Summary: Improve assignment of Kinesis shards to subtasks Key: FLINK-24639 URL: https://issues.apache.org/jira/browse/FLINK-24639 Project: Flink Issue Type: Improv

[GitHub] [flink] flinkbot edited a comment on pull request #17562: [FLINK-16206][table-planner] Support JSON_ARRAYAGG

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17562: URL: https://github.com/apache/flink/pull/17562#issuecomment-951200622 ## CI report: * 7a90ad8e577b79b3f68fbed12a5824f6b822c129 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17518: [FLINK-24018][build] Remove Scala dependencies from Java APIs

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17518: URL: https://github.com/apache/flink/pull/17518#issuecomment-946526433 ## CI report: * d5a8ba676046f94bcdb8607231becd051ee4c7db Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17549: URL: https://github.com/apache/flink/pull/17549#issuecomment-949678124 ## CI report: * 5ea492bfda82c87d79bf7ab6fb999f65e8c872ca Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17563: [hotfix][flink-connector-jdbc] Removed un-used variable from test fixture

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17563: URL: https://github.com/apache/flink/pull/17563#issuecomment-951350039 ## CI report: * ac1900b42fb04a42e58a297c2e1bef8f66f7f10a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17563: [hotfix][flink-connector-jdbc] Removed un-used variable from test fixture

2021-10-25 Thread GitBox
flinkbot commented on pull request #17563: URL: https://github.com/apache/flink/pull/17563#issuecomment-951351112 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 pro

[GitHub] [flink] flinkbot commented on pull request #17563: [hotfix][flink-connector-jdbc] Removed un-used variable from test fixture

2021-10-25 Thread GitBox
flinkbot commented on pull request #17563: URL: https://github.com/apache/flink/pull/17563#issuecomment-951350039 ## CI report: * ac1900b42fb04a42e58a297c2e1bef8f66f7f10a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] mans2singh opened a new pull request #17563: [hotfix][flink-connector-jdbc] Removed un-used variable from test fixture

2021-10-25 Thread GitBox
mans2singh opened a new pull request #17563: URL: https://github.com/apache/flink/pull/17563 ## What is the purpose of the change * JdbcTestFixture does not use SELECT_ID_BOOKS variable ## Brief change log * Removed un-used variable ## Verifying this change

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 083a2773e9edc56a79acebb824dec0e424442456 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * e377697fc0cb853615137e934d268650259762f4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 083a2773e9edc56a79acebb824dec0e424442456 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * e377697fc0cb853615137e934d268650259762f4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 083a2773e9edc56a79acebb824dec0e424442456 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 083a2773e9edc56a79acebb824dec0e424442456 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 083a2773e9edc56a79acebb824dec0e424442456 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 083a2773e9edc56a79acebb824dec0e424442456 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23986) Add support for opting-out of Scala

2021-10-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23986: - Release Note: The Java DataSet/-Stream APIs are now independent from Scala and no longer

[jira] [Updated] (FLINK-23986) Add support for opting-out of Scala

2021-10-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23986: - Release Note: The Java DataSet/-Stream APIs are now independent from Scala and no longer

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17549: URL: https://github.com/apache/flink/pull/17549#issuecomment-949678124 ## CI report: * 5c0c45fbb0cc26c41ac386601d0682245ec5b814 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-24638) Unknown variable or type "org.apache.flink.table.utils.DateTimeUtils"

2021-10-25 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-24638: --- Summary: Unknown variable or type "org.apache.flink.table.utils.DateTimeUtils" Key: FLINK-24638 URL: https://issues.apache.org/jira/browse/FLINK-24638 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 083a2773e9edc56a79acebb824dec0e424442456 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-25 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 083a2773e9edc56a79acebb824dec0e424442456 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-24637) Move savepoint disposal operation cache into Dispatcher

2021-10-25 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24637: Summary: Move savepoint disposal operation cache into Dispatcher Key: FLINK-24637 URL: https://issues.apache.org/jira/browse/FLINK-24637 Project: Flink

  1   2   3   4   >