[GitHub] [flink] flinkbot edited a comment on pull request #17642: [hotfix][table-common] Add `DataType#excludeFields`

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17642: URL: https://github.com/apache/flink/pull/17642#issuecomment-957339647 ## CI report: * 777cf600e61be71bd337375fd275f5e0f7d5119a Azure:

[GitHub] [flink] MartijnVisser commented on pull request #17635: [FLINK-24724][buildsystem] Update Sun XML Bind dependencies to latest minor version

2021-11-04 Thread GitBox
MartijnVisser commented on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-960686850 @fapaul `flink-connector-hbase-1.4` pulls `jaxb-impl` in via Hadoop dependencies, which is the same behaviour as currently on master. ``` [INFO]

[jira] [Updated] (FLINK-24719) Update Postgres test dependencies to 0.13.4

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24719: --- Summary: Update Postgres test dependencies to 0.13.4 (was: Update Postgres and Postgress

[jira] [Updated] (FLINK-24724) Update Sun XML Bind dependencies to v3.0.2

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24724: --- Summary: Update Sun XML Bind dependencies to v3.0.2 (was: Update Sun XML Bind dependencies

[jira] [Updated] (FLINK-24715) Update multiple Jackson dependencies to v2.13.0

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24715: --- Summary: Update multiple Jackson dependencies to v2.13.0 (was: Update Jackson to latest

[GitHub] [flink] flinkbot edited a comment on pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17663: URL: https://github.com/apache/flink/pull/17663#issuecomment-959548410 ## CI report: * 7310e043a821d9bb5a58597566284d98df6988cc Azure:

[GitHub] [flink] zentol merged pull request #17608: [FLINK-24550][rpc] Use ContextClassLoader for message deserialization

2021-11-04 Thread GitBox
zentol merged pull request #17608: URL: https://github.com/apache/flink/pull/17608 -- 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] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * 5b8ef0d842c6c865384ef5bc3304666a1de19e2d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 81a2c27c93b3a84b2713f2fc5bb63f2dae5db7a5 Azure:

[jira] [Updated] (FLINK-24740) Update testcontainers dependency to v1.16.2

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24740: --- Summary: Update testcontainers dependency to v1.16.2 (was: Update testcontainers

[GitHub] [flink] MartijnVisser commented on pull request #17646: [FLINK-24740][testinfrastructure] Update testcontainers dependency to the latest version

2021-11-04 Thread GitBox
MartijnVisser commented on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-960691191 @alpreu Thanks for the feedback, I'll do that from now on -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] zhuzhurk closed pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

2021-11-04 Thread GitBox
zhuzhurk closed pull request #15229: URL: https://github.com/apache/flink/pull/15229 -- 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] MartijnVisser edited a comment on pull request #17635: [FLINK-24724][buildsystem] Update Sun XML Bind dependencies to latest minor version

2021-11-04 Thread GitBox
MartijnVisser edited a comment on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-960686850 @fapaul `flink-connector-hbase-1.4` pulls `jaxb-impl` in via Hadoop dependencies, which is the same behaviour as currently on master. ``` [INFO]

[GitHub] [flink] zhuzhurk commented on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

2021-11-04 Thread GitBox
zhuzhurk commented on pull request #15229: URL: https://github.com/apache/flink/pull/15229#issuecomment-960688952 Thanks for reviewing! @tillrohrmann @Thesharing Merging as the CI is green now. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] zentol commented on a change in pull request #17593: [FLINK-24603][e2e] Add test for Scala-free Flink

2021-11-04 Thread GitBox
zentol commented on a change in pull request #17593: URL: https://github.com/apache/flink/pull/17593#discussion_r742752655 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-scala/pom.xml ## @@ -0,0 +1,227 @@ + + +http://maven.apache.org/POM/4.0.0

[GitHub] [flink] flinkbot edited a comment on pull request #17677: [FLINK-24766][table] Ceiling/flooring dates to day returns wrong results

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17677: URL: https://github.com/apache/flink/pull/17677#issuecomment-960677604 ## CI report: * 94ad5ca8987d7eabc59104ea7c9f2d31dd6a5a42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17671: [FLINK-24749][coordination] Reuse CheckpointStatsTracker

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17671: URL: https://github.com/apache/flink/pull/17671#issuecomment-960546813 ## CI report: * a47e00cf36e9b56fd0404fe039c3071908851b42 Azure:

[GitHub] [flink] zentol commented on pull request #17593: [FLINK-24603][e2e] Add test for Scala-free Flink

