huwh commented on PR #22686:
URL: https://github.com/apache/flink/pull/22686#issuecomment-1592415971
@Thesharing, do you have any recommendations or concerns? I'd like to merge
this so I can continue working on https://github.com/apache/flink/pull/22674.
--
This is an automated
snuyanzin opened a new pull request, #60:
URL: https://github.com/apache/flink-connector-jdbc/pull/60
By default it inherints `flink.forkCountITCase` == 2 from flink.
The PR sets it to 1
it looks sqlserver container has issues with starting in several surefire
forks...
Based on
fredia commented on code in PR #22744:
URL: https://github.com/apache/flink/pull/22744#discussion_r1230401732
##
flink-tests/src/test/java/org/apache/flink/test/state/ChangelogCompatibilityITCase.java:
##
@@ -169,18 +160,32 @@ private String tryCheckpointAndStop(JobGraph
fredia commented on code in PR #22744:
URL: https://github.com/apache/flink/pull/22744#discussion_r1230394122
##
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java:
##
@@ -375,6 +378,49 @@ public
Tartarus0zm commented on code in PR #22344:
URL: https://github.com/apache/flink/pull/22344#discussion_r1230400637
##
flink-core/src/main/java/org/apache/flink/core/execution/JobStatusHook.java:
##
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package
link3280 commented on PR #19798:
URL: https://github.com/apache/flink/pull/19798#issuecomment-1592254363
I think we have a good reason to consider it as a bug: pyflink uses `#` as a
separator in the configurations (e.g.
[
https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732625#comment-17732625
]
chenyuexin edited comment on FLINK-32341 at 6/15/23 2:32 AM:
-
I submitting
flinkbot commented on PR #22785:
URL: https://github.com/apache/flink/pull/22785#issuecomment-1592173099
## CI report:
* 7ab91efe41ee1acc9ac984d58f275efe830fe046 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32259:
---
Labels: pull-request-available (was: )
> Add ARRAY_JOIN support in SQL & Table API
>
hanyuzheng7 opened a new pull request, #22785:
URL: https://github.com/apache/flink/pull/22785
## What is the purpose of the change
This is an implementation of ARRAY_JOIN
## Brief change log
Returns a string that represents the concatenation of the elements in the
given
[
https://issues.apache.org/jira/browse/FLINK-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo closed FLINK-31233.
--
Resolution: Fixed
> no error should be logged when retrieving the task manager's stdout if it
>
[
https://issues.apache.org/jira/browse/FLINK-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732803#comment-17732803
]
Yangze Guo commented on FLINK-31233:
master: c418b57870aaf5b4f4f9d0f69a70366b583ae166
KarmaGYZ merged PR #22137:
URL: https://github.com/apache/flink/pull/22137
--
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:
[
https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732799#comment-17732799
]
wgcn edited comment on FLINK-32319 at 6/14/23 11:26 PM:
Hi~[~Wencong Liu],I
[
https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732799#comment-17732799
]
wgcn commented on FLINK-32319:
--
Hi~[~Wencong Liu],I Increased taskmanager.network.request-backoff.max to
becketqin commented on code in PR #22509:
URL: https://github.com/apache/flink/pull/22509#discussion_r1230258326
##
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java:
##
@@ -231,6 +231,27 @@ public class YarnConfigOptions {
dependabot[bot] opened a new pull request, #33:
URL: https://github.com/apache/flink-connector-kafka/pull/33
Bumps [guava](https://github.com/google/guava) from 30.1.1-jre to 32.0.0-jre.
Release notes
Sourced from https://github.com/google/guava/releases;>guava's releases.
dependabot[bot] opened a new pull request, #79:
URL: https://github.com/apache/flink-connector-aws/pull/79
Bumps [guava](https://github.com/google/guava) from 29.0-jre to 32.0.0-jre.
Release notes
Sourced from https://github.com/google/guava/releases;>guava's releases.
ferenc-csaky opened a new pull request, #12:
URL: https://github.com/apache/flink-connector-hbase/pull/12
Currently, the `hbase-1.4` connector test fails, cause the CP is messed up,
but I need to track that down. There is room for improvement in the test setup,
but Junit 5 does not allow
flinkbot commented on PR #22784:
URL: https://github.com/apache/flink/pull/22784#issuecomment-1592076213
## CI report:
* 23140c38ebec878824e1d8cee4c7fbedbf7d9f94 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22783:
URL: https://github.com/apache/flink/pull/22783#issuecomment-1592072115
## CI report:
* 1fab531a76de8724103ecfc521f2ae64a7cf01ca UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] opened a new pull request, #22784:
URL: https://github.com/apache/flink/pull/22784
Bumps [guava](https://github.com/google/guava) from 27.0.1-jre to 32.0.0-jre.
Release notes
Sourced from https://github.com/google/guava/releases;>guava's releases.
32.0.0
dependabot[bot] opened a new pull request, #22783:
URL: https://github.com/apache/flink/pull/22783
Bumps [guava](https://github.com/google/guava) from 27.0.1-jre to 32.0.0-jre.
Release notes
Sourced from https://github.com/google/guava/releases;>guava's releases.
32.0.0
ColtenP commented on PR #22782:
URL: https://github.com/apache/flink/pull/22782#issuecomment-1592058741
@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 specific comment.
flinkbot commented on PR #22782:
URL: https://github.com/apache/flink/pull/22782#issuecomment-1591930074
## CI report:
* 481b4232b1e1fa4bdc4aa0874e9887b01918528c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732746#comment-17732746
]
Colten Pilgreen commented on FLINK-32034:
-
[~dianfu] -
ColtenP commented on PR #22782:
URL: https://github.com/apache/flink/pull/22782#issuecomment-1591923753
@dianfu - Here is the request to fix the reported issue
[FLINK-32034](https://issues.apache.org/jira/browse/FLINK-32034).
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32034:
---
Labels: pull-request-available (was: )
> Python's DistUtils is deprecated as of 3.10
>
ColtenP opened a new pull request, #22782:
URL: https://github.com/apache/flink/pull/22782
## What is the purpose of the change
Distutils is deprecated in pythons version 3.10 and above, this script
provides the same functionality and works with all the supported python version
of
[
https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732731#comment-17732731
]
Colten Pilgreen commented on FLINK-32034:
-
[~dianfu] - Yep, I sure can do that. PR incoming
StefanRRichter merged PR #22771:
URL: https://github.com/apache/flink/pull/22771
--
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:
[
https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732625#comment-17732625
]
chenyuexin commented on FLINK-32341:
I submitting the official example demo job by standalone
[
https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732620#comment-17732620
]
chenyuexin commented on FLINK-32341:
I submitting the official example demo job by standalone
[ https://issues.apache.org/jira/browse/FLINK-32341 ]
chenyuexin deleted comment on FLINK-32341:
was (Author: JIRAUSER295713):
I submitting the official example demo job by standalone deployment, the start
shell commands for JM and TM are as
[
https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732611#comment-17732611
]
Chesnay Schepler edited comment on FLINK-32341 at 6/14/23 4:24 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732611#comment-17732611
]
Chesnay Schepler commented on FLINK-32341:
--
What kind of job are you submitting? I'm reasonable
flinkbot commented on PR #22781:
URL: https://github.com/apache/flink/pull/22781#issuecomment-1591559680
## CI report:
* 128d74698093146bbb385715c0866a0fb1d335a6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32341:
---
Labels: pull-request-available (was: )
> Fix resource requirements rest API response
chachae opened a new pull request, #22781:
URL: https://github.com/apache/flink/pull/22781
link to [FLINK-32341](https://issues.apache.org/jira/browse/FLINK-32341)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
chenyuexin created FLINK-32341:
--
Summary: Fix resource requirements rest API response empty result
Key: FLINK-32341
URL: https://issues.apache.org/jira/browse/FLINK-32341
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergii Nazarov updated FLINK-32340:
---
Description:
Prerequisites:
* Deployment via Apache Flink Kubernetes operator with version
hanyuzheng7 commented on PR #22717:
URL: https://github.com/apache/flink/pull/22717#issuecomment-1591459045
@snuyanzin Do you think it is ok for merge now?
--
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
hanyuzheng7 commented on PR #22717:
URL: https://github.com/apache/flink/pull/22717#issuecomment-1591455480
Hi, @snuyanzin. Thank you for your comments. As first PR, thank you for your
help, and let learn a lot.
--
This is an automated message from the Apache Git Service.
To respond to
hanyuzheng7 commented on PR #22717:
URL: https://github.com/apache/flink/pull/22717#issuecomment-1591424654
@snuyanzin
Thank you for your help, I have already fixed it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-32340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergii Nazarov updated FLINK-32340:
---
Description:
Prerequisites:
* Deployment via Apache Flink Kubernetes operator with version
Sergii Nazarov created FLINK-32340:
--
Summary: NPE in K8s operator which brakes current and subsequent
deployments
Key: FLINK-32340
URL: https://issues.apache.org/jira/browse/FLINK-32340
Project:
[
https://issues.apache.org/jira/browse/FLINK-31782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31782:
---
Labels: pull-request-available (was: )
> Make DefaultLeaderElectionService implement
>
XComp commented on PR #22640:
URL: https://github.com/apache/flink/pull/22640#issuecomment-1591349303
> I don't really follow the UUID change. If the multiCLES got by without it
so far, what do we need it for now?
> > the HA backend should be the owner of the session ID: Theoretically,
WencongLiu commented on PR #22733:
URL: https://github.com/apache/flink/pull/22733#issuecomment-1591241912
Thanks for the carefully review. I've updated the
`TieredStorageNettyServiceImpl`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
zentol commented on code in PR #22601:
URL: https://github.com/apache/flink/pull/22601#discussion_r1229632471
##
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java:
##
@@ -247,7 +247,7 @@ private LeaderElection
[
https://issues.apache.org/jira/browse/FLINK-32331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32331.
--
Resolution: Fixed
Fixed in apache/flink-connector-shared-utils@ci_utils:
MartijnVisser merged PR #15:
URL: https://github.com/apache/flink-connector-shared-utils/pull/15
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732537#comment-17732537
]
Andriy Redko commented on FLINK-31856:
--
Thanks [~mhjtrifork] , made it in, should be easier to
[
https://issues.apache.org/jira/browse/FLINK-24881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-24881.
--
Resolution: Not A Bug
Hi, sorry for a late response, I have just stumbled across this ticket.
[
https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-32040:
Affects Version/s: 1.17.0
1.16.0
> The WatermarkStrategy defined with the
[
https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732524#comment-17732524
]
Dian Fu commented on FLINK-32040:
-
Good catch! I think you are right that this is a bug. cc [~Juntao Hu]
XComp commented on PR #22642:
URL: https://github.com/apache/flink/pull/22642#issuecomment-1591155371
Rebased on FLINK-31781 to include the libssl fix from master and the format
fix
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-32177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32177:
---
Labels: pull-request-available (was: )
> Refactor
>
[
https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-32040:
Priority: Major (was: Blocker)
> The WatermarkStrategy defined with the Function(with_idleness) report
[
https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732518#comment-17732518
]
Dian Fu commented on FLINK-32034:
-
[~coltenp] Thanks for reporting this issue and the finding. Would you
[
https://issues.apache.org/jira/browse/FLINK-32207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-32207.
---
Resolution: Duplicate
> Error import Pyflink.table.descriptors due to python3.10 version mismatch
>
[
https://issues.apache.org/jira/browse/FLINK-32207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732515#comment-17732515
]
Dian Fu commented on FLINK-32207:
-
This seems duplicate with FLINK-32206. Closing this ticket~. Feel
XComp commented on code in PR #22601:
URL: https://github.com/apache/flink/pull/22601#discussion_r1229545380
##
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java:
##
@@ -247,7 +247,7 @@ private LeaderElection
[
https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732513#comment-17732513
]
Dian Fu commented on FLINK-32206:
-
'Kafka' has already been removed from 'pyflink.table.descriptors'. I
huwh commented on PR #22137:
URL: https://github.com/apache/flink/pull/22137#issuecomment-1591105458
@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 specific comment.
To
[
https://issues.apache.org/jira/browse/FLINK-31916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-31916.
-
Resolution: Fixed
Merged to master via 626d70d86d3bee944edf548606b38042f31e09b6
> Python API only
dianfu merged PR #22776:
URL: https://github.com/apache/flink/pull/22776
--
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:
XComp commented on code in PR #22601:
URL: https://github.com/apache/flink/pull/22601#discussion_r1229512559
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/AbstractLeaderElectionService.java:
##
@@ -27,29 +27,37 @@
public abstract class
XComp commented on code in PR #22601:
URL: https://github.com/apache/flink/pull/22601#discussion_r1229501119
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/AbstractLeaderElectionService.java:
##
@@ -27,29 +27,37 @@
public abstract class
ashangit opened a new pull request, #621:
URL: https://github.com/apache/flink-kubernetes-operator/pull/621
## What is the purpose of the change
This pull request add a check to ensure that no TaskManager pods are running
while waiting for cluster shutdown.
With standalone
[
https://issues.apache.org/jira/browse/FLINK-32334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32334:
---
Labels: pull-request-available (was: )
> Operator failed to create taskmanager deployment
XComp commented on PR #22404:
URL: https://github.com/apache/flink/pull/22404#issuecomment-1591051518
rebase
--
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
[
https://issues.apache.org/jira/browse/FLINK-32339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732495#comment-17732495
]
Matthias Pohl commented on FLINK-32339:
---
But I'm still not 100% sure whether it will help: The
huwh commented on PR #22137:
URL: https://github.com/apache/flink/pull/22137#issuecomment-1591025199
Thanks, unit tests have been fixed.
`testStdoutFileHandlerHandleFileNotFoundException` failed because
`TestingChannelHandlerContext#write` return an unfinished future.
Since we
[
https://issues.apache.org/jira/browse/FLINK-32339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32339:
--
Description:
{{DefaultLeaderElectionService}} uses sequential execution through a single
flinkbot commented on PR #22780:
URL: https://github.com/apache/flink/pull/22780#issuecomment-1591022893
## CI report:
* 0fb564b8cdda9468405bdbc24f2e0f9ee5e0bbf8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Matthias Pohl created FLINK-32339:
-
Summary: Align lock usage in DefaultLeaderElectionService
Key: FLINK-32339
URL: https://issues.apache.org/jira/browse/FLINK-32339
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32338:
---
Labels: pull-request-available (was: )
> Add FailsOnJava17 annotation
>
zentol opened a new pull request, #22780:
URL: https://github.com/apache/flink/pull/22780
Adds an annotation for disabling tests on Java 17, similar to
`FailsOnJava11`, and sets up the test exclusion in maven.
This annotation won't be used that much; probably only a 1 or 2 tests will
flinkbot commented on PR #22779:
URL: https://github.com/apache/flink/pull/22779#issuecomment-1591006718
## CI report:
* 8d44eec94d767591d3bf968db5582da3543681f6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732491#comment-17732491
]
Matthias Pohl edited comment on FLINK-31878 at 6/14/23 11:23 AM:
-
I
[
https://issues.apache.org/jira/browse/FLINK-31878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732491#comment-17732491
]
Matthias Pohl commented on FLINK-31878:
---
I accidentally added FLINK-31878 as the Jira issue to a
snuyanzin opened a new pull request, #22779:
URL: https://github.com/apache/flink/pull/22779
## What is the purpose of the change
The problem case for `array_union` is
```sql
SELECT array_union(ARRAY[CAST(NULL AS INT)], ARRAY[1]); -- returns [NULL,
1], this is OK
SELECT
[
https://issues.apache.org/jira/browse/FLINK-32337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32337:
---
Labels: pull-request-available (was: )
> SQL array_union could return wrong result
>
Chesnay Schepler created FLINK-32338:
Summary: Add FailsOnJava17 annotation
Key: FLINK-32338
URL: https://issues.apache.org/jira/browse/FLINK-32338
Project: Flink
Issue Type: Sub-task
zentol commented on PR #22738:
URL: https://github.com/apache/flink/pull/22738#issuecomment-1590991638
> Ok, with that one I'm wondering how you identified all the places where
the parameter should be set.
For Java 17 we have to add `add-opens/add-exports` JVM arguments for any
Sergey Nuyanzin created FLINK-32337:
---
Summary: SQL array_union could return wrong result
Key: FLINK-32337
URL: https://issues.apache.org/jira/browse/FLINK-32337
Project: Flink
Issue Type:
flinkbot commented on PR #22778:
URL: https://github.com/apache/flink/pull/22778#issuecomment-1590984725
## CI report:
* a6d7491c7fdaffe98afc964c4d08e7952bd8abf2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32336:
---
Labels: pull-request-available (was: )
> PartitionITCase#ComparablePojo should be public
>
zentol opened a new pull request, #22778:
URL: https://github.com/apache/flink/pull/22778
POJOs should be public so they are serialized with the pojo serializer.
The modification to the `MinMaxSelector` is necessary because by being
treated as a pojo the partitioning is being
Chesnay Schepler created FLINK-32336:
Summary: PartitionITCase#ComparablePojo should be public
Key: FLINK-32336
URL: https://issues.apache.org/jira/browse/FLINK-32336
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-32334:
--
Assignee: Nicolas Fraison
> Operator failed to create taskmanager deployment because it
snuyanzin commented on PR #22717:
URL: https://github.com/apache/flink/pull/22717#issuecomment-1590918465
```sql
SELECT array_concat(ARRAY[CAST(NULL AS INT)], ARRAY[1]); -- returns [NULL,
1], this is OK
SELECT array_concat(ARRAY[1], ARRAY[CAST(NULL AS INT)]); -- returns [1, 0],
this
MartijnVisser commented on PR #15:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/15#issuecomment-1590864111
> to sleep eternally and reduce the CI timeout to some reasonably low value?
Yes, but that will mean that CI will always fail for these tests, right? For
[
https://issues.apache.org/jira/browse/FLINK-32334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732475#comment-17732475
]
Nicolas Fraison commented on FLINK-32334:
-
I can see in the log that we have wait once and then
[
https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-24998.
Fix Version/s: 1.18.0
Resolution: Fixed
> SIGSEGV in Kryo / C2 CompilerThread on
[
https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732473#comment-17732473
]
Chesnay Schepler commented on FLINK-24998:
--
CI image updated on master:
[
https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-24998:
--
> SIGSEGV in Kryo / C2 CompilerThread on Java 17
>
[
https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732473#comment-17732473
]
Chesnay Schepler edited comment on FLINK-24998 at 6/14/23 9:44 AM:
---
zentol merged PR #22737:
URL: https://github.com/apache/flink/pull/22737
--
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:
1 - 100 of 129 matches
Mail list logo