smarthi

May 24, 2020 1:41:46 PM software.amazon.codeguruprofilerjavaagent.ProfilingCommand runProfiler
INFO: An unexpected issue caused the profiling command to terminate
java.lang.BootstrapMethodError: call site initialization exception
	at java.lang.invoke.CallSite.makeSite(CallSite.java:341)
	at java.lang.invoke.MethodHandleNatives.linkCallSiteImpl(MethodHandleNatives.java:307)
	at java.lang.invoke.MethodHandleNatives.linkCallSite(MethodHandleNatives.java:297)
	at software.amazon.awssdk.http.apache.ApacheHttpClient.transformHeaders(ApacheHttpClient.java:276)
	at software.amazon.awssdk.http.apache.ApacheHttpClient.createResponse(ApacheHttpClient.java:261)
	at software.amazon.awssdk.http.apache.ApacheHttpClient.execute(ApacheHttpClient.java:241)
	at software.amazon.awssdk.http.apache.ApacheHttpClient.access$500(ApacheHttpClient.java:106)

smarthi

  private void executeJob(final ParameterTool parameters) throws Exception {
  
    StreamExecutionEnvironment execEnv = StreamExecutionEnvironment.getExecutionEnvironment();

    KeyedStream<Tuple3<String, String, Long>, Tuple> keyedDS = ....;

    WindowedStream<Tuple3<String, String, Long>, Tuple, GlobalWindow> windowedStream =
                            keyedDS.window(GlobalWindows.create());

    windowedStream.trigger(TimeoutTrigger.of(CountTrigger.of(3), 10));

smarthi

<settings>
   <profiles>
         <profile>
           <id>signed_release</id>
           <properties>
               <mavenExecutorId>forked-path</mavenExecutorId>
               <gpg.keyname>D3541808</gpg.keyname>
               <gpg.passphrase>xxx</gpg.passphrase>
<deploy.altRepository>incubator-pirk.releases::default::https://dist.apache.org/repos/dist/dev/incubator/pirk/</deploy.altRepository>
<username>apacheId</username>

smarthi

		if ( et == ExecType.CP ) 
			{
				Lop agg1 = null;
				if( isTernaryAggregateRewriteApplicable() ) {
					agg1 = constructLopsTernaryAggregateRewrite(et);
				}
				else if( isUnaryAggregateOuterCPRewriteApplicable() )
				{
					OperationTypes op = HopsAgg2Lops.get(_op);
					DirectionTypes dir = HopsDirection2Lops.get(_direction);