2021-11-04 Thread GitBox
zentol commented on pull request #17593: URL: https://github.com/apache/flink/pull/17593#issuecomment-960684706 Did you build `flink-dist` recently (as in, since we package Scala separately)? -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] zentol commented on a change in pull request #17593: [FLINK-24603][e2e] Add test for Scala-free Flink

2021-11-04 Thread GitBox
zentol commented on a change in pull request #17593: URL: https://github.com/apache/flink/pull/17593#discussion_r742751165 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkDistribution.java ## @@ -223,6

[GitHub] [flink] zentol commented on a change in pull request #17593: [FLINK-24603][e2e] Add test for Scala-free Flink

2021-11-04 Thread GitBox
zentol commented on a change in pull request #17593: URL: https://github.com/apache/flink/pull/17593#discussion_r742750729 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-scala/src/test/java/org/apache/flink/tests/scala/ScalaFreeITCase.java ## @@ -0,0 +1,130 @@

[GitHub] [flink] flinkbot commented on pull request #17677: [FLINK-24766][table] Ceiling/flooring dates to day returns wrong results

2021-11-04 Thread GitBox
flinkbot commented on pull request #17677: URL: https://github.com/apache/flink/pull/17677#issuecomment-960678271 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #17677: [FLINK-24766][table] Ceiling/flooring dates to day returns wrong results

2021-11-04 Thread GitBox
flinkbot commented on pull request #17677: URL: https://github.com/apache/flink/pull/17677#issuecomment-960677604 ## CI report: * 94ad5ca8987d7eabc59104ea7c9f2d31dd6a5a42 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] dawidwys commented on a change in pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-04 Thread GitBox
dawidwys commented on a change in pull request #17663: URL: https://github.com/apache/flink/pull/17663#discussion_r742748495 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -338,10 +338,13 @@ void

[GitHub] [flink] akalash commented on a change in pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-04 Thread GitBox
akalash commented on a change in pull request #17663: URL: https://github.com/apache/flink/pull/17663#discussion_r742749519 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -338,10 +338,13 @@ void

[jira] [Updated] (FLINK-24766) Ceiling/flooring dates to day return wrong results

2021-11-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24766: Summary: Ceiling/flooring dates to day return wrong results (was: Ceiling/flooring dates

[GitHub] [flink] tsreaper commented on pull request #17672: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

2021-11-04 Thread GitBox
tsreaper commented on pull request #17672: URL: https://github.com/apache/flink/pull/17672#issuecomment-960675682 Hi @Tartarus0zm , thanks for the commit. Although this is a very simple change, it would be better to add some tests reflecting such change both for validating and to

[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * 0f17a159cbb94e1c1caeeba53de096a225b49ad7 Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-04 Thread GitBox
dawidwys commented on a change in pull request #17663: URL: https://github.com/apache/flink/pull/17663#discussion_r742748495 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -338,10 +338,13 @@ void

[jira] [Updated] (FLINK-24766) Ceiling/flooring dates to day return wrong resuls

2021-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24766: --- Labels: pull-request-available (was: ) > Ceiling/flooring dates to day return wrong resuls

[GitHub] [flink] snuyanzin opened a new pull request #17677: [FLINK-24766][table] Ceiling/flooring dates to day returns wrong results

2021-11-04 Thread GitBox
snuyanzin opened a new pull request #17677: URL: https://github.com/apache/flink/pull/17677 ## What is the purpose of the change The PR fixes behavior of the queries like ```sql SELECT CEIL(DATE '2021-11-04' TO DAY) AS `ceil`, FLOOR(DATE '2021-11-04' TO DAY) AS `floor`;

[jira] [Commented] (FLINK-24768) Upgrade Web Frontend to Angular v13 and NG-Zorro v13

2021-11-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438665#comment-17438665 ] Ingo Bürk commented on FLINK-24768: --- I would be careful here and wait for the next minor release.

[GitHub] [flink] flinkbot edited a comment on pull request #17669: [FLINK-24762][table-runtime] Remove agg function: INCR_SUM

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17669: URL: https://github.com/apache/flink/pull/17669#issuecomment-960539323 ## CI report: * c484eb521588d5812ba1dbcd19cf10551c5a14bd Azure:

[GitHub] [flink] akalash commented on a change in pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-04 Thread GitBox
akalash commented on a change in pull request #17663: URL: https://github.com/apache/flink/pull/17663#discussion_r742742833 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -338,10 +338,13 @@ void

[GitHub] [flink] MartijnVisser commented on pull request #11999: [FLINK-14100][jdbc] Added Oracle dialect

2021-11-04 Thread GitBox
MartijnVisser commented on pull request #11999: URL: https://github.com/apache/flink/pull/11999#issuecomment-960660741 @eskabetxe I misread your comment, thanks for the PR! I'll try to find a reviewer for that. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] MartijnVisser removed a comment on pull request #11999: [FLINK-14100][jdbc] Added Oracle dialect

2021-11-04 Thread GitBox
MartijnVisser removed a comment on pull request #11999: URL: https://github.com/apache/flink/pull/11999#issuecomment-960659792 @eskabetxe Could it be that the commit hasn't been pushed yet? The latest commit I see 8ab267b861904c026a6fa30e98d21742c83d9979 from the 8th of March 2020? --

[jira] [Commented] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

2021-11-04 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438663#comment-17438663 ] Liu commented on FLINK-24767: - It seems like that the behavior only happens in batch mode. > A keyBy

[GitHub] [flink] MartijnVisser commented on pull request #11999: [FLINK-14100][jdbc] Added Oracle dialect

2021-11-04 Thread GitBox
MartijnVisser commented on pull request #11999: URL: https://github.com/apache/flink/pull/11999#issuecomment-960659792 @eskabetxe Could it be that the commit hasn't been pushed yet? The latest commit I see 8ab267b861904c026a6fa30e98d21742c83d9979 from the 8th of March 2020? -- This is

[GitHub] [flink] akalash commented on a change in pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-04 Thread GitBox
akalash commented on a change in pull request #17663: URL: https://github.com/apache/flink/pull/17663#discussion_r742739855 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -338,10 +338,13 @@ void

[jira] [Assigned] (FLINK-24762) Remove agg function: INCR_SUM

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-24762: -- Assignee: Shuo Cheng > Remove agg function: INCR_SUM > -

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-04 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r742733725 ## File path: flink-connectors/flink-connector-aws/pom.xml ## @@ -0,0 +1,137 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Closed] (FLINK-24751) flink SQL comile failed cause by: java.lang.StackOverflowError

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-24751. -- Resolution: Not A Problem Great that you've resolved the problem! I'm closing the ticket now.

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * c683b88035514ec2decda77911bb5447f9932a21 Azure:

[GitHub] [flink] XComp commented on a change in pull request #17593: [FLINK-24603][e2e] Add test for Scala-free Flink

2021-11-04 Thread GitBox
XComp commented on a change in pull request #17593: URL: https://github.com/apache/flink/pull/17593#discussion_r742703871 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-scala/src/test/java/org/apache/flink/tests/scala/ScalaFreeITCase.java ## @@ -0,0 +1,130 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 01a4524c33cf83bfa9f75004a5b960529cb8f660 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540 ## CI report: * 8cc41c6ba9b71c1acf31ce4ff196459c9da6c923 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #15229: URL: https://github.com/apache/flink/pull/15229#issuecomment-82978 ## CI report: * d0d0ab65a5e4ac04bcb6f5ec1b440380e52c25e3 Azure:

[jira] [Commented] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

2021-11-04 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438650#comment-17438650 ] Fabian Paul commented on FLINK-24767: - [~guoweima] can you take a look at this? > A keyBy following

[jira] [Updated] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24767: --- Component/s: (was: API / DataStream) > A keyBy following countWindow does not preserve

[jira] [Updated] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

2021-11-04 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24767: Component/s: Runtime / Network > A keyBy following countWindow does not preserve order within the

[GitHub] [flink] alpreu commented on pull request #17646: [FLINK-24740][testinfrastructure] Update testcontainers dependency to the latest version

2021-11-04 Thread GitBox
alpreu commented on pull request #17646: URL: https://github.com/apache/flink/pull/17646#issuecomment-960641784 Thank you for your contribution, the change looks good to me  One small nit, I would prefer the pr/commit message to state the actual bumped version (1.16.2) instead of

[GitHub] [flink] flinkbot commented on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

2021-11-04 Thread GitBox
flinkbot commented on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641609 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #17675: FLINK SQL checkpoint不生效

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17675: URL: https://github.com/apache/flink/pull/17675#issuecomment-960637510 ## CI report: * acaad856ee68422130719bd44cb204da45d130ab Azure:

[GitHub] [flink] eskabetxe commented on pull request #11999: [FLINK-14100][jdbc] Added Oracle dialect

2021-11-04 Thread GitBox
eskabetxe commented on pull request #11999: URL: https://github.com/apache/flink/pull/11999#issuecomment-960641394 I resolved the conflicts and update to new changes introduced in https://issues.apache.org/jira/browse/FLINK-24253 here https://github.com/apache/flink/pull/17676 -- This

[GitHub] [flink] flinkbot commented on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

2021-11-04 Thread GitBox
flinkbot commented on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 01a4524c33cf83bfa9f75004a5b960529cb8f660 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] JingGe commented on a change in pull request #17656: [FLINK-24741]Deprecate FileRecordFormat

2021-11-04 Thread GitBox
JingGe commented on a change in pull request #17656: URL: https://github.com/apache/flink/pull/17656#discussion_r742720425 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/FileSource.java ## @@ -181,12 +178,15 @@ private

[jira] [Commented] (FLINK-14100) Introduce OracleDialect

2021-11-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438641#comment-17438641 ] João Boto commented on FLINK-14100: --- [~MartijnVisser], I create this PR to add this functionality with

[jira] [Assigned] (FLINK-24768) Upgrade Web Frontend to Angular v13 and NG-Zorro v13

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-24768: -- Assignee: Junhan Yang > Upgrade Web Frontend to Angular v13 and NG-Zorro v13 >

[jira] [Assigned] (FLINK-24737) Update outdated web dependencies in flink-runtime-web

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-24737: -- Assignee: Junhan Yang > Update outdated web dependencies in flink-runtime-web >

[GitHub] [flink] eskabetxe opened a new pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

2021-11-04 Thread GitBox
eskabetxe opened a new pull request #17676: URL: https://github.com/apache/flink/pull/17676 ## What is the purpose of the change Add the implementation of the Oracle dialect for JDBC connectors ## Brief change log - Implemented OracleDialect extending AbstractDialect -

[jira] [Updated] (FLINK-18418) document example error

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18418: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Created] (FLINK-24768) Upgrade Web Frontend to Angular v13 and NG-Zorro v13

2021-11-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-24768: -- Summary: Upgrade Web Frontend to Angular v13 and NG-Zorro v13 Key: FLINK-24768 URL: https://issues.apache.org/jira/browse/FLINK-24768 Project: Flink

[jira] [Updated] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18473: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails locally

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

[jira] [Updated] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18478: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-18523) Advance watermark if there is no data in all of the partitions after some time

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18523: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18489) java.lang.ArrayIndexOutOfBoundsException from DataOutputSerializer.write

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18489: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18535) Elasticsearch connector hangs for threads deadlocked

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

[jira] [Updated] (FLINK-18582) Add title anchor link for file event_driven.zh.md

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18582: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18574) DownloadPipelineArtifact failes occasionally

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18574: --- Labels: auto-deprioritized-critical auto-deprioritized-major test-stability (was:

[jira] [Updated] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23525: --- Labels: auto-deprioritized-blocker auto-deprioritized-critical test-stability (was:

[jira] [Updated] (FLINK-18445) Short circuit join condition for lookup join

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18445: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18657) Change semantics of DESCRIBE SELECT statement

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18657: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[GitHub] [flink] flinkbot commented on pull request #17675: FLINK SQL checkpoint不生效

2021-11-04 Thread GitBox
flinkbot commented on pull request #17675: URL: https://github.com/apache/flink/pull/17675#issuecomment-960637510 ## CI report: * acaad856ee68422130719bd44cb204da45d130ab UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-18601) TaskManager shut down often in standalone cluster

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18601: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[GitHub] [flink] flinkbot edited a comment on pull request #17668: [FLINK-24401][runtime] Fix the bug of TM cannot exit after Metaspace OOM

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17668: URL: https://github.com/apache/flink/pull/17668#issuecomment-960521098 ## CI report: * daf34569f403cfe2a87b0f117a0a97d2653cdd1c Azure:

[jira] [Updated] (FLINK-18983) Job doesn't changed to failed if close function has blocked

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

[jira] [Updated] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format

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

[GitHub] [flink] flinkbot commented on pull request #17675: FLINK SQL checkpoint不生效

2021-11-04 Thread GitBox
flinkbot commented on pull request #17675: URL: https://github.com/apache/flink/pull/17675#issuecomment-960636604 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-24737) Update outdated web dependencies in flink-runtime-web

2021-11-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438622#comment-17438622 ] Martijn Visser commented on FLINK-24737: Sounds good. I'll make a new Jira for updating the

[GitHub] [flink] fanghj opened a new pull request #17675: FLINK SQL checkpoint不生效

2021-11-04 Thread GitBox
fanghj opened a new pull request #17675: URL: https://github.com/apache/flink/pull/17675 flink版本 1.13 cdc 版本 2.02 配置文件 flink-conf.yaml 设置如下 state.backend: filesystem state.checkpoints.dir: file:///tmp/flink-checkpoints state.savepoints.dir:

[jira] [Assigned] (FLINK-24738) Fail during announcing buffer size to released local channel

2021-11-04 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-24738: - Assignee: Anton Kalashnikov > Fail during announcing buffer size to released

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17670: URL: https://github.com/apache/flink/pull/17670#issuecomment-960539433 ## CI report: * dde91e1cf145a36e329a88159e53eac00b453d6c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17666: URL: https://github.com/apache/flink/pull/17666#issuecomment-960514675 ## CI report: * 52c5a34f17c5f2ec50f0e0c6326df1022cc98f4d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17674: URL: https://github.com/apache/flink/pull/17674#issuecomment-960623713 ## CI report: * 5ecbaae9efe02bb52c058d99ec3043f26ecea021 Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-04 Thread GitBox
dawidwys commented on a change in pull request #17663: URL: https://github.com/apache/flink/pull/17663#discussion_r742701577 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -338,10 +338,13 @@ void

[GitHub] [flink] flinkbot commented on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist

2021-11-04 Thread GitBox
flinkbot commented on pull request #17674: URL: https://github.com/apache/flink/pull/17674#issuecomment-960623713 ## CI report: * 5ecbaae9efe02bb52c058d99ec3043f26ecea021 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * Unknown: [CANCELED](TBD) * 0f17a159cbb94e1c1caeeba53de096a225b49ad7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 9ef85b7ce0c52befc9a195c19b24fb921b1df74f Azure:

[GitHub] [flink] flinkbot commented on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist

2021-11-04 Thread GitBox
flinkbot commented on pull request #17674: URL: https://github.com/apache/flink/pull/17674#issuecomment-960621922 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] [Updated] (FLINK-24755) sun.misc doesn't exist

2021-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24755: --- Labels: pull-request-available (was: ) > sun.misc doesn't exist > -- >

[GitHub] [flink] Aitozi opened a new pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist

2021-11-04 Thread GitBox
Aitozi opened a new pull request #17674: URL: https://github.com/apache/flink/pull/17674 ## What is the purpose of the change Add guidance to solve the package sun.misc does not exist -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 9ef85b7ce0c52befc9a195c19b24fb921b1df74f Azure:

[jira] [Commented] (FLINK-24746) Alibaba maven mirror is unstable

2021-11-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438609#comment-17438609 ] Chesnay Schepler commented on FLINK-24746: -- I will setup a nexus instance on each machine,

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-04 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r742695413 ## File path: flink-connectors/flink-connector-aws/src/test/java/org/apache/flink/connector/kinesis/sink/KinesisDataStreamsSinkITCase.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17663: URL: https://github.com/apache/flink/pull/17663#issuecomment-959548410 ## CI report: * 7310e043a821d9bb5a58597566284d98df6988cc Azure:

[GitHub] [flink] echauchot commented on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-04 Thread GitBox
echauchot commented on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-960615936 > > > > > @echauchot > > > > > > Sure, I saw the comments about split and data types etc... But I feel unconfortable about draft PRs because they usually cannot be merged

[GitHub] [flink] flinkbot edited a comment on pull request #17578: [FLINK-24208][rest] Support user-supplied Savepoint triggerId

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17578: URL: https://github.com/apache/flink/pull/17578#issuecomment-952731483 ## CI report: * 639b420be63844073345b89063cba258cc652f23 Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-04 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r742693530 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AwsV2Util.java ## @@ -130,7

[GitHub] [flink] flinkbot edited a comment on pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17663: URL: https://github.com/apache/flink/pull/17663#issuecomment-959548410 ## CI report: * 7310e043a821d9bb5a58597566284d98df6988cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17578: [FLINK-24208][rest] Support user-supplied Savepoint triggerId

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17578: URL: https://github.com/apache/flink/pull/17578#issuecomment-952731483 ## CI report: * 639b420be63844073345b89063cba258cc652f23 Azure:

<    1   2   3   4   5   6   7   8   >